HTTPPostEmitter listens on the event channel and posts the events to an http server Events are serialized into json, and sent via a POST request to the given Uri http errors are logged as warnings to the console, and won't stop the Emitter.

JSONLogEmitter constructs a LogEmitter to use with a transporter pipeline.

LogEmitter constructs a LogEmitter to use with a transporter pipeline.

NewBootEvent (surprisingly) creates a new BaseEvent.

NewEmitter creates a new emitter that will listen on the listen channel and use the emit EmitFunc to process events.

NewErrorEvent are events sent to indicate a problem processing on one of the nodes.

NewExitEvent (surprisingly) creates a new BaseEvent.

NewMetricsEvent creates a new metrics event.

NoopEmitter consumes the events from the listening channel and does nothing with them this is useful for cli utilities that dump output to stdout in any case, and don't want to clutter the program's output with metrics.

BadStatusError wraps the underlying error when the provided is not parsable time.ParseDuration.

Emitter types are used by the transporter pipeline to consume events from a pipeline's event channel and process them.

Event is an interface that describes data which is produced periodically by the running transporter.

EmitFunc is a function that takes an Event as input and emits it.