internal

Documentation

Index

• type Command
  • func NewLinuxCommand(cfg *Config, instanceID string, command string) (*Command, error)
  • func (cmd *Command) Result() (string, error)
• type Config
  • func NewConfig(profile string, region string, timeout time.Duration) (*Config, error)
• type Container
  • func FindPossibleContainerByIdentifier(cfg *Config, cluster string, task string, container string) ([]Container, error)
  • func FindPossibleContainers(cfg *Config, cluster string) ([]Container, error)
• type EC2Session
  • func NewEC2Session(cfg *Config, input *ssm.StartSessionInput) (EC2Session, error)
• type ECSSession
  • func NewECSSession(cfg *Config, input *ecs.ExecuteCommandInput) (ECSSession, error)
• type Instance
  • func FindInstanceByIdentifier(cfg *Config, identifier string) ([]Instance, error)
  • func FindPossibleInstances(cfg *Config) ([]Instance, error)
• type RunSCPInput
• type RunSSHInput
• type SCPMode

Types

type Command

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

func NewLinuxCommand

func NewLinuxCommand(cfg *Config, instanceID string, command string) (*Command, error)

func (*Command) Result

func (cmd *Command) Result() (string, error)

type Config

type Config struct {
	Profile string
	Region  string
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(profile string, region string, timeout time.Duration) (*Config, error)

type Container

type Container struct {
	Task string
	Name string
}

func FindPossibleContainerByIdentifier

func FindPossibleContainerByIdentifier(cfg *Config, cluster string, task string, container string) ([]Container, error)

func FindPossibleContainers

func FindPossibleContainers(cfg *Config, cluster string) ([]Container, error)

type EC2Session

type EC2Session interface {
	Close() error
	RunPlugin() error
	RunSSH(input *RunSSHInput) error
	RunSCP(input *RunSCPInput) error
}

func NewEC2Session

func NewEC2Session(cfg *Config, input *ssm.StartSessionInput) (EC2Session, error)

type ECSSession

type ECSSession interface {
	Close() error
	RunPlugin() error
}

func NewECSSession

func NewECSSession(cfg *Config, input *ecs.ExecuteCommandInput) (ECSSession, error)

type Instance

type Instance struct {
	Name string
	ID   string
}

func FindInstanceByIdentifier

func FindInstanceByIdentifier(cfg *Config, identifier string) ([]Instance, error)

func FindPossibleInstances

func FindPossibleInstances(cfg *Config) ([]Instance, error)

type RunSCPInput

type RunSCPInput struct {
	User       string
	InstanceID string
	Identity   string
	Sources    []string
	Target     string
	Mode       SCPMode
}

type RunSSHInput

type RunSSHInput struct {
	User                string
	InstanceID          string
	Identity            string
	LocalPortForwarding string
	Command             string
}

type SCPMode

type SCPMode string

const (
	SCPModeSending   SCPMode = "sending"
	SCPModeReceiving SCPMode = "receiving"
)