Versions in this module Expand all Collapse all v1 v1.3.1 Sep 14, 2016 Changes in this version + func PrintPublishEvent(event common.MapStr) + type ChanClient struct + Channel chan common.MapStr + func (c ChanClient) PublishEvent(event common.MapStr, opts ...ClientOption) bool + func (c ChanClient) PublishEvents(events []common.MapStr, opts ...ClientOption) bool + type Client interface + PublishEvent func(event common.MapStr, opts ...ClientOption) bool + PublishEvents func(events []common.MapStr, opts ...ClientOption) bool + type ClientOption func(option Context) Context + func Signal(signaler outputs.Signaler) ClientOption + type Context struct + Signal outputs.Signaler + func Guaranteed(o Context) Context + func Sync(o Context) Context + type ExtChanClient struct + Channel chan PublishMessage + func (c ExtChanClient) PublishEvent(event common.MapStr, opts ...ClientOption) bool + func (c ExtChanClient) PublishEvents(events []common.MapStr, opts ...ClientOption) bool + type PublishMessage struct + Context Context + Events []common.MapStr + type PublisherType struct + GeoLite *libgeo.GeoIP + IgnoreOutgoing bool + Index string + IpAddrs []string + Output []*outputWorker + RefreshTopologyTimer <-chan time.Time + TopologyOutput outputs.TopologyOutputer + func New(beatName string, configs map[string]outputs.MothershipConfig, ...) (*PublisherType, error) + func (publisher *PublisherType) Client() Client + func (publisher *PublisherType) GetServerName(ip string) string + func (publisher *PublisherType) IsPublisherIP(ip string) bool + func (publisher *PublisherType) PublishTopology(params ...string) error + func (publisher *PublisherType) UpdateTopologyPeriodically() + type ShipperConfig struct + BulkQueueSize *int + Geoip common.Geoip + Ignore_outgoing bool + Name string + QueueSize *int + Refresh_topology_freq int + Tags []string + Topology_expire int + type Topology struct + Ip string + Name string + type TransactionalEventPublisher interface + PublishTransaction func(transaction outputs.Signaler, events []common.MapStr) Other modules containing this package github.com/snappyflow/beats/v7
Go to main page