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 Options
• type Server
  • func New(options *Options) (*Server, error)
  • func (s *Server) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)
• type Tunnel
  • func NewTunnel(options *Options) (*Tunnel, error)
  • func (t *Tunnel) Run(stopCh <-chan struct{}, wg *sync.WaitGroup)

Constants

const (
	DEFAULT_RECONCILIATION = 5 * time.Minute
)

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

Functions

func GetNodeHostIP

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

Types

type Controller

type Controller struct {
	Logger log.Logger
	// contains filtered or unexported fields
}

func NewController

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

func (*Controller) Run

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

type Options

type Options struct {
	Logger log.Logger

	//Used by the controller
	KubeConfig  string
	Context     string
	ServiceCIDR string

	//Used by the tunnel
	ClientCA    string
	Certificate string
	PrivateKey  string
}

type Server

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

func New

func New(options *Options) (*Server, error)

func (*Server) Run

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

type Tunnel

type Tunnel struct {
	Server *guttle.Server

	Logger log.Logger
}

func NewTunnel

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

func (*Tunnel) Run

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