elastic

Documentation

Index

• Variables
• func BulkIndex(ctx context.Context, transport esapi.Transport, index, documentID string, ...) (*esapi.Response, error)
• func Delete(ctx context.Context, transport esapi.Transport, index, documentID string) (*esapi.Response, error)
• func Index(ctx context.Context, transport esapi.Transport, index, documentID string, ...) (*esapi.Response, error)
• func Info(ctx context.Context, transport esapi.Transport) (*esapi.Response, error)
• func Int32Pointer(v int32) *int32
• func Int64Pointer(v int64) *int64
• func IntPointer(v int) *int
• func NewElasticSearchClient(cfg *common_utils.BaseConfig) (*elasticsearch.Client, error)
• func StringPointer(v string) *string
• func Update(ctx context.Context, transport esapi.Transport, index, documentID string, ...) (*esapi.Response, error)
• type Doc
• type EsHits
• type GetResponse
• type MultiMatch
• type MultiMatchQuery
• type MultiMatchSearchQuery
• type SearchListResponse
  • func SearchMatchPhrasePrefix[T any](ctx context.Context, transport esapi.Transport, ...) (*SearchListResponse[T], error)
  • func SearchMultiMatchPrefix[T any](ctx context.Context, transport esapi.Transport, ...) (*SearchListResponse[T], error)
• type SearchMatchPrefixRequest
• type SearchOptions

Variables

var (
	ErrMultiMatchSearchPrefix = errors.New("MultiMatchSearchPrefix response error")
)

Functions

func BulkIndex

func BulkIndex(ctx context.Context, transport esapi.Transport, index, documentID string, v []any) (*esapi.Response, error)

func Delete

func Delete(ctx context.Context, transport esapi.Transport, index, documentID string) (*esapi.Response, error)

func Index

func Index(ctx context.Context, transport esapi.Transport, index, documentID string, v any) (*esapi.Response, error)

func Info

func Info(ctx context.Context, transport esapi.Transport) (*esapi.Response, error)

func Int32Pointer

func Int32Pointer(v int32) *int32

func Int64Pointer

func Int64Pointer(v int64) *int64

func IntPointer

func IntPointer(v int) *int

func NewElasticSearchClient

func NewElasticSearchClient(cfg *common_utils.BaseConfig) (*elasticsearch.Client, error)

func StringPointer

func StringPointer(v string) *string

func Update

func Update(ctx context.Context, transport esapi.Transport, index, documentID string, document any) (*esapi.Response, error)

Types

type Doc

type Doc struct {
	Doc any `json:"doc"`
}

Doc is update request wrapper for any json serializable data

type EsHits

type EsHits[T any] struct {
	Hits struct {
		Total struct {
			Value int64 `json:"value"`
		} `json:"total"`
		Hits []struct {
			Source T `json:"_source"`
		} `json:"hits"`
	} `json:"hits"`
}

type GetResponse

type GetResponse[T any] struct {
	Index       string `json:"_index"`
	Id          string `json:"_id"`
	Version     int    `json:"_version"`
	SeqNo       int    `json:"_seq_no"`
	PrimaryTerm int    `json:"_primary_term"`
	Found       bool   `json:"found"`
	Source      T      `json:"_source"`
}

type MultiMatch

type MultiMatch struct {
	Fields []string `json:"fields"`
	Query  string   `json:"query"`
	Type   string   `json:"type"`
}

type MultiMatchQuery

type MultiMatchQuery struct {
	MultiMatch MultiMatch `json:"multi_match"`
}

type MultiMatchSearchQuery

type MultiMatchSearchQuery struct {
	Query MultiMatchQuery `json:"query"`
	Sort  []any           `json:"sort"`
}

type SearchListResponse

type SearchListResponse[T any] struct {
	List  []T   `json:"list"`
	Total int64 `json:"total"`
}

func SearchMatchPhrasePrefix

func SearchMatchPhrasePrefix[T any](ctx context.Context, transport esapi.Transport, request SearchMatchPrefixRequest) (*SearchListResponse[T], error)

func SearchMultiMatchPrefix

func SearchMultiMatchPrefix[T any](ctx context.Context, transport esapi.Transport, request SearchMatchPrefixRequest) (*SearchListResponse[T], error)

type SearchMatchPrefixRequest

type SearchMatchPrefixRequest struct {
	Index   []string
	Term    string
	Size    int
	From    int
	Sort    []string
	Fields  []string
	SortMap map[string]any
}

type SearchOptions

type SearchOptions struct {
	Size   int
	From   int
	Sort   []string
	Fields []string
}