grpc

Documentation

Index

• func RegisterOrchestratorGRPC(e *echo.Echo, queries *queries.Queries, jwt jwt.JWTHandler, ...) error
• func RegisterWorkflowRPC(e *echo.Echo, jwt jwt.JWTHandler, ...) error
• type GRPCServer
  • func NewJobServer(orchestratorClient pbConnect.OrchestratorServiceClient, jwt jwt.JWTHandler, ...) (*GRPCServer, error)
  • func NewRunnerServer(jwt jwt.JWTHandler, orchestratorClient pbConnect.OrchestratorServiceClient, ...) (*GRPCServer, error)
  • func (s *GRPCServer) Start(address string) error

Functions

func RegisterOrchestratorGRPC

func RegisterOrchestratorGRPC(e *echo.Echo, queries *queries.Queries, jwt jwt.JWTHandler, bucketClient *storage.BucketClient, git *git.Handler) error

func RegisterWorkflowRPC

func RegisterWorkflowRPC(e *echo.Echo, jwt jwt.JWTHandler, orchestratorClient pbConnect.OrchestratorServiceClient, workflowMeta *pb.WorkflowMeta, worstJobConclusion map[string]pb.Conclusion, stepLogs map[string]*stream.LogStream, eventStream *stream.EventStream) error

Types

type GRPCServer

type GRPCServer struct {
	// contains filtered or unexported fields
}

func NewJobServer

func NewJobServer(orchestratorClient pbConnect.OrchestratorServiceClient, jwt jwt.JWTHandler, address string, workflowMeta *pb.WorkflowMeta) (*GRPCServer, error)

func NewRunnerServer

func NewRunnerServer(jwt jwt.JWTHandler, orchestratorClient pbConnect.OrchestratorServiceClient, runner runner.Handler) (*GRPCServer, error)

func (*GRPCServer) Start

func (s *GRPCServer) Start(address string) error