publish

Documentation

Index

• type BufferedStdoutPublisher
  • func NewBufferedStdoutPublisher(bufsize int) *BufferedStdoutPublisher
  • func (bp *BufferedStdoutPublisher) Publish(data interface{}, timestamp time.Time)
  • func (bp *BufferedStdoutPublisher) Run()
• type HoneycombPublisher
  • func NewHoneycombPublisher(config libhoney.Config) *HoneycombPublisher
  • func (bp *HoneycombPublisher) Publish(data interface{}, timestamp time.Time)
  • func (bp *HoneycombPublisher) Run()
• type Publisher

Types

type BufferedStdoutPublisher

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

BufferedStdoutPublisher buffers serialized events before sending them to stdout. It /drops/ additional events if the channel buffer becomes full. If ingestion can't keep up with TCP traffic, it's better to drop events than packets.

func NewBufferedStdoutPublisher

func NewBufferedStdoutPublisher(bufsize int) *BufferedStdoutPublisher

func (*BufferedStdoutPublisher) Publish

func (bp *BufferedStdoutPublisher) Publish(data interface{}, timestamp time.Time)

func (*BufferedStdoutPublisher) Run

func (bp *BufferedStdoutPublisher) Run()

type HoneycombPublisher

type HoneycombPublisher struct{}

func NewHoneycombPublisher

func NewHoneycombPublisher(config libhoney.Config) *HoneycombPublisher

func (*HoneycombPublisher) Publish

func (bp *HoneycombPublisher) Publish(data interface{}, timestamp time.Time)

func (*HoneycombPublisher) Run

func (bp *HoneycombPublisher) Run()

type Publisher

type Publisher interface {
	Publish(interface{}, time.Time)
}