elasticsearch

package
v0.9.71 Latest Latest
Warning

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

Go to latest
Published: Jun 29, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name = "elasticsearch"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ElasticsearchOutput

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

func (*ElasticsearchOutput) Close

func (output *ElasticsearchOutput) Close()

func (*ElasticsearchOutput) Configure

func (output *ElasticsearchOutput) Configure(pipelineName string, data map[string]interface{}) error

func (*ElasticsearchOutput) Execute

func (output *ElasticsearchOutput) Execute(msgs []*core.Msg) error

func (*ElasticsearchOutput) GetRouter

func (output *ElasticsearchOutput) GetRouter() core.Router

func (*ElasticsearchOutput) Start

func (output *ElasticsearchOutput) Start() error

type ElasticsearchPluginConfig

type ElasticsearchPluginConfig struct {
	ServerConfig     *ElasticsearchServerConfig `mapstructure:"server" json:"server"`
	Routes           []map[string]interface{}   `mapstructure:"routes" json:"routes"`
	IgnoreBadRequest bool                       `mapstructure:"ignore-bad-request" json:"ignore-bad-request"`
}

type ElasticsearchServerAuth

type ElasticsearchServerAuth struct {
	Username string `mapstructure:"username" toml:"username" json:"username"`
	Password string `mapstructure:"password" toml:"password" json:"password"`
}

type ElasticsearchServerConfig

type ElasticsearchServerConfig struct {
	URLs    []string                 `mapstructure:"urls" toml:"urls" json:"urls"`
	Sniff   bool                     `mapstructure:"sniff" toml:"sniff" json:"sniff"`
	Auth    *ElasticsearchServerAuth `mapstructure:"auth" toml:"auth" json:"auth"`
	Timeout int                      `mapstructure:"timeout" toml:"timeout" json:"timeout"`
}

Jump to

Keyboard shortcuts

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