Versions in this module Expand all Collapse all v1 v1.0.0 Nov 24, 2015 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, ts time.Time, 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 + DataType string + Db int + Db_topology int + Filename string + Flush_interval *int + Host string + Hosts []string + Index string + LoadBalance *bool + Max_retries *int + Number_of_files int + Password string + Path string + Port int + Pretty *bool + Protocol string + Reconnect_interval int + Rotate_every_kb int + Save_topology bool + TLS *TLSConfig + Timeout int + Username string + Worker int + type OutputBuilder interface + NewOutput func(beat string, 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(beat string, configs map[string]MothershipConfig, topologyExpire int) ([]OutputPlugin, error) + type Outputer interface + PublishEvent func(trans Signaler, ts time.Time, 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.0-rc2 Nov 17, 2015 v1.0.0-rc1 Nov 5, 2015 v1.0.0-beta4 Oct 22, 2015 v1.0.0-beta3 Sep 4, 2015 v1.0.0-beta2 Jul 13, 2015
Go to main page