Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrTooEarlyForStateAssociation = fmt.Errorf("too early for state association")
ErrTooEarlyForStateAssociation is returned when state data arrives before entity is registered
Functions ¶
This section is empty.
Types ¶
type Dependencies ¶
type Dependencies struct {
EntityCache *cache.EntityCache
MarkerCache *cache.MarkerCache
LogManager *logging.SlogManager
ParserService parser.Service
}
Dependencies holds all dependencies for the worker manager
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages worker goroutines
func NewManager ¶
func NewManager(deps Dependencies, backend storage.Backend) *Manager
NewManager creates a new worker manager
func (*Manager) RegisterHandlers ¶
func (m *Manager) RegisterHandlers(d *dispatcher.Dispatcher)
RegisterHandlers registers all event handlers with the dispatcher.
Source Files
Click to show internal directories.
Click to hide internal directories.