k8s

Documentation

Index

• func UseEndpointSlices(kubeClient kubernetes.Interface) bool
• type Client
  • func New(cfg *Config) (*Client, error)
  • func (c *Client) CreateMlSecret(namespace, controllerDeploymentName, secretName string) error
  • func (c *Client) Errorf(svc *v1.Service, kind, msg string, args ...interface{})
  • func (c *Client) Infof(svc *v1.Service, kind, msg string, args ...interface{})
  • func (c *Client) PodIPs(namespace, labels string) ([]string, error)
  • func (c *Client) Run(stopCh <-chan struct{}) error
  • func (c *Client) UpdateStatus(svc *v1.Service) error
• type Config
• type Listener
  • func (l *Listener) ConfigHandler(logger log.Logger, config *config.Config) controllers.SyncState
  • func (l *Listener) NodeHandler(logger log.Logger, node *v1.Node) controllers.SyncState
  • func (l *Listener) PoolHandler(logger log.Logger, pools map[string]*config.Pool) controllers.SyncState
  • func (l *Listener) ServiceHandler(logger log.Logger, serviceName string, svc *v1.Service, ...) controllers.SyncState

Functions

func UseEndpointSlices

func UseEndpointSlices(kubeClient kubernetes.Interface) bool

UseEndpointSlices detect if Endpoints Slices are enabled in the cluster.

Types

type Client

type Client struct {
	ForceSync func()
	// contains filtered or unexported fields
}

Client watches a Kubernetes cluster and translates events into Controller method calls.

func New

func New(cfg *Config) (*Client, error)

New connects to masterAddr, using kubeconfig to authenticate.

The client uses processName to identify itself to the cluster (e.g. when logging events).

func (*Client) CreateMlSecret

func (c *Client) CreateMlSecret(namespace, controllerDeploymentName, secretName string) error

CreateMlSecret create the memberlist secret.

func (*Client) Errorf

func (c *Client) Errorf(svc *v1.Service, kind, msg string, args ...interface{})

Errorf logs an error event about svc to the Kubernetes cluster.

func (*Client) Infof

func (c *Client) Infof(svc *v1.Service, kind, msg string, args ...interface{})

Infof logs an informational event about svc to the Kubernetes cluster.

func (*Client) PodIPs

func (c *Client) PodIPs(namespace, labels string) ([]string, error)

PodIPs returns the IPs of all the pods matched by the labels string.

func (*Client) Run

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

Run watches for events on the Kubernetes cluster, and dispatches calls to the Controller.

func (*Client) UpdateStatus

func (c *Client) UpdateStatus(svc *v1.Service) error

UpdateStatus writes the protected "status" field of svc back into the Kubernetes cluster.

type Config

type Config struct {
	ProcessName         string
	NodeName            string
	MetricsHost         string
	MetricsPort         int
	EnablePprof         bool
	ReadEndpoints       bool
	Logger              log.Logger
	DisableEpSlices     bool
	Namespace           string
	ValidateConfig      config.Validate
	EnableWebhook       bool
	DisableCertRotation bool
	CertDir             string
	CertServiceName     string
	LoadBalancerClass   string
	Listener
}

Config specifies the configuration of the Kubernetes client/watcher.

type Listener

type Listener struct {
	sync.Mutex
	ServiceChanged func(log.Logger, string, *v1.Service, epslices.EpsOrSlices) controllers.SyncState
	ConfigChanged  func(log.Logger, *config.Config) controllers.SyncState
	PoolChanged    func(log.Logger, map[string]*config.Pool) controllers.SyncState
	NodeChanged    func(log.Logger, *v1.Node) controllers.SyncState
}

func (*Listener) ConfigHandler

func (l *Listener) ConfigHandler(logger log.Logger, config *config.Config) controllers.SyncState

func (*Listener) NodeHandler

func (l *Listener) NodeHandler(logger log.Logger, node *v1.Node) controllers.SyncState

func (*Listener) PoolHandler

func (l *Listener) PoolHandler(logger log.Logger, pools map[string]*config.Pool) controllers.SyncState

func (*Listener) ServiceHandler

func (l *Listener) ServiceHandler(logger log.Logger, serviceName string, svc *v1.Service, endpointsOrSlices epslices.EpsOrSlices) controllers.SyncState