Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
Factory for modules
func NewFactory ¶
func NewFactory(outlet channel.OutleterFactory, registrar *registrar.Registrar, beatVersion string, pipelineLoaderFactory PipelineLoaderFactory, beatDone chan struct{}) *Factory
NewFactory instantiates a new Factory
type Fileset ¶
type Fileset struct {
// contains filtered or unexported fields
}
Fileset struct is the representation of a fileset.
func New ¶
func New( modulesPath string, name string, mcfg *ModuleConfig, fcfg *FilesetConfig) (*Fileset, error)
New allocates a new Fileset object with the given configuration.
func (*Fileset) GetMLConfigs ¶
func (fs *Fileset) GetMLConfigs() []mlimporter.MLConfig
GetMLConfigs returns the list of machine-learning configurations declared by this fileset.
func (*Fileset) GetPipeline ¶
func (*Fileset) GetRequiredProcessors ¶
func (fs *Fileset) GetRequiredProcessors() []ProcessorRequirement
GetRequiredProcessors returns the list of processors on which this fileset depends.
type FilesetConfig ¶
type FilesetConfig struct {
Enabled *bool `config:"enabled"`
Var map[string]interface{} `config:"var"`
Prospector map[string]interface{} `config:"prospector"`
}
FilesetConfig contains the configuration file options for a fileset
type ModuleConfig ¶
type ModuleConfig struct {
Module string `config:"module" validate:"required"`
Enabled *bool `config:"enabled"`
// Filesets is inlined by code, see mcfgFromConfig
Filesets map[string]*FilesetConfig
}
ModuleConfig contains the configuration file options for a module
type ModuleOverrides ¶
func (*ModuleOverrides) Get ¶
func (mo *ModuleOverrides) Get(module, fileset string) []*common.Config
Get returns an array of configuration overrides that should be merged in order.
type ModuleRegistry ¶
type ModuleRegistry struct {
// contains filtered or unexported fields
}
func NewModuleRegistry ¶
func NewModuleRegistry(moduleConfigs []*common.Config, beatVersion string) (*ModuleRegistry, error)
NewModuleRegistry reads and loads the configured module into the registry.
func (*ModuleRegistry) Empty ¶
func (reg *ModuleRegistry) Empty() bool
func (*ModuleRegistry) GetProspectorConfigs ¶
func (reg *ModuleRegistry) GetProspectorConfigs() ([]*common.Config, error)
func (*ModuleRegistry) InfoString ¶
func (reg *ModuleRegistry) InfoString() string
InfoString returns the enabled modules and filesets in a single string, ready to be shown to the user
func (*ModuleRegistry) LoadML ¶
func (reg *ModuleRegistry) LoadML(esClient PipelineLoader) error
LoadML loads the machine-learning configurations into Elasticsearch, if Xpack is avaiable
func (*ModuleRegistry) LoadPipelines ¶
func (reg *ModuleRegistry) LoadPipelines(esClient PipelineLoader) error
LoadPipelines loads the pipelines for each configured fileset.
type PipelineLoader ¶
type PipelineLoader interface {
LoadJSON(path string, json map[string]interface{}) ([]byte, error)
Request(method, path string, pipeline string, params map[string]string, body interface{}) (int, []byte, error)
GetVersion() string
}
PipelineLoader is a subset of the Elasticsearch client API capable of loading the pipelines.
type PipelineLoaderFactory ¶
type PipelineLoaderFactory func() (PipelineLoader, error)
PipelineLoader factory builds and returns a PipelineLoader
Source Files
¶
- config.go
- factory.go
- fileset.go
- flags.go
- modules.go