Versions in this module Expand all Collapse all v1 v1.2.3 May 18, 2016 v1.2.2 Apr 26, 2016 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 Incompatible versions in this module v5.0.0-alpha2+incompatible May 2, 2016 v5.0.0-alpha1+incompatible Apr 5, 2016
Go to main page