Versions in this module Expand all Collapse all v0 v0.2.0 Jun 2, 2022 Changes in this version type Feed + Settings *storage.SyncedSettings v0.1.0 May 8, 2022 Changes in this version + type Feed struct + Namespace *storage.SyncedNamespace + func New(namespaceID string, db *storage.BadgerClient, ackDeadline time.Duration, ...) (*Feed, error) + func (f *Feed) Close() error + func (f *Feed) Tasks() TaskStream + type Lease struct + func (l *Lease) Feed() *Feed + func (l *Lease) Release() + type Manager struct + func NewManager(db *storage.BadgerClient, raft *raft.Raft) *Manager + func (qm *Manager) Close() error + func (qm *Manager) Lease(namespace string) (*Lease, error) + func (qm *Manager) Tasks(namespace string, handle func(tasks TaskStream) error) error + type TaskBroker struct + func NewTaskBroker(stream proto.Queue_PullServer, fm *Manager, raft *raft.Raft) *TaskBroker + func (tb *TaskBroker) Close() error + func (tb *TaskBroker) Start() error + type TaskStream <-chan *proto.Task
Go to main page