elasticsearch

Documentation

Index

• func NewScrollIterator(ctx context.Context, client *elastic.Client, timeout time.Duration, ...) (storekit.Iterator, error)
• func NewSearchIterator(ctx context.Context, client *elastic.Client, timeout time.Duration, ...) (storekit.Iterator, error)
• type SortItem

Functions

func NewScrollIterator

func NewScrollIterator(
	ctx context.Context,
	client *elastic.Client,
	timeout time.Duration,
	pageSize int,
	indices []string,
	sorts []*SortItem,
	search func() (*elastic.SearchSource, error),
	decode func(data *elastic.SearchHit) (interface{}, error),
) (storekit.Iterator, error)

NewScrollIterator .

func NewSearchIterator

func NewSearchIterator(
	ctx context.Context,
	client *elastic.Client,
	timeout time.Duration,
	fromOffset int,
	pageSize int,
	indices []string,
	sorts []*SortItem,
	searchAfter []interface{},
	search func() (*elastic.SearchSource, error),
	decode func(data *elastic.SearchHit) (interface{}, error),
) (storekit.Iterator, error)

NewSearchIterator .

Types

type SortItem

type SortItem struct {
	Key       string
	Ascending bool
}

SortItem .