elasticsearch

Documentation

Index

• type Config
• type Emitter
  • func New(config Config) (emitter *Emitter, err error)
  • func (e *Emitter) Close()
  • func (e *Emitter) Emit(result transaction.Result)

Types

type Config

type Config struct {
	Username          string        `json:"username" yaml:"username"`
	Password          string        `json:"password" yaml:"password"`
	Urls              []string      `json:"urls" yaml:"urls"`
	Index             string        `json:"index" yaml:"index"`
	MaxPendingBytes   int64         `json:"max_pending_bytes" yaml:"max_pending_bytes"`
	MaxPendingResults int64         `json:"max_pending_results" yaml:"max_pending_results"`
	MaxPendingTime    time.Duration `json:"max_pending_time" yaml:"max_pending_time"`
}

Config for elasticsearch emitter

type Emitter

type Emitter struct {
	// contains filtered or unexported fields
}

Emitter for elasticsearch

func New

func New(config Config) (emitter *Emitter, err error)

New creates a new transaction.Result emmiter

func (*Emitter) Close

func (e *Emitter) Close()

Close and flush pending data

func (*Emitter) Emit

func (e *Emitter) Emit(result transaction.Result)

Emit results