elastic

package

v0.13.0 Latest Latest Go to latest Published: Apr 19, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/raystack/meteor

Links

Open Source Insights

README ¶

Elasticsearch

Extract index metadata from an Elasticsearch cluster.

Usage

source:
  name: elastic
  config:
    host: http://localhost:9200
    user: elastic
    password: changeme

Configuration

Key	Type	Required	Description
`host`	`string`	Yes	Host address of the Elasticsearch server (include scheme).
`user`	`string`	No	Username for authentication.
`password`	`string`	No	Password for authentication.

Entities

Entity type: table
URN format: urn:elasticsearch:{scope}:index:{index_name}

Property	Type	Description
`properties.columns`	`[]object`	List of column objects from the index mapping.
`properties.columns[].name`	`string`	Field name.
`properties.columns[].data_type`	`string`	Elasticsearch field type (e.g. `text`, `keyword`).
`properties.profile.total_rows`	`int`	Number of documents in the index (omitted if zero).
`properties.number_of_shards`	`string`	Number of primary shards for the index.
`properties.number_of_replicas`	`string`	Number of replica shards for the index.

Edges

This extractor does not emit edges.

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

elastic.go

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