bulk

Documentation

Index

• type Indexer
  • func NewIndexer7(address string, index string, logger *zerolog.Logger) (Indexer, error)
  • func NewIndexer8(address string, index string, apikey string, logger *zerolog.Logger) (Indexer, error)
• type Indexer7
  • func (idx *Indexer7) CloseBulk() error
  • func (idx *Indexer7) CreateIndex(schema []byte) error
  • func (idx *Indexer7) Delete(id string) error
  • func (idx *Indexer7) Index(id string, doc any) error
  • func (idx *Indexer7) Info() (clientVersion string, serverVersion string, err error)
  • func (idx *Indexer7) StartBulk(workers int, flushbytes int, flushtime time.Duration) error
• type Indexer8
  • func (idx *Indexer8) CloseBulk() error
  • func (idx *Indexer8) CreateIndex(schema []byte) error
  • func (idx *Indexer8) Delete(id string) error
  • func (idx *Indexer8) Index(id string, doc any) error
  • func (idx *Indexer8) Info() (clientVersion string, serverVersion string, err error)
  • func (idx *Indexer8) StartBulk(workers int, flushbytes int, flushtime time.Duration) error

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 *zerolog.Logger) (Indexer, error)

func NewIndexer8

func NewIndexer8(address string, index string, apikey string, logger *zerolog.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