esutils

Documentation

Index

• Constants
• func NewMapping(mp MappingPayload) string
• type Base
  • func (b *Base) GetIndex() string
  • func (b *Base) GetType() string
  • func (b *Base) SetType(s string)
• type Es
  • func NewEs(esIndex, esType string, opts ...EsOption) *Es
  • func (es *Es) BulkDelete(ctx context.Context, ids []string) error
  • func (es *Es) BulkSaveOrUpdate(ctx context.Context, docs []interface{}) error
  • func (es *Es) CheckTypeExists(ctx context.Context) (b bool, err error)
  • func (es *Es) ClearIndex(ctx context.Context) error
  • func (es *Es) Count(ctx context.Context, paging *Paging) (int64, error)
  • func (es *Es) DeleteIndex(ctx context.Context) error
  • func (es *Es) GetByID(ctx context.Context, id string) (map[string]interface{}, error)
  • func (es *Es) List(ctx context.Context, paging *Paging, ...) ([]interface{}, error)
  • func (es *Es) NewIndex(ctx context.Context, mapping string) (exists bool, err error)
  • func (es *Es) Page(ctx context.Context, paging *Paging) (PageResult, error)
  • func (es *Es) PutMapping(ctx context.Context, mp MappingPayload) error
  • func (es *Es) Random(ctx context.Context, paging *Paging) ([]map[string]interface{}, error)
  • func (es *Es) SaveOrUpdate(ctx context.Context, doc interface{}) (string, error)
  • func (e *Es) SetIndex(index string)
  • func (e *Es) SetType(estype string)
  • func (es *Es) Stat(ctx context.Context, paging *Paging, aggr interface{}) (map[string]interface{}, error)
• type EsOption
  • func WithClient(client *elastic.Client) EsOption
  • func WithLogger(logger *logrus.Logger) EsOption
  • func WithPassword(password string) EsOption
  • func WithUrls(urls []string) EsOption
  • func WithUsername(username string) EsOption
• type Field
• type IBase
• type MappingPayload
• type PageResult
• type Paging
• type QueryCond
• type Sort

Constants

const (
	// SHOULD represents should query
	SHOULD queryLogic = iota + 1
	// MUST represents must query
	MUST
	// MUSTNOT represents must_not query
	MUSTNOT
)

const (
	// TERMS represents terms query
	TERMS queryType = iota + 1
	// MATCHPHRASE represents match_phrase query
	MATCHPHRASE
	// RANGE represents range query
	RANGE
	// PREFIX represents prefix query
	PREFIX
	// WILDCARD https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-wildcard-query.html
	WILDCARD
	// EXISTS https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-prefix-query.html
	EXISTS
)

const (
	// TEXT represents text field type
	TEXT esFieldType = "text"
	// KEYWORD represents keyword field type
	KEYWORD esFieldType = "keyword"
	// DATE represents date field type
	DATE esFieldType = "date"
	// LONG represents long field type
	LONG esFieldType = "long"
	// INTEGER represents integer field type
	INTEGER esFieldType = "integer"
	// SHORT represents short field type
	SHORT esFieldType = "short"
	// DOUBLE represents double field type
	DOUBLE esFieldType = "double"
	// FLOAT represents float field type
	FLOAT esFieldType = "float"
	// BOOL represents bool field type
	BOOL esFieldType = "boolean"
)

Functions

func NewMapping

func NewMapping(mp MappingPayload) string

NewMapping return es mapping json string from mp

Types

type Base

type Base struct {
	Index string `json:"index"`
	Type  string `json:"type"`
}

Base defines es index and type

func (*Base) GetIndex

func (b *Base) GetIndex() string

GetIndex return index name

func (*Base) GetType

func (b *Base) GetType() string

GetType return es type name

func (*Base) SetType

func (b *Base) SetType(s string)

SetType sets es type

type Es

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

Es defines properties for connecting to an es instance

func NewEs

func NewEs(esIndex, esType string, opts ...EsOption) *Es

NewEs creates an Es instance

func (*Es) BulkDelete

func (es *Es) BulkDelete(ctx context.Context, ids []string) error

BulkDelete delete es docs specified by ids in bulk

func (*Es) BulkSaveOrUpdate

func (es *Es) BulkSaveOrUpdate(ctx context.Context, docs []interface{}) error

