handler

package
v0.9.1 Latest Latest
Warning

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

Go to latest
Published: May 9, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 LinkerdInfo added in v0.2.0

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

LinkerdInfo is responsible for obtaining Linkerd related data and sending it to the Bcloud API in the form of `LinkerdMessage` objects

func NewLinkerdInfo added in v0.2.0

func NewLinkerdInfo(k8sClient *k8s.Client, apiClient *api.Client) *LinkerdInfo

NewLinkerdInfo instantiates a new k8s event handler.

func (*LinkerdInfo) Start added in v0.2.0

func (h *LinkerdInfo) Start()

Start initiates linkerd info handler

func (*LinkerdInfo) Stop added in v0.2.0

func (h *LinkerdInfo) Stop()

Stop terminates the handler.

type ManageAgent added in v0.4.1

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

func NewManageAgent added in v0.4.1

func NewManageAgent(k8sClient *k8s.Client, apiClient *api.Client) *ManageAgent

NewManageAgent instantiates a new agent commands handler

func (*ManageAgent) Start added in v0.4.1

func (h *ManageAgent) Start()

Start initiates ManageAgent handler

func (*ManageAgent) Stop added in v0.4.1

func (h *ManageAgent) Stop()

Stop terminates the 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.

Jump to

Keyboard shortcuts

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