Versions in this module Expand all Collapse all v1 v1.3.1 Sep 14, 2016 Changes in this version + var ErrNoConnectionConfigured = errors.New("No connection configured") + var ErrNoHostsConfigured = errors.New("no host configuration found") + var ErrTempBulkFailure = errors.New("temporary bulk send failure") + type ConnectionMode interface + Close func() error + PublishEvent func(trans outputs.Signaler, opts outputs.Options, event common.MapStr) error + PublishEvents func(trans outputs.Signaler, opts outputs.Options, events []common.MapStr) error + type FailOverConnectionMode struct + func NewFailOverConnectionMode(clients []ProtocolClient, maxAttempts int, waitRetry, timeout time.Duration) (*FailOverConnectionMode, error) + func (f *FailOverConnectionMode) Close() error + func (f *FailOverConnectionMode) PublishEvent(signaler outputs.Signaler, opts outputs.Options, event common.MapStr) error + func (f *FailOverConnectionMode) PublishEvents(signaler outputs.Signaler, opts outputs.Options, events []common.MapStr) error + type LoadBalancerMode struct + func NewLoadBalancerMode(clients []ProtocolClient, maxAttempts int, ...) (*LoadBalancerMode, error) + func (m *LoadBalancerMode) Close() error + func (m *LoadBalancerMode) PublishEvent(signaler outputs.Signaler, opts outputs.Options, event common.MapStr) error + func (m *LoadBalancerMode) PublishEvents(signaler outputs.Signaler, opts outputs.Options, events []common.MapStr) error + type ProtocolClient interface + Close func() error + Connect func(timeout time.Duration) error + IsConnected func() bool + PublishEvent func(event common.MapStr) error + PublishEvents func(events []common.MapStr) (nextEvents []common.MapStr, err error) + func MakeClients(config outputs.MothershipConfig, ...) ([]ProtocolClient, error) + type SingleConnectionMode struct + func NewSingleConnectionMode(client ProtocolClient, maxAttempts int, ...) (*SingleConnectionMode, error) + func (s *SingleConnectionMode) Close() error + func (s *SingleConnectionMode) PublishEvent(signaler outputs.Signaler, opts outputs.Options, event common.MapStr) error + func (s *SingleConnectionMode) PublishEvents(signaler outputs.Signaler, opts outputs.Options, events []common.MapStr) error
Go to main page