esmodel

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: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name = "esmodel"
)

Variables

This section is empty.

Functions

func Capitalize

func Capitalize(str string) string

Types

type EsModelOutput

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

func (*EsModelOutput) Close

func (output *EsModelOutput) Close()

func (*EsModelOutput) Configure

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

func (*EsModelOutput) Execute

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

func (*EsModelOutput) GetRouter

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

func (*EsModelOutput) Start

func (output *EsModelOutput) Start() error

type EsModelPluginConfig

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

type EsModelServerConfig

type EsModelServerConfig struct {
	URLs       []string                               `mapstructure:"urls" toml:"urls" json:"urls"`
	Sniff      bool                                   `mapstructure:"sniff" toml:"sniff" json:"sniff"`
	Auth       *elasticsearch.ElasticsearchServerAuth `mapstructure:"auth" toml:"auth" json:"auth"`
	Timeout    int                                    `mapstructure:"timeout" toml:"timeout" json:"timeout"`
	RetryCount int                                    `mapstructure:"retry-count" toml:"retry-count" json:"retry-count"`
}

type EsScript

type EsScript struct {
	Script EsScriptInfo `json:"script"`
}

type EsScriptInfo

type EsScriptInfo struct {
	Lang   string `json:"lang"`
	Source string `json:"source"`
}

Jump to

Keyboard shortcuts

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