kubernetesevents

Documentation

Index

• Constants
• func ConnectToEventStream(handlers []Handler, conf config.Config) error
• type ChangeHandler
  • func NewChangeHandler(rancherClient *client.RancherClient, kubernetesClient *kubernetesclient.Client, ...) *ChangeHandler
  • func (h *ChangeHandler) GetKindHandled() string
  • func (h *ChangeHandler) Handle(event model.WatchEvent) error
• type GenericHandler
  • func NewHandler(rancherClient *client.RancherClient, kubernetesClient *kubernetesclient.Client, ...) *GenericHandler
  • func (h *GenericHandler) GetKindHandled() string
  • func (h *GenericHandler) Handle(event model.WatchEvent) error
• type Handler

Constants

const NamespaceKind string = "namespaces"

const ServiceKind string = "services"

Functions

func ConnectToEventStream

func ConnectToEventStream(handlers []Handler, conf config.Config) error

Types

type ChangeHandler

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

func NewChangeHandler

func NewChangeHandler(rancherClient *client.RancherClient, kubernetesClient *kubernetesclient.Client, kindHandled string) *ChangeHandler

func (*ChangeHandler) GetKindHandled

func (h *ChangeHandler) GetKindHandled() string

func (*ChangeHandler) Handle

func (h *ChangeHandler) Handle(event model.WatchEvent) error

type GenericHandler

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

Capable of handling RC and Service events

func NewHandler

func NewHandler(rancherClient *client.RancherClient, kubernetesClient *kubernetesclient.Client, kindHandled string) *GenericHandler

func (*GenericHandler) GetKindHandled

func (h *GenericHandler) GetKindHandled() string

func (*GenericHandler) Handle

func (h *GenericHandler) Handle(event model.WatchEvent) error

type Handler

type Handler interface {
	Handle(event model.WatchEvent) error
	GetKindHandled() string
}