pubsub

Documentation

Index

• type PubSub
  • func New(name string, factoryMethod func() pubsub.PubSub) PubSub
• type Registry
  • func NewRegistry() Registry

Types

type PubSub

type PubSub struct {
	Name          string
	FactoryMethod func() pubsub.PubSub
}

PubSub is a pub/sub component definition.

func New

func New(name string, factoryMethod func() pubsub.PubSub) PubSub

New creates a PubSub.

type Registry

type Registry interface {
	Register(components ...PubSub)
	Create(name, version string) (pubsub.PubSub, error)
}

Registry is the interface for callers to get registered pub-sub components.

func NewRegistry

func NewRegistry() Registry

NewRegistry returns a new pub sub registry.