tunneler

Documentation

Index

• func TunnelSyncHealthChecker(tunneler Tunneler) func(req *http.Request) error
• type AddressFunc
• type InstallSSHKey
• type SSHTunneler
  • func (c *SSHTunneler) Dial(ctx context.Context, net, addr string) (net.Conn, error)
  • func (c *SSHTunneler) Run(getAddresses AddressFunc)
  • func (c *SSHTunneler) SecondsSinceSSHKeySync() int64
  • func (c *SSHTunneler) SecondsSinceSync() int64
  • func (c *SSHTunneler) Stop()
• type Tunneler
  • func New(sshUser, sshKeyfile string, healthCheckURL *url.URL, ...) Tunneler

Functions

func TunnelSyncHealthChecker

func TunnelSyncHealthChecker(tunneler Tunneler) func(req *http.Request) error

TunnelSyncHealthChecker returns a health func that indicates if a tunneler is healthy. It's compatible with healthz.NamedCheck

Types

type AddressFunc

type AddressFunc func() (addresses []string, err error)

type InstallSSHKey

type InstallSSHKey func(ctx context.Context, user string, data []byte) error

type SSHTunneler

type SSHTunneler struct {
	SSHUser        string
	SSHKeyfile     string
	InstallSSHKey  InstallSSHKey
	HealthCheckURL *url.URL
	// contains filtered or unexported fields
}

func (*SSHTunneler) Dial

func (c *SSHTunneler) Dial(ctx context.Context, net, addr string) (net.Conn, error)

func (*SSHTunneler) Run

func (c *SSHTunneler) Run(getAddresses AddressFunc)

Run establishes tunnel loops and returns

func (*SSHTunneler) SecondsSinceSSHKeySync

func (c *SSHTunneler) SecondsSinceSSHKeySync() int64

func (*SSHTunneler) SecondsSinceSync

func (c *SSHTunneler) SecondsSinceSync() int64

func (*SSHTunneler) Stop

func (c *SSHTunneler) Stop()

Stop gracefully shuts down the tunneler

type Tunneler

type Tunneler interface {
	Run(AddressFunc)
	Stop()
	Dial(ctx context.Context, net, addr string) (net.Conn, error)
	SecondsSinceSync() int64
	SecondsSinceSSHKeySync() int64
}

func New

func New(sshUser, sshKeyfile string, healthCheckURL *url.URL, installSSHKey InstallSSHKey) Tunneler