k8s

Documentation

Index

• func NewClient(kubeCfgFile string, logger *logrus.Logger) (kubernetes.Interface, error)
• func NewClientWithQPS(kubeCfgFile string, logger *logrus.Logger, qps float32, burst int) (kubernetes.Interface, error)
• type Controller
  • func NewController(log *logrus.Logger, gimbalKubeClient kubernetes.Interface, ...) *Controller
  • func (c *Controller) Run(stopCh <-chan struct{}) error

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

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