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) SetURL(url string) error
  • func (conf *RabbitEventBusConfig) URL() string
  • 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 {
	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

func (conf *RabbitEventBusConfig) SetURL(url string) error

SetURL reconfigures the address of the RabbitMQ host

func (*RabbitEventBusConfig) URL

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