handler

Documentation

Index

• type EventChannel
• type Handler
  • func New(client client.Client, channel chan event.GenericEvent, provider *api.Provider) (h *Handler, err error)
  • func (r *Handler) End()
  • func (r *Handler) Enqueue(event event.GenericEvent)
  • func (r *Handler) Error(w *libweb.Watch, err error)
  • func (r *Handler) Inventory() web.Client
  • func (r *Handler) Match(object meta.Object, ref core.ObjectReference) bool
  • func (r *Handler) MatchProvider(ref core.ObjectReference) bool
  • func (r *Handler) Provider() *api.Provider
  • func (r *Handler) Started(id uint64)
• type ProviderMap
• type WatchManager
  • func (m *WatchManager) Deleted(provider *api.Provider)
  • func (m *WatchManager) Ensure(provider *api.Provider, resource interface{}, handler libweb.EventHandler) (watch *libweb.Watch, err error)

Types

type EventChannel

type EventChannel chan event.GenericEvent

Generic event.

type Handler

type Handler struct {
	libweb.StockEventHandler
	// k8s client.
	client.Client
	// contains filtered or unexported fields
}

Provider watch event handler.

func New

func New(
	client client.Client,
	channel chan event.GenericEvent,
	provider *api.Provider) (h *Handler, err error)

Handler factory.

func (*Handler) End

func (r *Handler) End()

Watch ended by peer. The database has been closed.

func (*Handler) Enqueue

func (r *Handler) Enqueue(event event.GenericEvent)

Enqueue reconcile request.

func (*Handler) Error

func (r *Handler) Error(w *libweb.Watch, err error)

Watch error. Repair the watch.

func (*Handler) Inventory

func (r *Handler) Inventory() web.Client

Get an inventory client.

func (*Handler) Match

func (r *Handler) Match(object meta.Object, ref core.ObjectReference) bool

Ref matches object.

func (*Handler) MatchProvider

func (r *Handler) MatchProvider(ref core.ObjectReference) bool

Match provider.

func (*Handler) Provider

func (r *Handler) Provider() *api.Provider

The associated provider.

func (*Handler) Started

func (r *Handler) Started(id uint64)

Inventory watch has parity.

type ProviderMap

type ProviderMap map[types.UID]watchMap

Provider map keyed by provider.UID.

type WatchManager

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

Watch manager.

func (*WatchManager) Deleted

func (m *WatchManager) Deleted(provider *api.Provider)

A provider has been deleted. Delete associated watches.

func (*WatchManager) Ensure

func (m *WatchManager) Ensure(
	provider *api.Provider,
	resource interface{},
	handler libweb.EventHandler) (watch *libweb.Watch, err error)

Ensure watch has been created. An existing watch that is not `alive` will be replaced.