broker

Documentation

Index

• type AmqpBroker
  • func NewAmqpBroker(option *AmqpBrokerOptions) *AmqpBroker
  • func (a *AmqpBroker) Consume(queue *Queue) error
  • func (a *AmqpBroker) Health() bool
  • func (a *AmqpBroker) Publish(key string, body []byte) error
  • func (a *AmqpBroker) PublishDelay(queue string, body []byte, delay int64) error
• type AmqpBrokerOptions
• type Broker
• type Queue
• type Status

Types

type AmqpBroker

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

func NewAmqpBroker

func NewAmqpBroker(option *AmqpBrokerOptions) *AmqpBroker

func (*AmqpBroker) Consume

func (a *AmqpBroker) Consume(queue *Queue) error

func (*AmqpBroker) Health

func (a *AmqpBroker) Health() bool

func (*AmqpBroker) Publish

func (a *AmqpBroker) Publish(key string, body []byte) error

func (*AmqpBroker) PublishDelay

func (a *AmqpBroker) PublishDelay(queue string, body []byte, delay int64) error

type AmqpBrokerOptions

type AmqpBrokerOptions struct {
	Url          string
	Exchange     string
	ExchangeType string
}

type Broker

type Broker interface {
	Consume(queue *Queue) error
	Publish(key string, body []byte) error
	PublishDelay(queue string, body []byte, delay int64) error
	Health() bool
}

type Queue

type Queue struct {
	Name       string
	RouteKey   string
	RetryQueue []int64
	Handle     func([]byte) Status
}

type Status

type Status int

const (
	Success Status = iota
	Retry
)