Documentation
¶
Index ¶
- Constants
- 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 PeriodicEventGenerator
- type ProviderMap
- type Stoppable
- type WatchManager
- func (m *WatchManager) Deleted(provider *api.Provider)
- func (m *WatchManager) End()
- func (m *WatchManager) Ensure(provider *api.Provider, resource interface{}, handler libweb.EventHandler) (watch *libweb.Watch, err error)
- func (m *WatchManager) EnsurePeriodicEvents(provider *api.Provider, resource interface{}, interval time.Duration, ...)
Constants ¶
View Source
const (
DefaultEventInterval = time.Second * 10
)
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 PeriodicEventGenerator ¶
type PeriodicEventGenerator struct {
// contains filtered or unexported fields
}
func (*PeriodicEventGenerator) End ¶
func (r *PeriodicEventGenerator) End()
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.
func (*WatchManager) Ensure ¶
func (m *WatchManager) Ensure( provider *api.Provider, resource interface{}, handler libweb.EventHandler) (watch *libweb.Watch, err error)
Ensure a watch has been created.
func (*WatchManager) EnsurePeriodicEvents ¶
func (m *WatchManager) EnsurePeriodicEvents( provider *api.Provider, resource interface{}, interval time.Duration, tickFunc func())
Ensure that we've started a periodic event generator for the provider resource.
Source Files
Click to show internal directories.
Click to hide internal directories.