internal

Documentation

Index

• func RequestIdFromContext(ctx context.Context) string
• type AWSService
  • func NewAWSService(ctx context.Context) (*AWSService, error)
  • func (awsService *AWSService) FilterECSServices(ctx context.Context, services []*EcsService) ([]*ServiceMessage, error)
  • func (awsService *AWSService) ListECSServices(ctx context.Context, cluster string) ([]*EcsService, error)
  • func (awsService *AWSService) PublishServiceMessage(ctx context.Context, sqsQueueURL string, serviceMessage *ServiceMessage) (*string, error)
• type EcsNotify
  • func NewEcsNotify() *EcsNotify
• type EcsService
  • func NewEcsService() *EcsService
• type ServiceMessage
  • func NewServiceMessage() *ServiceMessage

Functions

func RequestIdFromContext

func RequestIdFromContext(ctx context.Context) string

Get AWSRequestId from Lambda Context Object

Types

type AWSService

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

func NewAWSService

func NewAWSService(ctx context.Context) (*AWSService, error)

func (*AWSService) FilterECSServices

func (awsService *AWSService) FilterECSServices(ctx context.Context, services []*EcsService) ([]*ServiceMessage, error)

Filter ECS Services latest TaskDefinition matching required dockerlabels

func (*AWSService) ListECSServices

func (awsService *AWSService) ListECSServices(ctx context.Context, cluster string) ([]*EcsService, error)

List All the ECS Services running within ECS Cluster

func (*AWSService) PublishServiceMessage

func (awsService *AWSService) PublishServiceMessage(ctx context.Context, sqsQueueURL string, serviceMessage *ServiceMessage) (*string, error)

Publish ECS Service Messages to SQS for further processing

type EcsNotify

type EcsNotify struct {
	Cluster string `json:"cluster"`
}

func NewEcsNotify

func NewEcsNotify() *EcsNotify

type EcsService

type EcsService struct {
	Cluster        string `json:"cluster"`
	Service        string `json:"service"`
	TaskDefinition string `json:"task_definition"`
}

func NewEcsService

func NewEcsService() *EcsService

type ServiceMessage

type ServiceMessage struct {
	Cluster               string `json:"cluster"`
	Service               string `json:"service"`
	NotifyMeContainerPort string `json:"notify_me_container_port"`
	NotifyMeAPIUri        string `json:"notify_me_api_uri"`
}

func NewServiceMessage

func NewServiceMessage() *ServiceMessage