esmodel

Documentation

Index

• Constants
• func Capitalize(str string) string
• type EsModelOutput
  • func (output *EsModelOutput) Close()
  • func (output *EsModelOutput) Configure(pipelineName string, data map[string]interface{}) error
  • func (output *EsModelOutput) Execute(msgs []*core.Msg) error
  • func (output *EsModelOutput) GetRouter() core.Router
  • func (output *EsModelOutput) Start() error
• type EsModelPluginConfig
• type EsModelServerConfig
• type EsScript
• type EsScriptInfo

Constants

const (
	Name = "esmodel"
)

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