client

Documentation

Index

• type Bulker
  • func NewBulker(cli *elastic.Client) (*Bulker, error)
  • func (b *Bulker) Rm(index string, ids ...string)
  • func (b *Bulker) Save(docs ...backup.Document)
• type Client
  • func New(cluster app.Cluster, usr app.User) (*Client, error)
  • func (cli *Client) Bulk() (*Bulker, error)

Types

type Bulker

type Bulker struct {
	*elastic.BulkProcessor
}

func NewBulker

func NewBulker(cli *elastic.Client) (*Bulker, error)

func (*Bulker) Rm

func (b *Bulker) Rm(index string, ids ...string)

Add adds requests to remove given ids.

func (*Bulker) Save

func (b *Bulker) Save(docs ...backup.Document)

type Client

type Client struct {
	*elastic.Client
}

func New

func New(cluster app.Cluster, usr app.User) (*Client, error)

func (*Client) Bulk

func (cli *Client) Bulk() (*Bulker, error)