Help us shape the future of Go! Take the 2026 Go Developer Survey

server

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2018 License: Apache-2.0 Imports: 23 Imported by: 2

Documentation

Index

Constants

View Source
const (
	DEFAULT_RECONCILIATION = 5 * time.Minute
)
View Source
const (
	KUBERNIKUS_TUNNELS iptables.Chain = "KUBERNIKUS-TUNNELS"
)

Variables

This section is empty.

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 added in v1.3.0

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 added in v1.3.0

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

func New added in v1.3.0

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

func (*Server) Run added in v1.3.0

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL