elastic

README

elastic search

Usage

source:
  name: elasticsearch
  config:
    host: elastic_server

Inputs

Key	Value	Example	Description
host	string	http://localhost:9200	Host of the Elastic server	required
user	string	admin	User ID to access the server	optional
password	string	1234	Password for the Server	optional

Outputs

Field	Sample Value
resource.urn	elasticsearch.index1
resource.name	index1
profile.total_rows	1
schema	[]Column

Column

Field	Sample Value
name	SomeStr
data_type	text

Contributing

Refer to the contribution guidelines for information on contributing to this module.

Documentation

Index

• type Config
• type Extractor
  • func New(logger log.Logger) *Extractor
  • func (e *Extractor) Extract(ctx context.Context, emit plugins.Emit) (err error)
  • func (e *Extractor) Init(ctx context.Context, config plugins.Config) (err error)

Types

type Config

type Config struct {
	User     string `json:"user" yaml:"user" mapstructure:"user"`
	Password string `json:"password" yaml:"password" mapstructure:"password"`
	Host     string `json:"host" yaml:"host" mapstructure:"host" validate:"required"`
}

type Extractor

type Extractor struct {
	plugins.BaseExtractor
	// contains filtered or unexported fields
}

Extractor manages the extraction of data from elastic

func New

func New(logger log.Logger) *Extractor

New returns a pointer to an initialized Extractor Object

func (*Extractor) Extract

func (e *Extractor) Extract(ctx context.Context, emit plugins.Emit) (err error)

Extract extracts the data from the elastic server and collected through the emitter

func (*Extractor) Init

func (e *Extractor) Init(ctx context.Context, config plugins.Config) (err error)

Init initializes the extractor