client

Documentation

Index

• type Client
  • func NewClient(url string) *Client
  • func (c *Client) ApproveRunTask(ctx context.Context, runID, taskID string, changeGroupsUpdateToken string) (*http.Response, error)
  • func (c *Client) CheckCache(ctx context.Context, key string, prefix bool) (*http.Response, error)
  • func (c *Client) CreateRun(ctx context.Context, req *rsapitypes.RunCreateRequest) (*rsapitypes.RunResponse, *http.Response, error)
  • func (c *Client) GetArchive(ctx context.Context, taskID string, step int) (*http.Response, error)
  • func (c *Client) GetCache(ctx context.Context, key string, prefix bool) (*http.Response, error)
  • func (c *Client) GetExecutorTask(ctx context.Context, executorID, etID string) (*rstypes.ExecutorTask, *http.Response, error)
  • func (c *Client) GetExecutorTasks(ctx context.Context, executorID string) ([]*rstypes.ExecutorTask, *http.Response, error)
  • func (c *Client) GetGroupFirstQueuedRuns(ctx context.Context, group string, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)
  • func (c *Client) GetGroupLastRun(ctx context.Context, group string, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)
  • func (c *Client) GetGroupQueuedRuns(ctx context.Context, group string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)
  • func (c *Client) GetGroupRunningRuns(ctx context.Context, group string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)
  • func (c *Client) GetLogs(ctx context.Context, runID, taskID string, setup bool, step int, follow bool) (*http.Response, error)
  • func (c *Client) GetQueuedRuns(ctx context.Context, start string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)
  • func (c *Client) GetRun(ctx context.Context, runID string, changeGroups []string) (*rsapitypes.RunResponse, *http.Response, error)
  • func (c *Client) GetRunEvents(ctx context.Context, startRunEventID string) (*http.Response, error)
  • func (c *Client) GetRunningRuns(ctx context.Context, start string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)
  • func (c *Client) GetRuns(ctx context.Context, phaseFilter, resultFilter, groups []string, lastRun bool, ...) (*rsapitypes.GetRunsResponse, *http.Response, error)
  • func (c *Client) PutCache(ctx context.Context, key string, size int64, r io.Reader) (*http.Response, error)
  • func (c *Client) RunActions(ctx context.Context, runID string, req *rsapitypes.RunActionsRequest) (*http.Response, error)
  • func (c *Client) RunTaskActions(ctx context.Context, runID, taskID string, ...) (*http.Response, error)
  • func (c *Client) RunTaskSetAnnotations(ctx context.Context, runID, taskID string, annotations map[string]string, ...) (*http.Response, error)
  • func (c *Client) SendExecutorStatus(ctx context.Context, executor *rstypes.Executor) (*http.Response, error)
  • func (c *Client) SendExecutorTaskStatus(ctx context.Context, executorID string, et *rstypes.ExecutorTask) (*http.Response, error)
  • func (c *Client) SetHTTPClient(client *http.Client)
  • func (c *Client) StartRun(ctx context.Context, runID string, changeGroupsUpdateToken string) (*http.Response, error)

Types

type Client

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

func NewClient

func NewClient(url string) *Client

NewClient initializes and returns a API client.

func (*Client) ApproveRunTask

func (c *Client) ApproveRunTask(ctx context.Context, runID, taskID string, changeGroupsUpdateToken string) (*http.Response, error)

func (*Client) CheckCache

func (c *Client) CheckCache(ctx context.Context, key string, prefix bool) (*http.Response, error)

func (*Client) CreateRun

func (c *Client) CreateRun(ctx context.Context, req *rsapitypes.RunCreateRequest) (*rsapitypes.RunResponse, *http.Response, error)

func (*Client) GetArchive

func (c *Client) GetArchive(ctx context.Context, taskID string, step int) (*http.Response, error)

func (*Client) GetCache

func (c *Client) GetCache(ctx context.Context, key string, prefix bool) (*http.Response, error)

func (*Client) GetExecutorTask

func (c *Client) GetExecutorTask(ctx context.Context, executorID, etID string) (*rstypes.ExecutorTask, *http.Response, error)

func (*Client) GetExecutorTasks

func (c *Client) GetExecutorTasks(ctx context.Context, executorID string) ([]*rstypes.ExecutorTask, *http.Response, error)

func (*Client) GetGroupFirstQueuedRuns

func (c *Client) GetGroupFirstQueuedRuns(ctx context.Context, group string, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)

func (*Client) GetGroupLastRun

func (c *Client) GetGroupLastRun(ctx context.Context, group string, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)

func (*Client) GetGroupQueuedRuns

func (c *Client) GetGroupQueuedRuns(ctx context.Context, group string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)

func (*Client) GetGroupRunningRuns

func (c *Client) GetGroupRunningRuns(ctx context.Context, group string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)

func (*Client) GetLogs

func (c *Client) GetLogs(ctx context.Context, runID, taskID string, setup bool, step int, follow bool) (*http.Response, error)

func (*Client) GetQueuedRuns

func (c *Client) GetQueuedRuns(ctx context.Context, start string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)

func (*Client) GetRun

func (c *Client) GetRun(ctx context.Context, runID string, changeGroups []string) (*rsapitypes.RunResponse, *http.Response, error)

func (*Client) GetRunEvents

func (c *Client) GetRunEvents(ctx context.Context, startRunEventID string) (*http.Response, error)

func (*Client) GetRunningRuns

func (c *Client) GetRunningRuns(ctx context.Context, start string, limit int, changeGroups []string) (*rsapitypes.GetRunsResponse, *http.Response, error)

func (*Client) GetRuns

func (c *Client) GetRuns(ctx context.Context, phaseFilter, resultFilter, groups []string, lastRun bool, changeGroups []string, start string, limit int, asc bool) (*rsapitypes.GetRunsResponse, *http.Response, error)

func (*Client) PutCache

func (c *Client) PutCache(ctx context.Context, key string, size int64, r io.Reader) (*http.Response, error)

func (*Client) RunActions

func (c *Client) RunActions(ctx context.Context, runID string, req *rsapitypes.RunActionsRequest) (*http.Response, error)

func (*Client) RunTaskActions

func (c *Client) RunTaskActions(ctx context.Context, runID, taskID string, req *rsapitypes.RunTaskActionsRequest) (*http.Response, error)

func (*Client) RunTaskSetAnnotations

func (c *Client) RunTaskSetAnnotations(ctx context.Context, runID, taskID string, annotations map[string]string, changeGroupsUpdateToken string) (*http.Response, error)

func (*Client) SendExecutorStatus

func (c *Client) SendExecutorStatus(ctx context.Context, executor *rstypes.Executor) (*http.Response, error)

func (*Client) SendExecutorTaskStatus

func (c *Client) SendExecutorTaskStatus(ctx context.Context, executorID string, et *rstypes.ExecutorTask) (*http.Response, error)

func (*Client) SetHTTPClient

func (c *Client) SetHTTPClient(client *http.Client)

SetHTTPClient replaces default http.Client with user given one.

func (*Client) StartRun

func (c *Client) StartRun(ctx context.Context, runID string, changeGroupsUpdateToken string) (*http.Response, error)