actions

Documentation

Index

• func ParseActionsErrorFromResponse(response *http.Response) error
• func RequestJSON[Req any, Res any](ctx context.Context, client *ActionsClient, method string, path string, ...) (*Res, error)
• type ActionsClient
  • func NewActionsClient(ctx context.Context, envData *env.Data, config *github.GitHubConfig) (*ActionsClient, error)
  • func (client *ActionsClient) AcquireJobs(ctx context.Context, runnerScaleSetId int, messageQueueAccessToken string, ...) ([]int64, error)
  • func (client *ActionsClient) CreateMessageSession(ctx context.Context, runnerScaleSetId int, owner string) (*types.RunnerScaleSetSession, error)
  • func (client *ActionsClient) CreateRunner(ctx context.Context, runnerScaleSetID int, runnerName string) (*types.RunnerScaleSetJitRunnerConfig, error)
  • func (client *ActionsClient) CreateRunnerScaleSet(ctx context.Context, runner *types.RunnerScaleSet) (*types.RunnerScaleSet, error)
  • func (client *ActionsClient) DeleteMessage(ctx context.Context, messageQueueUrl, messageQueueAccessToken string, ...) error
  • func (client *ActionsClient) DeleteMessageSession(ctx context.Context, runnerScaleSetId int, sessionId *uuid.UUID) error
  • func (client *ActionsClient) DeleteRunner(ctx context.Context, runnerID int) error
  • func (client *ActionsClient) DeleteRunnerScaleSet(ctx context.Context, runnerScaleSetId int) error
  • func (client *ActionsClient) GetAcquirableJobs(ctx context.Context, runnerScaleSetId int) (*types.AcquirableJobList, error)
  • func (client *ActionsClient) GetMessage(ctx context.Context, messageQueueUrl, messageQueueAccessToken string, ...) (*types.RunnerScaleSetMessage, error)
  • func (client *ActionsClient) GetRunner(ctx context.Context, runnerName string) (*types.RunnerReference, error)
  • func (client *ActionsClient) GetRunnerScaleSet(ctx context.Context, runnerGroupId int, runnerName string) (*types.RunnerScaleSet, error)
  • func (client *ActionsClient) RefreshMessageSession(ctx context.Context, runnerScaleSetId int, sessionId *uuid.UUID) (*types.RunnerScaleSetSession, error)
• type ActionsError
  • func (e *ActionsError) Error() string
• type ActionsService

Functions

func ParseActionsErrorFromResponse

func ParseActionsErrorFromResponse(response *http.Response) error

func RequestJSON

func RequestJSON[Req any, Res any](ctx context.Context, client *ActionsClient, method string, path string, body *Req) (*Res, error)

Types

type ActionsClient

type ActionsClient struct {
	*retryablehttp.Client
	// contains filtered or unexported fields
}

func NewActionsClient

func NewActionsClient(ctx context.Context, envData *env.Data, config *github.GitHubConfig) (*ActionsClient, error)

func (*ActionsClient) AcquireJobs

func (client *ActionsClient) AcquireJobs(ctx context.Context, runnerScaleSetId int, messageQueueAccessToken string, requestIds []int64) ([]int64, error)

func (*ActionsClient) CreateMessageSession

func (client *ActionsClient) CreateMessageSession(ctx context.Context, runnerScaleSetId int, owner string) (*types.RunnerScaleSetSession, error)

func (*ActionsClient) CreateRunner

func (client *ActionsClient) CreateRunner(ctx context.Context, runnerScaleSetID int, runnerName string) (*types.RunnerScaleSetJitRunnerConfig, error)

func (*ActionsClient) CreateRunnerScaleSet

func (client *ActionsClient) CreateRunnerScaleSet(ctx context.Context, runner *types.RunnerScaleSet) (*types.RunnerScaleSet, error)

func (*ActionsClient) DeleteMessage

func (client *ActionsClient) DeleteMessage(ctx context.Context, messageQueueUrl, messageQueueAccessToken string, messageId int64) error

func (*ActionsClient) DeleteMessageSession

func (client *ActionsClient) DeleteMessageSession(ctx context.Context, runnerScaleSetId int, sessionId *uuid.UUID) error

func (*ActionsClient) DeleteRunner

func (client *ActionsClient) DeleteRunner(ctx context.Context, runnerID int) error

func (*ActionsClient) DeleteRunnerScaleSet

func (client *ActionsClient) DeleteRunnerScaleSet(ctx context.Context, runnerScaleSetId int) error

func (*ActionsClient) GetAcquirableJobs

func (client *ActionsClient) GetAcquirableJobs(ctx context.Context, runnerScaleSetId int) (*types.AcquirableJobList, error)

func (*ActionsClient) GetMessage

func (client *ActionsClient) GetMessage(ctx context.Context, messageQueueUrl, messageQueueAccessToken string, lastMessageId int64) (*types.RunnerScaleSetMessage, error)

func (*ActionsClient) GetRunner

func (client *ActionsClient) GetRunner(ctx context.Context, runnerName string) (*types.RunnerReference, error)

func (*ActionsClient) GetRunnerScaleSet

func (client *ActionsClient) GetRunnerScaleSet(ctx context.Context, runnerGroupId int, runnerName string) (*types.RunnerScaleSet, error)

func (*ActionsClient) RefreshMessageSession

func (client *ActionsClient) RefreshMessageSession(ctx context.Context, runnerScaleSetId int, sessionId *uuid.UUID) (*types.RunnerScaleSetSession, error)

type ActionsError

type ActionsError struct {
	ExceptionName string `json:"typeName,omitempty"`
	Message       string `json:"message,omitempty"`
	StatusCode    int
}

func (*ActionsError) Error

func (e *ActionsError) Error() string

type ActionsService

type ActionsService interface {
	GetRunnerScaleSet(ctx context.Context, runnerGroupId int, runnerScaleSetName string) (*types.RunnerScaleSet, error)
	CreateRunnerScaleSet(ctx context.Context, runnerScaleSet *types.RunnerScaleSet) (*types.RunnerScaleSet, error)
	DeleteRunnerScaleSet(ctx context.Context, runnerScaleSetId int) error

	GetRunner(ctx context.Context, runnerName string) (*types.RunnerReference, error)
	CreateRunner(ctx context.Context, runnerScaleSetID int, runnerName string) (*types.RunnerScaleSetJitRunnerConfig, error)
	DeleteRunner(ctx context.Context, runnerID int) error

	CreateMessageSession(ctx context.Context, runnerScaleSetId int, owner string) (*types.RunnerScaleSetSession, error)
	DeleteMessageSession(ctx context.Context, runnerScaleSetId int, sessionId *uuid.UUID) error
	RefreshMessageSession(ctx context.Context, runnerScaleSetId int, sessionId *uuid.UUID) (*types.RunnerScaleSetSession, error)

	AcquireJobs(ctx context.Context, runnerScaleSetId int, messageQueueAccessToken string, requestIds []int64) ([]int64, error)
	GetAcquirableJobs(ctx context.Context, runnerScaleSetId int) (*types.AcquirableJobList, error)

	GetMessage(ctx context.Context, messageQueueUrl, messageQueueAccessToken string, lastMessageId int64) (*types.RunnerScaleSetMessage, error)
	DeleteMessage(ctx context.Context, messageQueueUrl, messageQueueAccessToken string, messageId int64) error
}