Documentation ¶
Index ¶
- type Dispatcher
- func (d *Dispatcher) OnDatamodelStatus(status api.SyncStatus)
- func (d *Dispatcher) OnStatusUpdated(status api.SyncStatus)
- func (d *Dispatcher) OnUpdate(update api.Update) (filterOut bool)
- func (d *Dispatcher) OnUpdates(updates []api.Update)
- func (d *Dispatcher) Register(keyExample model.Key, receiver UpdateHandler)
- func (d *Dispatcher) RegisterStatusHandler(handler StatusHandler)
- type StatusHandler
- type UpdateHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher fans out incoming events based on their reflect.Type. One or more UpdateHandler functions can be registered for each type.
The Dispatcher supports rudimentary filtering: UpdateHandlers are called in the order they were added. Earlier handlers can return filterOut=true to prevent further handlers being called.
func NewDispatcher ¶
func NewDispatcher() *Dispatcher
NewDispatcher creates a Dispatcher with all its event handlers set to no-ops.
func (*Dispatcher) OnDatamodelStatus ¶
func (d *Dispatcher) OnDatamodelStatus(status api.SyncStatus)
func (*Dispatcher) OnStatusUpdated ¶
func (d *Dispatcher) OnStatusUpdated(status api.SyncStatus)
func (*Dispatcher) OnUpdates ¶
func (d *Dispatcher) OnUpdates(updates []api.Update)
func (*Dispatcher) Register ¶
func (d *Dispatcher) Register(keyExample model.Key, receiver UpdateHandler)
func (*Dispatcher) RegisterStatusHandler ¶
func (d *Dispatcher) RegisterStatusHandler(handler StatusHandler)
type StatusHandler ¶
type StatusHandler func(status api.SyncStatus)
type UpdateHandler ¶
Click to show internal directories.
Click to hide internal directories.