ecsclient

Documentation

Index

• Constants
• func NewECSClient(credentialProvider *credentials.Credentials, config *config.Config, ...) api.ECSClient
• type APIECSClient
  • func (client *APIECSClient) CreateCluster(clusterName string) (string, error)
  • func (client *APIECSClient) DiscoverPollEndpoint(containerInstanceArn string) (string, error)
  • func (client *APIECSClient) DiscoverTelemetryEndpoint(containerInstanceArn string) (string, error)
  • func (client *APIECSClient) RegisterContainerInstance(containerInstanceArn string, attributes []string) (string, error)
  • func (client *APIECSClient) SetSDK(sdk api.ECSSDK)
  • func (client *APIECSClient) SetSubmitStateChangeSDK(sdk api.ECSSubmitStateSDK)
  • func (client *APIECSClient) SubmitContainerStateChange(change api.ContainerStateChange) error
  • func (client *APIECSClient) SubmitTaskStateChange(change api.TaskStateChange) error

Constants

const (
	RoundtripTimeout = 5 * time.Second
)

Functions

func NewECSClient

func NewECSClient(credentialProvider *credentials.Credentials, config *config.Config, httpClient *http.Client, ec2MetadataClient ec2.EC2MetadataClient) api.ECSClient

Types

type APIECSClient

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

APIECSClient implements ECSClient

func (*APIECSClient) CreateCluster

func (client *APIECSClient) CreateCluster(clusterName string) (string, error)

CreateCluster creates a cluster from a given name and returns its arn

func (*APIECSClient) DiscoverPollEndpoint

func (client *APIECSClient) DiscoverPollEndpoint(containerInstanceArn string) (string, error)

func (*APIECSClient) DiscoverTelemetryEndpoint

func (client *APIECSClient) DiscoverTelemetryEndpoint(containerInstanceArn string) (string, error)

func (*APIECSClient) RegisterContainerInstance

func (client *APIECSClient) RegisterContainerInstance(containerInstanceArn string, attributes []string) (string, error)

func (*APIECSClient) SetSDK

func (client *APIECSClient) SetSDK(sdk api.ECSSDK)

SetSDK overrides the SDK to the given one. This is useful for injecting a test implementation

func (*APIECSClient) SetSubmitStateChangeSDK

func (client *APIECSClient) SetSubmitStateChangeSDK(sdk api.ECSSubmitStateSDK)

SetSubmitStateChangeSDK overrides the SDK to the given one. This is useful for injecting a test implementation

func (*APIECSClient) SubmitContainerStateChange

func (client *APIECSClient) SubmitContainerStateChange(change api.ContainerStateChange) error

func (*APIECSClient) SubmitTaskStateChange

func (client *APIECSClient) SubmitTaskStateChange(change api.TaskStateChange) error