aws

Documentation

Index

• type AutoscalingApi
  • func (self *AutoscalingApi) AttachLoadBalancers(group string, lb []string) (*autoscaling.AttachLoadBalancersOutput, error)
  • func (self *AutoscalingApi) DescribeAutoScalingGroups(groups []string) (map[string]*autoscaling.Group, error)
  • func (self *AutoscalingApi) DescribeLoadBalancerState(group string) (map[string]*autoscaling.LoadBalancerState, error)
  • func (self *AutoscalingApi) DetachLoadBalancers(group string, lb []string) (*autoscaling.DetachLoadBalancersOutput, error)
• type AwsManager
  • func NewAwsManager(region string) *AwsManager
  • func (self *AwsManager) AutoscalingApi() *AutoscalingApi
  • func (self *AwsManager) EcsApi() *EcsApi
  • func (self *AwsManager) ElbApi() *ElbApi
  • func (self *AwsManager) S3Api() *S3Api
  • func (self *AwsManager) SnsApi() *SnsApi
• type EcsApi
  • func (self *EcsApi) CreateCluster(clusterName string) (*ecs.CreateClusterOutput, error)
  • func (self *EcsApi) CreateService(cluster string, service string, desiredCount int64, lb []*ecs.LoadBalancer, ...) (*ecs.CreateServiceOutput, error)
  • func (self *EcsApi) DeleteCluster(clusterName string) (*ecs.DeleteClusterOutput, error)
  • func (self *EcsApi) DeleteService(cluster string, service string) (*ecs.DeleteServiceOutput, error)
  • func (self *EcsApi) DeregisterTaskDefinition(taskName string) (*ecs.DeregisterTaskDefinitionOutput, error)
  • func (self *EcsApi) DescribeClusters(clusterNames []*string) (*ecs.DescribeClustersOutput, error)
  • func (self *EcsApi) DescribeService(cluster string, services []*string) (*ecs.DescribeServicesOutput, error)
  • func (self *EcsApi) DescribeTaskDefinition(defName string) (*ecs.DescribeTaskDefinitionOutput, error)
  • func (self *EcsApi) DescribeTasks(cluster string, tasks []*string) (*ecs.DescribeTasksOutput, error)
  • func (self *EcsApi) ListClusters(maxResult int64) (*ecs.ListClustersOutput, error)
  • func (self *EcsApi) ListContainerInstances(cluster string) (*ecs.ListContainerInstancesOutput, error)
  • func (self *EcsApi) ListServices(cluster string) (*ecs.ListServicesOutput, error)
  • func (self *EcsApi) ListTasks(cluster string, service string) (*ecs.ListTasksOutput, error)
  • func (self *EcsApi) RegisterTaskDefinition(taskName string, conDefs []*ecs.ContainerDefinition, volumes []*ecs.Volume) (*ecs.RegisterTaskDefinitionOutput, error)
  • func (self *EcsApi) StopTask(cluster string, task string) (*ecs.StopTaskOutput, error)
  • func (self *EcsApi) UpdateService(cluster string, service string, desiredCount int64, taskDef string) (*ecs.UpdateServiceOutput, error)
• type ElbApi
  • func (self *ElbApi) DeregisterInstancesFromLoadBalancer(lb string, instances []*elb.Instance) (*elb.DeregisterInstancesFromLoadBalancerOutput, error)
  • func (self *ElbApi) DescribeLoadBalancers(names []string) (*elb.DescribeLoadBalancersOutput, error)
  • func (self *ElbApi) RegisterInstancesWithLoadBalancer(name string, instances []*elb.Instance) (*elb.RegisterInstancesWithLoadBalancerOutput, error)
• type S3Api
  • func (self *S3Api) GetObject(bucket string, key string) (*s3.GetObjectOutput, error)
• type SnsApi
  • func (self *SnsApi) Publish(topicArn string, message interface{}) (*sns.PublishOutput, error)

Types

type AutoscalingApi

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

func (*AutoscalingApi) AttachLoadBalancers

func (self *AutoscalingApi) AttachLoadBalancers(group string, lb []string) (*autoscaling.AttachLoadBalancersOutput, error)

func (*AutoscalingApi) DescribeAutoScalingGroups

func (self *AutoscalingApi) DescribeAutoScalingGroups(groups []string) (map[string]*autoscaling.Group, error)

func (*AutoscalingApi) DescribeLoadBalancerState

func (self *AutoscalingApi) DescribeLoadBalancerState(group string) (map[string]*autoscaling.LoadBalancerState, error)

