Documentation
¶
Index ¶
- type Dispatcher
- func (s *Dispatcher) CleanupTask(ctp *launcher.CleanupTaskParams) (*launcher.CleanupTaskResult, error)
- func (s *Dispatcher) DefineAndLaunch(dp *launcher.DefineAndLaunchParams) (*launcher.DefineAndLaunchResult, error)
- func (s *Dispatcher) DefineTask(dp *launcher.DefineTaskParams) (*launcher.DefineTaskResult, error)
- func (s *Dispatcher) GetTaskLogs(gtlp *launcher.GetTaskLogsParams) (*launcher.GetTaskLogsResult, error)
- func (s *Dispatcher) GetTaskStatus(gts *launcher.GetTaskStatusParams) (*launcher.GetTaskStatusResult, error)
- func (s *Dispatcher) LaunchTask(rt *launcher.LaunchTaskParams) (*launcher.LaunchTaskResult, error)
- func (s *Dispatcher) WaitForTask(wft *launcher.WaitForTaskParams) (*launcher.WaitForTaskResult, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
Dispatcher dispatches definition and launch requests to the correct backend
func New ¶
func New(cfgs ...*aws.Config) *Dispatcher
New create a service dispatcher with the AWS configuration overrides
func (*Dispatcher) CleanupTask ¶
func (s *Dispatcher) CleanupTask(ctp *launcher.CleanupTaskParams) (*launcher.CleanupTaskResult, error)
CleanupTask clean up task definition, internally this is dispatched to the correct AWS service for creation
func (*Dispatcher) DefineAndLaunch ¶
func (s *Dispatcher) DefineAndLaunch(dp *launcher.DefineAndLaunchParams) (*launcher.DefineAndLaunchResult, error)
DefineAndLaunch create a definition, internally this is dispatched to the correct AWS service for creation
func (*Dispatcher) DefineTask ¶
func (s *Dispatcher) DefineTask(dp *launcher.DefineTaskParams) (*launcher.DefineTaskResult, error)
DefineTask create a definition, internally this is dispatched to the correct AWS service for creation
func (*Dispatcher) GetTaskLogs ¶
func (s *Dispatcher) GetTaskLogs(gtlp *launcher.GetTaskLogsParams) (*launcher.GetTaskLogsResult, error)
GetTaskLogs get the logs for a task, internally this is dispatched to the correct AWS service for creation
func (*Dispatcher) GetTaskStatus ¶
func (s *Dispatcher) GetTaskStatus(gts *launcher.GetTaskStatusParams) (*launcher.GetTaskStatusResult, error)
GetTaskStatus get task status, internally this is dispatched to the correct AWS service for creation
func (*Dispatcher) LaunchTask ¶
func (s *Dispatcher) LaunchTask(rt *launcher.LaunchTaskParams) (*launcher.LaunchTaskResult, error)
LaunchTask run a task, internally this is dispatched to the correct AWS service for creation
func (*Dispatcher) WaitForTask ¶
func (s *Dispatcher) WaitForTask(wft *launcher.WaitForTaskParams) (*launcher.WaitForTaskResult, error)
WaitForTask wait for a task to complete, internally this is dispatched to the correct AWS service for creation