broker

Documentation

Index

• type AmqpBroker
  • func NewAmqpBroker(connectionName string) (*AmqpBroker, error)
  • func (b *AmqpBroker) AddChainJobs(jobs ...queue.IBrokerJob) error
  • func (b *AmqpBroker) AddChainJobsWithQueue(queueName string, jobs ...queue.IBrokerJob) error
  • func (b *AmqpBroker) AddJob(jobs ...queue.IBrokerJob) error
  • func (b *AmqpBroker) AddJobWithQueue(queueName string, jobs ...queue.IBrokerJob) error
  • func (b *AmqpBroker) Connection(name string) queue.IBroker
  • func (b *AmqpBroker) RunServe(queueName string, concurrentCount int) error
• type RedisBroker
  • func NewRedisBroker(connectionName string) (*RedisBroker, error)
  • func (b *RedisBroker) AddChainJobs(jobs ...queue.IBrokerJob) error
  • func (b *RedisBroker) AddChainJobsWithQueue(queueName string, jobs ...queue.IBrokerJob) error
  • func (b *RedisBroker) AddJob(jobs ...queue.IBrokerJob) error
  • func (b *RedisBroker) AddJobWithQueue(queueName string, jobs ...queue.IBrokerJob) error
  • func (b *RedisBroker) Connection(name string) queue.IBroker
  • func (b *RedisBroker) RunServe(queueName string, concurrentCount int) error
• type SyncBroker
  • func NewSyncBroker(connection string) *SyncBroker
  • func (s *SyncBroker) AddChainJobs(jobs ...queue.IBrokerJob) error
  • func (s *SyncBroker) AddChainJobsWithQueue(queueName string, jobs ...queue.IBrokerJob) error
  • func (s *SyncBroker) AddJob(jobs ...queue.IBrokerJob) error
  • func (s *SyncBroker) AddJobWithQueue(queueName string, jobs ...queue.IBrokerJob) error
  • func (s *SyncBroker) Connection(name string) queue.IBroker
  • func (s *SyncBroker) RunServe(queueName string, concurrentCount int) error

Types

type AmqpBroker

type AmqpBroker struct {
	// contains filtered or unexported fields
}

func NewAmqpBroker

func NewAmqpBroker(connectionName string) (*AmqpBroker, error)

func (*AmqpBroker) AddChainJobs

func (b *AmqpBroker) AddChainJobs(jobs ...queue.IBrokerJob) error

func (*AmqpBroker) AddChainJobsWithQueue

func (b *AmqpBroker) AddChainJobsWithQueue(queueName string, jobs ...queue.IBrokerJob) error

func (*AmqpBroker) AddJob

func (b *AmqpBroker) AddJob(jobs ...queue.IBrokerJob) error

func (*AmqpBroker) AddJobWithQueue

func (b *AmqpBroker) AddJobWithQueue(queueName string, jobs ...queue.IBrokerJob) error

func (*AmqpBroker) Connection

func (b *AmqpBroker) Connection(name string) queue.IBroker

func (*AmqpBroker) RunServe

func (b *AmqpBroker) RunServe(queueName string, concurrentCount int) error

type RedisBroker

type RedisBroker struct {
	// contains filtered or unexported fields
}

func NewRedisBroker

func NewRedisBroker(connectionName string) (*RedisBroker, error)

func (*RedisBroker) AddChainJobs

func (b *RedisBroker) AddChainJobs(jobs ...queue.IBrokerJob) error

func (*RedisBroker) AddChainJobsWithQueue

func (b *RedisBroker) AddChainJobsWithQueue(queueName string, jobs ...queue.IBrokerJob) error

func (*RedisBroker) AddJob

func (b *RedisBroker) AddJob(jobs ...queue.IBrokerJob) error

func (*RedisBroker) AddJobWithQueue

func (b *RedisBroker) AddJobWithQueue(queueName string, jobs ...queue.IBrokerJob) error

func (*RedisBroker) Connection

func (b *RedisBroker) Connection(name string) queue.IBroker

func (*RedisBroker) RunServe

func (b *RedisBroker) RunServe(queueName string, concurrentCount int) error

type SyncBroker

type SyncBroker struct {
	// contains filtered or unexported fields
}

func NewSyncBroker

func NewSyncBroker(connection string) *SyncBroker

func (*SyncBroker) AddChainJobs

func (s *SyncBroker) AddChainJobs(jobs ...queue.IBrokerJob) error

func (*SyncBroker) AddChainJobsWithQueue

func (s *SyncBroker) AddChainJobsWithQueue(queueName string, jobs ...queue.IBrokerJob) error

func (*SyncBroker) AddJob

func (s *SyncBroker) AddJob(jobs ...queue.IBrokerJob) error

func (*SyncBroker) AddJobWithQueue

func (s *SyncBroker) AddJobWithQueue(queueName string, jobs ...queue.IBrokerJob) error

func (*SyncBroker) Connection

func (s *SyncBroker) Connection(name string) queue.IBroker

func (*SyncBroker) RunServe

func (s *SyncBroker) RunServe(queueName string, concurrentCount int) error