elasticsearch7

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Aug 25, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Package elasticsearch7 provides the client using go-elasticsearch driver.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewManager

func NewManager(client *es7.Client, opts ...elasticsteps.ManagerOption) *elasticsteps.Manager

NewManager initiates a new data manager.

func WithInstance

func WithInstance(name string, client *es7.Client) elasticsteps.ManagerOption

WithInstance adds a new es instance.

Types

type Client

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

Client is a wrapper around elasticsearch7.Client.

func (*Client) CreateIndex

func (c *Client) CreateIndex(ctx context.Context, index string, config *string) error

CreateIndex satisfies elasticsteps.Client.

func (*Client) DeleteAllDocuments added in v0.3.0

func (c *Client) DeleteAllDocuments(ctx context.Context, index string) error

DeleteAllDocuments satisfies elasticsteps.Client.

func (*Client) DeleteIndex

func (c *Client) DeleteIndex(ctx context.Context, indices ...string) error

DeleteIndex satisfies elasticsteps.Client.

func (*Client) FindDocuments

func (c *Client) FindDocuments(ctx context.Context, index string, query *string) ([]json.RawMessage, error)

FindDocuments satisfies elasticsteps.Client.

func (*Client) GetIndex

func (c *Client) GetIndex(ctx context.Context, index string) (json.RawMessage, error)

GetIndex satisfies elasticsteps.Client.

func (*Client) IndexDocuments

func (c *Client) IndexDocuments(ctx context.Context, index string, docs ...elasticsteps.Document) error

IndexDocuments satisfies elasticsteps.Client.

func (*Client) RecreateIndex

func (c *Client) RecreateIndex(ctx context.Context, index string, config *string) error

RecreateIndex satisfies elasticsteps.Client.

Jump to

Keyboard shortcuts

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