kubernetesevents

Documentation

Index

• Constants
• func ConnectToEventStream(handlers []Handler, conf config.Config) error
• func NewServiceHandler(rClient *client.RancherClient, kClient *kubernetesclient.Client, ...) *serviceHandler
• func SyncAndWatchEventStream(handlers []SyncHandler) 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 DeltaFIFO
  • func NewDeltaFIFO(handler SyncHandler, doneChan chan error) *DeltaFIFO
  • func (d *DeltaFIFO) Add(event model.WatchEvent) error
  • func (d *DeltaFIFO) Pop() model.WatchEvent
  • func (d *DeltaFIFO) Process()
• 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
• type SyncHandler

Constants

const NamespaceKind string = "namespaces"

const ServiceKind string = "services"

Functions

func ConnectToEventStream

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

func NewServiceHandler

func NewServiceHandler(rClient *client.RancherClient, kClient *kubernetesclient.Client, conf config.Config) *serviceHandler

func SyncAndWatchEventStream

func SyncAndWatchEventStream(handlers []SyncHandler) 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 DeltaFIFO

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

func NewDeltaFIFO

func NewDeltaFIFO(handler SyncHandler, doneChan chan error) *DeltaFIFO

func (*DeltaFIFO) Add

func (d *DeltaFIFO) Add(event model.WatchEvent) error

thread safe add

func (*DeltaFIFO) Pop

func (d *DeltaFIFO) Pop() model.WatchEvent

blocks until a value is available

func (*DeltaFIFO) Process

func (d *DeltaFIFO) Process()

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
}

type SyncHandler

type SyncHandler interface {
	Add(interface{}) error
	Delete(interface{}) error
	Decode(model.WatchEvent) (interface{}, error)
	GetListURL() string
	GetWatchURL() string
	GetKey(model.WatchEvent) (string, error)
}