queue

package

v1.1.3-0...-a28cbea Latest Latest Go to latest Published: Feb 26, 2021 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var ErrNoAvailablePusher = errors.New("no available pusher")

This section is empty.

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

func (pusher *BalancedPusher) Name() string

func (pusher *BalancedPusher) Push(message string) error

type Consumer interface {
	Consume(string) error
	OnEvent(event interface{})
}

type ConsumerFactory func() (Consumer, error)

type Listener interface {
	OnPause()
	OnResume()
}

type MessageQueue interface {
	Start()
	Stop()
}

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

func (pusher *MultiPusher) Name() string

func (pusher *MultiPusher) Push(message string) error

type Poller interface {
	Name() string
	Poll() string
}

type ProduceListener interface {
	OnProducerPause()
	OnProducerResume()
}

type Producer interface {
	AddListener(listener ProduceListener)
	Produce() (string, bool)
}

type ProducerFactory func() (Producer, error)

type Pusher interface {
	Name() string
	Push(string) error
}

func NewBalancedPusher(pushers []Pusher) Pusher

func NewMultiPusher(pushers []Pusher) Pusher

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

func NewQueue(producerFactory ProducerFactory, consumerFactory ConsumerFactory) *Queue

func (queue *Queue) AddListener(listener Listener)

func (queue *Queue) Broadcast(message interface{})

func (queue *Queue) SetName(name string)

func (queue *Queue) SetNumConsumer(count int)

func (queue *Queue) SetNumProducer(count int)

func (queue *Queue) Start()

func (queue *Queue) Stop()