Versions in this module Expand all Collapse all v0 v0.2.0 Feb 28, 2017 v0.1.3 Feb 9, 2017 v0.1.2 Jan 27, 2017 Changes in this version + type BadStatusError struct + func (e BadStatusError) Error() string + type EmitFunc func(Event) error + func JSONLogEmitter() EmitFunc type Emitter + func NewEmitter(listen chan Event, emit EmitFunc) Emitter type Event + Logger func() log.Logger v0.1.1 Aug 27, 2015 v0.1.0 Aug 6, 2015 v0.0.4 Jul 13, 2015 Changes in this version + type JsonLogEmitter struct + func NewJsonLogEmitter() *JsonLogEmitter + func (e *JsonLogEmitter) Init(ch chan Event) + func (e *JsonLogEmitter) Start() + func (e *JsonLogEmitter) Stop() v0.0.3 Jan 14, 2015 v0.0.2 Dec 29, 2014 Changes in this version + type BaseEvent struct + Endpoints map[string]string + Kind string + Ts int64 + Version string + func NewBootEvent(ts int64, version string, endpoints map[string]string) *BaseEvent + func NewExitEvent(ts int64, version string, endpoints map[string]string) *BaseEvent + func (e *BaseEvent) Emit() ([]byte, error) + func (e *BaseEvent) String() string + type Emitter interface + Init func(chan Event) + Start func() + Stop func() + type ErrorEvent struct + Kind string + Message string + Path string + Record bson.M + Ts int64 + func NewErrorEvent(ts int64, path string, record bson.M, message string) *ErrorEvent + func (e *ErrorEvent) Emit() ([]byte, error) + func (e *ErrorEvent) String() string + type Event interface + Emit func() ([]byte, error) + String func() string + type HTTPPostEmitter struct + func NewHTTPPostEmitter(uri, key, pid string) *HTTPPostEmitter + func (e *HTTPPostEmitter) Init(ch chan Event) + func (e *HTTPPostEmitter) Start() + func (e *HTTPPostEmitter) Stop() + type LogEmitter struct + func NewLogEmitter() *LogEmitter + func (e *LogEmitter) Init(ch chan Event) + func (e *LogEmitter) Start() + func (e *LogEmitter) Stop() + type MetricsEvent struct + Kind string + Path string + Records int + Ts int64 + func NewMetricsEvent(ts int64, path string, records int) *MetricsEvent + func (e *MetricsEvent) Emit() ([]byte, error) + func (e *MetricsEvent) String() string + type NoopEmitter struct + func NewNoopEmitter() *NoopEmitter + func (e *NoopEmitter) Init(ch chan Event) + func (e *NoopEmitter) Start() + func (e *NoopEmitter) Stop()
Go to main page