internal

package
v0.0.0-...-4165e0f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 6, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL