elasticsearch

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 2, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package elasticsearch implements a result emitter for elasticsearch.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL