acs

Documentation

Index

• Constants
• type AckRequest
• type AgentCommunicationClient
  • func NewAgentCommunicationClient(endpoint string, cfg *config.Config, ...) *AgentCommunicationClient
  • func (acc *AgentCommunicationClient) Ack(message *Payload) bool
  • func (acc *AgentCommunicationClient) Poll(acceptInvalidCert bool) (<-chan *Payload, <-chan error, error)
• type HealthResponse
• type Payload
• type PollCallback
• type PollResponse

Constants

const CONNECT_TIMEOUT = 3 * time.Second

const HEARTBEAT_JITTER = 3 * time.Minute

const HEARTBEAT_TIMEOUT = 5 * time.Minute

The maximum time to wait between heartbeats without disconnecting

Types

type AckRequest

type AckRequest struct {
	ClusterArn           string `json:"cluster"`
	ContainerInstanceArn string `json:"containerInstance"`
	MessageId            string `json:"messageId"`
}

type AgentCommunicationClient

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

AgentCommunicationClient is a client that keeps track of connections to the AgentCommunication backend service. It stores configuration needed to connect and its current connection

func NewAgentCommunicationClient

func NewAgentCommunicationClient(endpoint string, cfg *config.Config, credentialProvider credentials.AWSCredentialProvider, containerInstanceArn string) *AgentCommunicationClient

func (*AgentCommunicationClient) Ack

func (acc *AgentCommunicationClient) Ack(message *Payload) bool

Ack acknowledges that a given message was recieved. It is expected to be called after Poll such that Poll has already opened a websocket connection.

func (*AgentCommunicationClient) Poll

func (acc *AgentCommunicationClient) Poll(acceptInvalidCert bool) (<-chan *Payload, <-chan error, error)

Poll contacts the agent communication service and opens a websocket to wait for updates. It emits each state update to the Payload channel it returns

type HealthResponse

type HealthResponse struct {
	Healthy bool `json:"healthy"`
}

type Payload

type Payload struct {
	Tasks     []*api.Task
	MessageId string
}

type PollCallback

type PollCallback func(api.Task)

type PollResponse

type PollResponse struct {
	MessageType string `json:"type"`
	//TODO handle other messageTypes, this should be union type
	Message Payload `json:"message"`
}