Versions in this module Expand all Collapse all v0 v0.1.1 Dec 20, 2017 Changes in this version + type Controller interface + AddEntityHandler func(h EntityHandler) + Shutdown func() + Start func() + Watcher func() Watcher + func NewController(store entitystore.EntityStore, options Options) Controller + type DefaultController struct + func (dc *DefaultController) AddEntityHandler(h EntityHandler) + func (dc *DefaultController) Shutdown() + func (dc *DefaultController) Start() + func (dc *DefaultController) Watcher() Watcher + type EntityHandler interface + Add func(obj entitystore.Entity) error + Delete func(obj entitystore.Entity) error + Error func(obj entitystore.Entity) error + Type func() reflect.Type + Update func(obj entitystore.Entity) error + type Options struct + Namespace string + OrganizationID string + ResyncPeriod time.Duration + Workers int + type Watcher chan<- entitystore.Entity + func (w *Watcher) OnAction(e entitystore.Entity)
Go to main page