job

type Api struct {
	// contains filtered or unexported fields
}

type CancelTaskRequest struct {
	TaskID xid.ID `path:"task_id"`
}

type CancelTaskResponse struct{}

type CreateTaskRequest struct {
	Name        string      `body:"name"`
	Args        interface{} `body:"args"`
	ContentType string      `body:"contentType"`
}

type CreateTaskResponse struct {
	TaskID xid.ID `json:"taskID"`
}

type ListWorkerRequest struct{}

type ListWorkerResponse struct {
	Workers []ListWorkerResponseItem `json:"workers"`
}

type ListWorkerResponseItem struct {
	ID              string           `json:"id"`
	LastUpdate      time.Time        `json:"lastUpdate"`
	RegisteredTasks []string         `json:"registeredTasks"`
	Load            map[string]int32 `json:"load"`
}

type Option func(options *Options)

type Options struct {
	Tasks []task.Task
}