Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

esx

package module

Go to main page

Versions in this module

v1

v1.0.6

Sep 19, 2022

v1.0.5

Sep 19, 2022

Changes in this version

+ type HealthResult struct

+ ActivePriShards int

+ ActiveSdPct float64

+ ActiveShards int

+ DelayShards int

+ InFlightFetch int

+ InitingShards int

+ NumOfDataNodes int

+ NumOfNodes int

+ PendingTasks int

+ RelocatShards int

+ Status string

+ TaskMaxWaitMs int

+ UnAssignShards int

+ func Health(client *Client) (HealthResult, error)

+ func HealthWithPool() (HealthResult, error)

+ type IndexInfo struct

+ Index string

+ Status string

+ func Cat(client *Client, pattern string) ([]IndexInfo, error)

+ func CatWithPool(pattern string) ([]IndexInfo, error)

v1.0.4

Sep 18, 2022

v1.0.3

Sep 16, 2022

Changes in this version

+ const APPLICATION_JSON

+ const CONTENT_TYPE

v1.0.2

Sep 14, 2022

Changes in this version

+ const ES_REJECTED_ERROR

+ const HTTP_REQ_FAIL

+ const HTTP_RESP_READ_FAIL

+ const HTTP_SELF_CODE

+ func AliasAction(client *Client, aliasname string, actions []map[string]map[string]string) error

+ func AliasActionWithPool(aliasname string, actions []map[string]map[string]string) error

+ func AliasQuery(client *Client, aliasname string) ([]string, error)

+ func AliasQueryWithPool(aliasname string) ([]string, error)

+ func Create(client *Client, indexname string) bool

+ func CreateWithPool(indexname string) bool

+ func Del(client *Client, indexList []string) []string

+ func DelWithPool(indexList []string) []string

+ func Exist(client *Client, indexname string) bool

+ func ExistWithPool(indexname string) bool

+ func Flush(client *Client, indexname string) bool

+ func FlushWithPool(indexname string) bool

+ func GetTimeTemps(s string) string

+ func NewPool(logger *zap.Logger, opt Option, size int) error

+ func TempCreate(client *Client, name string, qdata []byte) error

+ func TempCreateWithPool(name string, qdata []byte) error

+ func TempExist(client *Client, name string) bool

+ func TempExistWithPool(name string) bool

+ type Ack struct

+ Acknowledged bool

+ Status int

+ type BulkClient struct

+ func NewBulkClient(logger *zap.Logger, client *Client, opt BulkOption) *BulkClient

+ func (c *BulkClient) Add(indexname, typename, message string) (int, time.Duration)

+ func (c *BulkClient) Send() (int, time.Duration)

+ func (c *BulkClient) Stop()

+ func (c *BulkClient) Tick() (int, time.Duration)

+ type BulkOption struct

+ MaxCT int

+ MaxSize int

+ MaxTime time.Duration

+ Tid int

+ type Client struct

+ func NewClient(logger *zap.Logger, opt Option) (*Client, error)

+ func NewClientWithID(logger *zap.Logger, opt Option, tid int) (*Client, error)

+ func (c *Client) GetResponse(method, uri, data string, headers map[string]string) (int, []byte)

+ type ClientPool struct

+ var Pool *ClientPool

+ func (c *ClientPool) Get() *Client

+ func (c *ClientPool) GetTimeout(t time.Duration) (*Client, error)

+ func (c *ClientPool) Put(client *Client)

+ type EasyRequest struct

+ Filters map[string]any

+ Funcs map[string][]string

+ Interval string

+ MustNot []map[string]any

+ PreIndex string

+ QueryString string

+ ScriptedMetric *ScriptedMetric

+ Shoulds []map[string]any

+ Size int64

+ Terms []string

+ TimeField string

+ TimeFrom int64

+ TimePattern string

+ TimeShift int64

+ TimeTill int64

+ type HitsResponse struct

+ Index string

+ Score float64

+ Source map[string]any

+ type Option struct

+ Addrs []string

+ Password string

+ Timeout time.Duration

+ Username string

+ type ReqParam struct

+ Terms []string

+ type ScriptedMetric struct

+ CombineScript string

+ InitScript string

+ MapScript string

+ Params map[string]any

+ ReduceScript string

+ Toggle bool

+ type SearchRequest struct

+ Aggs map[string]map[string]any

+ Indices []string

+ Query struct{ ... }

+ Size int64

+ func NewSearchRequest(in *EasyRequest) (SearchRequest, error)

+ func (c *SearchRequest) Tostring() string

+ type SearchResponse struct

+ Aggs map[string]json.RawMessage

+ Hits struct{ ... }

+ Shards struct{ ... }

+ Status int

+ Timeout bool

+ type SearchResult struct

+ Aggs []map[string]any

+ Hits []map[string]any

+ Total int64

+ func ParseSearchResult(in []byte, req *EasyRequest) (SearchResult, error)

+ func Search(client *Client, in EasyRequest) (SearchResult, error)

+ func SearchWithPool(in EasyRequest) (SearchResult, error)

+ func (c *SearchResult) Tostring() string