pubsub

Documentation

Index

• func NewGRPCPubSub(l logger.Logger, socket string) *grpcPubSub
• type Registry
  • func NewRegistry() *Registry
  • func (p *Registry) Create(name, version, logName string) (pubsub.PubSub, error)
  • func (p *Registry) RegisterComponent(componentFactory func(logger.Logger) pubsub.PubSub, names ...string)

Functions

func NewGRPCPubSub

func NewGRPCPubSub(l logger.Logger, socket string) *grpcPubSub

NewGRPCPubSub creates a new grpc pubsub using the given socket factory.

Types

type Registry

type Registry struct {
	Logger logger.Logger
	// contains filtered or unexported fields
}

var DefaultRegistry *Registry = NewRegistry()

DefaultRegistry is the singleton with the registry.

func NewRegistry

func NewRegistry() *Registry

NewRegistry returns a new pub sub registry.

func (*Registry) Create

func (p *Registry) Create(name, version, logName string) (pubsub.PubSub, error)

Create instantiates a pub/sub based on `name`.

func (*Registry) RegisterComponent

func (p *Registry) RegisterComponent(componentFactory func(logger.Logger) pubsub.PubSub, names ...string)

RegisterComponent adds a new message bus to the registry.