package connrotation

import "k8s.io/client-go/util/connrotation"

Package connrotation implements a connection dialer that tracks and can close all created connections.

This is used for credential rotation of long-lived connections, when there's no way to re-authenticate on a live connection.

Index ¶

• type DialFunc
• type Dialer
• func NewDialer(dial DialFunc) *Dialer
• func (d *Dialer) CloseAll()
• func (d *Dialer) Dial(network, address string) (net.Conn, error)
• func (d *Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

Types ¶

type DialFunc ¶

type DialFunc func(ctx context.Context, network, address string) (net.Conn, error)

DialFunc is a shorthand for signature of net.DialContext.

type Dialer ¶

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

Dialer opens connections through Dial and tracks them.

func NewDialer ¶

func NewDialer(dial DialFunc) *Dialer

NewDialer creates a new Dialer instance.

If dial is not nil, it will be used to create new underlying connections. Otherwise net.DialContext is used.

func (*Dialer) CloseAll ¶

func (d *Dialer) CloseAll()

CloseAll forcibly closes all tracked connections.

Note: new connections may get created before CloseAll returns.

func (*Dialer) Dial ¶

func (d *Dialer) Dial(network, address string) (net.Conn, error)

Dial creates a new tracked connection.

func (*Dialer) DialContext ¶

func (d *Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

DialContext creates a new tracked connection.

Source Files ¶

connrotation.go