server

Documentation

Index

• Constants
• func GetNodeHostIP(node *v1.Node) (net.IP, error)
• type Controller
  • func NewController(informer informers.NodeInformer, serviceCIDR string, tunnel *guttle.Server) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}, wg *sync.WaitGroup)
• type Tunnel
  • func NewTunnel(options *TunnelOptions) (*Tunnel, error)
  • func (t *Tunnel) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)
• type TunnelOptions

Constants

const (
	KUBERNIKUS_TUNNELS iptables.Chain = "KUBERNIKUS-TUNNELS"
)

Functions

func GetNodeHostIP

func GetNodeHostIP(node *v1.Node) (net.IP, error)

Types

type Controller

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

func NewController

func NewController(informer informers.NodeInformer, serviceCIDR string, tunnel *guttle.Server) *Controller

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}, wg *sync.WaitGroup)

type Tunnel

type Tunnel struct {
	Server *guttle.Server
}

func NewTunnel

func NewTunnel(options *TunnelOptions) (*Tunnel, error)

func (*Tunnel) Run

func (t *Tunnel) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)

type TunnelOptions

type TunnelOptions struct {
	ClientCA    string
	Certificate string
	PrivateKey  string
}