Versions in this module Expand all Collapse all v1 v1.1.1 Feb 11, 2016 v1.1.0 Feb 2, 2016 Changes in this version + var ErrJSONEncodeFailed = errors.New("json encode failed") + var ErrNotConnected = errors.New("not connected") + var ErrResponseRead = errors.New("bulk item status parse failed.") + type BulkResult struct + Items []json.RawMessage + type Client struct + func NewClient(esURL, index string, proxyURL *url.URL, tls *tls.Config, ...) *Client + func (client *Client) Clone() *Client + func (client *Client) PublishEvent(event common.MapStr) error + func (client *Client) PublishEvents(events []common.MapStr) ([]common.MapStr, error) + type Connection struct + Password string + URL string + Username string + func (conn *Connection) Bulk(index, docType string, params map[string]string, body []interface{}) (*QueryResult, error) + func (conn *Connection) BulkWith(index string, docType string, params map[string]string, ...) (*QueryResult, error) + func (conn *Connection) Close() error + func (conn *Connection) Connect(timeout time.Duration) error + func (conn *Connection) IsConnected() bool + func (conn *Connection) Ping(timeout time.Duration) (bool, error) + func (es *Connection) CountSearchURI(index string, docType string, params map[string]string) (int, *CountResults, error) + func (es *Connection) CreateIndex(index string, body interface{}) (int, *QueryResult, error) + func (es *Connection) Delete(index string, docType string, id string, params map[string]string) (int, *QueryResult, error) + func (es *Connection) Index(index, docType, id string, params map[string]string, body interface{}) (int, *QueryResult, error) + func (es *Connection) Refresh(index string) (int, *QueryResult, error) + func (es *Connection) SearchURI(index string, docType string, params map[string]string) (int, *SearchResults, error) + type CountResults struct + Count int + Shards json.RawMessage + type Hits struct + Hits []json.RawMessage + Total int + type MetaBuilder func(interface{}) interface + type QueryResult struct + Created bool + Exists bool + Found bool + ID string + Index string + Matches []string + Ok bool + Source json.RawMessage + Type string + Version int + func (r QueryResult) String() string + type SearchResults struct + Aggs map[string]json.RawMessage + Hits Hits + Shards json.RawMessage + Took int v1.0.1 Dec 17, 2015
Go to main page