eventhandler

Documentation

Index

• func HandleEngineEvents(taskEngine engine.TaskEngine, client api.ECSClient, eventhandler *TaskHandler)
• type TaskHandler
  • func NewTaskHandler(stateManager statemanager.Saver) *TaskHandler
  • func (handler *TaskHandler) AddStateChangeEvent(change statechange.Event, client api.ECSClient) error
  • func (handler *TaskHandler) SubmitTaskEvents(taskEvents *eventList, client api.ECSClient)

Functions

func HandleEngineEvents

func HandleEngineEvents(taskEngine engine.TaskEngine, client api.ECSClient, eventhandler *TaskHandler)

Types

type TaskHandler

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

TaskHandler encapsulates the the map of a task arn to task and container events associated with said task

func NewTaskHandler

func NewTaskHandler(stateManager statemanager.Saver) *TaskHandler

NewTaskHandler returns a pointer to TaskHandler

func (*TaskHandler) AddStateChangeEvent

func (handler *TaskHandler) AddStateChangeEvent(change statechange.Event, client api.ECSClient) error

AddStateChangeEvent queues up a state change for sending using the given client.

func (*TaskHandler) SubmitTaskEvents

func (handler *TaskHandler) SubmitTaskEvents(taskEvents *eventList, client api.ECSClient)

Continuously retries sending an event until it succeeds, sleeping between each attempt