k8s

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2018 License: Apache-2.0 Imports: 15 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient

func NewClient(kubeCfgFile string, logger *logrus.Logger) (kubernetes.Interface, error)

NewClient returns a Kubernetes client using the given config. If no config is provided, assumes it is running inside a Kubernetes cluster and uses the in-cluster config.

func NewClientWithQPS added in v0.3.0

func NewClientWithQPS(kubeCfgFile string, logger *logrus.Logger, qps float32, burst int) (kubernetes.Interface, error)

NewClientWithQPS returns a Kubernetes client using the given configuration and rate limiting parameters. If no config is provided, assumes it is running inside a Kubernetes cluster and uses the in-cluster config.

Types

type Controller

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

Controller receives notifications from the Kubernetes API and translates those objects into additions and removals entries of services / endpoints

func NewController

func NewController(log *logrus.Logger, gimbalKubeClient kubernetes.Interface, kubeInformerFactory kubeinformers.SharedInformerFactory,
	backendName string, threadiness int, metrics localmetrics.DiscovererMetrics) *Controller

NewController returns a new NewController

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{}) error

Run gets the party started

Jump to

Keyboard shortcuts

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