Versions in this module Expand all Collapse all v0 v0.3.2 Jun 22, 2015 Changes in this version + const BulkDelaySeconds + const BulkMaxBuffer + const BulkMaxDocs + const DefaultDecayDuration + const DefaultDomain + const DefaultPort + const DefaultProtocol + const MAX_SHUTDOWN_SECS + const Version + var ErrInvalidIndexLine = errors.New("Cannot parse indexline") + var ErrInvalidShardLine = errors.New("Cannot parse shardline") + var RecordNotFound = errors.New("record not found") + func Escape(args map[string]interface{}) (s string, err error) + func GetIndexUrl(index string, _type string, id string, parentId string, version int, ...) (retval string, e error) + func ScrollDuration(duration string) string + func WriteBulkBytes(op string, index string, _type string, id, ttl string, date *time.Time, ...) ([]byte, error) + type AggregateDsl struct + AggregatesVal map[string]*AggregateDsl + Filters *FilterWrap + Name string + Type interface{} + TypeName string + func Aggregate(name string) *AggregateDsl + func (d *AggregateDsl) Aggregates(aggs ...*AggregateDsl) *AggregateDsl + func (d *AggregateDsl) Avg(field string) *AggregateDsl + func (d *AggregateDsl) Cardinality(field string, rehash bool, threshold int) *AggregateDsl + func (d *AggregateDsl) DateHistogram(field, interval string) *AggregateDsl + func (d *AggregateDsl) ExtendedStats(field string) *AggregateDsl + func (d *AggregateDsl) Filter(filters ...interface{}) *AggregateDsl + func (d *AggregateDsl) Global() *AggregateDsl + func (d *AggregateDsl) Histogram(field string, interval int) *AggregateDsl + func (d *AggregateDsl) MarshalJSON() ([]byte, error) + func (d *AggregateDsl) Max(field string) *AggregateDsl + func (d *AggregateDsl) Min(field string) *AggregateDsl + func (d *AggregateDsl) Missing(field string) *AggregateDsl + func (d *AggregateDsl) Percentiles(field string) *AggregateDsl + func (d *AggregateDsl) SignificantTerms(field string) *AggregateDsl + func (d *AggregateDsl) Stats(field string) *AggregateDsl + func (d *AggregateDsl) Sum(field string) *AggregateDsl + func (d *AggregateDsl) Terms(field string) *AggregateDsl + func (d *AggregateDsl) TermsWithSize(field string, size int) *AggregateDsl + func (d *AggregateDsl) ValueCount(field string) *AggregateDsl + type AllocateCommand struct + AllowPrimary bool + Index string + Node string + Shard string + type AnalyzeResponse struct + Tokens []Token + type AnalyzerOptions struct + Index string + Path string + type BaseResponse struct + Created bool + Exists bool + Found bool + Id string + Index string + Matches []string + Ok bool + Source *json.RawMessage + Type string + Version int + type BoolClause string + type BulkIndexer struct + BufferDelayMax time.Duration + BulkMaxBuffer int + BulkMaxDocs int + ErrorChannel chan *ErrorBuffer + RetryForSeconds int + Sender func(*bytes.Buffer) error + func (b *BulkIndexer) Delete(index, _type, id string, refresh bool) + func (b *BulkIndexer) Flush() + func (b *BulkIndexer) Index(index string, _type string, id, ttl string, date *time.Time, data interface{}, ...) error + func (b *BulkIndexer) NumErrors() uint64 + func (b *BulkIndexer) PendingDocuments() int + func (b *BulkIndexer) Send(buf *bytes.Buffer) error + func (b *BulkIndexer) Start() + func (b *BulkIndexer) Stop() + func (b *BulkIndexer) Update(index string, _type string, id, ttl string, date *time.Time, data interface{}, ...) error + func (b *BulkIndexer) UpdateWithPartialDoc(index string, _type string, id, ttl string, date *time.Time, ...) error + func (b *BulkIndexer) UpdateWithWithScript(index string, _type string, id, ttl string, date *time.Time, script string, ...) error + type CPU struct + CacheSizeInBytes int + CoresPerSocket int + Mhz int + Model string + TotalCores int + TotalSockets int + Vendor string + type CancelCommand struct + AllowPrimary bool + Index string + Node string + Shard string + type Cardinality struct + Field string + PrecisionThreshold float64 + Rehash bool + type CatIndexDocs struct + Count int64 + Deleted int64 + type CatIndexInfo struct + Docs CatIndexDocs + Health string + Name string + Replicas int + Shards int + Store CatIndexStore + func NewCatIndexInfo(indexLine string) (catIndex *CatIndexInfo, err error) + type CatIndexStore struct + PriSize int64 + Size int64 + type CatShardInfo struct + Docs int64 + IndexName string + NodeIP string + NodeName string + Primary string + Shard int + State string + Store int64 + func NewCatShardInfo(rawCat string) (catshard *CatShardInfo, err error) + func (s *CatShardInfo) String() string + type CatShards []CatShardInfo + func (s *CatShards) String() string + type Cluster struct + Name string + type ClusterHealthResponse struct + ActivePrimaryShards int + ActiveShards int + ClusterName string + InitializingShards int + NumberOfDataNodes int + NumberOfNodes int + RelocatingShards int + Status string + TimedOut bool + UnassignedShards int + type ClusterSettingsResponse struct + Persistent map[string]int + Transient map[string]int + type ClusterStateFilter struct + FilterBlocks bool + FilterIndices []string + FilterMetadata bool + FilterNodes bool + FilterRoutingTable bool + func (f ClusterStateFilter) Parameterize() []string + type ClusterStateIndiceResponse struct + State string + type ClusterStateMetadataResponse struct + Indices map[string]ClusterStateIndiceResponse + type ClusterStateNodeResponse struct + Name string + TransportAddress string + type ClusterStateResponse struct + ClusterName string + MasterNode string + Metadata ClusterStateMetadataResponse + Nodes map[string]ClusterStateNodeResponse + type ClusterStateRoutingTableResponse struct + type Commands struct + Commands []interface{} + type Conn struct + ClusterDomains []string + DecayDuration time.Duration + Domain string + Hosts []string + Password string + Port string + Protocol string + RequestTracer func(method, url, body string) + Username string + func NewConn() *Conn + func (c *Conn) AddAlias(index string, alias string) (BaseResponse, error) + func (c *Conn) AllNodesInfo() (NodeInfo, error) + func (c *Conn) AnalyzeIndices(index string, args map[string]interface{}) (AnalyzeResponse, error) + func (c *Conn) ClearCache(clearId bool, clearBloom bool, args map[string]interface{}, indices ...string) (ExtendedStatus, error) + func (c *Conn) Close() + func (c *Conn) CloseIndex(index string) (BaseResponse, error) + func (c *Conn) CloseIndices() (BaseResponse, error) + func (c *Conn) ClusterState(filter ClusterStateFilter) (ClusterStateResponse, error) + func (c *Conn) Count(index string, _type string, args map[string]interface{}, query interface{}) (CountResponse, error) + func (c *Conn) CreateIndex(index string) (BaseResponse, error) + func (c *Conn) CreateIndexWithSettings(index string, settings interface{}) (BaseResponse, error) + func (c *Conn) CreateSnapshotRepository(name string, args map[string]interface{}, settings interface{}) (BaseResponse, error) + func (c *Conn) Delete(index string, _type string, id string, args map[string]interface{}) (BaseResponse, error) + func (c *Conn) DeleteByQuery(indices []string, types []string, args map[string]interface{}, ...) (BaseResponse, error) + func (c *Conn) DeleteIndex(index string) (BaseResponse, error) + func (c *Conn) DeleteMapping(index string, typeName string) (BaseResponse, error) + func (c *Conn) DoCommand(method string, url string, args map[string]interface{}, data interface{}) ([]byte, error) + func (c *Conn) Exists(index string, _type string, id string, args map[string]interface{}) (BaseResponse, error) + func (c *Conn) ExistsBool(index string, _type string, id string, args map[string]interface{}) (bool, error) + func (c *Conn) ExistsIndex(index string, _type string, args map[string]interface{}) (bool, error) + func (c *Conn) Explain(index string, _type string, id string, args map[string]interface{}, ...) (Match, error) + func (c *Conn) Flush(indices ...string) (BaseResponse, error) + func (c *Conn) Get(index string, _type string, id string, args map[string]interface{}) (BaseResponse, error) + func (c *Conn) GetCatIndexInfo(pattern string) (catIndices []CatIndexInfo) + func (c *Conn) GetCatShards() (shards CatShards) + func (c *Conn) GetCustom(index string, _type string, id string, args map[string]interface{}, ...) (BaseResponse, error) + func (c *Conn) GetSnapshotByName(repository, name string, args map[string]interface{}) (GetSnapshotsResponse, error) + func (c *Conn) GetSnapshots(repository string, args map[string]interface{}) (GetSnapshotsResponse, error) + func (c *Conn) GetSource(index string, _type string, id string, args map[string]interface{}, ...) error + func (c *Conn) Health(indices ...string) (ClusterHealthResponse, error) + func (c *Conn) Index(index string, _type string, id string, args map[string]interface{}, ...) (BaseResponse, error) + func (c *Conn) IndexWithParameters(index string, _type string, id string, parentId string, version int, ...) (BaseResponse, error) + func (c *Conn) IndicesExists(indices ...string) (bool, error) + func (c *Conn) MGet(index string, _type string, mgetRequest MGetRequestContainer, ...) (MGetResponseContainer, error) + func (c *Conn) MoreLikeThis(index string, _type string, id string, args map[string]interface{}, ...) (BaseResponse, error) + func (c *Conn) NewBulkIndexer(maxConns int) *BulkIndexer + func (c *Conn) NewBulkIndexerErrors(maxConns, retrySeconds int) *BulkIndexer + func (c *Conn) NewRequest(method, path, query string) (*Request, error) + func (c *Conn) NodesInfo(information []string, nodes ...string) (NodeInfo, error) + func (c *Conn) NodesShutdown(delay int, nodes ...string) error + func (c *Conn) NodesStats() (NodeStatsResponse, error) + func (c *Conn) OpenIndex(index string) (BaseResponse, error) + func (c *Conn) OpenIndices() (BaseResponse, error) + func (c *Conn) OptimizeIndices(args map[string]interface{}, indices ...string) (ExtendedStatus, error) + func (c *Conn) Percolate(index string, _type string, name string, args map[string]interface{}, ...) (Match, error) + func (c *Conn) PutMapping(index string, typeName string, instance interface{}, opt MappingOptions) error + func (c *Conn) PutMappingFromJSON(index string, typeName string, mapping []byte) error + func (c *Conn) PutSettings(index string, settings interface{}) (BaseResponse, error) + func (c *Conn) Refresh(indices ...string) (BaseResponse, error) + func (c *Conn) RegisterPercolate(index string, name string, args map[string]interface{}, query OneTermQuery) (BaseResponse, error) + func (c *Conn) Reroute(dryRun bool, commands Commands) (ClusterHealthResponse, error) + func (c *Conn) RestoreSnapshot(repository, name string, args map[string]interface{}, query interface{}) (BaseResponse, error) + func (c *Conn) Scroll(args map[string]interface{}, scroll_id string) (SearchResult, error) + func (c *Conn) Search(index string, _type string, args map[string]interface{}, query interface{}) (SearchResult, error) + func (c *Conn) SearchUri(index, _type string, args map[string]interface{}) (SearchResult, error) + func (c *Conn) SetHosts(newhosts []string) + func (c *Conn) SetPort(port string) + func (c *Conn) Snapshot(indices ...string) (ExtendedStatus, error) + func (c *Conn) Status(args map[string]interface{}, indices ...string) (BaseResponse, error) + func (c *Conn) Suggest(index string, args map[string]interface{}, query interface{}) (SuggestResults, error) + func (c *Conn) TakeSnapshot(repository, name string, args map[string]interface{}, query interface{}) (BaseResponse, error) + func (c *Conn) Update(index string, _type string, id string, args map[string]interface{}, ...) (BaseResponse, error) + func (c *Conn) UpdateSetting(args map[string]interface{}, filter_indices ...string) (ClusterStateResponse, error) + func (c *Conn) UpdateSettings(settingType string, key string, value int) (ClusterSettingsResponse, error) + func (c *Conn) UpdateWithPartialDoc(index string, _type string, id string, args map[string]interface{}, ...) (BaseResponse, error) + func (c *Conn) UpdateWithScript(index string, _type string, id string, args map[string]interface{}, ...) (BaseResponse, error) + func (c *Conn) Validate(index string, _type string, args map[string]interface{}) (BaseResponse, error) + func (c *Conn) WaitForStatus(status string, timeout int, indices ...string) (ClusterHealthResponse, error) + type CountResponse struct + Count int + Shard Status + type DateHistogram struct + Field string + Interval string + type DeleteByQueryResponse struct + Indicies map[string]IndexStatus + Status bool + type ESError struct + Code int + What string + When time.Time + func (e ESError) Error() string + type ErrorBuffer struct + Buf *bytes.Buffer + Err error + type Explaination struct + Error string + Index string + Valid bool + type Explanation struct + Description string + Details []*Explanation + Value float32 + func (e *Explanation) String(indent string) string + type ExtendedStatus struct + Ok StatusBool + ShardsStatus Status + type FacetDsl struct + Ranges map[string]*RangeDsl + Terms map[string]*Term + func Facet() *FacetDsl + func (m *FacetDsl) Fields(fields ...string) *FacetDsl + func (m *FacetDsl) MarshalJSON() ([]byte, error) + func (m *FacetDsl) Range(r *RangeDsl) *FacetDsl + func (m *FacetDsl) Regex(field, match string) *FacetDsl + func (m *FacetDsl) Size(size string) *FacetDsl + func (m *FacetDsl) Term(t *Term) *FacetDsl + type Facets struct + Tag struct{ ... } + type Failure struct + Index string + Reason string + Shard StatusInt + func (f Failure) String() string + type FieldAggregate struct + Field string + Size *int + type FilterClause interface + String func() string + type FilterOp struct + Exist map[string]string + MissingVal map[string]string + Range map[string]map[string]interface{} + TermsMap map[string][]interface{} + func Filter() *FilterOp + func Range() *FilterOp + func (f *FilterOp) Add(fop *FilterOp) *FilterOp + func (f *FilterOp) Exists(name string) *FilterOp + func (f *FilterOp) Field(fld string) *FilterOp + func (f *FilterOp) From(from string) *FilterOp + func (f *FilterOp) Gt(gt interface{}) *FilterOp + func (f *FilterOp) Lt(lt interface{}) *FilterOp + func (f *FilterOp) Missing(name string) *FilterOp + func (f *FilterOp) Terms(field string, values ...interface{}) *FilterOp + func (f *FilterOp) To(to string) *FilterOp + type FilterWrap struct + func CompoundFilter(fl ...interface{}) *FilterWrap + func NewFilterWrap() *FilterWrap + func (f *FilterWrap) Bool(s string) + func (f *FilterWrap) MarshalJSON() ([]byte, error) + func (f *FilterWrap) String() string + type Float32Nullable float32 + func (i *Float32Nullable) UnmarshalJSON(data []byte) error + type GetSnapshotsResponse struct + Snapshots []struct{ ... } + type Highlight map[string][]string + type Histogram struct + Field string + Interval float64 + type Hit struct + Explanation *Explanation + Fields *json.RawMessage + Highlight *Highlight + Id string + Index string + Score Float32Nullable + Source *json.RawMessage + Type string + type Hits struct + Hits []Hit + Total int + func (h *Hits) Len() int + type Http struct + BoundAddress string + PublishAddress string + type IdOptions struct + Index string + Path string + type IndexStatus struct + Shards Status + type Interface struct + Address string + MacAddress string + Name string + type JVM struct + GcCollectors []string + Mem *JvmMem + MemoryPools []string + Pid int + StartTime int + VMName string + VMVendor string + VMVersion string + Version string + type JsonAlias struct + Alias string + Index string + type JsonAliasAdd struct + Add JsonAlias + type JsonAliases struct + Actions []JsonAliasAdd + type JvmMem struct + DirectMaxInBytes int + HeapInitInBytes int + HeapMaxInBytes int + NonHeapInitInBytes int + NonHeapMaxInBytes int + type MEM struct + TotalInBytes int + type MGetRequest struct + Fields []string + ID string + IDS []string + Index string + Type string + type MGetRequestContainer struct + Docs []MGetRequest + type MGetResponseContainer struct + Docs []BaseResponse + type MLT struct + Analyzer string + Boost float32 + BoostTerms int + Fields []string + LikeText string + MaxDocFrequency int + MaxQueryTerms int + MaxWordLength int + MinDocFrequency int + MinTermFrequency int + MinWordLength int + PercentTermsToMatch float32 + StopWords []string + type Mapping map[string]MappingOptions + func MappingForType(typeName string, opts MappingOptions) Mapping + func (m_ Mapping) Options() MappingOptions + type MappingOptions struct + Analyzer *AnalyzerOptions + Id IdOptions + Parent *ParentOptions + Properties map[string]interface{} + Routing *RoutingOptions + Size *SizeOptions + Source *SourceOptions + Timestamp TimestampOptions + Type *TypeOptions + type Match struct + Explanation *Explanation + Matches []string + OK bool + type MatchAll struct + All string + type MoreLikeThisQuery struct + MoreLikeThis MLT + type MoveCommand struct + FromNode string + Index string + Shard string + ToNode string + type MultiMatch struct + Fields []string + Query string + type Network struct + PrimaryInterface *Interface + RefreshInterval int + type Node struct + Build string + Host string + Hostname string + Http *Http + HttpAddress string + Ip string + JVM *JVM + Name string + Network *Network + OS *OS + Plugins []*Plugin + Process *Process + Settings *Settings + ThreadPool *ThreadPool + Transport *Transport + TransportAddress string + Version string + type NodeInfo struct + ClusterName string + Nodes map[string]Node + type NodeStatsFSDataResponse struct + Available int64 + Device string + DiskReadSize int64 + DiskReads int64 + DiskWriteSize int64 + DiskWrites int64 + Free int64 + Mount string + Path string + Total int64 + type NodeStatsFSResponse struct + Data []NodeStatsFSDataResponse + Timestamp int64 + type NodeStatsFieldDataBreakerResponse struct + EstimatedSize string + EstimatedSizeInBytes int64 + MaximumSize string + MaximumSizeInBytes int64 + Overhead float64 + Tripped int64 + type NodeStatsHTTPResponse struct + CurrentOpen int64 + TotalOpen int64 + type NodeStatsIndicesCompletionResponse struct + SizeInBytes int64 + type NodeStatsIndicesDocsResponse struct + Count int64 + Deleted int64 + type NodeStatsIndicesFieldDataResponse struct + Evictions int64 + MemorySizeInBytes int64 + type NodeStatsIndicesFilterCacheResponse struct + Evictions int64 + MemorySizeInBytes int64 + type NodeStatsIndicesFlushResponse struct + Total int64 + TotalTimeInMs int64 + type NodeStatsIndicesGetResponse struct + Current int64 + ExistsTime int64 + ExistsTotal int64 + MissingTime int64 + MissingTotal int64 + Time int64 + Total int64 + type NodeStatsIndicesIdCacheResponse struct + MemorySizeInBytes int64 + type NodeStatsIndicesIndexingResponse struct + DeleteCurrent int64 + DeleteTime int64 + DeleteTotal int64 + IndexCurrent int64 + IndexTime int64 + IndexTotal int64 + type NodeStatsIndicesMergesResponse struct + Current int64 + CurrentDocs int64 + CurrentSizeInBytes int64 + Total int64 + TotalDocs int64 + TotalSizeInBytes int64 + TotalTimeInMs int64 + type NodeStatsIndicesPercolateResponse struct + Current int64 + MemorySize string + MemorySizeInBytes int64 + Queries int64 + TimeInMs int64 + Total int64 + type NodeStatsIndicesRefreshResponse struct + Total int64 + TotalTimeInMs int64 + type NodeStatsIndicesResponse struct + Completion NodeStatsIndicesCompletionResponse + Docs NodeStatsIndicesDocsResponse + FieldData NodeStatsIndicesFieldDataResponse + FilterCache NodeStatsIndicesFilterCacheResponse + Flush NodeStatsIndicesFlushResponse + Get NodeStatsIndicesGetResponse + IdCache NodeStatsIndicesIdCacheResponse + Indexing NodeStatsIndicesIndexingResponse + Merges NodeStatsIndicesMergesResponse + Percolate NodeStatsIndicesPercolateResponse + Refresh NodeStatsIndicesRefreshResponse + Search NodeStatsIndicesSearchResponse + Segments NodeStatsIndicesSegmentsResponse + Store NodeStatsIndicesStoreResponse + Suggest NodeStatsIndicesSuggestResponse + Translog NodeStatsIndicesTranslogResponse + Warmer NodeStatsIndicesWarmerResponse + type NodeStatsIndicesSearchResponse struct + FetchCurrent int64 + FetchTime int64 + FetchTotal int64 + OpenContext int64 + QueryCurrent int64 + QueryTime int64 + QueryTotal int64 + type NodeStatsIndicesSegmentsResponse struct + Count int64 + IndexWriterMemoryInBytes int64 + MemoryInBytes int64 + VersionMapMemoryInBytes int64 + type NodeStatsIndicesStoreResponse struct + Size int64 + ThrottleTime int64 + type NodeStatsIndicesSuggestResponse struct + Current int64 + TimeInMs int64 + Total int64 + type NodeStatsIndicesTranslogResponse struct + Operations int64 + SizeInBytes int64 + type NodeStatsIndicesWarmerResponse struct + Current int64 + Total int64 + TotalTimeInMs int64 + type NodeStatsJVMBufferPoolsResponse struct + Count int64 + TotalCapacityInBytes int64 + UsedInBytes int64 + type NodeStatsJVMGCCollectorsAgeResponse struct + Count int64 + TimeInMs int64 + type NodeStatsJVMGCResponse struct + Collectors map[string]NodeStatsJVMGCCollectorsAgeResponse + type NodeStatsJVMMemPoolsResponse struct + MaxInBytes int64 + PeakMaxInBytes int64 + PeakUsedInBytes int64 + UsedInBytes int64 + type NodeStatsJVMMemResponse struct + HeapCommitedInBytes int64 + HeapMaxInBytes int64 + HeapUsedInBytes int64 + HeapUsedPercent int64 + NonHeapCommittedInBytes int64 + NonHeapUsedInBytes int64 + Pools map[string]NodeStatsJVMMemPoolsResponse + type NodeStatsJVMResponse struct + BufferPools map[string]NodeStatsJVMBufferPoolsResponse + GC NodeStatsJVMGCResponse + Mem NodeStatsJVMMemResponse + Threads NodeStatsJVMThreadsResponse + Timestame int64 + UptimeInMs int64 + type NodeStatsJVMThreadsResponse struct + Count int64 + PeakCount int64 + type NodeStatsNetworkResponse struct + TCP NodeStatsTCPResponse + type NodeStatsNodeAttributes struct + Client string + Data string + type NodeStatsNodeResponse struct + Attributes NodeStatsNodeAttributes + FS NodeStatsFSResponse + FieldDataBreaker NodeStatsFieldDataBreakerResponse + Host string + Hostname string + IP []string + Indices NodeStatsIndicesResponse + JVM NodeStatsJVMResponse + Name string + Network NodeStatsNetworkResponse + OS NodeStatsOSResponse + Process NodeStatsProcessResponse + ThreadPool map[string]NodeStatsThreadPoolPoolResponse + Timestamp int64 + Transport NodeStatsTransportResponse + TransportAddress string + type NodeStatsOSCPUResponse struct + Idle int64 + Steal int64 + Sys int64 + User int64 + type NodeStatsOSMemResponse struct + ActualFree int64 + ActualUsed int64 + Free int64 + Used int64 + type NodeStatsOSResponse struct + CPU NodeStatsOSCPUResponse + LoadAvg []float64 + Mem NodeStatsOSMemResponse + Swap NodeStatsOSSwapResponse + Timestamp int64 + Uptime int64 + type NodeStatsOSSwapResponse struct + Free int64 + Used int64 + type NodeStatsProcessCPUResponse struct + Percent int64 + Sys int64 + Total int64 + User int64 + type NodeStatsProcessMemResponse struct + Resident int64 + Share int64 + TotalVirtual int64 + type NodeStatsProcessResponse struct + CPU NodeStatsProcessCPUResponse + Memory NodeStatsProcessMemResponse + OpenFD int64 + Timestamp int64 + type NodeStatsResponse struct + ClusterName string + Nodes map[string]NodeStatsNodeResponse + type NodeStatsTCPResponse struct + ActiveOpens int64 + AttemptFails int64 + CurrEstab int64 + EstabResets int64 + InErrs int64 + InSegs int64 + OutRsts int64 + OutSegs int64 + PassiveOpens int64 + RetransSegs int64 + type NodeStatsThreadPoolPoolResponse struct + Active int64 + Completed int64 + Largest int64 + Queue int64 + Rejected int64 + Threads int64 + type NodeStatsTransportResponse struct + RxCount int64 + RxSize int64 + ServerOpen int64 + TxCount int64 + TxSize int64 + type OS struct + AvailableProcessors int + CPU *CPU + RefreshInterval int + type OneTermQuery struct + Query struct{ ... } + type ParentOptions struct + Type string + type Path struct + Logs string + type Plugin struct + Description string + Jvm bool + Name string + Site bool + Url string + type Process struct + Id int + MaxFileDescriptors int + Mlockall bool + RefreshInterval int + type QueryDsl struct + FilterVal *FilterOp + func Query() *QueryDsl + func (q *QueryDsl) All() *QueryDsl + func (q *QueryDsl) Fields(fields, search, exists, missing string) *QueryDsl + func (q *QueryDsl) Filter(f *FilterOp) *QueryDsl + func (q *QueryDsl) FunctionScore(mode string, functions ...map[string]interface{}) *QueryDsl + func (q *QueryDsl) MultiMatch(s string, fields []string) *QueryDsl + func (q *QueryDsl) Qs(qs *QueryString) *QueryDsl + func (q *QueryDsl) Range(fop *FilterOp) *QueryDsl + func (q *QueryDsl) Search(searchFor string) *QueryDsl + func (q *QueryDsl) Term(name, value string) *QueryDsl + func (qd *QueryDsl) MarshalJSON() ([]byte, error) + type QueryEmbed struct + FunctionScore map[string]interface{} + MatchAll *MatchAll + MultiMatch *MultiMatch + Qs *QueryString + Terms map[string]string + type QueryString struct + DefaultField string + DefaultOperator string + Exists string + Fields []string + Missing string + Query string + func NewQueryString(field, query string) QueryString + type QueryWrap struct + Qs QueryString + type RangeDef struct + Field string + Values []*RangeVal + type RangeDsl struct + FilterVal *FilterWrap + RangeDef *RangeDef + func FacetRange(field string) *RangeDsl + func (m *RangeDsl) Range(from, to string) *RangeDsl + func (s *RangeDsl) Filter(fl ...interface{}) *RangeDsl + type RangeVal struct + From string + To string + type Request struct + func (r *Request) Do(v interface{}) (int, []byte, error) + func (r *Request) DoResponse(v interface{}) (*http.Response, []byte, error) + func (r *Request) SetBody(body io.Reader) + func (r *Request) SetBodyBytes(body []byte) + func (r *Request) SetBodyJson(data interface{}) error + func (r *Request) SetBodyString(body string) + type RoutingOptions struct + Path string + Required bool + type SWAP struct + TotalInBytes int + type SearchDsl struct + AggregatesVal map[string]*AggregateDsl + FacetVal *FacetDsl + FilterVal *FilterWrap + FromVal int + Index string + QueryVal *QueryDsl + SizeVal int + SortBody []*SortDsl + func Search(index string) *SearchDsl + func (s *SearchDsl) Aggregates(aggs ...*AggregateDsl) *SearchDsl + func (s *SearchDsl) Bytes(conn *Conn) ([]byte, error) + func (s *SearchDsl) Facet(f *FacetDsl) *SearchDsl + func (s *SearchDsl) Fields(fields ...string) *SearchDsl + func (s *SearchDsl) Filter(fl ...interface{}) *SearchDsl + func (s *SearchDsl) From(from string) *SearchDsl + func (s *SearchDsl) Pretty() *SearchDsl + func (s *SearchDsl) Query(q *QueryDsl) *SearchDsl + func (s *SearchDsl) Result(conn *Conn) (*SearchResult, error) + func (s *SearchDsl) Scroll(duration string) *SearchDsl + func (s *SearchDsl) Search(srch string) *SearchDsl + func (s *SearchDsl) SearchType(searchType string) *SearchDsl + func (s *SearchDsl) Size(size string) *SearchDsl + func (s *SearchDsl) Sort(sort ...*SortDsl) *SearchDsl + func (s *SearchDsl) Source(returnSource bool) *SearchDsl + func (s *SearchDsl) Type(indexType string) *SearchDsl + type SearchRequest struct + Filter struct{ ... } + From int + Query OneTermQuery + Size int + type SearchResult struct + Aggregations json.RawMessage + Facets json.RawMessage + Hits Hits + RawJSON []byte + ScrollId string + ShardStatus Status + Suggestions Suggestions + TimedOut bool + Took int + func (s *SearchResult) String() string + type Settings struct + Foreground string + Name string + Path *Path + type SizeOptions struct + Enabled bool + Store bool + type SortBody []interface + type SortDsl struct + IsDesc bool + Name string + func Sort(field string) *SortDsl + func (s *SortDsl) Asc() *SortDsl + func (s *SortDsl) Desc() *SortDsl + func (s *SortDsl) MarshalJSON() ([]byte, error) + type SourceOptions struct + Enabled bool + Excludes []string + Includes []string + type Status struct + Failed StatusInt + Failures []Failure + Successful StatusInt + Total StatusInt + type StatusBool bool + func (self *StatusBool) MarshalJSON() ([]byte, error) + func (self *StatusBool) UnmarshalJSON(b []byte) error + type StatusInt int + func (self *StatusInt) MarshalJSON() ([]byte, error) + func (self *StatusInt) UnmarshalJSON(b []byte) error + type SuggestResults struct + ShardStatus Status + func (s SuggestResults) Result(suggestName string) ([]Suggestion, error) + type Suggestion struct + Length int + Offset int + Options []SuggestionOption + Text string + type SuggestionOption struct + Payload json.RawMessage + Score Float32Nullable + Text string + type Suggestions map[string][]Suggestion + type Term struct + FilterVal *FilterWrap + Terms Terms + func NewTerm(fields ...string) *Term + func (s *Term) Filter(fl ...interface{}) *Term + type Terms struct + Fields []string + Regex string + Size string + func (t *Terms) MarshalJSON() ([]byte, error) + type ThreadPool struct + Bulk *ThreadPoolConfig + Flush *ThreadPoolConfig + Generic *ThreadPoolConfig + Get *ThreadPoolConfig + Index *ThreadPoolConfig + Management *ThreadPoolConfig + Merge *ThreadPoolConfig + Optimize *ThreadPoolConfig + Percolate *ThreadPoolConfig + Refresh *ThreadPoolConfig + Search *ThreadPoolConfig + Snapshot *ThreadPoolConfig + Suggest *ThreadPoolConfig + Warmer *ThreadPoolConfig + type ThreadPoolConfig struct + KeepAlive string + Max int + Min int + QueueSize interface{} + Type string + type TimestampOptions struct + Enabled bool + type Token struct + EndOffset int + Name string + Position int + StartOffset int + Type string + type Transport struct + BoundAddress string + PublishAddress string + type TypeOptions struct + Index string + Store bool + type Validation struct + Explainations []Explaination + Shards Status + Valid bool