v7

Documentation

Index

• type Client
  • func NewClient(cfg interface{}) (*Client, error)
  • func (c *Client) Bulk(ctx context.Context, reader io.Reader) (io.ReadCloser, error)
  • func (c *Client) GetClient() *elasticsearch.Client
  • func (c *Client) Ping(ctx context.Context) error
  • func (c *Client) PrepareCreateOperation(item sdk.Record) (interface{}, interface{}, error)
  • func (c *Client) PrepareDeleteOperation(key string) (interface{}, error)
  • func (c *Client) PrepareUpsertOperation(key string, item sdk.Record) (interface{}, interface{}, error)
• type ErrorResponse

Types

type Client

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

func NewClient

func NewClient(cfg interface{}) (*Client, error)

func (*Client) Bulk

func (c *Client) Bulk(ctx context.Context, reader io.Reader) (io.ReadCloser, error)

func (*Client) GetClient

func (c *Client) GetClient() *elasticsearch.Client

GetClient returns Elasticsearch v7 client.

func (*Client) Ping

func (c *Client) Ping(ctx context.Context) error

func (*Client) PrepareCreateOperation

func (c *Client) PrepareCreateOperation(item sdk.Record) (interface{}, interface{}, error)

func (*Client) PrepareDeleteOperation

func (c *Client) PrepareDeleteOperation(key string) (interface{}, error)

func (*Client) PrepareUpsertOperation

func (c *Client) PrepareUpsertOperation(key string, item sdk.Record) (interface{}, interface{}, error)

type ErrorResponse

type ErrorResponse struct {
	Error struct {
		Type   string `json:"type"`
		Reason string `json:"reason"`
	} `json:"error"`
}