Documentation
¶
Index ¶
Constants ¶
View Source
const ( AsyncKafka = async_kafka.Name Mysql = mysql.Name Stdout = stdout.Name Elasticsearch = elasticsearch.Name EsModel = esmodel.Name )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DumpOutput ¶
type DumpOutput struct {
// contains filtered or unexported fields
}
func (*DumpOutput) Close ¶
func (plugin *DumpOutput) Close()
func (*DumpOutput) Configure ¶
func (plugin *DumpOutput) Configure(pipelineName string, data map[string]interface{}) error
func (*DumpOutput) GetRouter ¶ added in v0.9.17
func (plugin *DumpOutput) GetRouter() core.Router
func (*DumpOutput) Start ¶
func (plugin *DumpOutput) Start() error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.