v5

Documentation

Index

• type Client
  • func NewClient(cfg *config.Config) (*Client, error)
  • func (c *Client) Iterate(ctx context.Context, req *elastic.IterateRequest) (<-chan *diff.Document, <-chan error)
  • func (c *Client) SetBatchSize(size int)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client implements an Elasticsearch 5.x client.

func NewClient

func NewClient(cfg *config.Config) (*Client, error)

NewClient creates a new Client.

func (*Client) Iterate

func (c *Client) Iterate(ctx context.Context, req *elastic.IterateRequest) (<-chan *diff.Document, <-chan error)

Iterate iterates over the index.

func (*Client) SetBatchSize

func (c *Client) SetBatchSize(size int)

SetBatchSize specifies the size of a single scroll operation.