session

Documentation

Index

• Constants
• func NewDockerExecSessionHandler(logger *zap.Logger, proxyConfig *sshConfig.ProxyConfig) *dockerExecSessionHandler
• func NewEc2InstanceConnectSessionHandler(logger *zap.Logger, config *config.ProxyConfig) *sshSessionHandler
• func NewKubectlExecSessionHandler(logger *zap.Logger, proxyConfig *sshConfig.ProxyConfig) *kubectlExecSessionHandler
• func NewLocalSessionHandler(logger *zap.Logger, config *config.ProxyConfig) *localSessionHandler
• func NewSshSessionHandler(logger *zap.Logger, config *config.ProxyConfig) (*sshSessionHandler, error)
• func NewSsmSessionHandler(logger *zap.Logger, config *config.ProxyConfig) (*ssmSessionHandler, error)
• type PipeWriteChannel
  • func NewPipeWriteChannel(channel ssh.Channel) *PipeWriteChannel
  • func (pwc *PipeWriteChannel) Write(data []byte) (int, error)
• type SessionHandler

Constants

const (
	StdinBufferLimit    = 1024
	ResizeSleepInterval = 500 * time.Millisecond
)

Functions

func NewDockerExecSessionHandler

func NewDockerExecSessionHandler(
	logger *zap.Logger,
	proxyConfig *sshConfig.ProxyConfig,
) *dockerExecSessionHandler

func NewEc2InstanceConnectSessionHandler

func NewEc2InstanceConnectSessionHandler(logger *zap.Logger, config *config.ProxyConfig) *sshSessionHandler

func NewKubectlExecSessionHandler

func NewKubectlExecSessionHandler(
	logger *zap.Logger,
	proxyConfig *sshConfig.ProxyConfig,
) *kubectlExecSessionHandler

func NewLocalSessionHandler

func NewLocalSessionHandler(logger *zap.Logger, config *config.ProxyConfig) *localSessionHandler

func NewSshSessionHandler

func NewSshSessionHandler(logger *zap.Logger, config *config.ProxyConfig) (*sshSessionHandler, error)

func NewSsmSessionHandler

func NewSsmSessionHandler(logger *zap.Logger, config *config.ProxyConfig) (*ssmSessionHandler, error)

Types

type PipeWriteChannel

type PipeWriteChannel struct {
	ssh.Channel
	// contains filtered or unexported fields
}

func NewPipeWriteChannel

func NewPipeWriteChannel(channel ssh.Channel) *PipeWriteChannel

func (*PipeWriteChannel) Write

func (pwc *PipeWriteChannel) Write(data []byte) (int, error)

type SessionHandler

type SessionHandler interface {
	Proxy(conn net.Conn)
}