scalesets

package

v0.2.0-alpha Latest Latest Go to latest Published: Jul 6, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudbase/garm

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type MessageSession
type ScaleSetClient
- func NewClient(cli common.GithubClient) (*ScaleSetClient, 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) error

func (*MessageSession) GetMessage ¶

func (m *MessageSession) GetMessage(ctx context.Context, lastMessageID int64, maxCapacity uint) (params.RunnerScaleSetMessage, error)

func (*MessageSession) LastError ¶

func (m *MessageSession) LastError() error

func (*MessageSession) MessageQueueAccessToken ¶

func (m *MessageSession) MessageQueueAccessToken() string

func (*MessageSession) Refresh ¶

func (m *MessageSession) Refresh(ctx context.Context) error

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 (s *ScaleSetClient) AcquireJobs(ctx context.Context, runnerScaleSetID int, messageQueueAccessToken string, requestIDs []int64) ([]int64, error)

func (*ScaleSetClient) CreateMessageSession ¶

func (s *ScaleSetClient) CreateMessageSession(ctx context.Context, runnerScaleSetID int, owner string) (*MessageSession, error)

func (*ScaleSetClient) CreateRunnerScaleSet ¶

func (s *ScaleSetClient) CreateRunnerScaleSet(ctx context.Context, runnerScaleSet *params.RunnerScaleSet) (params.RunnerScaleSet, 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) error

func (*ScaleSetClient) DeleteRunnerScaleSet ¶

func (s *ScaleSetClient) DeleteRunnerScaleSet(ctx context.Context, runnerScaleSetID int) error

func (*ScaleSetClient) Do ¶

func (s *ScaleSetClient) Do(req *http.Request) (*http.Response, error)

func (*ScaleSetClient) GenerateJitRunnerConfig ¶

func (s *ScaleSetClient) GenerateJitRunnerConfig(ctx context.Context, runnerName string, scaleSetID int) (params.RunnerScaleSetJitRunnerConfig, error)

func (*ScaleSetClient) GetAcquirableJobs ¶

func (s *ScaleSetClient) GetAcquirableJobs(ctx context.Context, runnerScaleSetID int) (params.AcquirableJobList, error)

func (*ScaleSetClient) GetRunner ¶

func (s *ScaleSetClient) GetRunner(ctx context.Context, runnerID int64) (params.RunnerReference, error)

func (*ScaleSetClient) GetRunnerByName ¶

func (s *ScaleSetClient) GetRunnerByName(ctx context.Context, runnerName string) (params.RunnerReference, error)

func (*ScaleSetClient) GetRunnerGroupByName ¶

func (s *ScaleSetClient) GetRunnerGroupByName(ctx context.Context, runnerGroup string) (params.RunnerGroup, error)

func (*ScaleSetClient) GetRunnerScaleSetByID ¶

func (s *ScaleSetClient) GetRunnerScaleSetByID(ctx context.Context, runnerScaleSetID int) (params.RunnerScaleSet, error)

func (*ScaleSetClient) GetRunnerScaleSetByNameAndRunnerGroup ¶

func (s *ScaleSetClient) GetRunnerScaleSetByNameAndRunnerGroup(ctx context.Context, runnerGroupID int, name string) (params.RunnerScaleSet, error)

func (*ScaleSetClient) ListAllRunners ¶

func (s *ScaleSetClient) ListAllRunners(ctx context.Context) (params.RunnerReferenceList, error)

func (*ScaleSetClient) ListRunnerScaleSets ¶

func (s *ScaleSetClient) ListRunnerScaleSets(ctx context.Context) (*params.RunnerScaleSetsResponse, error)

ListRunnerScaleSets lists all runner scale sets in a github entity.

func (*ScaleSetClient) RemoveRunner ¶

func (s *ScaleSetClient) RemoveRunner(ctx context.Context, runnerID int64) 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, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL