Documentation ¶
Index ¶
- Constants
- type SwarmingTaskExecutor
- func (s *SwarmingTaskExecutor) GetFreeMachines(ctx context.Context, pool string) ([]*types.Machine, error)
- func (s *SwarmingTaskExecutor) GetPendingTasks(ctx context.Context, pool string) ([]*types.TaskResult, error)
- func (s *SwarmingTaskExecutor) GetTaskCompletionStatuses(ctx context.Context, taskIDs []string) ([]bool, error)
- func (s *SwarmingTaskExecutor) GetTaskResult(ctx context.Context, taskID string) (*types.TaskResult, error)
- func (s *SwarmingTaskExecutor) TriggerTask(ctx context.Context, req *types.TaskRequest) (*types.TaskResult, error)
Constants ¶
View Source
const ( // SwarmingUser is the user associated with Swarming tasks triggered by // this package. SwarmingUser = "skiabot@google.com" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SwarmingTaskExecutor ¶
type SwarmingTaskExecutor struct {
// contains filtered or unexported fields
}
SwarmingTaskExecutor implements types.TaskExecutor.
func NewSwarmingTaskExecutor ¶
func NewSwarmingTaskExecutor(s swarming.ApiClient, casInstance, pubSubTopic string) *SwarmingTaskExecutor
NewSwarmingTaskExecutor returns a SwarmingTaskExecutor instance.
func (*SwarmingTaskExecutor) GetFreeMachines ¶
func (s *SwarmingTaskExecutor) GetFreeMachines(ctx context.Context, pool string) ([]*types.Machine, error)
GetFreeMachines implements types.TaskExecutor.
func (*SwarmingTaskExecutor) GetPendingTasks ¶
func (s *SwarmingTaskExecutor) GetPendingTasks(ctx context.Context, pool string) ([]*types.TaskResult, error)
GetPendingTasks implements types.TaskExecutor.
func (*SwarmingTaskExecutor) GetTaskCompletionStatuses ¶
func (s *SwarmingTaskExecutor) GetTaskCompletionStatuses(ctx context.Context, taskIDs []string) ([]bool, error)
GetTaskCompletionStatuses implements types.TaskExecutor.
func (*SwarmingTaskExecutor) GetTaskResult ¶
func (s *SwarmingTaskExecutor) GetTaskResult(ctx context.Context, taskID string) (*types.TaskResult, error)
GetTaskResult implements types.TaskExecutor.
func (*SwarmingTaskExecutor) TriggerTask ¶
func (s *SwarmingTaskExecutor) TriggerTask(ctx context.Context, req *types.TaskRequest) (*types.TaskResult, error)
TriggerTask implements types.TaskExecutor.
Click to show internal directories.
Click to hide internal directories.