queue

Aug 30, 2024

Changes in this version

type Manager

+ ErrorHandler contracts.ErrorHandler

Sep 3, 2021

Changes in this version

type Dispatcher

+ DefaultConnection string

Sep 3, 2021

Changes in this version

+ var DefaultManager = NewManager()

+ func WithDefaults()

+ type Config struct

+ Connection string

+ Connections map[string]map[string]interface{}

+ Listening bool

+ RunningWorkers []string

+ Workers map[string]WorkerConfig

+ type ConnectionRegister func(config map[string]interface{}) contracts.Connection

+ type Dispatcher struct

+ var DefaultDispatcher Dispatcher

+ func (d Dispatcher) After(delay time.Duration) *PayloadHolder

+ func (d Dispatcher) Dispatch(payload interface{}) error

+ func (d Dispatcher) On(on string) *PayloadHolder

+ type Manager struct

+ func NewManager() *Manager

+ func (m *Manager) Close(workers ...string)

+ func (m *Manager) GetConnection(con string) (contracts.Connection, error)

+ func (m *Manager) GetWorker(worker string) (contracts.Worker, bool)

+ func (m *Manager) RegisterConnection(connection string, cr ConnectionRegister)

+ func (m *Manager) RegisterWorker(name string, worker contracts.Worker)

+ func (m *Manager) ResolveConnection(connection string, config map[string]interface{}) (contracts.Connection, error)

+ func (m *Manager) Work(done chan struct{}, workers ...string)

+ type PayloadHolder struct

+ func (ph *PayloadHolder) After(delay time.Duration) *PayloadHolder

+ func (ph *PayloadHolder) Dispatch(payload ...interface{}) error

+ func (ph *PayloadHolder) On(on string) *PayloadHolder

+ type WorkerConfig struct

+ Concurrency int

+ Connection string