Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ElasticsearchIndexer ¶
type Emitter ¶
type Emitter interface { scaffold.Contextualizer Emit(item interface{}) error Flush() error }
func ContextEmitter ¶
func NewElasticsearchEmitter ¶
func NewElasticsearchEmitter(cfg services.ElasticsearchConfig, indexer ElasticsearchIndexer) Emitter
func NewKinesisEmitter ¶
func NewMultiEmitter ¶
func NewNoopEmitter ¶
func NewNoopEmitter() Emitter
Click to show internal directories.
Click to hide internal directories.