client

package module

v0.0.0-...-4a658a7 Latest Latest Go to latest Published: Feb 5, 2023 License: MIT Imports: 10 Imported by: 0

Details

AFAIRE

View Source

const (
	ErrCreated  = errors.Sentinel("job created")
	ErrReserved = errors.Sentinel("job reserved")
	ErrUpdated  = errors.Sentinel("job updated")
)

This section is empty.

This section is empty.

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

func New(logger *logger.Logger, cfg *balancer.Config) (*Client, error)

func (cl *Client) CreateJob(ctx context.Context, jtc *sdk.JobToCreate) (*sdk.Job, error)

func (cl *Client) CreateWorkflow(ctx context.Context, wtc *sdk.WorkflowToCreate) (*sdk.Workflow, *sdk.Job, error)

func (cl *Client) NextJob(ctx context.Context, namespace, host, worker string) (*sdk.Job, error)

func (cl *Client) UpdateJob(ctx context.Context, jtu *sdk.JobToUpdate) (*sdk.Job, *sdk.Job, error)