Documentation
¶
Overview ¶
Package client talks to Flowbot /gateway/v1 worker APIs.
Index ¶
- type Client
- func (c *Client) Claim(ctx context.Context, workerID string) (*types.GatewayJob, error)
- func (c *Client) Complete(ctx context.Context, jobID string, req types.GatewayCompleteRequest) error
- func (c *Client) GetJob(ctx context.Context, jobID string) (*types.GatewayJob, error)
- func (c *Client) Heartbeat(ctx context.Context, workerID, jobID string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client talks to Flowbot /gateway/v1 APIs.
func (*Client) Complete ¶
func (c *Client) Complete(ctx context.Context, jobID string, req types.GatewayCompleteRequest) error
Complete reports a terminal job result.
Click to show internal directories.
Click to hide internal directories.