server

package

v0.12.2 Latest Latest Go to latest Published: Jan 9, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KubernetesBackedServer struct {
	ClientFunc func() client.Client
	// contains filtered or unexported fields
}

KubernetesBackedServer is a server that implements a workflow API.

func NewKubeBackedServer(logger logr.Logger, kubeconfig, apiserver, namespace string) (*KubernetesBackedServer, error)

NewKubeBackedServer returns a server that implements the Workflow server interface for a given kubeconfig.

func NewKubeBackedServerFromREST(logger logr.Logger, config *rest.Config, namespace string) (*KubernetesBackedServer, error)

NewKubeBackedServerFromREST returns a server that implements the Workflow server interface with the given Kubernetes rest client and namespace.

func (s *KubernetesBackedServer) GetWorkflowActions(ctx context.Context, req *proto.WorkflowActionsRequest) (*proto.WorkflowActionList, error)

func (s *KubernetesBackedServer) GetWorkflowContexts(req *proto.WorkflowContextRequest, stream proto.WorkflowService_GetWorkflowContextsServer) error

func (s *KubernetesBackedServer) Register(server *grpc.Server)

Register registers the service on the gRPC server.

func (s *KubernetesBackedServer) ReportActionStatus(ctx context.Context, req *proto.WorkflowActionStatus) (*proto.Empty, error)