elasticsearch

package
v0.0.0-...-f6b4a90 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New 

func New(content interface{}) (protocol.Input, error)

Types

type EsConfig 

type EsConfig struct {
	Host   string  `yaml:"host"`
	Quries []Query `yaml:"quries"`
}

type EsInput 

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

func (*EsInput) Emit 

func (input *EsInput) Emit() map[string]interface{}

func (*EsInput) Run 

func (input *EsInput) Run()

func (*EsInput) Stop 

func (input *EsInput) Stop()

type Query 

type Query struct {
	Index string `yaml:"index"`
	Body  string `yaml:"body"`
	Retry int    `yaml:"retry" default:"0"` // retry qury in every <Retry>s
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.