bulk

package
v2.0.1 Latest Latest
Warning

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

Go to latest
Published: Aug 26, 2023 License: Apache-2.0 Imports: 20 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Indexer

type Indexer interface {
	Info() (clientVersion string, serverVersion string, err error)
	CreateIndex(schema []byte) error
	StartBulk(workers int, flushbytes int, flushtime time.Duration) error
	CloseBulk() error
	Delete(id string) error
	Index(id string, content any) error
}

func NewIndexer7

func NewIndexer7(address string, index string, logger *logging.Logger) (Indexer, error)

func NewIndexer8

func NewIndexer8(address string, index string, apikey string, logger *logging.Logger) (Indexer, error)

type Indexer7

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

func (*Indexer7) CloseBulk

func (idx *Indexer7) CloseBulk() error

func (*Indexer7) CreateIndex

func (idx *Indexer7) CreateIndex(schema []byte) error

func (*Indexer7) Delete

func (idx *Indexer7) Delete(id string) error

func (*Indexer7) Index

func (idx *Indexer7) Index(id string, doc any) error

func (*Indexer7) Info

func (idx *Indexer7) Info() (clientVersion string, serverVersion string, err error)

func (*Indexer7) StartBulk

func (idx *Indexer7) StartBulk(workers int, flushbytes int, flushtime time.Duration) error

type Indexer8

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

func (*Indexer8) CloseBulk

func (idx *Indexer8) CloseBulk() error

func (*Indexer8) CreateIndex

func (idx *Indexer8) CreateIndex(schema []byte) error

func (*Indexer8) Delete

func (idx *Indexer8) Delete(id string) error

func (*Indexer8) Index

func (idx *Indexer8) Index(id string, doc any) error

func (*Indexer8) Info

func (idx *Indexer8) Info() (clientVersion string, serverVersion string, err error)

func (*Indexer8) StartBulk

func (idx *Indexer8) StartBulk(workers int, flushbytes int, flushtime time.Duration) error

Jump to

Keyboard shortcuts

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