es

Documentation

Index

• func BulkDelete[D DocIdGetter](index string, docs []D) error
• func BulkIndex[D DocIdGetter](index string, docs []D) error
• func Client() *elasticsearch.TypedClient
• func GetDocById[T any](index string, id string) (*T, error)
• func InitEs(addresses []string, username string, password string, debug bool)
• func QueryTerm[T any](index string, from int, size int, termMap map[string]any) (records []T, total int, err error)
• func QueryTerms[T any](index string, filed string, values []any) ([]T, error)
• func QueryTermsId[T any](index string, values []any) ([]T, error)
• type DocIdGetter

Functions

func BulkDelete

func BulkDelete[D DocIdGetter](index string, docs []D) error

func BulkIndex

func BulkIndex[D DocIdGetter](index string, docs []D) error

func Client

func Client() *elasticsearch.TypedClient

func GetDocById

func GetDocById[T any](index string, id string) (*T, error)

func InitEs

func InitEs(addresses []string, username string, password string, debug bool)

func QueryTerm

func QueryTerm[T any](index string, from int, size int, termMap map[string]any) (records []T, total int, err error)

func QueryTerms

func QueryTerms[T any](index string, filed string, values []any) ([]T, error)

func QueryTermsId

func QueryTermsId[T any](index string, values []any) ([]T, error)

Types

type DocIdGetter

type DocIdGetter interface {
	GetDocId() string
}