runners

Documentation

Index

• type RunnerManager
  • func NewRunnerManager(ctx context.Context, client actions.ActionsService, runnerScaleSetId int) (*RunnerManager, error)
  • func (m *RunnerManager) AcquireJobs(ctx context.Context, requestIds []int64) error
  • func (m *RunnerManager) Close() error
  • func (m *RunnerManager) ProcessMessages(ctx context.Context, handler func(msg *types.RunnerScaleSetMessage) error) error
• type RunnerManagerInterface
• type RunnerMessageProcessor
  • func NewRunnerMessageProcessor(ctx context.Context, runnerManager RunnerManagerInterface, ...) *RunnerMessageProcessor
  • func (p *RunnerMessageProcessor) StartProcessingMessages() error
• type RunnerProvisionerInterface
• type VMTracker
  • func NewVMTracker(orkaClient orka.OrkaService, actionsClient actions.ActionsService, ...) *VMTracker
  • func (tracker *VMTracker) Start(ctx context.Context, interval time.Duration)
  • func (tracker *VMTracker) Track(vmName string)
  • func (tracker *VMTracker) Untrack(vmName string)

Types

type RunnerManager

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

func NewRunnerManager

func NewRunnerManager(ctx context.Context, client actions.ActionsService, runnerScaleSetId int) (*RunnerManager, error)

func (*RunnerManager) AcquireJobs

func (m *RunnerManager) AcquireJobs(ctx context.Context, requestIds []int64) error

func (*RunnerManager) Close

func (m *RunnerManager) Close() error

func (*RunnerManager) ProcessMessages

func (m *RunnerManager) ProcessMessages(ctx context.Context, handler func(msg *types.RunnerScaleSetMessage) error) error

type RunnerManagerInterface

type RunnerManagerInterface interface {
	ProcessMessages(ctx context.Context, handler func(msg *types.RunnerScaleSetMessage) error) error
	AcquireJobs(ctx context.Context, requestIds []int64) error
}

type RunnerMessageProcessor

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

func NewRunnerMessageProcessor

func NewRunnerMessageProcessor(ctx context.Context, runnerManager RunnerManagerInterface, runnerProvisioner RunnerProvisionerInterface, vmTracker *VMTracker, runnerScaleSet *types.RunnerScaleSet) *RunnerMessageProcessor

func (*RunnerMessageProcessor) StartProcessingMessages

func (p *RunnerMessageProcessor) StartProcessingMessages() error

type RunnerProvisionerInterface

type RunnerProvisionerInterface interface {
	ProvisionRunner(ctx context.Context) (*orka.VMCommandExecutor, []string, error)
	CleanupResources(ctx context.Context, runnerName string)
}

type VMTracker

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

func NewVMTracker

func NewVMTracker(orkaClient orka.OrkaService, actionsClient actions.ActionsService, logger *zap.SugaredLogger) *VMTracker

func (*VMTracker) Start

func (tracker *VMTracker) Start(ctx context.Context, interval time.Duration)

func (*VMTracker) Track

func (tracker *VMTracker) Track(vmName string)

func (*VMTracker) Untrack

func (tracker *VMTracker) Untrack(vmName string)