endpoint

Documentation

Index

• func MakeComputeCreateExecutorEndpoint(s Service) endpoint.Endpoint
• func MakeComputeCreateProjectEndpoint(s Service) endpoint.Endpoint
• func MakeComputeCreateTaskEndpoint(s Service) endpoint.Endpoint
• func MakeComputeDeleteExecutorEndpoint(s Service) endpoint.Endpoint
• func MakeComputeDeleteProjectByIDEndpoint(s Service) endpoint.Endpoint
• func MakeComputeDeleteTaskEndpoint(s Service) endpoint.Endpoint
• func MakeComputeGetExecutorEndpoint(s Service) endpoint.Endpoint
• func MakeComputeGetProjectEndpoint(s Service) endpoint.Endpoint
• func MakeComputeGetTaskEndpoint(s Service) endpoint.Endpoint
• func MakeComputeListExecutorsEndpoint(s Service) endpoint.Endpoint
• func MakeComputeListProjectsEndpoint(s Service) endpoint.Endpoint
• func MakeComputePopReadyTaskEndpoint(s Service) endpoint.Endpoint
• func MakeComputeUpdateTaskEndpoint(s Service) endpoint.Endpoint
• type Endpoints
  • func MakeClientEndpoints(instance string, ...) (Endpoints, error)
  • func (e Endpoints) CreateExecutor(ctx context.Context, name string, pack string, data []byte) (*project.Executor, error)
  • func (e Endpoints) CreateProject(ctx context.Context, name string) (*project.Project, error)
  • func (e Endpoints) CreateTask(ctx context.Context, projID project.ProjectID, execID project.ExecutorID, ...) (*project.Task, error)
  • func (e Endpoints) DeleteExecutorByID(ctx context.Context, execID project.ExecutorID) error
  • func (e Endpoints) DeleteProjectByID(ctx context.Context, id project.ProjectID) error
  • func (e Endpoints) DeleteTaskByID(ctx context.Context, id project.TaskID) error
  • func (e Endpoints) GetExecutorByID(ctx context.Context, execID project.ExecutorID) (*project.Executor, error)
  • func (e Endpoints) GetProjectByID(ctx context.Context, id project.ProjectID) (*project.Project, error)
  • func (e Endpoints) GetTaskByID(ctx context.Context, id project.TaskID) (*project.Task, error)
  • func (e Endpoints) ListExecutors(ctx context.Context) ([]*project.Executor, error)
  • func (e Endpoints) ListProjects(ctx context.Context) ([]*project.Project, error)
  • func (e Endpoints) PopReadyTask(ctx context.Context) (*project.Task, error)
  • func (e Endpoints) UpdateTaskByID(ctx context.Context, id project.TaskID, task *project.Task) (*project.Task, error)

Functions

func MakeComputeCreateExecutorEndpoint

func MakeComputeCreateExecutorEndpoint(s Service) endpoint.Endpoint

func MakeComputeCreateProjectEndpoint

func MakeComputeCreateProjectEndpoint(s Service) endpoint.Endpoint

func MakeComputeCreateTaskEndpoint

func MakeComputeCreateTaskEndpoint(s Service) endpoint.Endpoint

func MakeComputeDeleteExecutorEndpoint

func MakeComputeDeleteExecutorEndpoint(s Service) endpoint.Endpoint

func MakeComputeDeleteProjectByIDEndpoint

func MakeComputeDeleteProjectByIDEndpoint(s Service) endpoint.Endpoint

func MakeComputeDeleteTaskEndpoint

func MakeComputeDeleteTaskEndpoint(s Service) endpoint.Endpoint

func MakeComputeGetExecutorEndpoint

func MakeComputeGetExecutorEndpoint(s Service) endpoint.Endpoint

func MakeComputeGetProjectEndpoint

func MakeComputeGetProjectEndpoint(s Service) endpoint.Endpoint

func MakeComputeGetTaskEndpoint

