session

Documentation

Index

• func NewCredentialsMetadataSetter(taskEngine engine.TaskEngine) *credentialsMetadataSetter
• func NewENIHandler(state dockerstate.TaskEngineState, dataClient data.Client) *eniHandler
• func NewManifestMessageIDAccessor() *manifestMessageIDAccessor
• func NewPayloadMessageHandler(taskEngine engine.TaskEngine, ecsClient ecs.ECSClient, dataClient data.Client, ...) *payloadMessageHandler
• func NewSequenceNumberAccessor(latestSeqNumberTaskManifest *int64, dataClient data.Client) *sequenceNumberAccessor
• func NewTaskComparer(taskEngine engine.TaskEngine) *taskComparer
• func NewTaskStopper(taskEngine engine.TaskEngine, dataClient data.Client) *taskStopper
• type UnrecognizedTaskError
  • func (err UnrecognizedTaskError) Error() string

Functions

func NewCredentialsMetadataSetter

func NewCredentialsMetadataSetter(taskEngine engine.TaskEngine) *credentialsMetadataSetter

NewCredentialsMetadataSetter creates a new credentialsMetadataSetter.

func NewENIHandler

func NewENIHandler(state dockerstate.TaskEngineState, dataClient data.Client) *eniHandler

NewENIHandler creates a new eniHandler.

func NewManifestMessageIDAccessor

func NewManifestMessageIDAccessor() *manifestMessageIDAccessor

NewManifestMessageIDAccessor creates a new manifestMessageIDAccessor.

func NewPayloadMessageHandler

func NewPayloadMessageHandler(taskEngine engine.TaskEngine,
	ecsClient ecs.ECSClient,
	dataClient data.Client,
	taskHandler *eventhandler.TaskHandler,
	credentialsManager credentials.Manager,
	latestSeqNumberTaskManifest *int64) *payloadMessageHandler

NewPayloadMessageHandler creates a new payloadMessageHandler.

func NewSequenceNumberAccessor

func NewSequenceNumberAccessor(latestSeqNumberTaskManifest *int64, dataClient data.Client) *sequenceNumberAccessor

NewSequenceNumberAccessor creates a new NewSequenceNumberAccessor.

func NewTaskComparer

func NewTaskComparer(taskEngine engine.TaskEngine) *taskComparer

NewTaskComparer creates a new taskComparer.

func NewTaskStopper

func NewTaskStopper(taskEngine engine.TaskEngine, dataClient data.Client) *taskStopper

NewTaskStopper creates a new taskStopper.

Types

type UnrecognizedTaskError

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

func (UnrecognizedTaskError) Error

func (err UnrecognizedTaskError) Error() string