apiserver

Documentation

Index

• type JobApiServerImpl
  • func (s *JobApiServerImpl) RecordTaskOutput(ctx context.Context, request *jobapi_pb.TaskOutputRecordRequest) (*jobapi_pb.TaskOutputRecordResponse, error)
  • func (s *JobApiServerImpl) StartWorkflow(ctx context.Context, request *jobapi_pb.WorkflowStartRequest) (*jobapi_pb.WorkflowStartResponse, error)

Types

type JobApiServerImpl

type JobApiServerImpl struct {
	WorkflowDao          dao.WorkflowDao
	WorkflowExecutionDao dao.WorkflowExecutionDao
	TaskExecutionDao     dao.TaskExecutionDao
}

func (*JobApiServerImpl) RecordTaskOutput

func (s *JobApiServerImpl) RecordTaskOutput(ctx context.Context, request *jobapi_pb.TaskOutputRecordRequest) (*jobapi_pb.TaskOutputRecordResponse, error)

func (*JobApiServerImpl) StartWorkflow

func (s *JobApiServerImpl) StartWorkflow(ctx context.Context, request *jobapi_pb.WorkflowStartRequest) (*jobapi_pb.WorkflowStartResponse, error)