aws_ecs

Documentation

Index

• func RunTaskInput(msg *awsinfra_tpb.RunECSTaskMessage) (*ecs.RunTaskInput, error)
• type ECSTaskStateChangeEvent
• type ECSTaskStateChangeEvent_Container
• type ECSWorker
  • func NewECSWorker(db tokenstore.DBLite, ecsClient awsapi.ECSAPI) (*ECSWorker, error)
  • func (handler *ECSWorker) HandleECSTaskEvent(ctx context.Context, eventID string, taskEvent *ECSTaskStateChangeEvent) error
  • func (handler *ECSWorker) RunECSTask(ctx context.Context, msg *awsinfra_tpb.RunECSTaskMessage) (*emptypb.Empty, error)

Functions

func RunTaskInput

func RunTaskInput(msg *awsinfra_tpb.RunECSTaskMessage) (*ecs.RunTaskInput, error)

Types

type ECSTaskStateChangeEvent

type ECSTaskStateChangeEvent struct {
	ClusterArn    string                              `json:"clusterArn"`
	TaskArn       string                              `json:"taskArn"`
	LastStatus    string                              `json:"lastStatus"`
	StoppedAt     string                              `json:"stoppedAt"`
	StoppedReason string                              `json:"stoppedReason"`
	StopCode      *string                             `json:"stopCode"`
	Group         *string                             `json:"group"`
	Containers    []ECSTaskStateChangeEvent_Container `json:"containers"`
	StartedBy     string                              `json:"startedBy"`
}

type ECSTaskStateChangeEvent_Container

type ECSTaskStateChangeEvent_Container struct {
	ContainerArn string  `json:"containerArn"`
	LastStatus   string  `json:"lastStatus"`
	Reason       *string `json:"reason"`
	Name         string  `json:"name"`
	ExitCode     *int    `json:"exitCode"`
}

type ECSWorker

type ECSWorker struct {
	awsinfra_tpb.UnimplementedECSRequestTopicServer
	// contains filtered or unexported fields
}

func NewECSWorker

func NewECSWorker(db tokenstore.DBLite, ecsClient awsapi.ECSAPI) (*ECSWorker, error)

func (*ECSWorker) HandleECSTaskEvent

func (handler *ECSWorker) HandleECSTaskEvent(ctx context.Context, eventID string, taskEvent *ECSTaskStateChangeEvent) error

func (*ECSWorker) RunECSTask

func (handler *ECSWorker) RunECSTask(ctx context.Context, msg *awsinfra_tpb.RunECSTaskMessage) (*emptypb.Empty, error)