executor

Documentation

Overview

Package executor implements ECS task execution and session management.

Index

• Variables
• 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) PortForwardSession(ctx context.Context, options *PortForwardSessionOptions) error
  • func (e *Executor) ShellSession(ctx context.Context, options *ShellSessionOptions) error
• type PortForwardSessionOptions
• type ShellSessionOptions

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

func (e *Executor) PortForwardSession(ctx context.Context, options *PortForwardSessionOptions) error

PortForwardSession starts a port forwarding session with the provided options.

func (*Executor) ShellSession

func (e *Executor) ShellSession(ctx context.Context, options *ShellSessionOptions) error

ShellSession starts a shell session with the provided options.

type PortForwardSessionOptions

type PortForwardSessionOptions struct {
	ClusterName        string
	TaskARN            string
	ContainerRuntimeID string
	Host               string
	PortNumber         int
	LocalPortNumber    int
}

PortForwardSessionOptions contains the configuration options for port forwarding sessions.

type ShellSessionOptions

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

ShellSessionOptions contains the configuration options for executing a shell session.