Documentation
¶
Index ¶
- type EventChannel
- type Handler
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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) Enqueue ¶
func (r *Handler) Enqueue(event event.GenericEvent)
Enqueue reconcile request.
func (*Handler) MatchProvider ¶
func (r *Handler) MatchProvider(ref core.ObjectReference) bool
Match provider.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.