handler

Documentation

Index

• type Event
  • func NewEvent(k8sClient *k8s.Client, apiClient *api.Client) *Event
  • func (h *Event) Start(sharedInformers informers.SharedInformerFactory)
• type Workload
  • func NewWorkload(k8sClient *k8s.Client, apiClient *api.Client) *Workload
  • func (h *Workload) Start(sharedInformers informers.SharedInformerFactory)
  • func (h *Workload) Stop()

Types

type Event

type Event struct {
	// contains filtered or unexported fields
}

Event listens to the k8s API for events, and forwards them to the Buoyant Cloud API.

func NewEvent

func NewEvent(k8sClient *k8s.Client, apiClient *api.Client) *Event

NewEvent instantiates a new k8s event handler.

func (*Event) Start

func (h *Event) Start(sharedInformers informers.SharedInformerFactory)

Start initiates listening to a k8s event handler.

type Workload

type Workload struct {
	// contains filtered or unexported fields
}

Workload listens to the k8s API for DaemonSet, Deployment, and StatefulSet changes, and forwards them to the Buoyant Cloud API.

func NewWorkload

func NewWorkload(k8sClient *k8s.Client, apiClient *api.Client) *Workload

NewWorkload instantiates a new k8s workload handler.

func (*Workload) Start

func (h *Workload) Start(sharedInformers informers.SharedInformerFactory)

Start begins a polling loop, periodically resyncing all k8s objects with the Buoyant Cloud API. This syncing operation runs independently from the k8s handlers, but messages are syncronized via the WorkloadStream.

func (*Workload) Stop

func (h *Workload) Stop()

Stop terminates the WorkloadStream resync loop.