esmodel

Sep 20, 2019

Changes in this version

+ const Name

+ func Capitalize(str string) string

+ type EsModelOutput struct

+ 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 struct

+ IgnoreBadRequest bool

+ Routes []map[string]interface{}

+ ServerConfig *EsModelServerConfig

+ type EsModelServerConfig struct

+ Auth *elasticsearch.ElasticsearchServerAuth

+ RetryCount int

+ Sniff bool

+ Timeout int

+ URLs []string

+ type EsScript struct

+ Script EsScriptInfo

+ type EsScriptInfo struct

+ Lang string

+ Source string