outputs

package
v1.0.0-beta3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2015 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var OutputNames = []string{
	"unknown",
	"redis",
	"elasticsearch",
	"file",
}

Output names

Functions

This section is empty.

Types

type MothershipConfig

type MothershipConfig struct {
	Enabled            bool
	Save_topology      bool
	Host               string
	Port               int
	Hosts              []string
	Protocol           string
	Username           string
	Password           string
	Index              string
	Path               string
	Db                 int
	Db_topology        int
	Timeout            int
	Reconnect_interval int
	Filename           string
	Rotate_every_kb    int
	Number_of_files    int
	DataType           string
	Flush_interval     *int
	Bulk_size          *int
	Max_retries        *int
}

type OutputInterface

type OutputInterface interface {
	// Initialize the output plugin
	Init(beat string, config MothershipConfig, topology_expire int) error

	// Register the agent name and its IPs to the topology map
	PublishIPs(name string, localAddrs []string) error

	// Get the agent name with a specific IP from the topology map
	GetNameByIP(ip string) string

	// Publish event
	PublishEvent(ts time.Time, event common.MapStr) error
}

Functions to be exported by a output plugin

type OutputPlugin

type OutputPlugin uint16

Output identifier

const (
	UnknownOutput OutputPlugin = iota
	RedisOutput
	ElasticsearchOutput
	FileOutput
)

Output constants

func (OutputPlugin) String

func (o OutputPlugin) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL