pubsub

Documentation

Index

• type Config
• type Factory
  • func NewFactory(compType string, f func() pubsub.PubSub) *Factory
• type Registry
  • func NewRegistry(info *info.RuntimeInfo) Registry

Types

type Config

type Config struct {
	ref.Config
	Type     string            `json:"type"`
	Metadata map[string]string `json:"metadata"`
}

Config wraps configuration for a pubsub implementation

type Factory

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

func NewFactory

func NewFactory(compType string, f func() pubsub.PubSub) *Factory

type Registry

type Registry interface {
	Register(fs ...*Factory)
	Create(compType string) (dpubsub.PubSub, error)
}

Registry is the pubsub registry with pubsub name as the key

func NewRegistry

func NewRegistry(info *info.RuntimeInfo) Registry