controller

type Controller interface {
	Start()
	Shutdown()

	Watcher() Watcher

	AddEntityHandler(h EntityHandler)
}

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

type EntityHandler interface {
	Type() reflect.Type
	Add(obj entitystore.Entity) error
	Update(obj entitystore.Entity) error
	Delete(obj entitystore.Entity) error
	Error(obj entitystore.Entity) error
	// Sync returns a list of entities which to process.  This method should call out and determine the actual state
	// of entities.
	Sync(organizationID string, resyncPeriod time.Duration) ([]entitystore.Entity, error)
}

type Options struct {
	OrganizationID string
	Namespace      string

	ResyncPeriod time.Duration
	Workers      int
}

type Watcher chan<- entitystore.Entity