handler

Documentation

Overview

Package handler deals with appropriately reacting to all ACS messages as well as maintaining the connection to ACS.

Index

• Variables
• func AcsWsUrl(endpoint, cluster, containerInstanceArn string, taskEngine engine.TaskEngine) string
• func StartSession(ctx context.Context, args StartSessionArguments) error
• type StartSessionArguments
• type UnrecognizedTaskError
  • func (err UnrecognizedTaskError) Error() string

Variables

var SequenceNumber = utilatomic.NewIncreasingInt64(1)

SequenceNumber is a number shared between all ACS clients which indicates the last sequence number successfully handled.

Functions

func AcsWsUrl

func AcsWsUrl(endpoint, cluster, containerInstanceArn string, taskEngine engine.TaskEngine) string

AcsWsUrl returns the websocket url for ACS given the endpoint.

func StartSession

func StartSession(ctx context.Context, args StartSessionArguments) error

StartSession creates a session with ACS and handles requests using the passed in arguments.

Types

type StartSessionArguments

type StartSessionArguments struct {
	ContainerInstanceArn string
	CredentialProvider   *credentials.Credentials
	Config               *config.Config
	TaskEngine           engine.TaskEngine
	ECSClient            api.ECSClient
	StateManager         statemanager.StateManager
	AcceptInvalidCert    bool
}

StartSessionArguments is a struct representing all the things this handler needs... This is really a hack to get by-name instead of positional arguments since there are too many for positional to be wieldy

type UnrecognizedTaskError

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

func (UnrecognizedTaskError) Error

func (err UnrecognizedTaskError) Error() string