Documentation ¶
Index ¶
- type Client
- func (c *Client) CountDocuments(index string, query string) uint64
- func (c *Client) Read(process engine.ProcessQuery, writer engine.Target, ...) engine.ProcessShardResult
- func (c *Client) ResolveIndex(indexExpression string) []engine.SourceCollection
- func (c *Client) Write(process engine.ProcessQuery, data []engine.Datum) engine.WriteResult
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 (*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
Click to show internal directories.
Click to hide internal directories.