README ¶ brood The goal of this package is to provide a message broker in the style of redis, kafka or similar software - but as a library. NOTE: This package is currently not for production as it is under heavy development. Expand ▾ Collapse ▴ Documentation ¶ Index ¶ Variables type Brood func New(in, out chan spore.Spore) *Brood func (b *Brood) ListenAndServe(url string) error func (b *Brood) Publish(s spore.Spore) error func (b *Brood) Subscribe(hives string) (chan spore.Spore, error) Constants ¶ This section is empty. Variables ¶ View Source var ( ErrNotImplemented = errors.New("brood: not implemented yet") ) Functions ¶ This section is empty. Types ¶ type Brood ¶ type Brood struct { // contains filtered or unexported fields } func New ¶ func New(in, out chan spore.Spore) *Brood func (*Brood) ListenAndServe ¶ func (b *Brood) ListenAndServe(url string) error func (*Brood) Publish ¶ func (b *Brood) Publish(s spore.Spore) error func (*Brood) Subscribe ¶ func (b *Brood) Subscribe(hives string) (chan spore.Spore, error) Source Files ¶ View all Source files brood.go Directories ¶ Show internal Expand all Path Synopsis pb Package pb is a reverse proxy. Package pb is a reverse proxy. spore Click to show internal directories. Click to hide internal directories.