kubernetes: k8s.io/kubernetes/pkg/master/tunneler Index | Files

package tunneler

import "k8s.io/kubernetes/pkg/master/tunneler"

Index

Package Files

ssh.go

func TunnelSyncHealthChecker Uses

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

type AddressFunc Uses

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

type InstallSSHKey Uses

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

type SSHTunneler Uses

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

func (*SSHTunneler) Dial Uses

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

func (*SSHTunneler) Run Uses

func (c *SSHTunneler) Run(getAddresses AddressFunc)

Run establishes tunnel loops and returns

func (*SSHTunneler) SecondsSinceSSHKeySync Uses

func (c *SSHTunneler) SecondsSinceSSHKeySync() int64

func (*SSHTunneler) SecondsSinceSync Uses

func (c *SSHTunneler) SecondsSinceSync() int64

func (*SSHTunneler) Stop Uses

func (c *SSHTunneler) Stop()

Stop gracefully shuts down the tunneler

type Tunneler Uses

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

func New Uses

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

Package tunneler imports 14 packages (graph) and is imported by 7 packages. Updated 2019-02-09. Refresh now. Tools for package owners.