plexer

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 NewPlexer() *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

Variables

var (
	MissingPublisher = errors.New("A publisher is needed")
)

Types

type BatchPublisher

type BatchPublisher func(MessageSet) error

type Message

type Message struct {
	ID   string
	Tags []string
	Data string
}

type MessageSet

type MessageSet struct {
	Tags     []string
	Messages []Message
}

type Plexer

type Plexer struct {
	// contains filtered or unexported fields
}

func NewPlexer

func NewPlexer() *Plexer

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 (plex *Plexer) PublishSingle(id string, tags []string, data string) error

func (*Plexer) RemoveBatcher

func (plex *Plexer) RemoveBatcher(name string)

func (*Plexer) RemoveObserver

func (plex *Plexer) RemoveObserver(name string)

type SinglePublisher

type SinglePublisher func([]string, string) error