func MakeComputeGetTaskEndpoint(s Service) endpoint.Endpoint

func MakeComputeListExecutorsEndpoint

func MakeComputeListExecutorsEndpoint(s Service) endpoint.Endpoint

func MakeComputeListProjectsEndpoint

func MakeComputeListProjectsEndpoint(s Service) endpoint.Endpoint

func MakeComputePopReadyTaskEndpoint

func MakeComputePopReadyTaskEndpoint(s Service) endpoint.Endpoint

func MakeComputeUpdateTaskEndpoint

func MakeComputeUpdateTaskEndpoint(s Service) endpoint.Endpoint

Types

type Endpoints

type Endpoints struct {
	ComputeCreateExecutorEndpoint     endpoint.Endpoint
	ComputeDeleteExecutorByIDEndpoint endpoint.Endpoint
	ComputeGetExecutorByIDEndpoint    endpoint.Endpoint
	ComputeListExecutorsEndpoint      endpoint.Endpoint
	ComputeCreateProjectEndpoint      endpoint.Endpoint
	ComputeDeleteProjectByIDEndpoint  endpoint.Endpoint
	ComputeGetProjectByIDEndpoint     endpoint.Endpoint
	ComputeListProjectsEndpoint       endpoint.Endpoint
	ComputeCreateTaskEndpoint         endpoint.Endpoint
	ComputeDeleteTaskByIDEndpoint     endpoint.Endpoint
	ComputeGetTaskByIDEndpoint        endpoint.Endpoint
	ComputeUpdateTaskByIDEndpoint     endpoint.Endpoint
	ComputePopReadyTaskEndpoint       endpoint.Endpoint
}

func MakeClientEndpoints

func MakeClientEndpoints(
	instance string,
	encodeRequestFactory jhttptransport.EncodeRequestFuncMiddleware,
	decodeResponseFactory jhttptransport.DecodeResponseFuncMiddleware,
	opts []httptransport.ClientOption) (Endpoints, error)

func (Endpoints) CreateExecutor

func (e Endpoints) CreateExecutor(ctx context.Context, name string, pack string, data []byte) (*project.Executor, error)

func (Endpoints) CreateProject

func (e Endpoints) CreateProject(ctx context.Context, name string) (*project.Project, error)

func (Endpoints) CreateTask

func (e Endpoints) CreateTask(ctx context.Context, projID project.ProjectID, execID project.ExecutorID, name string, data []byte) (*project.Task, error)

func (Endpoints) DeleteExecutorByID

func (e Endpoints) DeleteExecutorByID(ctx context.Context, execID project.ExecutorID) error

func (Endpoints) DeleteProjectByID

func (e Endpoints) DeleteProjectByID(ctx context.Context, id project.ProjectID) error

func (Endpoints) DeleteTaskByID

func (e Endpoints) DeleteTaskByID(ctx context.Context, id project.TaskID) error

func (Endpoints) GetExecutorByID

func (e Endpoints) GetExecutorByID(ctx context.Context, execID project.ExecutorID) (*project.Executor, error)

func (Endpoints) GetProjectByID

func (e Endpoints) GetProjectByID(ctx context.Context, id project.ProjectID) (*project.Project, error)

func (Endpoints) GetTaskByID

func (e Endpoints) GetTaskByID(ctx context.Context, id project.TaskID) (*project.Task, error)

func (Endpoints) ListExecutors

func (e Endpoints) ListExecutors(ctx context.Context) ([]*project.Executor, error)

func (Endpoints) ListProjects

func (e Endpoints) ListProjects(ctx context.Context) ([]*project.Project, error)

func (Endpoints) PopReadyTask

func (e Endpoints) PopReadyTask(ctx context.Context) (*project.Task, error)

func (Endpoints) UpdateTaskByID

func (e Endpoints) UpdateTaskByID(ctx context.Context, id project.TaskID, task *project.Task) (*project.Task, error)