Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultExchangeName = "m8_events" // name of the monoskope exchange CACertPath = "/etc/eventstore/certs/buscerts/ca.crt" TLSCertPath = "/etc/eventstore/certs/buscerts/tls.crt" TLSKeyPath = "/etc/eventstore/certs/buscerts/tls.key" )
Variables ¶
This section is empty.
Functions ¶
func NewRabbitEventBusConsumer ¶
func NewRabbitEventBusConsumer(conf *RabbitEventBusConfig) (evs.EventBusConsumer, error)
NewRabbitEventBusConsumer creates a new EventBusConsumer for rabbitmq.
func NewRabbitEventBusPublisher ¶
func NewRabbitEventBusPublisher(conf *RabbitEventBusConfig) (evs.EventBusPublisher, error)
NewRabbitEventBusPublisher creates a new EventBusPublisher for rabbitmq.
Types ¶
type RabbitEventBusConfig ¶
type RabbitEventBusConfig struct {
Name string // Name of the client, required
RoutingKeyPrefix string // Prefix for routing of messages
ExchangeName string // Name of the exchange to initialize/use
AMQPConfig *amqp.Config
// contains filtered or unexported fields
}
func NewRabbitEventBusConfig ¶
func NewRabbitEventBusConfig(name, url, routingKeyPrefix string) (*RabbitEventBusConfig, error)
NewRabbitEventBusConfig creates a new RabbitEventBusConfig with defaults.
func (*RabbitEventBusConfig) SetURL ¶ added in v0.3.4
func (conf *RabbitEventBusConfig) SetURL(url string) error
SetURL reconfigures the address of the RabbitMQ host
func (*RabbitEventBusConfig) URL ¶ added in v0.3.4
func (conf *RabbitEventBusConfig) URL() string
URL of the RabbitMQ host to connect to
func (*RabbitEventBusConfig) Validate ¶
func (conf *RabbitEventBusConfig) Validate() error
Validate validates the configuration
Source Files
Click to show internal directories.
Click to hide internal directories.