Added GateNode message (#296)

* added GateNode message Signed-off-by: Daniel Rammer <[email protected]> * added signal service Signed-off-by: Daniel Rammer <[email protected]> * fleshed out Signal service Signed-off-by: Daniel Rammer <[email protected]> * updated signal service with a GetOrCreateSignal and SetSignal API Signed-off-by: Daniel Rammer <[email protected]> * updated signal service api to use GetOrCreate semantics Signed-off-by: Daniel Rammer <[email protected]> * added the ListSignals API Signed-off-by: Daniel Rammer <[email protected]> * fixed SignalListResponse proto name Signed-off-by: Daniel Rammer <[email protected]> * set HTTP API parameters Signed-off-by: Daniel Rammer <[email protected]> * generated protos Signed-off-by: Daniel Rammer <[email protected]> * documented GateNode Signed-off-by: Daniel Rammer <[email protected]> * updated signal list API Signed-off-by: Daniel Rammer <[email protected]> * filled out signal list api Signed-off-by: Daniel Rammer <[email protected]> * addressing pr comments on docs Signed-off-by: Daniel Rammer <[email protected]> * added an output variable name to the signal condition Signed-off-by: Daniel Rammer <[email protected]> * reworded signal condition docs Signed-off-by: Daniel Rammer <[email protected]> * added ApproveCondition to GateNode Signed-off-by: Daniel Rammer <[email protected]> * removed authOpt Signed-off-by: Daniel Rammer <[email protected]> * fixed types Signed-off-by: Daniel Rammer <[email protected]> * updated doc_gen_deps to fix docs generation Signed-off-by: Daniel Rammer <[email protected]> Signed-off-by: Daniel Rammer <[email protected]>
flyteorg · Oct 25, 2022 · 03ef411 · 03ef411
1 parent 1cbb9a9
commit 03ef411
Show file tree

Hide file tree

Showing 64 changed files with 31,871 additions and 574 deletions.
diff --git a/flyteidl/clients/go/admin/client.go b/flyteidl/clients/go/admin/client.go
@@ -29,6 +29,7 @@ type Clientset struct {
 	healthServiceClient       grpc_health_v1.HealthClient
 	identityServiceClient     service.IdentityServiceClient
 	dataProxyServiceClient    service.DataProxyServiceClient
+	signalServiceClient       service.SignalServiceClient
 }
 
 // AdminClient retrieves the AdminServiceClient
@@ -54,6 +55,10 @@ func (c Clientset) DataProxyClient() service.DataProxyServiceClient {
 	return c.dataProxyServiceClient
 }
 
+func (c Clientset) SignalServiceClient() service.SignalServiceClient {
+	return c.signalServiceClient
+}
+
 func NewAdminClient(ctx context.Context, conn *grpc.ClientConn) service.AdminServiceClient {
 	logger.Infof(ctx, "Initialized Admin client")
 	return service.NewAdminServiceClient(conn)
@@ -186,6 +191,7 @@ func initializeClients(ctx context.Context, cfg *Config, tokenCache cache.TokenC
 	cs.identityServiceClient = service.NewIdentityServiceClient(adminConnection)
 	cs.healthServiceClient = grpc_health_v1.NewHealthClient(adminConnection)
 	cs.dataProxyServiceClient = service.NewDataProxyServiceClient(adminConnection)
+	cs.signalServiceClient = service.NewSignalServiceClient(adminConnection)
 
 	return &cs, nil
 }

diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/signal.grpc.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/admin/signal.grpc.pb.cc
diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/signal.grpc.pb.h b/flyteidl/gen/pb-cpp/flyteidl/admin/signal.grpc.pb.h
diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/signal.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/admin/signal.pb.cc