tunnels

Documentation

Index

• type AddressData
• type BastionEntity
• type BastionService
• type EndpointInfo
  • func (e *EndpointInfo) String() string
• type EndpointProvider
• type KeyProvider
• type Request
• type SocksTunnel
  • func NewSocksTunnel(bastionService BastionService, keyProvider KeyProvider, ...) *SocksTunnel
  • func (self *SocksTunnel) Start(ctx context.Context)
  • func (self *SocksTunnel) Stop()
• type SshTunnel
  • func NewSshTunnel(bastionService BastionService, keyProvider KeyProvider, ...) *SshTunnel
  • func (self *SshTunnel) Start(ctx context.Context)
  • func (self *SshTunnel) Stop()

Types

type AddressData

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

type BastionEntity

type BastionEntity struct {
	Id   string `json:"id"`
	IP   string `json:"ip"`
	User string `json:"user"`
}

type BastionService

type BastionService interface {
	GetBastion(ctx context.Context) (*BastionEntity, error)
	PushKey(ctx context.Context, bastion *BastionEntity, pub string) error
}

type EndpointInfo

type EndpointInfo struct {
	Protocol string `json:"protocol"`
	Host     string `json:"host"`
	Port     int    `json:"port"`
}

func (*EndpointInfo) String

func (e *EndpointInfo) String() string

type EndpointProvider

type EndpointProvider interface {
	GetEndpoint(ctx context.Context) (*EndpointInfo, error)
}

type KeyProvider

type KeyProvider interface {
	RetireveKey() ([]byte, []byte)
}

type Request

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

type SocksTunnel

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

func NewSocksTunnel

func NewSocksTunnel(
	bastionService BastionService,
	keyProvider KeyProvider,
	endpointProviders []EndpointProvider,
	proxyPort int,
) *SocksTunnel

func (*SocksTunnel) Start

func (self *SocksTunnel) Start(ctx context.Context)

func (*SocksTunnel) Stop

func (self *SocksTunnel) Stop()

type SshTunnel

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

func NewSshTunnel

func NewSshTunnel(
	bastionService BastionService,
	keyProvider KeyProvider,
	destination EndpointProvider,
	localPort int,
) *SshTunnel

func (*SshTunnel) Start

func (self *SshTunnel) Start(ctx context.Context)

func (*SshTunnel) Stop

func (self *SshTunnel) Stop()