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(ctx context.Context, obj entitystore.Entity) error
	Update(ctx context.Context, obj entitystore.Entity) error
	Delete(ctx context.Context, obj entitystore.Entity) error
	Error(ctx context.Context, 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(ctx context.Context, organizationID string, resyncPeriod time.Duration) ([]entitystore.Entity, error)
}

type Options struct {
	OrganizationID string
	Namespace      string

	ResyncPeriod time.Duration
	Workers      int
}

type WatchEvent struct {
	Entity entitystore.Entity
	Ctx    context.Context
}

type Watcher chan<- WatchEvent