func (*AutoscalingApi) DetachLoadBalancers

func (self *AutoscalingApi) DetachLoadBalancers(group string, lb []string) (*autoscaling.DetachLoadBalancersOutput, error)

type AwsManager

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

func NewAwsManager

func NewAwsManager(region string) *AwsManager

func (*AwsManager) AutoscalingApi

func (self *AwsManager) AutoscalingApi() *AutoscalingApi

func (*AwsManager) EcsApi

func (self *AwsManager) EcsApi() *EcsApi

func (*AwsManager) ElbApi

func (self *AwsManager) ElbApi() *ElbApi

func (*AwsManager) S3Api

func (self *AwsManager) S3Api() *S3Api

func (*AwsManager) SnsApi

func (self *AwsManager) SnsApi() *SnsApi

type EcsApi

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

func (*EcsApi) CreateCluster

func (self *EcsApi) CreateCluster(clusterName string) (*ecs.CreateClusterOutput, error)

Cluster API

func (*EcsApi) CreateService

func (self *EcsApi) CreateService(cluster string, service string, desiredCount int64, lb []*ecs.LoadBalancer, taskDef string, role string) (*ecs.CreateServiceOutput, error)

Service API

func (*EcsApi) DeleteCluster

func (self *EcsApi) DeleteCluster(clusterName string) (*ecs.DeleteClusterOutput, error)

func (*EcsApi) DeleteService

func (self *EcsApi) DeleteService(cluster string, service string) (*ecs.DeleteServiceOutput, error)

func (*EcsApi) DeregisterTaskDefinition

func (self *EcsApi) DeregisterTaskDefinition(taskName string) (*ecs.DeregisterTaskDefinitionOutput, error)

func (*EcsApi) DescribeClusters

func (self *EcsApi) DescribeClusters(clusterNames []*string) (*ecs.DescribeClustersOutput, error)

func (*EcsApi) DescribeService

func (self *EcsApi) DescribeService(cluster string, services []*string) (*ecs.DescribeServicesOutput, error)

func (*EcsApi) DescribeTaskDefinition

func (self *EcsApi) DescribeTaskDefinition(defName string) (*ecs.DescribeTaskDefinitionOutput, error)

TASK API

func (*EcsApi) DescribeTasks

func (self *EcsApi) DescribeTasks(cluster string, tasks []*string) (*ecs.DescribeTasksOutput, error)

func (*EcsApi) ListClusters

func (self *EcsApi) ListClusters(maxResult int64) (*ecs.ListClustersOutput, error)

func (*EcsApi) ListContainerInstances

func (self *EcsApi) ListContainerInstances(cluster string) (*ecs.ListContainerInstancesOutput, error)

func (*EcsApi) ListServices

func (self *EcsApi) ListServices(cluster string) (*ecs.ListServicesOutput, error)

func (*EcsApi) ListTasks

func (self *EcsApi) ListTasks(cluster string, service string) (*ecs.ListTasksOutput, error)

func (*EcsApi) RegisterTaskDefinition

func (self *EcsApi) RegisterTaskDefinition(taskName string, conDefs []*ecs.ContainerDefinition, volumes []*ecs.Volume) (*ecs.RegisterTaskDefinitionOutput, error)

func (*EcsApi) StopTask

func (self *EcsApi) StopTask(cluster string, task string) (*ecs.StopTaskOutput, error)

func (*EcsApi) UpdateService

func (self *EcsApi) UpdateService(cluster string, service string, desiredCount int64, taskDef string) (*ecs.UpdateServiceOutput, error)

type ElbApi

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

func (*ElbApi) DeregisterInstancesFromLoadBalancer

func (self *ElbApi) DeregisterInstancesFromLoadBalancer(lb string, instances []*elb.Instance) (*elb.DeregisterInstancesFromLoadBalancerOutput, error)

func (*ElbApi) DescribeLoadBalancers

func (self *ElbApi) DescribeLoadBalancers(names []string) (*elb.DescribeLoadBalancersOutput, error)

func (*ElbApi) RegisterInstancesWithLoadBalancer

func (self *ElbApi) RegisterInstancesWithLoadBalancer(name string, instances []*elb.Instance) (*elb.RegisterInstancesWithLoadBalancerOutput, error)

type S3Api

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

func (*S3Api) GetObject

func (self *S3Api) GetObject(bucket string, key string) (*s3.GetObjectOutput, error)

type SnsApi

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

func (*SnsApi) Publish

func (self *SnsApi) Publish(topicArn string, message interface{}) (*sns.PublishOutput, error)