messaging

Documentation

Overview

Package messaging provides a broker wrapper for go-micro broker.

The messaging package's structures are self-initialized by fx and bootstrapper. Fields are populated via yaml values or env variables. Env variables overwrite yaml configuration.

Index

• type BrokerWithOptions
  • func NewBroker(registry registry.Registry, config *config.BrokerConfig) BrokerWithOptions

Types

type BrokerWithOptions

type BrokerWithOptions struct {
	Broker     broker.Broker
	SubOptions broker.SubscribeOptions
}

A BrokerWithOptions embeds go-micro compatible broker and encapsulates subscriber options for fine-grained configuration.

func NewBroker

func NewBroker(registry registry.Registry, config *config.BrokerConfig) BrokerWithOptions

A BrokerWrapper constructor. Called automatically by fx and bootstrapper with config path provided via cli.

Returns a wrapper broker instance used to initialize a go-micro broker.