MCPcopy Create free account

hub / github.com/olivere/elastic / functions

Functions5,566 in github.com/olivere/elastic

↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_security_get_user.go:90
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_security_delete_user.go:94
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
snapshot_delete_repository.go:102
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_security_enable_user.go:94
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_get_settings.go:139
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
cluster_stats.go:93
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
snapshot_verify_repository.go:101
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_rollup_start.go:86
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_exists_template.go:103
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
search_shards.go:133
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_get_field_mapping.go:141
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
termvectors.go:240
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
snapshot_create.go:120
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_rollup_put.go:93
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
pit_open.go:139
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_clear_cache.go:142
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_get.go:128
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_watcher_stats.go:91
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_delete_component_template.go:101
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_exists.go:121
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
nodes_stats.go:155
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
snapshot_delete.go:93
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_security_disable_user.go:94
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_watcher_deactivate_watch.go:93
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_unfreeze.go:138
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
indices_put_template.go:166
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_security_delete_role.go:86
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
snapshot_get.go:116
↓ 1 callersMethodbuildURL
buildURL builds the URL for the operation.
xpack_async_search_delete.go:87
↓ 1 callersMethodcommitRequired
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 callersFunctioncreateResponseError
createResponseError creates an Error structure from the HTTP response, its status code and the error information sent by Elasticsearch.
errors.go:44
↓ 1 callersMethoddumpRequest
dumpRequest dumps the given HTTP request to the trace log.
client.go:859
↓ 1 callersMethoddumpResponse
dumpResponse dumps the given HTTP response to the trace log.
client.go:869
↓ 1 callersMethoddup
()
bulk_processor.go:227
↓ 1 callersMethodexpand
(buf *bytes.Buffer, values map[string]interface{})
uritemplates/uritemplates.go:207
↓ 1 callersMethodexpandArray
(buf *bytes.Buffer, t templateTerm, a []interface{})
uritemplates/uritemplates.go:272
↓ 1 callersMethodfirst
-- First -- first takes the first page of search results.
scroll.go:403
↓ 1 callersMethodflusher
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 callersMethodgetBody
getBody returns the body of the request, if not explicitly set via BodyJson or BodyString.
indices_rollover.go:198
↓ 1 callersMethodhasSort
()
search_source.go:168
↓ 1 callersFunctionisConflict
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 callersFunctionisConnErr
isConnErr returns true if the error indicates that Elastic could not find an Elasticsearch host to connect to.
trace/opencensus/transport.go:159
↓ 1 callersFunctionisForbidden
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 callersFunctionisNotFound
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 callersFunctionisTimeout
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 callersFunctionjitter
jitter randomizes the interval to return a value of [0.5*millis .. 1.5*millis].
backoff.go:127
↓ 1 callersMethodmonitor
()
cluster-test/cluster-test.go:163
↓ 1 callersFunctionnewBulkProcessor
( client *Client, beforeFn BulkBeforeFunc, afterFn BulkAfterFunc, name string, numWorkers int, bulkActio
bulk_processor.go:284
↓ 1 callersFunctionnewBulkProcessorStats
newBulkProcessorStats initializes and returns a BulkProcessorStats struct.
bulk_processor.go:217
↓ 1 callersFunctionnewBulkWorker
newBulkWorker creates a new bulkWorker instance.
bulk_processor.go:456
↓ 1 callersMethodnext
-- Next --
scroll.go:551
↓ 1 callersFunctionparseExpression
(expression string)
uritemplates/uritemplates.go:112
↓ 1 callersFunctionparseTerm
(term string)
uritemplates/uritemplates.go:162
↓ 1 callersFunctionpopulate
populate will fill an example index.
recipes/search_with_point_in_time/search.go:98
↓ 1 callersMethodrawScriptSource
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 callersMethodremoveBlankIndexNames
()
indices_put_alias.go:46
↓ 1 callersMethodremoveBlankIndexNames
()
indices_put_alias.go:162
↓ 1 callersMethodsearch
()
cluster-test/cluster-test.go:289
↓ 1 callersMethodsetBodyJson
setBodyJson encodes the body as a struct to be marshaled via json.Marshal.
request.go:54
↓ 1 callersMethodsetBodyString
setBodyString encodes the body as a string.
request.go:65
↓ 1 callersFunctionsetSpanStatus
See https://github.com/opencensus-integrations/ocsql/blob/master/driver.go#L749
trace/opencensus/transport.go:84
↓ 1 callersMethodsetup
()
cluster-test/cluster-test.go:185
↓ 1 callersFunctionsetupTestClientAndCreateIndexAndAddDocsNoSource
(t logger, options ...ClientOptionFunc)
setup_test.go:462
↓ 1 callersMethodsourceAsMap
source returns the search source. It is used by Reindex.
search_request.go:567
↓ 1 callersMethodstartupHealthcheck
startupHealthcheck is used at startup to check if the server is available at all.
client.go:1173
↓ 1 callersFunctiontestClusterRerouteWithCommands
(client *Client, t *testing.T)
cluster_reroute_test.go:66
↓ 1 callersFunctiontestClusterRerouteWithoutBody
(client *Client, t *testing.T)
cluster_reroute_test.go:107
↓ 1 callersFunctiontestIntervalQueryFuzzy
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:172
↓ 1 callersFunctiontestIntervalQueryMatch
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:31
↓ 1 callersFunctiontestIntervalQueryPrefix
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:78
↓ 1 callersFunctiontestIntervalQueryWildcard
(client *Client, t *testing.T)
search_queries_interval_integration_test.go:125
↓ 1 callersMethodupdateConns
updateConns updates the clients' connections with new information gather by a sniff operation.
client.go:1040
↓ 1 callersMethodupdateStats
(res *BulkResponse)
bulk_processor.go:623
↓ 1 callersMethodwaitForActiveConnection
(ready chan<- struct{})
bulk_processor.go:594
↓ 1 callersMethodwork
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
MethodAbortOnVersionConflict
AbortOnVersionConflict aborts the request on version conflicts. It is an alias to setting Conflicts("abort").
reindex.go:188
MethodAbortOnVersionConflict
AbortOnVersionConflict aborts the request on version conflicts. It is an alias to setting Conflicts("abort").
update_by_query.go:202
MethodAbortOnVersionConflict
AbortOnVersionConflict aborts the request on version conflicts. It is an alias to setting Conflicts("abort").
delete_by_query.go:190
MethodAccuracy
(accuracy float64)
suggester_phrase.go:455
MethodAccuracy
(accuracy float64)
suggester_term.go:84
MethodActions
Actions is a list of actions that should be returned. Leave empty to return all.
tasks_list.go:96
MethodActions
Actions is a list of actions that should be cancelled. Leave empty to cancel all.
tasks_cancel.go:101
MethodActive
Active specifies whether the watch is in/active by default.
xpack_watcher_put_watch.go:92
MethodAdd
Add adds a score function that will execute on all the documents matching the filter.
search_queries_fsq.go:48
MethodAdd
Add clauses to use in the query.
search_queries_span_near.go:29
MethodAddBucketsPath
AddBucketsPath adds a bucket path to use for this pipeline aggregator.
search_aggs_pipeline_bucket_selector.go:76
MethodAddMaskRangeWithKey
(key, mask string)
search_aggs_bucket_ip_range.go:59
MethodAddRange
(from, to interface{})
search_aggs_bucket_geo_distance.go:68
MethodAddRange
(from, to string)
search_aggs_bucket_ip_range.go:64
MethodAddRange
(from, to interface{})
search_aggs_bucket_date_range.go:85
MethodAddRangeWithKey
(key string, from, to interface{})
search_aggs_bucket_geo_distance.go:73
MethodAddRangeWithKey
(key, from, to string)
search_aggs_bucket_ip_range.go:69
MethodAddRangeWithKey
(key string, from, to interface{})
search_aggs_bucket_date_range.go:90
MethodAddRangeWithKey
(key string, from, to interface{})
search_aggs_bucket_range.go:84
MethodAddUnboundedFrom
(to float64)
search_aggs_bucket_geo_distance.go:88
MethodAddUnboundedFrom
(to string)
search_aggs_bucket_ip_range.go:84
MethodAddUnboundedFrom
(to interface{})
search_aggs_bucket_date_range.go:105
MethodAddUnboundedFromWithKey
(key string, to float64)
search_aggs_bucket_geo_distance.go:93
MethodAddUnboundedFromWithKey
(key, to string)
search_aggs_bucket_ip_range.go:89
MethodAddUnboundedFromWithKey
(key string, to interface{})
search_aggs_bucket_date_range.go:110
← previousnext →1,401–1,500 of 5,566, ranked by callers