mq

Documentation

Index

• func Register(tp string, f Factory)
• type Consumer
• type Factory
  • func NewFactory(tp string) Factory
• type FactoryFunc
  • func (f FactoryFunc) New(name string) (Queue, error)
  • func (f FactoryFunc) NewConsumer(name string) (Consumer, error)
  • func (f FactoryFunc) NewProducer(name string) (Producer, error)
• type Producer
• type Queue

Functions

func Register

func Register(tp string, f Factory)

Types

type Consumer

type Consumer interface {
	Consume() (pool.Task, error)
}

type Factory

type Factory interface {
	New(name string) (Queue, error)
	NewProducer(name string) (Producer, error)
	NewConsumer(name string) (Consumer, error)
}

func NewFactory

func NewFactory(tp string) Factory

type FactoryFunc

type FactoryFunc func(name string) (Queue, error)

func (FactoryFunc) New

func (f FactoryFunc) New(name string) (Queue, error)

func (FactoryFunc) NewConsumer

func (f FactoryFunc) NewConsumer(name string) (Consumer, error)

func (FactoryFunc) NewProducer

func (f FactoryFunc) NewProducer(name string) (Producer, error)

type Producer

type Producer interface {
	Produce(task pool.Task) error
}

type Queue

type Queue interface {
	Producer
	Consumer
	io.Closer
}