api

Documentation

Index

• func NewOpenApiDefinitionHandler(baseURL string) (http.HandlerFunc, error)
• func RegisterHealthRoute(router chi.Router)
• func RegisterOpenAPIDefinitionRoute(baseURL string, router chi.Router) error
• type TaskHandler
  • func (ts *TaskHandler) GetTaskV1(_ context.Context, taskName string) (openapi.ImplResponse, error)
  • func (th *TaskHandler) ListTasksV1(_ context.Context) (openapi.ImplResponse, error)
• type WorkHandler
  • func (wh *WorkHandler) GetWorkV1(_ context.Context) (openapi.ImplResponse, error)
  • func (wh *WorkHandler) ReportWorkV1(_ context.Context, req openapi.ReportWorkV1Request) (openapi.ImplResponse, error)
  • func (wh *WorkHandler) ScheduleRunV1(_ context.Context, req openapi.ScheduleRunV1Request) (openapi.ImplResponse, error)

Functions

func NewOpenApiDefinitionHandler

func NewOpenApiDefinitionHandler(baseURL string) (http.HandlerFunc, error)

func RegisterHealthRoute

func RegisterHealthRoute(router chi.Router)

func RegisterOpenAPIDefinitionRoute

func RegisterOpenAPIDefinitionRoute(baseURL string, router chi.Router) error

Types

type TaskHandler

type TaskHandler struct {
	TaskService *service.TaskService
}

func (*TaskHandler) GetTaskV1

func (ts *TaskHandler) GetTaskV1(_ context.Context, taskName string) (openapi.ImplResponse, error)

GetTaskV1 implements openapi.TaskAPIServicer

func (*TaskHandler) ListTasksV1

func (th *TaskHandler) ListTasksV1(_ context.Context) (openapi.ImplResponse, error)

ListTasksV1 implements openapi.TaskAPIServicer

type WorkHandler

type WorkHandler struct {
	WorkerService *service.WorkerService
}

func (*WorkHandler) GetWorkV1

func (wh *WorkHandler) GetWorkV1(_ context.Context) (openapi.ImplResponse, error)

func (*WorkHandler) ReportWorkV1

func (wh *WorkHandler) ReportWorkV1(_ context.Context, req openapi.ReportWorkV1Request) (openapi.ImplResponse, error)

func (*WorkHandler) ScheduleRunV1

func (wh *WorkHandler) ScheduleRunV1(_ context.Context, req openapi.ScheduleRunV1Request) (openapi.ImplResponse, error)