runnerLocal

Documentation

Index

• func NewRunner(jwtHandler *jwt.JWTHandler) (runner.Handler, error)
• type Handler
  • func (h *Handler) CleanUpJobs(ctx context.Context, workflowID string, ...) (*pb.RunnerServiceCleanUpJobsResponse, error)
  • func (h *Handler) GetLogStream(ctx context.Context, workflowID string, ...) (*pb.RunnerServiceGetLogStreamResponse, error)
  • func (h *Handler) GetRunnerType() types.RunnerType
  • func (h *Handler) StartJob(ctx context.Context, workflowID string, req *pb.RunnerServiceStartJobRequest) (*pb.RunnerServiceStartJobResponse, error)
  • func (h *Handler) StartWorkflow(ctx context.Context, workflowID string, ...) (*pb.RunnerServiceStartWorkflowResponse, error)
  • func (h *Handler) StopJob(ctx context.Context, workflowID string, req *pb.RunnerServiceStopJobRequest) (*pb.RunnerServiceStopJobResponse, error)
  • func (h *Handler) StopWorkflow(ctx context.Context, workflowID string, ...) (*pb.RunnerServiceStopWorkflowResponse, error)

Functions

func NewRunner

func NewRunner(jwtHandler *jwt.JWTHandler) (runner.Handler, error)

Types

type Handler

type Handler struct {
	JWTHandler *jwt.JWTHandler
	// contains filtered or unexported fields
}

func (*Handler) CleanUpJobs

func (h *Handler) CleanUpJobs(ctx context.Context, workflowID string, workflowReq *pb.RunnerServiceCleanUpJobsRequest) (*pb.RunnerServiceCleanUpJobsResponse, error)

func (*Handler) GetLogStream

func (h *Handler) GetLogStream(ctx context.Context, workflowID string, req *pb.RunnerServiceGetLogStreamRequest) (*pb.RunnerServiceGetLogStreamResponse, error)

func (*Handler) GetRunnerType

func (h *Handler) GetRunnerType() types.RunnerType

func (*Handler) StartJob

func (h *Handler) StartJob(ctx context.Context, workflowID string, req *pb.RunnerServiceStartJobRequest) (*pb.RunnerServiceStartJobResponse, error)

func (*Handler) StartWorkflow

func (h *Handler) StartWorkflow(ctx context.Context, workflowID string, workflowReq *pb.RunnerServiceStartWorkflowRequest) (*pb.RunnerServiceStartWorkflowResponse, error)

func (*Handler) StopJob

func (h *Handler) StopJob(ctx context.Context, workflowID string, req *pb.RunnerServiceStopJobRequest) (*pb.RunnerServiceStopJobResponse, error)

func (*Handler) StopWorkflow

func (h *Handler) StopWorkflow(ctx context.Context, workflowID string, workflowReq *pb.RunnerServiceStopWorkflowRequest) (*pb.RunnerServiceStopWorkflowResponse, error)