command

Documentation

Index

• type DocumentName
• type ExecSessionAPI
• type ExecTarget
• type PortTarget
• type RemoteSession
  • func StartExecSession(ctx context.Context, ecsClient ExecSessionAPI, ssmClient SessionAPI, ...) (RemoteSession, error)
  • func StartPortForwardSession(ctx context.Context, ssmClient SessionAPI, portTarget PortTarget, ...) (RemoteSession, error)
  • func (s RemoteSession) Run(ctx context.Context, plugin session_manager.Plugin) error
• type SessionAPI

Types

type DocumentName

type DocumentName string

const (
	PORT_FORWARD_DOCUMENT_NAME        DocumentName = "AWS-StartPortForwardingSession"
	REMOTE_PORT_FORWARD_DOCUMENT_NAME DocumentName = "AWS-StartPortForwardingSessionToRemoteHost"
)

type ExecSessionAPI

type ExecSessionAPI interface {
	ExecuteCommand(context.Context, *ecs.ExecuteCommandInput, ...func(*ecs.Options)) (*ecs.ExecuteCommandOutput, error)
	DescribeTasks(context.Context, *ecs.DescribeTasksInput, ...func(*ecs.Options)) (*ecs.DescribeTasksOutput, error)
}

type ExecTarget

type ExecTarget struct {
	Cluster       string
	TaskARN       string
	ContainerName string
}

type PortTarget

type PortTarget struct {
	SSMTarget string
}

type RemoteSession

type RemoteSession struct {
	ID         string
	Invocation session_manager.Invocation
	// contains filtered or unexported fields
}

func StartExecSession

func StartExecSession(
	ctx context.Context,
	ecsClient ExecSessionAPI,
	ssmClient SessionAPI,
	execTarget ExecTarget,
	command string,
	region string,
) (RemoteSession, error)

func StartPortForwardSession

func StartPortForwardSession(
	ctx context.Context,
	ssmClient SessionAPI,
	portTarget PortTarget,
	region string,
	doc DocumentName,
	params map[string][]string,
) (RemoteSession, error)

func (RemoteSession) Run

func (s RemoteSession) Run(ctx context.Context, plugin session_manager.Plugin) error

type SessionAPI

type SessionAPI interface {
	StartSession(context.Context, *ssm.StartSessionInput, ...func(*ssm.Options)) (*ssm.StartSessionOutput, error)
	TerminateSession(context.Context, *ssm.TerminateSessionInput, ...func(*ssm.Options)) (*ssm.TerminateSessionOutput, error)
}