queue

package module

v0.0.3 Latest Latest Go to latest Published: Sep 3, 2021 License: BSD-3-Clause Imports: 6 Imported by: 1

Details

This section is empty.

View Source

var DefaultManager = NewManager()

func WithDefaults()

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

type Dispatcher struct {
	DefaultConnection string
}

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 {
	// contains filtered or unexported fields
}

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 {
	// contains filtered or unexported fields
}

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

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

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