publisher

Documentation

Index

• Variables
• func PrintPublishEvent(event common.MapStr)
• type PublisherType
  • func (publisher *PublisherType) GetServerName(ip string) string
  • func (publisher *PublisherType) Init(publishDisabled bool, outputs map[string]outputs.MothershipConfig, ...) error
  • func (publisher *PublisherType) PublishTopology(params ...string) error
  • func (publisher *PublisherType) UpdateTopologyPeriodically()
• type ShipperConfig
• type Topology

Variables

var EnabledOutputPlugins map[outputs.OutputPlugin]outputs.OutputInterface = map[outputs.OutputPlugin]outputs.OutputInterface{
	outputs.RedisOutput:         new(redis.RedisOutput),
	outputs.ElasticsearchOutput: new(elasticsearch.ElasticsearchOutput),
	outputs.FileOutput:          new(fileout.FileOutput),
}

Functions

func PrintPublishEvent

func PrintPublishEvent(event common.MapStr)

Types

type PublisherType

type PublisherType struct {
	Index          string
	Output         []outputs.OutputInterface
	TopologyOutput outputs.OutputInterface
	IgnoreOutgoing bool
	GeoLite        *libgeo.GeoIP

	RefreshTopologyTimer <-chan time.Time
	Queue                chan common.MapStr
	// contains filtered or unexported fields
}

var Publisher PublisherType

func (*PublisherType) GetServerName

func (publisher *PublisherType) GetServerName(ip string) string

func (*PublisherType) Init

func (publisher *PublisherType) Init(publishDisabled bool,
	outputs map[string]outputs.MothershipConfig, shipper ShipperConfig) error

func (*PublisherType) PublishTopology

func (publisher *PublisherType) PublishTopology(params ...string) error

func (*PublisherType) UpdateTopologyPeriodically

func (publisher *PublisherType) UpdateTopologyPeriodically()

type ShipperConfig

type ShipperConfig struct {
	Name                  string
	Refresh_topology_freq int
	Ignore_outgoing       bool
	Topology_expire       int
	Tags                  []string
	Geoip                 common.Geoip
}

type Topology

type Topology struct {
	Name string `json:"name"`
	Ip   string `json:"ip"`
}