Documentation ¶
Overview ¶
Package plexer provides the means to live publish or store stats. In pulse, influx is a BatchPublisher, and mist is a SinglePublisher.
Index ¶
- Variables
- type BatchPublisher
- type Message
- type MessageSet
- type Plexer
- func (plex *Plexer) AddBatcher(name string, observer BatchPublisher)
- func (plex *Plexer) AddObserver(name string, observer SinglePublisher)
- func (plex *Plexer) Publish(messages MessageSet) error
- func (plex *Plexer) PublishSingle(id string, tags []string, data string) error
- func (plex *Plexer) RemoveBatcher(name string)
- func (plex *Plexer) RemoveObserver(name string)
- type SinglePublisher
Constants ¶
This section is empty.
Variables ¶
View Source
var (
MissingPublisher = errors.New("A publisher is needed")
)
Functions ¶
This section is empty.
Types ¶
type BatchPublisher ¶
type BatchPublisher func(MessageSet) error
type MessageSet ¶
type Plexer ¶
type Plexer struct {
// contains filtered or unexported fields
}
func (*Plexer) AddBatcher ¶
func (plex *Plexer) AddBatcher(name string, observer BatchPublisher)
func (*Plexer) AddObserver ¶
func (plex *Plexer) AddObserver(name string, observer SinglePublisher)
func (*Plexer) Publish ¶
func (plex *Plexer) Publish(messages MessageSet) error
func (*Plexer) PublishSingle ¶
func (*Plexer) RemoveBatcher ¶
func (*Plexer) RemoveObserver ¶
type SinglePublisher ¶
Click to show internal directories.
Click to hide internal directories.