mirror of
https://github.com/Icinga/icingabeat.git
synced 2025-08-16 23:38:09 +02:00
16 lines
358 B
Go
16 lines
358 B
Go
package channel
|
|
|
|
import (
|
|
"github.com/elastic/beats/filebeat/util"
|
|
"github.com/elastic/beats/libbeat/common"
|
|
)
|
|
|
|
// Factory is used to create a new Outlet instance
|
|
type Factory func(*common.Config, *common.MapStrPointer) (Outleter, error)
|
|
|
|
// Outleter is the outlet for a prospector
|
|
type Outleter interface {
|
|
Close() error
|
|
OnEvent(data *util.Data) bool
|
|
}
|