queue

package module

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

Details

This section is empty.

View Source

var DefaultManager = NewManager()

This section is empty.

type ConnectionRegister func() (contracts.Connection, error)

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(connection string) (contracts.Connection, error)

GetConnection, get queue connection

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

GetWorker, get queue worker

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

RegisterConnection, register queue connection

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

RegisterWorker, register queue worker

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

Work, run worker process

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