queue

Documentation

Index

• type Client
  • func New(addr string, cert *transport.Cert, trace bool) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) GetCancel(ctx context.Context, id int64) (bool, error)
  • func (c *Client) NextQueueItem(ctx context.Context, queueName, hostname string) (*model.QueueItem, error)
  • func (c *Client) SetCancel(ctx context.Context, id int64) error
  • func (c *Client) SetStatus(ctx context.Context, id int64, status bool) error
  • func (c *Client) Submit(ctx context.Context, sub *types.Submission) error

Types

type Client

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

Client is the queue client.

func New

func New(addr string, cert *transport.Cert, trace bool) (*Client, error)

New constructs a new *Client.

func (*Client) Close

func (c *Client) Close() error

Close closes the client's tracing functionality

func (*Client) GetCancel

func (c *Client) GetCancel(ctx context.Context, id int64) (bool, error)

GetCancel retrieves the cancel state of the run.

func (*Client) NextQueueItem

func (c *Client) NextQueueItem(ctx context.Context, queueName, hostname string) (*model.QueueItem, error)

NextQueueItem returns the next item in the queue.

func (*Client) SetCancel

func (c *Client) SetCancel(ctx context.Context, id int64) error

SetCancel sets the cancel state for a given run id.

func (*Client) SetStatus

func (c *Client) SetStatus(ctx context.Context, id int64, status bool) error

SetStatus completes the run by returning its status back to the system.

func (*Client) Submit

func (c *Client) Submit(ctx context.Context, sub *types.Submission) error

Submit submits a push or pull request to the queue.