Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/olivere/elastic
/ functions
Functions
5,566 in github.com/olivere/elastic
⨍
Functions
5,566
◇
Types & classes
868
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_security_get_user.go:90
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_security_delete_user.go:94
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
snapshot_delete_repository.go:102
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_security_enable_user.go:94
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_get_settings.go:139
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
cluster_stats.go:93
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
snapshot_verify_repository.go:101
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_rollup_start.go:86
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_exists_template.go:103
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
search_shards.go:133
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_get_field_mapping.go:141
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
termvectors.go:240
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
snapshot_create.go:120
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_rollup_put.go:93
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
pit_open.go:139
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_clear_cache.go:142
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_get.go:128
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_watcher_stats.go:91
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_delete_component_template.go:101
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_exists.go:121
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
nodes_stats.go:155
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
snapshot_delete.go:93
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_security_disable_user.go:94
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_watcher_deactivate_watch.go:93
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_unfreeze.go:138
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
indices_put_template.go:166
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_security_delete_role.go:86
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
snapshot_get.go:116
↓ 1 callers
Method
buildURL
buildURL builds the URL for the operation.
xpack_async_search_delete.go:87
↓ 1 callers
Method
commitRequired
commitRequired returns true if the service has to commit its bulk requests. This can be either because the number of actions or the estimated size in
bulk_processor.go:648
↓ 1 callers
Function
createResponseError
createResponseError creates an Error structure from the HTTP response, its status code and the error information sent by Elasticsearch.
errors.go:44
↓ 1 callers
Method
dumpRequest
dumpRequest dumps the given HTTP request to the trace log.
client.go:859
↓ 1 callers
Method
dumpResponse
dumpResponse dumps the given HTTP response to the trace log.
client.go:869
↓ 1 callers
Method
dup
()
bulk_processor.go:227
↓ 1 callers
Method
expand
(buf *bytes.Buffer, values map[string]interface{})
uritemplates/uritemplates.go:207
↓ 1 callers
Method
expandArray
(buf *bytes.Buffer, t templateTerm, a []interface{})
uritemplates/uritemplates.go:272
↓ 1 callers
Method
first
-- First -- first takes the first page of search results.
scroll.go:403
↓ 1 callers
Method
flusher
flusher is a single goroutine that periodically asks all workers to commit their outstanding bulk requests. It is only started if FlushInterval is gre
bulk_processor.go:424
↓ 1 callers
Method
getBody
getBody returns the body of the request, if not explicitly set via BodyJson or BodyString.
indices_rollover.go:198
↓ 1 callers
Method
hasSort
()
search_source.go:168
↓ 1 callers
Function
isConflict
isConflict returns true if the given error indicates that the Elasticsearch operation resulted in a version conflict. This can occur in operations lik
trace/opencensus/transport.go:195
↓ 1 callers
Function
isConnErr
isConnErr returns true if the error indicates that Elastic could not find an Elasticsearch host to connect to.
trace/opencensus/transport.go:159
↓ 1 callers
Function
isForbidden
isForbidden returns true if the given error indicates that Elasticsearch returned HTTP status 403. This happens e.g. due to a missing license. The err
trace/opencensus/transport.go:203
↓ 1 callers
Function
isNotFound
isNotFound returns true if the given error indicates that Elasticsearch returned HTTP status 404. The err parameter can be of type *elastic.Error, ela
trace/opencensus/transport.go:179
↓ 1 callers
Function
isTimeout
isTimeout returns true if the given error indicates that Elasticsearch returned HTTP status 408. The err parameter can be of type *elastic.Error, elas
trace/opencensus/transport.go:186
↓ 1 callers
Function
jitter
jitter randomizes the interval to return a value of [0.5*millis .. 1.5*millis].
backoff.go:127
↓ 1 callers
Method
monitor
()
cluster-test/cluster-test.go:163
↓ 1 callers
Function
newBulkProcessor
( client *Client, beforeFn BulkBeforeFunc, afterFn BulkAfterFunc, name string, numWorkers int, bulkActio
bulk_processor.go:284
↓ 1 callers
Function
newBulkProcessorStats
newBulkProcessorStats initializes and returns a BulkProcessorStats struct.
bulk_processor.go:217
↓ 1 callers
Function
newBulkWorker
newBulkWorker creates a new bulkWorker instance.
bulk_processor.go:456
↓ 1 callers
Method
next
-- Next --
scroll.go:551
↓ 1 callers
Function
parseExpression
(expression string)
uritemplates/uritemplates.go:112
↓ 1 callers
Function
parseTerm
(term string)
uritemplates/uritemplates.go:162
↓ 1 callers
Function
populate
populate will fill an example index.
recipes/search_with_point_in_time/search.go:98
↓ 1 callers
Method
rawScriptSource
rawScriptSource returns an embeddable script. If it uses a short script form, e.g. "ctx._source.likes++" (without the quotes), it is quoted. Otherwise
script.go:114
↓ 1 callers
Method
removeBlankIndexNames
()
indices_put_alias.go:46
↓ 1 callers
Method
removeBlankIndexNames
()
indices_put_alias.go:162
↓ 1 callers
Method
search
()
cluster-test/cluster-test.go:289
↓ 1 callers
Method
setBodyJson
setBodyJson encodes the body as a struct to be marshaled via json.Marshal.
request.go:54
↓ 1 callers
Method
setBodyString
setBodyString encodes the body as a string.
request.go:65
↓ 1 callers
Function
setSpanStatus
See https://github.com/opencensus-integrations/ocsql/blob/master/driver.go#L749
trace/opencensus/transport.go:84
↓ 1 callers
Method
setup
()
cluster-test/cluster-test.go:185
↓ 1 callers
Function
setupTestClientAndCreateIndexAndAddDocsNoSource
(t logger, options ...ClientOptionFunc)
setup_test.go:462
↓ 1 callers
Method
sourceAsMap
source returns the search source. It is used by Reindex.
search_request.go:567
↓ 1 callers
Method
startupHealthcheck
startupHealthcheck is used at startup to check if the server is available at all.
client.go:1173
↓ 1 callers
Function
testClusterRerouteWithCommands
(client *Client, t *testing.T)
cluster_reroute_test.go:66
↓ 1 callers
Function
testClusterRerouteWithoutBody
(client *Client, t *testing.T)
cluster_reroute_test.go:107
↓ 1 callers
Function
testIntervalQueryFuzzy
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:172
↓ 1 callers
Function
testIntervalQueryMatch
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:31
↓ 1 callers
Function
testIntervalQueryPrefix
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:78
↓ 1 callers
Function
testIntervalQueryWildcard
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:125
↓ 1 callers
Method
updateConns
updateConns updates the clients' connections with new information gather by a sniff operation.
client.go:1040
↓ 1 callers
Method
updateStats
(res *BulkResponse)
bulk_processor.go:623
↓ 1 callers
Method
waitForActiveConnection
(ready chan<- struct{})
bulk_processor.go:594
↓ 1 callers
Method
work
work waits for bulk requests and manual flush calls on the respective channels and is invoked as a goroutine when the bulk processor is started.
bulk_processor.go:470
Method
AbortOnVersionConflict
AbortOnVersionConflict aborts the request on version conflicts. It is an alias to setting Conflicts("abort").
reindex.go:188
Method
AbortOnVersionConflict
AbortOnVersionConflict aborts the request on version conflicts. It is an alias to setting Conflicts("abort").
update_by_query.go:202
Method
AbortOnVersionConflict
AbortOnVersionConflict aborts the request on version conflicts. It is an alias to setting Conflicts("abort").
delete_by_query.go:190
Method
Accuracy
(accuracy float64)
suggester_phrase.go:455
Method
Accuracy
(accuracy float64)
suggester_term.go:84
Method
Actions
Actions is a list of actions that should be returned. Leave empty to return all.
tasks_list.go:96
Method
Actions
Actions is a list of actions that should be cancelled. Leave empty to cancel all.
tasks_cancel.go:101
Method
Active
Active specifies whether the watch is in/active by default.
xpack_watcher_put_watch.go:92
Method
Add
Add adds a score function that will execute on all the documents matching the filter.
search_queries_fsq.go:48
Method
Add
Add clauses to use in the query.
search_queries_span_near.go:29
Method
AddBucketsPath
AddBucketsPath adds a bucket path to use for this pipeline aggregator.
search_aggs_pipeline_bucket_selector.go:76
Method
AddMaskRangeWithKey
(key, mask string)
search_aggs_bucket_ip_range.go:59
Method
AddRange
(from, to interface{})
search_aggs_bucket_geo_distance.go:68
Method
AddRange
(from, to string)
search_aggs_bucket_ip_range.go:64
Method
AddRange
(from, to interface{})
search_aggs_bucket_date_range.go:85
Method
AddRangeWithKey
(key string, from, to interface{})
search_aggs_bucket_geo_distance.go:73
Method
AddRangeWithKey
(key, from, to string)
search_aggs_bucket_ip_range.go:69
Method
AddRangeWithKey
(key string, from, to interface{})
search_aggs_bucket_date_range.go:90
Method
AddRangeWithKey
(key string, from, to interface{})
search_aggs_bucket_range.go:84
Method
AddUnboundedFrom
(to float64)
search_aggs_bucket_geo_distance.go:88
Method
AddUnboundedFrom
(to string)
search_aggs_bucket_ip_range.go:84
Method
AddUnboundedFrom
(to interface{})
search_aggs_bucket_date_range.go:105
Method
AddUnboundedFromWithKey
(key string, to float64)
search_aggs_bucket_geo_distance.go:93
Method
AddUnboundedFromWithKey
(key, to string)
search_aggs_bucket_ip_range.go:89
Method
AddUnboundedFromWithKey
(key string, to interface{})
search_aggs_bucket_date_range.go:110
← previous
next →
1,401–1,500 of 5,566, ranked by callers