outputs

Documentation

Index

• Variables
• type MothershipConfig
• type OutputInterface
• type OutputPlugin
  • func (o OutputPlugin) String() string

Variables

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

Output names

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(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