network

Documentation

Index

• Constants
• func LoadClientTLSConfigFromFile() (*tls.Config, error)
• func LoadServerTLSConfigFromFile() (*tls.Config, error)
• func StartControlClient(ctx context.Context, dialer Dialer, target string) (ctrl.Service, error)
• type ControlServer
  • func StartControlServer(ctx context.Context, tlsConfigLoader func() (*tls.Config, error), ...) (*ControlServer, error)
  • func StartInsecureControlServer(ctx context.Context, options ...ControlServerOption) (*ControlServer, error)
  • func (cs *ControlServer) ClosedCh() <-chan struct{}
  • func (cs *ControlServer) ListeningPort() int
• type ControlServerOption
  • func WithPort(port int) ControlServerOption
• type ControlServerOptions
• type Dialer

Constants

const (
	KeepAlive = 30 * time.Second
)

Functions

func LoadClientTLSConfigFromFile

func LoadClientTLSConfigFromFile() (*tls.Config, error)

func LoadServerTLSConfigFromFile

func LoadServerTLSConfigFromFile() (*tls.Config, error)

func StartControlClient

func StartControlClient(ctx context.Context, dialer Dialer, target string) (ctrl.Service, error)

Types

type ControlServer

type ControlServer struct {
	ctrl.Service
	// contains filtered or unexported fields
}

func StartControlServer

func StartControlServer(ctx context.Context, tlsConfigLoader func() (*tls.Config, error), options ...ControlServerOption) (*ControlServer, error)

func StartInsecureControlServer

func StartInsecureControlServer(ctx context.Context, options ...ControlServerOption) (*ControlServer, error)

func (*ControlServer) ClosedCh

func (cs *ControlServer) ClosedCh() <-chan struct{}

ClosedCh returns a channel which is closed after the server stopped listening

func (*ControlServer) ListeningPort

func (cs *ControlServer) ListeningPort() int

ListeningPort is the port where the server is actually listening

type ControlServerOption

type ControlServerOption func(*ControlServerOptions)

func WithPort

func WithPort(port int) ControlServerOption

type ControlServerOptions

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

type Dialer

type Dialer interface {
	DialContext(ctx context.Context, network, addr string) (net.Conn, error)
}