nameresolver

Documentation

Index

• type Registry
  • func NewRegistry() *Registry
  • func (p *Registry) Create(name, version string) (nameresolver.Resolver, error)
  • func (p *Registry) RegisterComponent(componentFactory func() nameresolver.Resolver, names ...string)

Types

type Registry

type Registry struct {
	// 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 string) (nameresolver.Resolver, error)

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

func (*Registry) RegisterComponent

func (p *Registry) RegisterComponent(componentFactory func() nameresolver.Resolver, names ...string)

RegisterComponent adds a new message bus to the registry.