helper

type MetricSet struct {
	Name        string
	MetricSeter MetricSeter
	// Inherits config from module
	Config ModuleConfig
	Module *Module
	// contains filtered or unexported fields
}

type MetricSeter interface {
	// Setup of MetricSeter
	// MetricSet which contains the MetricSeter is passed. This gives access to config
	// and the module.
	Setup(ms *MetricSet) error

	// Method to periodically fetch a new event from a host
	// Fetch is called for each host. In case where host does not exist, it can be transferred
	// differently in the setup to have a different meaning. An example here is for filesystem
	// of topbeat, where each host could be a filesystem.
	// Fetch is called on the predefined interval and does not take delays into account.
	Fetch(ms *MetricSet, host string) (common.MapStr, error)
}

type Module struct {

	// Module config
	Config ModuleConfig

	Timeout time.Duration

	Publish chan common.MapStr
	// contains filtered or unexported fields
}

type ModuleConfig struct {
	Hosts      []string `config:"hosts"`
	Period     string   `config:"period"`
	Timeout    string   `config:"timeout"`
	Module     string   `config:"module"`
	MetricSets []string `config:"metricsets"`
	Enabled    bool     `config:"enabled"`
	Selectors  []string `config:"selectors"`

	common.EventMetadata `config:",inline"` // Fields and tags to add to events.
}

type Moduler interface {
	// Raw *common.Config config is passed. This allows each module to extract its own local config variables
	Setup(m *Module) error
}

type Register struct {
	Modulers     map[string]func() Moduler
	MetricSeters map[string]map[string]func() MetricSeter
}