Documentation
¶
Index ¶
- func Bind(c *gin.Context, obj interface{}) error
- func JSON(c *gin.Context, code int, data interface{})
- type HTTPError
- type Handler
- func (h *Handler) CancelJobExecution(ctx context.Context, request *api.CancelJobExecutionRequest) (*api.CancelJobExecutionResponse, error)
- func (h *Handler) CreatePipeline(ctx context.Context, request *api.CreatePipelineRequest) (*api.CreatePipelineResponse, error)
- func (h *Handler) GetJobExecution(ctx context.Context, in *api.GetJobExecutionRequest) (*api.GetJobExecutionResponse, error)
- func (h *Handler) GetLogLines(ctx context.Context, request *api.GetLogLinesRequest) (*api.GetLogLinesResponse, error)
- func (h *Handler) GetStepExecution(ctx context.Context, request *api.GetStepExecutionRequest) (*api.GetStepExecutionResponse, error)
- func (h *Handler) Heartbeat(ctx context.Context, request *api.HeartbeatRequest) (*api.HeartbeatResponse, error)
- func (h *Handler) ListJobExecutions(ctx context.Context, in *api.ListJobExecutionsRequest) (*api.ListJobExecutionsResponse, error)
- func (h *Handler) Ping(ctx context.Context, _ *api.ServerPingRequest) (*api.ServerPingResponse, error)
- func (h *Handler) RegisterRouter(g *gin.RouterGroup)
- func (h *Handler) RequestJob(ctx context.Context, request *api.RequestJobRequest) (*api.RequestJobResponse, error)
- func (h *Handler) RequestJobHandler(c *gin.Context)
- func (h *Handler) RerunJob(ctx context.Context, in *api.RerunJobRequest) (*api.RerunJobResponse, error)
- func (h *Handler) UpdateJobExecution(ctx context.Context, request *api.UpdateJobExecutionRequest) (*api.UpdateJobExecutionResponse, error)
- func (h *Handler) UpdateStepExecution(ctx context.Context, request *api.UpdateStepExecutionRequest) (*api.UpdateStepExecutionResponse, error)
- func (h *Handler) UploadLogLines(ctx context.Context, request *api.UpdateLogLinesRequest) (*api.UpdateLogLinesResponse, error)
- type Message
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Handler ¶
type Handler struct {
api.UnimplementedServerServer
// contains filtered or unexported fields
}
Handler is the http handler for the server.
func NewHandler ¶
func (*Handler) CancelJobExecution ¶
func (h *Handler) CancelJobExecution(ctx context.Context, request *api.CancelJobExecutionRequest) (*api.CancelJobExecutionResponse, error)
func (*Handler) CreatePipeline ¶
func (h *Handler) CreatePipeline(ctx context.Context, request *api.CreatePipelineRequest) (*api.CreatePipelineResponse, error)
func (*Handler) GetJobExecution ¶
func (h *Handler) GetJobExecution(ctx context.Context, in *api.GetJobExecutionRequest) (*api.GetJobExecutionResponse, error)
func (*Handler) GetLogLines ¶
func (h *Handler) GetLogLines(ctx context.Context, request *api.GetLogLinesRequest) (*api.GetLogLinesResponse, error)
func (*Handler) GetStepExecution ¶
func (h *Handler) GetStepExecution(ctx context.Context, request *api.GetStepExecutionRequest) (*api.GetStepExecutionResponse, error)
func (*Handler) Heartbeat ¶
func (h *Handler) Heartbeat(ctx context.Context, request *api.HeartbeatRequest) (*api.HeartbeatResponse, error)
func (*Handler) ListJobExecutions ¶
func (h *Handler) ListJobExecutions(ctx context.Context, in *api.ListJobExecutionsRequest) (*api.ListJobExecutionsResponse, error)
func (*Handler) Ping ¶
func (h *Handler) Ping(ctx context.Context, _ *api.ServerPingRequest) (*api.ServerPingResponse, error)
func (*Handler) RegisterRouter ¶
func (h *Handler) RegisterRouter(g *gin.RouterGroup)
func (*Handler) RequestJob ¶
func (h *Handler) RequestJob(ctx context.Context, request *api.RequestJobRequest) (*api.RequestJobResponse, error)
func (*Handler) RequestJobHandler ¶
func (*Handler) RerunJob ¶
func (h *Handler) RerunJob(ctx context.Context, in *api.RerunJobRequest) (*api.RerunJobResponse, error)
RerunJob rerun the job by the latest job execution. TODO: this implementation is not correct, rerun should create new job executions include jobs depends on it.
func (*Handler) UpdateJobExecution ¶
func (h *Handler) UpdateJobExecution(ctx context.Context, request *api.UpdateJobExecutionRequest) (*api.UpdateJobExecutionResponse, error)
func (*Handler) UpdateStepExecution ¶
func (h *Handler) UpdateStepExecution(ctx context.Context, request *api.UpdateStepExecutionRequest) (*api.UpdateStepExecutionResponse, error)
func (*Handler) UploadLogLines ¶
func (h *Handler) UploadLogLines(ctx context.Context, request *api.UpdateLogLinesRequest) (*api.UpdateLogLinesResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.