Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

elasticsearch

package

Go to main page

Versions in this module

v2

v2.0.17

Sep 22, 2024

v2.0.16

Aug 3, 2024

v2.0.15

Mar 10, 2024

v2.0.14

Mar 7, 2024

v2.0.12

Mar 7, 2024

v2.0.11

Feb 26, 2024

v2.0.10

Feb 26, 2024

v2.0.9

Jan 25, 2024

Changes in this version

+ const SortAsc

+ const SortDesc

+ var DefaultPageSize int64 = 15

+ var ErrArgsEmpty = errors.New("args is empty")

+ var ErrIndexNotExists = errors.New("no such index")

+ var ErrPropertiesEmpty = errors.New("properties is empty")

+ var ErrSetterEmpty = errors.New("setter is empty")

+ type Arg struct

+ func WithArg(key string, value any) Arg

+ type Body kind.JsonParam

+ func (b Body) Marshal() (body []byte, err error)

+ func (b Body) WithArgs(args ...Arg)

+ func (b Body) WithCursor(cursor string)

+ func (b Body) WithFetchSize(size int64)

+ func (b Body) WithProperties(properties result.MappingProperties)

+ func (b Body) WithQuery(query any)

+ func (b Body) WithSql(sqlStr string, args ...any)

+ type BulkCreate struct

+ func (bc *BulkCreate) Marshal() []byte

+ type BulkDelete struct

+ func (bc *BulkDelete) Marshal() []byte

+ type BulkIndex struct

+ func (bi *BulkIndex) Marshal() []byte

+ type BulkItem struct

+ func NewBulkItem(items ...BulkMarshal) *BulkItem

+ func (bi *BulkItem) Marshal() []byte

+ func (bi *BulkItem) WithCreate(index, id string, property Property) *BulkItem

+ func (bi *BulkItem) WithDelete(index, id string) *BulkItem

+ func (bi *BulkItem) WithIndex(index, id string, property Property) *BulkItem

+ func (bi *BulkItem) WithUpdate(index, id string, property Updater) *BulkItem

+ type BulkMarshal interface

+ Marshal func() []byte

+ type BulkUpdate struct

+ func (bu *BulkUpdate) Marshal() []byte

+ type Options struct

+ BaseUrl string

+ ConnMaxIdleTimeSec int

+ ConnMaxLifetimeSec int

+ DialTimeoutSec int

+ KeepaliveSec int

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ ReadBufferSize int

+ TimeoutSec int

+ UserName string

+ WriteBufferSize int

+ func DefaultOption() Options

+ func OptionsWithJson(conf string) (opt Options, err error)

+ func OptionsWithYaml(conf string) (opt Options, err error)

+ func (o *Options) ConnMaxIdleTime() time.Duration

+ func (o *Options) ConnMaxLifetime() time.Duration

+ func (o *Options) DialTimeout() time.Duration

+ func (o *Options) KeepaliveTime() time.Duration

+ func (o *Options) Timeout() time.Duration

+ type OrderItem struct

+ Format string

+ Mode string

+ Order string

+ type Pool struct

+ func NewPool(opt Options) (pool *Pool)

+ func (p *Pool) Bulk(ctx context.Context, bi *BulkItem) (res *result.Bulk, err error)

+ func (p *Pool) CloseSqlCursor(ctx context.Context, cursor string) (response *http_client.Response, err error)

+ func (p *Pool) DocDel(ctx context.Context, indexName, id string) (res *result.DocIndex, err error)

+ func (p *Pool) DocFieldIncr(ctx context.Context, indexName, id, field string, increment int64) (res *result.DocIndex, err error)

+ func (p *Pool) DocIndex(ctx context.Context, indexName string, body Body) (res *result.DocIndex, err error)

+ func (p *Pool) DocIndexWithId(ctx context.Context, indexName, id string, body Body) (res *result.DocIndex, err error)

+ func (p *Pool) DocMGet(ctx context.Context, indexName string, idList ...string) (res *result.Documents, err error)

+ func (p *Pool) DocUpdate(ctx context.Context, indexName, id string, setter Setter) (res *result.DocIndex, err error)

+ func (p *Pool) DocUpdateWithOptimistic(ctx context.Context, indexName, id string, setter Setter, ...) (res *result.DocIndex, err error)

+ func (p *Pool) Index(ctx context.Context, name string, args ...Arg) (res *result.Index, err error)

+ func (p *Pool) IndexDel(ctx context.Context, name string) (res *result.Index, err error)

+ func (p *Pool) IndexMapping(ctx context.Context, name string, properties result.MappingProperties) (res *result.Index, err error)

+ func (p *Pool) IndexMappingGet(ctx context.Context, target string) (res *result.IndexMapping, err error)

+ func (p *Pool) IndexSetting(ctx context.Context, name string, args ...Arg) (res *result.Index, err error)

+ func (p *Pool) IndexSettingGet(ctx context.Context, target string) (response *http_client.Response, err error)

+ func (p *Pool) Options() Options

+ func (p *Pool) Query(ctx context.Context, query *Query, format string, args ...Arg) (res *result.Sql, err error)

+ func (p *Pool) QueryWithCursor(ctx context.Context, cursor, format string, args ...Arg) (res *result.Sql, err error)

+ func (p *Pool) QueryWithDsl(ctx context.Context, indexName string, qs *QueryDsl) (*result.Search, error)

+ func (p *Pool) QueryWithString(ctx context.Context, indexName string, qs *QueryString) (*result.Search, error)

+ func (p *Pool) Request(ctx context.Context, method, path string, body []byte, ...) (response *http_client.Response, err error)

+ func (p *Pool) SearchBySql(ctx context.Context, size int64, format, sqlStr string, params []any, ...) (res *result.Sql, err error)

+ type Properties map[string]Property

+ func (p Properties) WithProperty(field string, prop Property)

+ type Property map[string]any

+ type Query struct

+ func AcquireQuery() *Query

+ func (q *Query) Avg(field string) (sql string, args []any)

+ func (q *Query) Close()

+ func (q *Query) Count(field string) (sql string, args []any)

+ func (q *Query) From(table string) *Query

+ func (q *Query) Group(fields ...string) *Query

+ func (q *Query) HasFrom() bool

+ func (q *Query) Having(having string) *Query

+ func (q *Query) Limit(limit int64) *Query

+ func (q *Query) Max(field string) (sql string, args []any)

+ func (q *Query) Min(field string) (sql string, args []any)

+ func (q *Query) Order(orders ...string) *Query

+ func (q *Query) Select(columns ...string) *Query

+ func (q *Query) Sql() (sql string, args []any)

+ func (q *Query) Sum(field string) (sql string, args []any)

+ func (q *Query) Where(condition condition.Condition) *Query

+ type QueryDsl struct

+ From int64

+ Query kind.JsonParam

+ SearchAfter []any

+ Size int64

+ Sort Sort

+ Source any

+ type QueryString struct

+ From int64

+ Query StringQuery

+ SearchAfter []any

+ Size int64

+ Sort Sort

+ Source any

+ func NewQueryString(q string) *QueryString

+ func (qs *QueryString) SetQuery(q string) *QueryString

+ type Setter map[string]any

+ func (s Setter) ToBody() (setter []byte, err error)

+ type Sort []SortItem

+ type SortItem map[string]OrderItem

+ type String struct

+ Query string

+ type StringQuery struct

+ QueryString String

+ type Updater struct

+ Doc Property

+ DocAsUpsert bool

+ Script Property

+ Source bool

Other modules containing this package

github.com/grpc-boot/base/v3