Documentation
¶
Index ¶
Constants ¶
View Source
const (
Name = "esmodel"
)
Variables ¶
This section is empty.
Functions ¶
func Capitalize ¶
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) 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 ¶
Click to show internal directories.
Click to hide internal directories.