session

type CredentialsMetadataSetter ¶

type CredentialsMetadataSetter interface {
	SetTaskRoleCredentialsMetadata(message *ecsacs.IAMRoleCredentialsMessage) error
	SetExecRoleCredentialsMetadata(message *ecsacs.IAMRoleCredentialsMessage) error
}

type ENIHandler ¶

type ENIHandler interface {
	HandleENIAttachment(eniAttachment *ni.ENIAttachment) error
}

type ManifestMessageIDAccessor ¶

type ManifestMessageIDAccessor interface {
	GetMessageID() string
	SetMessageID(messageID string) error
}

ManifestMessageIDAccessor stores the latest message ID that corresponds to the most recently processed task manifest message and is used to determine the validity of a task stop verification ack message.

type PayloadMessageHandler ¶

type PayloadMessageHandler interface {
	ProcessMessage(message *ecsacs.PayloadMessage,
		ackFunc func(*ecsacs.AckRequest, []*ecsacs.IAMRoleCredentialsAckRequest)) error
}

type ResourceHandler ¶

type ResourceHandler interface {
	HandleResourceAttachment(Attachment *resource.ResourceAttachment)
}

type SequenceNumberAccessor ¶

type SequenceNumberAccessor interface {
	GetLatestSequenceNumber() int64
	SetLatestSequenceNumber(seqNum int64) error
}

SequenceNumberAccessor is used to get and set state for the current container instance. It sets and gets the latest sequence number that corresponds to the most recent task manifest that the task manifest responder has processed it alo sets the latest message id

type Session ¶

type Session interface {
	Start(context.Context) error
	GetLastConnectedTime() time.Time
}

Session defines an interface for Agent's long-lived connection with ACS. The Session.Start() method can be used to start processing messages from ACS.

func NewSession(containerInstanceARN string,
	cluster string,
	ecsClient ecs.ECSClient,
	credentialsProvider *credentials.Credentials,
	inactiveInstanceCB func(),
	clientFactory wsclient.ClientFactory,
	metricsFactory metrics.EntryFactory,
	agentVersion string,
	agentHash string,
	dockerVersion string,
	minAgentConfig *wsclient.WSClientMinAgentConfig,
	payloadMessageHandler PayloadMessageHandler,
	credentialsManager rolecredentials.Manager,
	credentialsMetadataSetter CredentialsMetadataSetter,
	doctor *doctor.Doctor,
	eniHandler ENIHandler,
	manifestMessageIDAccessor ManifestMessageIDAccessor,
	taskComparer TaskComparer,
	sequenceNumberAccessor SequenceNumberAccessor,
	taskStopper TaskStopper,
	resourceHandler ResourceHandler,
	addUpdateRequestHandlers func(wsclient.ClientServer),
) Session

type TaskComparer ¶

type TaskComparer interface {
	CompareRunningTasksOnInstanceWithManifest(*ecsacs.TaskManifestMessage) ([]*ecsacs.TaskIdentifier, error)
}

TaskComparer gets and compares running tasks on an instance to those in the ACS manifest. It should be implemented by an underlying struct that has access to such data.

type TaskStopper ¶

type TaskStopper interface {
	StopTask(taskARN string)
}