elasticsearch

Documentation

Index

• Constants
• type ElasticsearchOutput
  • func (output *ElasticsearchOutput) Close()
  • func (output *ElasticsearchOutput) Configure(pipelineName string, data map[string]interface{}) error
  • func (output *ElasticsearchOutput) Execute(msgs []*core.Msg) error
  • func (output *ElasticsearchOutput) GetRouter() core.Router
  • func (output *ElasticsearchOutput) Start() error
• type ElasticsearchPluginConfig
• type ElasticsearchServerAuth
• type ElasticsearchServerConfig

Constants

const (
	Name = "elasticsearch"
)

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"`
}