relay

Documentation

Index

• func WithEmitter(ctx context.Context, e Emitter) context.Context
• type ElasticsearchIndexer
• type Emitter
  • func ContextEmitter(ctx context.Context) Emitter
  • func NewElasticsearchEmitter(cfg services.ElasticsearchConfig, indexer ElasticsearchIndexer) Emitter
  • func NewKinesisEmitter(stream string) Emitter
  • func NewMultiEmitter(emitters ...Emitter) Emitter
  • func NewNoopEmitter() Emitter

Functions

func WithEmitter

func WithEmitter(ctx context.Context, e Emitter) context.Context

Types

type ElasticsearchIndexer

type ElasticsearchIndexer struct {
	Index    func(item interface{}) string
	Type     func(item interface{}) *string
	Id       func(item interface{}) *string
	BodyJson func(item interface{}) interface{}
}

type Emitter

type Emitter interface {
	scaffold.Contextualizer
	Emit(item interface{}) error
	Flush() error
}

func ContextEmitter

func ContextEmitter(ctx context.Context) Emitter

func NewElasticsearchEmitter

func NewElasticsearchEmitter(cfg services.ElasticsearchConfig, indexer ElasticsearchIndexer) Emitter

func NewKinesisEmitter

func NewKinesisEmitter(stream string) Emitter

func NewMultiEmitter

func NewMultiEmitter(emitters ...Emitter) Emitter

func NewNoopEmitter

func NewNoopEmitter() Emitter