elasticsearch

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 21, 2022 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {
	Client *elasticsearch7.Client

	URL, Version string

	Indices []gjson.Result
}

func NewClient

func NewClient(URL string) *Client

*

  • Build a new elasticsearch client.

func (*Client) CountDocuments

func (c *Client) CountDocuments(index string, query string) uint64

func (*Client) Read

func (c *Client) Read(process engine.ProcessQuery, writer engine.Target, progressReporter *pb.ProgressBar) engine.ProcessShardResult

func (*Client) ResolveIndex

func (c *Client) ResolveIndex(indexExpression string) []engine.SourceCollection

func (*Client) Write

func (c *Client) Write(process engine.ProcessQuery, data []engine.Datum) engine.WriteResult

Jump to

Keyboard shortcuts

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