pubsub

Documentation

Index

• func Build() fx.Option
• type Bus
  • func NewRabbit(cfg config.Config) (Bus, error)
• type Embedded
  • func NewEmbedded() *Embedded
  • func (b *Embedded) Declare(topic string) Topic
  • func (b *Embedded) Publish(topic Topic, message []byte) error
  • func (b *Embedded) Subscribe(topic Topic, handler func([]byte) (bool, error)) error
• type Rabbit
  • func (r *Rabbit) Declare(t string) Topic
  • func (r *Rabbit) Publish(topic Topic, message []byte) error
  • func (r *Rabbit) Subscribe(topic Topic, handler func([]byte) (bool, error)) error
• type Topic

Functions

func Build

func Build() fx.Option

Types

type Bus

type Bus interface {
	Declare(topic string) Topic
	Publish(topic Topic, message []byte) error
	Subscribe(topic Topic, handler func([]byte) (bool, error)) error
}

func NewRabbit

func NewRabbit(cfg config.Config) (Bus, error)

type Embedded

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

func NewEmbedded

func NewEmbedded() *Embedded

func (*Embedded) Declare

func (b *Embedded) Declare(topic string) Topic

func (*Embedded) Publish

func (b *Embedded) Publish(topic Topic, message []byte) error

func (*Embedded) Subscribe

func (b *Embedded) Subscribe(topic Topic, handler func([]byte) (bool, error)) error

type Rabbit

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

func (*Rabbit) Declare

func (r *Rabbit) Declare(t string) Topic

Declare is meant to be used like: const MyQueue string

MyQueue = Declare("name_of_queue")

ps.Publish(MyQueue, ...)

func (*Rabbit) Publish

func (r *Rabbit) Publish(topic Topic, message []byte) error

func (*Rabbit) Subscribe

func (r *Rabbit) Subscribe(topic Topic, handler func([]byte) (bool, error)) error

type Topic

type Topic string