Versions in this module Expand all Collapse all v0 v0.6.6 Jul 3, 2020 Changes in this version + type Activator interface + Start func(ch chan<- bool) error + Stop func() + type Controller struct + func NewController(name string) *Controller + func (c *Controller) Activate(activator Activator) *Controller + func (c *Controller) Filter(filter Filter) *Controller + func (c *Controller) Partition(partitioner WorkPartitioner) *Controller + func (c *Controller) Reconcile(reconciler Reconciler) *Controller + func (c *Controller) Start() error + func (c *Controller) Stop() + func (c *Controller) Watch(watcher Watcher) *Controller + type DeviceResolver interface + Resolve func(id types.ID) (topodevice.ID, error) + type Filter interface + Accept func(id types.ID) bool + type LeadershipActivator struct + Store leadershipstore.Store + func (a *LeadershipActivator) Start(ch chan<- bool) error + func (a *LeadershipActivator) Stop() + type MastershipFilter struct + Resolver DeviceResolver + Store mastershipstore.Store + func (f *MastershipFilter) Accept(id types.ID) bool + type PartitionKey string + type Reconciler interface + Reconcile func(types.ID) (Result, error) + type RegexpDeviceResolver struct + Regexp regexp.Regexp + func (r *RegexpDeviceResolver) Resolve(id types.ID) (topodevice.ID, error) + type RegexpPartitioner struct + Regexp regexp.Regexp + func (p *RegexpPartitioner) Partition(id types.ID) (PartitionKey, error) + type Result struct + Requeue types.ID + type UnaryPartitioner struct + func (p *UnaryPartitioner) Partition(id types.ID) (PartitionKey, error) + type UnconditionalActivator struct + func (a *UnconditionalActivator) Start(ch chan<- bool) error + func (a *UnconditionalActivator) Stop() + type Watcher interface + Start func(ch chan<- types.ID) error + Stop func() + type WorkPartitioner interface + Partition func(id types.ID) (PartitionKey, error)
Go to main page