recovery

package
v8.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 17, 2024 License: Apache-2.0 Imports: 11 Imported by: 4

Documentation

Overview

Get index recovery information. Get information about ongoing and completed shard recoveries for one or more indices. For data streams, the API returns information for the stream's backing indices.

Shard recovery is the process of initializing a shard copy, such as restoring a primary shard from a snapshot or creating a replica shard from a primary shard. When a shard recovery completes, the recovered shard is available for search and indexing.

Recovery automatically occurs during the following processes:

* When creating an index for the first time. * When a node rejoins the cluster and starts up any missing primary shard copies using the data that it holds in its data path. * Creation of new replica shard copies from the primary. * Relocation of a shard copy to a different node in the same cluster. * A snapshot restore operation. * A clone, shrink, or split operation.

You can determine the cause of a shard recovery using the recovery or cat recovery APIs.

The index recovery API reports information about completed recoveries only for shard copies that currently exist in the cluster. It only reports the last recovery for each shard copy and does not report historical information about earlier recoveries, nor does it report information about the recoveries of shard copies that no longer exist. This means that if a shard copy completes a recovery and then Elasticsearch relocates it onto a different node then the information about the original recovery will not be shown in the recovery API.

Index

Constants

This section is empty.

Variables

View Source
var ErrBuildPath = errors.New("cannot build path, check for missing path parameters")

ErrBuildPath is returned in case of missing parameters within the build of the request.

Functions

This section is empty.

Types

type NewRecovery

type NewRecovery func() *Recovery

NewRecovery type alias for index.

func NewRecoveryFunc

func NewRecoveryFunc(tp elastictransport.Interface) NewRecovery

NewRecoveryFunc returns a new instance of Recovery with the provided transport. Used in the index of the library this allows to retrieve every apis in once place.

type Recovery

type Recovery struct {
	// contains filtered or unexported fields
}

func New

Get index recovery information. Get information about ongoing and completed shard recoveries for one or more indices. For data streams, the API returns information for the stream's backing indices.

Shard recovery is the process of initializing a shard copy, such as restoring a primary shard from a snapshot or creating a replica shard from a primary shard. When a shard recovery completes, the recovered shard is available for search and indexing.

Recovery automatically occurs during the following processes:

* When creating an index for the first time. * When a node rejoins the cluster and starts up any missing primary shard copies using the data that it holds in its data path. * Creation of new replica shard copies from the primary. * Relocation of a shard copy to a different node in the same cluster. * A snapshot restore operation. * A clone, shrink, or split operation.

You can determine the cause of a shard recovery using the recovery or cat recovery APIs.

The index recovery API reports information about completed recoveries only for shard copies that currently exist in the cluster. It only reports the last recovery for each shard copy and does not report historical information about earlier recoveries, nor does it report information about the recoveries of shard copies that no longer exist. This means that if a shard copy completes a recovery and then Elasticsearch relocates it onto a different node then the information about the original recovery will not be shown in the recovery API.

https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-recovery.html

func (*Recovery) ActiveOnly

func (r *Recovery) ActiveOnly(activeonly bool) *Recovery

ActiveOnly If `true`, the response only includes ongoing shard recoveries. API name: active_only

func (*Recovery) Detailed

func (r *Recovery) Detailed(detailed bool) *Recovery

Detailed If `true`, the response includes detailed information about shard recoveries. API name: detailed

func (Recovery) Do

func (r Recovery) Do(providedCtx context.Context) (Response, error)

Do runs the request through the transport, handle the response and returns a recovery.Response

func (*Recovery) ErrorTrace added in v8.14.0

func (r *Recovery) ErrorTrace(errortrace bool) *Recovery

ErrorTrace When set to `true` Elasticsearch will include the full stack trace of errors when they occur. API name: error_trace

func (*Recovery) FilterPath added in v8.14.0

func (r *Recovery) FilterPath(filterpaths ...string) *Recovery

FilterPath Comma-separated list of filters in dot notation which reduce the response returned by Elasticsearch. API name: filter_path

func (*Recovery) Header

func (r *Recovery) Header(key, value string) *Recovery

Header set a key, value pair in the Recovery headers map.

func (*Recovery) HttpRequest

func (r *Recovery) HttpRequest(ctx context.Context) (*http.Request, error)

HttpRequest returns the http.Request object built from the given parameters.

func (*Recovery) Human added in v8.14.0

func (r *Recovery) Human(human bool) *Recovery

Human When set to `true` will return statistics in a format suitable for humans. For example `"exists_time": "1h"` for humans and `"eixsts_time_in_millis": 3600000` for computers. When disabled the human readable values will be omitted. This makes sense for responses being consumed only by machines. API name: human

func (*Recovery) Index

func (r *Recovery) Index(index string) *Recovery

Index Comma-separated list of data streams, indices, and aliases used to limit the request. Supports wildcards (`*`). To target all data streams and indices, omit this parameter or use `*` or `_all`. API Name: index

func (Recovery) IsSuccess

func (r Recovery) IsSuccess(providedCtx context.Context) (bool, error)

IsSuccess allows to run a query with a context and retrieve the result as a boolean. This only exists for endpoints without a request payload and allows for quick control flow.

func (Recovery) Perform added in v8.7.0

func (r Recovery) Perform(providedCtx context.Context) (*http.Response, error)

Perform runs the http.Request through the provided transport and returns an http.Response.

func (*Recovery) Pretty added in v8.14.0

func (r *Recovery) Pretty(pretty bool) *Recovery

Pretty If set to `true` the returned JSON will be "pretty-formatted". Only use this option for debugging only. API name: pretty

type Response added in v8.7.0

type Response map[string]types.RecoveryStatus

func NewResponse added in v8.7.0

func NewResponse() Response

NewResponse returns a Response

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL