queue

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

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
}

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
}

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