outputs

Mar 30, 2016

Changes in this version

type MothershipConfig

+ Template Template

+ type Template struct

+ Name string

+ Overwrite bool

+ Path string

Feb 2, 2016

Changes in this version

+ var ErrCertificateNoKey = errors.New("key file not configured")

+ var ErrInvalidTLSVersion = errors.New("invalid TLS version string")

+ var ErrKeyNoCertificate = errors.New("certificate file not configured")

+ var ErrNotACertificate = errors.New("file is not a certificate")

+ var ErrUnknownCipherSuite = errors.New("unknown cypher suite")

+ var ErrUnknownCurveID = errors.New("unknown curve id")

+ func LoadTLSConfig(config *TLSConfig) (*tls.Config, error)

+ func RegisterOutputPlugin(name string, builder OutputBuilder)

+ func Signal(s Signaler, err error)

+ func SignalAll(signalers []Signaler, err error)

+ func SignalCompleted(s Signaler)

+ func SignalFailed(s Signaler, err error)

+ type BulkOutputer interface

+ BulkPublish func(trans Signaler, opts Options, event []common.MapStr) error

+ func CastBulkOutputer(out Outputer) BulkOutputer

+ type ChanSignal struct

+ func NewChanSignal(ch chan bool) *ChanSignal

+ func (c *ChanSignal) Completed()

+ func (c *ChanSignal) Failed()

+ type CompositeSignal struct

+ func (cs *CompositeSignal) Completed()

+ func (cs *CompositeSignal) Failed()

+ type MothershipConfig struct

+ BulkMaxSize *int

+ CompressionLevel *int

+ DataType string

+ Db int

+ Db_topology int

+ Filename string

+ FlushInterval *int

+ Host string

+ Hosts []string

+ Index string

+ LoadBalance *bool

+ MaxRetries *int

+ NumberOfFiles int

+ Password string

+ Path string

+ Port int

+ Pretty *bool

+ Protocol string

+ ProxyURL string

+ ReconnectInterval int

+ RotateEveryKb int

+ Save_topology bool

+ TLS *TLSConfig

+ Timeout int

+ Username string

+ Worker int

+ type Options struct

+ Guaranteed bool

+ type OutputBuilder interface

+ NewOutput func(config *MothershipConfig, topologyExpire int) (Outputer, error)

+ func FindOutputPlugin(name string) OutputBuilder

+ type OutputInterface interface

+ type OutputPlugin struct

+ Config MothershipConfig

+ Name string

+ Output Outputer

+ func InitOutputs(beatName string, configs map[string]MothershipConfig, topologyExpire int) ([]OutputPlugin, error)

+ type Outputer interface

+ PublishEvent func(trans Signaler, opts Options, event common.MapStr) error

+ type Signaler interface

+ Completed func()

+ Failed func()

+ func NewCompositeSignaler(signalers ...Signaler) Signaler

+ func NewSplitSignaler(s Signaler, count int) Signaler

+ type SplitSignal struct

+ func (s *SplitSignal) Completed()

+ func (s *SplitSignal) Failed()

+ type SyncSignal struct

+ func NewSyncSignal() *SyncSignal

+ func (s *SyncSignal) Completed()

+ func (s *SyncSignal) Failed()

+ func (s *SyncSignal) Wait() bool

+ type TLSConfig struct

+ CAs []string

+ Certificate string

+ CertificateKey string

+ CipherSuites []string

+ CurveTypes []string

+ Insecure bool

+ MaxVersion string

+ MinVersion string

+ type TopologyOutputer interface

+ GetNameByIP func(ip string) string

+ PublishIPs func(name string, localAddrs []string) error