wrappers

Documentation

Index

• func NewAWSSession() (*session.Session, error)
• type CSSWrapper
  • func NewCSSWrapper(clusterStateServiceEndpoint string) (CSSWrapper, error)
• type CloudwatchWrapper
  • func NewCloudwatchWrapper(sess *session.Session) (CloudwatchWrapper, error)
• type EC2Wrapper
  • func NewEC2Wrapper(sess *session.Session) (EC2Wrapper, error)
• type ECSWrapper
  • func NewECSWrapper(sess *session.Session) (ECSWrapper, error)

Functions

func NewAWSSession

func NewAWSSession() (*session.Session, error)

NewAWSSession creates an AWS session.

Types

type CSSWrapper

type CSSWrapper interface {
	ListInstances(cluster *string) ([]*models.ContainerInstance, error)
	GetInstance(cluster *string, instanceARN *string) (*models.ContainerInstance, error)
	ListTasks(cluster *string) ([]*models.Task, error)
	GetTask(cluster *string, taskARN *string) (*models.Task, error)
}

CSSWrapper defines methods to access wrapper methods to call CSS APIs

func NewCSSWrapper

func NewCSSWrapper(clusterStateServiceEndpoint string) (CSSWrapper, error)

NewCSSWrapper returns a new CSSWrapper for the canary

type CloudwatchWrapper

type CloudwatchWrapper interface {
	EmitSuccessMetric(metricName *string) error
	EmitFailureMetric(metricName *string) error
}

CloudwatchWrapper defines methods to access wrapper methods to call Cloudwatch APIs

func NewCloudwatchWrapper

func NewCloudwatchWrapper(sess *session.Session) (CloudwatchWrapper, error)

NewCloudwatchWrapper returns a new CloudwatchWrapper for the canary

type EC2Wrapper

type EC2Wrapper interface {
	LaunchInstances(count *int64, clusterName *string) ([]*string, error)
	TerminateInstances(instanceIDs []*string) error
}

EC2Wrapper defines methods to access wrapper methods to call EC2 APIs

func NewEC2Wrapper

func NewEC2Wrapper(sess *session.Session) (EC2Wrapper, error)

NewEC2Wrapper returns a new EC2Wrapper for the canary

type ECSWrapper

type ECSWrapper interface {
	CreateCluster(clusterName *string) error
	DeleteCluster(clusterName *string) error
	ListContainerInstances(clusterName *string) ([]*string, error)
	DeregisterContainerInstances(clusterName *string, instanceARNs []*string) error
	StartTask(clusterName *string, instanceARN *string) (*string, error)
}

ECSWrapper defines methods to access wrapper methods to call ECS APIs

func NewECSWrapper

func NewECSWrapper(sess *session.Session) (ECSWrapper, error)

NewECSWrapper returns a new ECSWrapper for the canary