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

package tunneler

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


Package Files


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 {
    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 4 packages. Updated 2020-09-03. Refresh now. Tools for package owners.