Documentation
¶
Index ¶
- Constants
- type MessageSession
- func (m *MessageSession) Close() error
- func (m *MessageSession) DeleteMessage(ctx context.Context, messageID int64) (err error)
- func (m *MessageSession) GetMessage(ctx context.Context, lastMessageID int64, maxCapacity uint) (_ params.RunnerScaleSetMessage, err error)
- func (m *MessageSession) LastError() error
- func (m *MessageSession) MessageQueueAccessToken() string
- func (m *MessageSession) Refresh(ctx context.Context) (err error)
- func (m *MessageSession) SessionsRelativeURL() (string, error)
- type ScaleSetClient
- func (s *ScaleSetClient) AcquireJobs(ctx context.Context, runnerScaleSetID int, messageQueueAccessToken string, ...) (_ []int64, err error)
- func (s *ScaleSetClient) CreateMessageSession(ctx context.Context, runnerScaleSetID int, owner string) (_ *MessageSession, err error)
- func (s *ScaleSetClient) CreateRunnerScaleSet(ctx context.Context, runnerScaleSet *params.RunnerScaleSet) (_ params.RunnerScaleSet, err error)
- func (s *ScaleSetClient) DeleteMessageSession(ctx context.Context, session *MessageSession) (err error)
- func (s *ScaleSetClient) DeleteRunnerScaleSet(ctx context.Context, runnerScaleSetID int) (err error)
- func (s *ScaleSetClient) Do(req *http.Request) (*http.Response, error)
- func (s *ScaleSetClient) GenerateJitRunnerConfig(ctx context.Context, runnerName string, scaleSetID int) (_ params.RunnerScaleSetJitRunnerConfig, err error)
- func (s *ScaleSetClient) GetAcquirableJobs(ctx context.Context, runnerScaleSetID int) (_ params.AcquirableJobList, err error)
- func (s *ScaleSetClient) GetGithubClient() (common.GithubClient, error)
- func (s *ScaleSetClient) GetRunner(ctx context.Context, runnerID int64) (_ params.RunnerReference, err error)
- func (s *ScaleSetClient) GetRunnerByName(ctx context.Context, runnerName string) (_ params.RunnerReference, err error)
- func (s *ScaleSetClient) GetRunnerGroupByName(ctx context.Context, runnerGroup string) (_ params.RunnerGroup, err error)
- func (s *ScaleSetClient) GetRunnerScaleSetByID(ctx context.Context, runnerScaleSetID int) (_ params.RunnerScaleSet, err error)
- func (s *ScaleSetClient) GetRunnerScaleSetByNameAndRunnerGroup(ctx context.Context, runnerGroupID int, name string) (_ params.RunnerScaleSet, err error)
- func (s *ScaleSetClient) ListAllRunners(ctx context.Context) (_ params.RunnerReferenceList, err error)
- func (s *ScaleSetClient) ListRunnerScaleSets(ctx context.Context) (_ *params.RunnerScaleSetsResponse, err error)
- func (s *ScaleSetClient) RemoveRunner(ctx context.Context, runnerID int64) (err error)
- func (s *ScaleSetClient) SetGithubClient(cli common.GithubClient)
- func (s *ScaleSetClient) UpdateRunnerScaleSet(ctx context.Context, runnerScaleSetID int, ...) (_ params.RunnerScaleSet, err error)
Constants ¶
View Source
const ( HeaderActionsActivityID = "ActivityId" HeaderGitHubRequestID = "X-GitHub-Request-Id" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageSession ¶
type MessageSession struct {
// contains filtered or unexported fields
}
func (*MessageSession) Close ¶
func (m *MessageSession) Close() error
func (*MessageSession) DeleteMessage ¶
func (m *MessageSession) DeleteMessage(ctx context.Context, messageID int64) (err error)
func (*MessageSession) GetMessage ¶
func (m *MessageSession) GetMessage(ctx context.Context, lastMessageID int64, maxCapacity uint) (_ params.RunnerScaleSetMessage, err error)
func (*MessageSession) LastError ¶
func (m *MessageSession) LastError() error
func (*MessageSession) MessageQueueAccessToken ¶
func (m *MessageSession) MessageQueueAccessToken() string
func (*MessageSession) SessionsRelativeURL ¶
func (m *MessageSession) SessionsRelativeURL() (string, error)
type ScaleSetClient ¶
type ScaleSetClient struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(cli common.GithubClient) (*ScaleSetClient, error)
func (*ScaleSetClient) AcquireJobs ¶
func (*ScaleSetClient) CreateMessageSession ¶
func (s *ScaleSetClient) CreateMessageSession(ctx context.Context, runnerScaleSetID int, owner string) (_ *MessageSession, err error)
func (*ScaleSetClient) CreateRunnerScaleSet ¶
func (s *ScaleSetClient) CreateRunnerScaleSet(ctx context.Context, runnerScaleSet *params.RunnerScaleSet) (_ params.RunnerScaleSet, err error)
CreateRunnerScaleSet creates a new runner scale set in the target GitHub entity.
func (*ScaleSetClient) DeleteMessageSession ¶
func (s *ScaleSetClient) DeleteMessageSession(ctx context.Context, session *MessageSession) (err error)
func (*ScaleSetClient) DeleteRunnerScaleSet ¶
func (s *ScaleSetClient) DeleteRunnerScaleSet(ctx context.Context, runnerScaleSetID int) (err error)
func (*ScaleSetClient) GenerateJitRunnerConfig ¶
func (s *ScaleSetClient) GenerateJitRunnerConfig(ctx context.Context, runnerName string, scaleSetID int) (_ params.RunnerScaleSetJitRunnerConfig, err error)
func (*ScaleSetClient) GetAcquirableJobs ¶
func (s *ScaleSetClient) GetAcquirableJobs(ctx context.Context, runnerScaleSetID int) (_ params.AcquirableJobList, err error)
func (*ScaleSetClient) GetGithubClient ¶
func (s *ScaleSetClient) GetGithubClient() (common.GithubClient, error)
func (*ScaleSetClient) GetRunner ¶
func (s *ScaleSetClient) GetRunner(ctx context.Context, runnerID int64) (_ params.RunnerReference, err error)
func (*ScaleSetClient) GetRunnerByName ¶
func (s *ScaleSetClient) GetRunnerByName(ctx context.Context, runnerName string) (_ params.RunnerReference, err error)
func (*ScaleSetClient) GetRunnerGroupByName ¶
func (s *ScaleSetClient) GetRunnerGroupByName(ctx context.Context, runnerGroup string) (_ params.RunnerGroup, err error)
func (*ScaleSetClient) GetRunnerScaleSetByID ¶
func (s *ScaleSetClient) GetRunnerScaleSetByID(ctx context.Context, runnerScaleSetID int) (_ params.RunnerScaleSet, err error)
func (*ScaleSetClient) GetRunnerScaleSetByNameAndRunnerGroup ¶
func (s *ScaleSetClient) GetRunnerScaleSetByNameAndRunnerGroup(ctx context.Context, runnerGroupID int, name string) (_ params.RunnerScaleSet, err error)
func (*ScaleSetClient) ListAllRunners ¶
func (s *ScaleSetClient) ListAllRunners(ctx context.Context) (_ params.RunnerReferenceList, err error)
func (*ScaleSetClient) ListRunnerScaleSets ¶
func (s *ScaleSetClient) ListRunnerScaleSets(ctx context.Context) (_ *params.RunnerScaleSetsResponse, err error)
ListRunnerScaleSets lists all runner scale sets in a github entity.
func (*ScaleSetClient) RemoveRunner ¶
func (s *ScaleSetClient) RemoveRunner(ctx context.Context, runnerID int64) (err error)
func (*ScaleSetClient) SetGithubClient ¶
func (s *ScaleSetClient) SetGithubClient(cli common.GithubClient)
func (*ScaleSetClient) UpdateRunnerScaleSet ¶
func (s *ScaleSetClient) UpdateRunnerScaleSet(ctx context.Context, runnerScaleSetID int, runnerScaleSet params.RunnerScaleSet) (_ params.RunnerScaleSet, err error)
Source Files
Click to show internal directories.
Click to hide internal directories.