BulkSaveOrUpdate save or update docs in bulk

func (*Es) CheckTypeExists

func (es *Es) CheckTypeExists(ctx context.Context) (b bool, err error)

CheckTypeExists assert the es type exists

func (*Es) ClearIndex

func (es *Es) ClearIndex(ctx context.Context) error

ClearIndex remove all docs

func (*Es) Count

func (es *Es) Count(ctx context.Context, paging *Paging) (int64, error)

Count counts docs by paging

func (*Es) DeleteIndex

func (es *Es) DeleteIndex(ctx context.Context) error

DeleteIndex removes the index

func (*Es) GetByID

func (es *Es) GetByID(ctx context.Context, id string) (map[string]interface{}, error)

GetByID gets a doc by id

func (*Es) List

func (es *Es) List(ctx context.Context, paging *Paging, callback func(message json.RawMessage) (interface{}, error)) ([]interface{}, error)

List fetch docs by paging

func (*Es) NewIndex

func (es *Es) NewIndex(ctx context.Context, mapping string) (exists bool, err error)

NewIndex creates a new index

func (*Es) Page

func (es *Es) Page(ctx context.Context, paging *Paging) (PageResult, error)

Page fetch pagination result

func (*Es) PutMapping

func (es *Es) PutMapping(ctx context.Context, mp MappingPayload) error

PutMapping updates mapping

func (*Es) Random

func (es *Es) Random(ctx context.Context, paging *Paging) ([]map[string]interface{}, error)

Random if paging is nil, randomly return 10 pcs of documents as default

func (*Es) SaveOrUpdate

func (es *Es) SaveOrUpdate(ctx context.Context, doc interface{}) (string, error)

SaveOrUpdate saves or updates doc

func (*Es) SetIndex

func (e *Es) SetIndex(index string)

SetIndex sets index

func (*Es) SetType

func (e *Es) SetType(estype string)

SetType sets type

func (*Es) Stat

func (es *Es) Stat(ctx context.Context, paging *Paging, aggr interface{}) (map[string]interface{}, error)

Stat aggr only accept map[string]interface{} or elastic.Aggregation

type EsOption

type EsOption func(*Es)

EsOption represents functions for changing Es properties

func WithClient

func WithClient(client *elastic.Client) EsOption

WithClient sets client

func WithLogger

func WithLogger(logger *logrus.Logger) EsOption

WithLogger sets logger

func WithPassword

func WithPassword(password string) EsOption

WithPassword sets password

func WithUrls

func WithUrls(urls []string) EsOption

WithUrls set urls

func WithUsername

func WithUsername(username string) EsOption

WithUsername sets username

type Field

type Field struct {
	Name   string      `json:"name"`
	Type   esFieldType `json:"type"`
	Format string      `json:"format"`
}

Field defines a es field

type IBase

type IBase interface {
	GetIndex() string
	GetType() string
	SetType(s string)
}

IBase wraps functions for getting es index and type

type MappingPayload

type MappingPayload struct {
	Base
	Fields []Field `json:"fields"`
}

MappingPayload defines request payload for es index mapping

type PageResult

type PageResult struct {
	Page        int           `json:"page"` // from 1
	PageSize    int           `json:"page_size"`
	Total       int           `json:"total"`
	Docs        []interface{} `json:"docs"`
	HasNextPage bool          `json:"has_next_page"`
}

PageResult represents result of pagination

type Paging

type Paging struct {
	StartDate  string      `json:"startDate"`
	EndDate    string      `json:"endDate"`
	DateField  string      `json:"dateField"`
	QueryConds []QueryCond `json:"queryConds"`
	Skip       int         `json:"skip"`
	Limit      int         `json:"limit"`
	Sortby     []Sort      `json:"sortby"`
}

Paging defines pagination query conditions

type QueryCond

type QueryCond struct {
	Pair       map[string][]interface{} `json:"pair"`
	QueryLogic queryLogic               `json:"queryLogic"`
	QueryType  queryType                `json:"queryType"`
	Children   []QueryCond              `json:"children"`
}

QueryCond defines query conditions

type Sort

type Sort struct {
	Field     string `json:"field"`
	Ascending bool   `json:"ascending"`
}

Sort defines sort condition