swarmingv2

Documentation

Index

• type SwarmingV2TaskExecutor
  • func NewSwarmingV2TaskExecutor(client swarmingv2.SwarmingV2Client, casInstance, pubSubTopic string) *SwarmingV2TaskExecutor
  • func (s *SwarmingV2TaskExecutor) GetFreeMachines(ctx context.Context, pool string) ([]*types.Machine, error)
  • func (s *SwarmingV2TaskExecutor) GetPendingTasks(ctx context.Context, pool string) ([]*types.TaskResult, error)
  • func (s *SwarmingV2TaskExecutor) GetTaskCompletionStatuses(ctx context.Context, taskIDs []string) ([]bool, error)
  • func (s *SwarmingV2TaskExecutor) GetTaskResult(ctx context.Context, taskID string) (*types.TaskResult, error)
  • func (s *SwarmingV2TaskExecutor) TriggerTask(ctx context.Context, req *types.TaskRequest) (*types.TaskResult, error)

Types

type SwarmingV2TaskExecutor

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

SwarmingV2TaskExecutor implements types.TaskExecutor.

func NewSwarmingV2TaskExecutor

func NewSwarmingV2TaskExecutor(client swarmingv2.SwarmingV2Client, casInstance, pubSubTopic string) *SwarmingV2TaskExecutor

NewSwarmingV2TaskExecutor returns a SwarmingTaskExecutor instance.

func (*SwarmingV2TaskExecutor) GetFreeMachines

func (s *SwarmingV2TaskExecutor) GetFreeMachines(ctx context.Context, pool string) ([]*types.Machine, error)

GetFreeMachines implements types.TaskExecutor.

func (*SwarmingV2TaskExecutor) GetPendingTasks

func (s *SwarmingV2TaskExecutor) GetPendingTasks(ctx context.Context, pool string) ([]*types.TaskResult, error)

GetPendingTasks implements types.TaskExecutor.

func (*SwarmingV2TaskExecutor) GetTaskCompletionStatuses

func (s *SwarmingV2TaskExecutor) GetTaskCompletionStatuses(ctx context.Context, taskIDs []string) ([]bool, error)

GetTaskCompletionStatuses implements types.TaskExecutor.

func (*SwarmingV2TaskExecutor) GetTaskResult

func (s *SwarmingV2TaskExecutor) GetTaskResult(ctx context.Context, taskID string) (*types.TaskResult, error)

GetTaskResult implements types.TaskExecutor.

func (*SwarmingV2TaskExecutor) TriggerTask

func (s *SwarmingV2TaskExecutor) TriggerTask(ctx context.Context, req *types.TaskRequest) (*types.TaskResult, error)

TriggerTask implements types.TaskExecutor.