server

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2017 License: Apache-2.0 Imports: 23 Imported by: 0

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)

Source Files

  • controller.go
  • options.go
  • server.go
  • tunnel.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.