resto

Documentation

Index

• Constants
• Variables
• type Client
  • func New(url, username, accessKey string, timeout time.Duration) Client
  • func (c *Client) GetJobAssetFileContent(ctx context.Context, jobID, fileName string) ([]byte, error)
  • func (c *Client) PollJob(ctx context.Context, id string, interval time.Duration) (job.Job, error)
  • func (c *Client) ReadAllowedCCY(ctx context.Context) (int, error)
  • func (c *Client) ReadJob(ctx context.Context, id string) (job.Job, error)

Constants

const ConsoleLogAsset = "console.log"

ConsoleLogAsset represents job asset log file name.

Variables

var (
	// ErrServerError is returned when the server was not able to correctly handle our request (status code >= 500).
	ErrServerError = errors.New("internal server error")
	// ErrJobNotFound is returned when the requested job was not found.
	ErrJobNotFound = errors.New("job was not found")
)

Types

type Client

type Client struct {
	HTTPClient *http.Client
	URL        string
	Username   string
	AccessKey  string
}

Client http client.

func New

func New(url, username, accessKey string, timeout time.Duration) Client

New creates a new client.

func (*Client) GetJobAssetFileContent

func (c *Client) GetJobAssetFileContent(ctx context.Context, jobID, fileName string) ([]byte, error)

GetJobAssetFileContent returns the job asset file content.

func (*Client) PollJob

func (c *Client) PollJob(ctx context.Context, id string, interval time.Duration) (job.Job, error)

PollJob polls job details at an interval, until the job has ended, whether successfully or due to an error.

func (*Client) ReadAllowedCCY

func (c *Client) ReadAllowedCCY(ctx context.Context) (int, error)

ReadAllowedCCY returns the allowed (max) concurrency for the current account.

func (*Client) ReadJob

func (c *Client) ReadJob(ctx context.Context, id string) (job.Job, error)

ReadJob returns the job details.