server

Documentation

Index

• type KubernetesBackedServer
  • func NewKubeBackedServer(logger logr.Logger, kubeconfig, apiserver, namespace string) (*KubernetesBackedServer, error)
  • func NewKubeBackedServerFromREST(logger logr.Logger, config *rest.Config, namespace string) (*KubernetesBackedServer, error)
  • func (s *KubernetesBackedServer) GetWorkflowActions(ctx context.Context, req *proto.WorkflowActionsRequest) (*proto.WorkflowActionList, error)
  • func (s *KubernetesBackedServer) GetWorkflowContexts(req *proto.WorkflowContextRequest, ...) error
  • func (s *KubernetesBackedServer) Register(server *grpc.Server)
  • func (s *KubernetesBackedServer) ReportActionStatus(ctx context.Context, req *proto.WorkflowActionStatus) (*proto.Empty, error)

Types

type KubernetesBackedServer

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

KubernetesBackedServer is a server that implements a workflow API.

func NewKubeBackedServer

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

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 (*KubernetesBackedServer) GetWorkflowActions

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

func (*KubernetesBackedServer) GetWorkflowContexts

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

func (*KubernetesBackedServer) Register

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

Register registers the service on the gRPC server.

func (*KubernetesBackedServer) ReportActionStatus

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