messaging

Documentation

Index

• Constants
• func NewRabbitEventBusConsumer(conf *RabbitEventBusConfig) (evs.EventBusConsumer, error)
• func NewRabbitEventBusPublisher(conf *RabbitEventBusConfig) (evs.EventBusPublisher, error)
• type CertAuth
  • func (me *CertAuth) Mechanism() string
  • func (me *CertAuth) Response() string
• type RabbitEventBusConfig
  • func NewRabbitEventBusConfig(name, url, routingKeyPrefix string) (*RabbitEventBusConfig, error)
  • func (conf *RabbitEventBusConfig) Validate() error

Constants

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"
)

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 CertAuth

type CertAuth struct {
}

CertAuth for RabbitMQ-auth-mechanism-ssl.

func (*CertAuth) Mechanism

func (me *CertAuth) Mechanism() string

func (*CertAuth) Response

func (me *CertAuth) Response() string

type RabbitEventBusConfig

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

func NewRabbitEventBusConfig

func NewRabbitEventBusConfig(name, url, routingKeyPrefix string) (*RabbitEventBusConfig, error)

NewRabbitEventBusConfig creates a new RabbitEventBusConfig with defaults.

func (*RabbitEventBusConfig) Validate

func (conf *RabbitEventBusConfig) Validate() error

Validate validates the configuration