publish

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(bufsize int) *BufferedStdoutPublisher

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

func (bp *BufferedStdoutPublisher) Run()

type HoneycombPublisher ¶

type HoneycombPublisher struct{}

func NewHoneycombPublisher(config libhoney.Config) *HoneycombPublisher

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

func (bp *HoneycombPublisher) Run()

type Publisher ¶

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