k8s

Documentation

Index

• type Client
  • func New(cfg *Config) (*Client, 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) Run() error
  • func (c *Client) Update(svc *v1.Service) (*v1.Service, error)
  • func (c *Client) UpdateStatus(svc *v1.Service) error
• type Config

Types

type Client

type Client struct {
	// 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) 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) Run

func (c *Client) Run() error

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

func (*Client) Update

func (c *Client) Update(svc *v1.Service) (*v1.Service, error)

Update writes svc back into the Kubernetes cluster. If successful, the updated Service is returned. Note that changes to svc.Status are not propagated, for that you need to call UpdateStatus.

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
	ConfigMapName string
	NodeName      string
	MetricsPort   int
	ReadEndpoints bool
	Logger        log.Logger

	ServiceChanged func(log.Logger, string, *v1.Service, *v1.Endpoints) bool
	ConfigChanged  func(log.Logger, *config.Config) bool
	NodeChanged    func(log.Logger, *v1.Node) bool
	Synced         func(log.Logger)
}

Config specifies the configuration of the Kubernetes client/watcher.