Versions in this module Expand all Collapse all v1 v1.2.1 Apr 7, 2016 v1.2.0 Mar 30, 2016 Changes in this version type MothershipConfig + Template Template + type Template struct + Name string + Overwrite bool + Path string v1.1.2 Mar 8, 2016 v1.1.1 Feb 11, 2016 v1.1.0 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 v1.0.1 Dec 17, 2015 Incompatible versions in this module v5.0.0-alpha1+incompatible Apr 5, 2016
Go to main page