executor

Documentation

Overview

Package executor implements ECS task execution and session management.

Index

• Variables
• type ExecuteSessionOptions
• type Executor
  • func NewExecutor(ecsClient *ecs.Client, kmsClient *kms.Client, ssmClient *ssm.Client, ...) *Executor
  • func NewFromConfig(cfg aws.Config, logger log.T) *Executor
  • func (e *Executor) ExecuteSession(ctx context.Context, options *ExecuteSessionOptions) error

Variables

var (
	// ErrInvalidARN indicates that the provided ARN is invalid.
	ErrInvalidARN = errors.New("invalid ARN")

	// ErrInvalidSessionType indicates that the provided session type is invalid.
	ErrInvalidSessionType = errors.New("invalid session type")
)

Types

type ExecuteSessionOptions

type ExecuteSessionOptions struct {
	ClusterName        string
	TaskARN            string
	ContainerName      string
	ContainerRuntimeID string
	Command            string
}

ExecuteSessionOptions contains the configuration options for executing a session.

type Executor

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

Executor manages ECS task execution and session management.

func NewExecutor

func NewExecutor(ecsClient *ecs.Client, kmsClient *kms.Client, ssmClient *ssm.Client, logger log.T) *Executor

NewExecutor creates a new Executor instance with the provided AWS clients and logger.

func NewFromConfig

func NewFromConfig(cfg aws.Config, logger log.T) *Executor

NewFromConfig creates a new Executor instance using the provided AWS configuration and logger.

func (*Executor) ExecuteSession

func (e *Executor) ExecuteSession(ctx context.Context, options *ExecuteSessionOptions) error

ExecuteSession executes a session with the provided options.