Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RequestIdFromContext ¶
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) DiscoverServiceTasks ¶
func (awsService *AWSService) DiscoverServiceTasks(ctx context.Context, serviceMessage *ServiceMessage) ([]*TaskNotifyMessage, error)
List of all ECS Tasks of an ECS Service
func (*AWSService) PublishServiceMessage ¶
func (awsService *AWSService) PublishServiceMessage(ctx context.Context, sqsQueueURL string, taskNotifyMessage *TaskNotifyMessage) (*string, error)
Publish ECS Service Task Messages to SQS for further processing
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
type TaskNotifyMessage ¶
type TaskNotifyMessage struct {
NotifyTaskArn string `json:"notify_task_arn"`
NotifyMeHostAddress string `json:"notify_me_host_address"`
NotifyMeHostPort string `json:"notify_me_host_port"`
NotifyMeAPIUri string `json:"notify_me_api_uri"`
}
func NewTaskNotifyMessage ¶
func NewTaskNotifyMessage() *TaskNotifyMessage
Click to show internal directories.
Click to hide internal directories.