queue

Documentation

Index

• type Producer
  • func NewProducer() *Producer
  • func (p *Producer) AddJob(job queue.IBrokerJob) queue.IProducer
  • func (p *Producer) Delay(eta time.Time) queue.IProducer
  • func (p *Producer) Dispatch() error
  • func (p *Producer) DispatchSync() error
  • func (p *Producer) OnConnection(connection string) queue.IProducer
  • func (p *Producer) OnQueue(queue string) queue.IProducer
• type QueueManager
  • func NewQueueManager() *QueueManager
  • func (m *QueueManager) Connection(connectionName string) queue.IBroker
  • func (m *QueueManager) DefaultConnectionName() string
• type ServiceProvider
  • func (sp *ServiceProvider) Boot()
  • func (sp *ServiceProvider) Register()

Types

type Producer

type Producer struct {
	Chain bool
	Jobs  []queue.IBrokerJob
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer() *Producer

func (*Producer) AddJob

func (p *Producer) AddJob(job queue.IBrokerJob) queue.IProducer

func (*Producer) Delay

func (p *Producer) Delay(eta time.Time) queue.IProducer

func (*Producer) Dispatch

func (p *Producer) Dispatch() error

func (*Producer) DispatchSync

func (p *Producer) DispatchSync() error

func (*Producer) OnConnection

func (p *Producer) OnConnection(connection string) queue.IProducer

func (*Producer) OnQueue

func (p *Producer) OnQueue(queue string) queue.IProducer

type QueueManager

type QueueManager struct {
	manager.Manager[queue.IBroker]
}

func NewQueueManager

func NewQueueManager() *QueueManager

func (*QueueManager) Connection

func (m *QueueManager) Connection(connectionName string) queue.IBroker

func (*QueueManager) DefaultConnectionName

func (m *QueueManager) DefaultConnectionName() string

type ServiceProvider

type ServiceProvider struct {
}

func (*ServiceProvider) Boot

func (sp *ServiceProvider) Boot()

func (*ServiceProvider) Register

func (sp *ServiceProvider) Register()