pub_sub

Documentation

Index

• type AMQPConfig
• type Bus
  • func NewRabbitBus(cfg *RabbitMQConfig) (Bus, error)
• type QueueOptions
• type RabbitMQConfig

Types

type AMQPConfig

type AMQPConfig struct {
	Exchange     string
	ExchangeType string
}

type Bus

type Bus interface {
	// Subscribe to the specified topic.
	Subscribe(topic string, cb func(data interface{}), options *QueueOptions) (func(), error)

	// Notify notifies the topic with the optional data
	Notify(topic string, data interface{}) error

	// DeleteQueue deletes a queue
	DeleteQueue(id string) error
}

Bus is an interface used for pub-sub like interactions

func NewRabbitBus

func NewRabbitBus(cfg *RabbitMQConfig) (Bus, error)

type QueueOptions

type QueueOptions struct {
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
}

type RabbitMQConfig

type RabbitMQConfig struct {
	RabbitMQUser     string
	RabbitMQPassword string
	RabbitMQHost     string
	RabbitMQPort     string
	AMQP             AMQPConfig

	Environment string
}