publisher

Documentation

Index

• Variables
• type EventPublisher
  • func NewPublisher(amqpConn *amqp.Connection) (EventPublisher, error)
• type Option
  • func BindingKey(bindingKey string) Option
  • func ExChangeName(exchangeName string) Option
  • func MessageTypeName(messageTypeName string) Option

Variables

var EventPublisherSet = wire.NewSet(NewPublisher)

Types

type EventPublisher

type EventPublisher interface {
	Configure(...Option) EventPublisher
	Publish(context.Context, []byte, string) error
}

func NewPublisher

func NewPublisher(amqpConn *amqp.Connection) (EventPublisher, error)

type Option

type Option func(*publisher)

func BindingKey

func BindingKey(bindingKey string) Option

func ExChangeName

func ExChangeName(exchangeName string) Option

func MessageTypeName

func MessageTypeName(messageTypeName string) Option