opensearchapi

package
v4.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2025 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Overview

SPDX-License-Identifier: Apache-2.0

The OpenSearch Contributors require contributions made to this file be licensed under the Apache-2.0 license or a compatible open source license.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ToPointer 

func ToPointer[V any](value V) *V

ToPointer converts any value to a pointer, mainly used for request parameters

Types

type AliasDeleteParams 

type AliasDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

AliasDeleteParams represents possible parameters for the AliasDeleteReq

type AliasDeleteReq 

type AliasDeleteReq struct {
	Indices []string
	Alias   []string

	Header http.Header
	Params AliasDeleteParams
}

AliasDeleteReq represents possible options for the alias delete request

func (AliasDeleteReq) GetRequest 

func (r AliasDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type AliasDeleteResp 

type AliasDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

AliasDeleteResp represents the returned struct of the alias delete response

func (AliasDeleteResp) Inspect 

func (r AliasDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type AliasExistsParams 

type AliasExistsParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	IgnoreUnavailable *bool
	Local             *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

AliasExistsParams represents possible parameters for the AliasExistsReq

type AliasExistsReq 

type AliasExistsReq struct {
	Indices []string
	Alias   []string

	Header http.Header
	Params AliasExistsParams
}

AliasExistsReq represents possible options for the alias exists request

func (AliasExistsReq) GetRequest 

func (r AliasExistsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type AliasGetParams 

type AliasGetParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	IgnoreUnavailable *bool
	Local             *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

AliasGetParams represents possible parameters for the AliasGetReq

type AliasGetReq 

type AliasGetReq struct {
	Indices []string
	Alias   []string

	Header http.Header
	Params AliasGetParams
}

AliasGetReq represents possible options for the alias get request

func (AliasGetReq) GetRequest 

func (r AliasGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type AliasGetResp 

type AliasGetResp struct {
	Indices map[string]struct {
		Aliases map[string]json.RawMessage `json:"aliases"`
	}
	// contains filtered or unexported fields
}

AliasGetResp represents the returned struct of the alias get response

func (AliasGetResp) Inspect 

func (r AliasGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type AliasPutParams 

type AliasPutParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

AliasPutParams represents possible parameters for the AliasPutReq

type AliasPutReq 

type AliasPutReq struct {
	Indices []string
	Alias   string

	Header http.Header
	Params AliasPutParams
}

AliasPutReq represents possible options for the alias put request

func (AliasPutReq) GetRequest 

func (r AliasPutReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type AliasPutResp 

type AliasPutResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

AliasPutResp represents the returned struct of the alias put response

func (AliasPutResp) Inspect 

func (r AliasPutResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type AliasesParams 

type AliasesParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

AliasesParams represents possible parameters for the AliasesReq

type AliasesReq 

type AliasesReq struct {
	Body io.Reader

	Header http.Header
	Params AliasesParams
}

AliasesReq represents possible options for the / request

func (AliasesReq) GetRequest 

func (r AliasesReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type AliasesResp 

type AliasesResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

AliasesResp represents the returned struct of the / response

func (AliasesResp) Inspect 

func (r AliasesResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type BulkParams 

type BulkParams struct {
	Pipeline            string
	Refresh             string
	RequireAlias        *bool
	Routing             string
	Source              any
	SourceExcludes      []string
	SourceIncludes      []string
	Timeout             time.Duration
	WaitForActiveShards string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

BulkParams represents possible parameters for the BulkReq

type BulkReq 

type BulkReq struct {
	Index  string
	Body   io.Reader
	Header http.Header
	Params BulkParams
}

BulkReq represents possible options for the /_bulk request

func (BulkReq) GetRequest 

func (r BulkReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type BulkResp 

type BulkResp struct {
	Took   int                       `json:"took"`
	Errors bool                      `json:"errors"`
	Items  []map[string]BulkRespItem `json:"items"`
	// contains filtered or unexported fields
}

BulkResp represents the returned struct of the /_bulk response

func (BulkResp) Inspect 

func (r BulkResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type BulkRespItem 

type BulkRespItem struct {
	Index   string `json:"_index"`
	ID      string `json:"_id"`
	Version int    `json:"_version"`
	Type    string `json:"_type"` // Deprecated field
	Result  string `json:"result"`
	Shards  struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	SeqNo       int `json:"_seq_no"`
	PrimaryTerm int `json:"_primary_term"`
	Status      int `json:"status"`
	Error       *struct {
		Type   string `json:"type"`
		Reason string `json:"reason"`
		Cause  struct {
			Type        string    `json:"type"`
			Reason      string    `json:"reason"`
			ScriptStack *[]string `json:"script_stack,omitempty"`
			Script      *string   `json:"script,omitempty"`
			Lang        *string   `json:"lang,omitempty"`
			Position    *struct {
				Offset int `json:"offset"`
				Start  int `json:"start"`
				End    int `json:"end"`
			} `json:"position,omitempty"`
			Cause *struct {
				Type   string  `json:"type"`
				Reason *string `json:"reason"`
			} `json:"caused_by"`
		} `json:"caused_by,omitempty"`
	} `json:"error,omitempty"`
}

BulkRespItem represents an item of the BulkResp

type CatAliasResp 

type CatAliasResp struct {
	Alias         string `json:"alias"`
	Index         string `json:"index"`
	Filter        string `json:"filter"`
	RoutingIndex  string `json:"routing.index"`
	RoutingSearch string `json:"routing.search"`
	IsWriteIndex  string `json:"is_write_index"`
}

CatAliasResp represents one index of the CatAliasesResp

type CatAliasesParams 

type CatAliasesParams struct {
	ExpandWildcards string
	H               []string
	Local           *bool
	Sort            []string
	V               *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatAliasesParams represents possible parameters for the CatAliasesReq

type CatAliasesReq 

type CatAliasesReq struct {
	Aliases []string
	Header  http.Header
	Params  CatAliasesParams
}

CatAliasesReq represent possible options for the /_cat/aliases request

func (CatAliasesReq) GetRequest 

func (r CatAliasesReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatAliasesResp 

type CatAliasesResp struct {
	Aliases []CatAliasResp
	// contains filtered or unexported fields
}

CatAliasesResp represents the returned struct of the /_cat/aliases response

func (CatAliasesResp) Inspect 

func (r CatAliasesResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatAllocationParams 

type CatAllocationParams struct {
	Bytes                 string
	ExpandWildcards       string
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatAllocationParams represents possible parameters for the CatAllocationReq

type CatAllocationReq 

type CatAllocationReq struct {
	NodeIDs []string
	Header  http.Header
	Params  CatAllocationParams
}

CatAllocationReq represent possible options for the /_cat/allocation request

func (CatAllocationReq) GetRequest 

func (r CatAllocationReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatAllocationResp 

type CatAllocationResp struct {
	Shards int `json:"shards,string"`
	// Pointer of string as the api can returns null for those fileds with Node set to "UNASSIGNED"
	DiskIndices *string `json:"disk.indices"`
	DiskUsed    *string `json:"disk.used"`
	DiskAvail   *string `json:"disk.avail"`
	DiskTotal   *string `json:"disk.total"`
	DiskPercent *int    `json:"disk.percent,string"`
	Host        *string `json:"host"`
	IP          *string `json:"ip"`
	Node        string  `json:"node"`
}

CatAllocationResp represents one index of the CatAllocationResp

type CatAllocationsResp 

type CatAllocationsResp struct {
	Allocations []CatAllocationResp
	// contains filtered or unexported fields
}

CatAllocationsResp represents the returned struct of the /_cat/allocation response

func (CatAllocationsResp) Inspect 

func (r CatAllocationsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatClusterManagerParams 

type CatClusterManagerParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatClusterManagerParams represents possible parameters for the CatClusterManagerReq

type CatClusterManagerReq 

type CatClusterManagerReq struct {
	Header http.Header
	Params CatClusterManagerParams
}

CatClusterManagerReq represent possible options for the /_cat/cluster_manager request

func (CatClusterManagerReq) GetRequest 

func (r CatClusterManagerReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatClusterManagerResp 

type CatClusterManagerResp struct {
	ID   string `json:"id"`
	Host string `json:"host"`
	IP   string `json:"ip"`
	Node string `json:"node"`
}

CatClusterManagerResp represents one index of the CatClusterManagerResp

type CatClusterManagersResp 

type CatClusterManagersResp struct {
	ClusterManagers []CatClusterManagerResp
	// contains filtered or unexported fields
}

CatClusterManagersResp represents the returned struct of the /_cat/cluster_manager response

func (CatClusterManagersResp) Inspect 

func (r CatClusterManagersResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatCountParams 

type CatCountParams struct {
	H    []string
	Sort []string
	V    *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatCountParams represents possible parameters for the CatCountReq

type CatCountReq 

type CatCountReq struct {
	Indices []string
	Header  http.Header
	Params  CatCountParams
}

CatCountReq represent possible options for the /_cat/count request

func (CatCountReq) GetRequest 

func (r CatCountReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatCountResp 

type CatCountResp struct {
	Epoch     int    `json:"epoch,string"`
	Timestamp string `json:"timestamp"`
	Count     int    `json:"count,string"`
}

CatCountResp represents one index of the CatCountResp

type CatCountsResp 

type CatCountsResp struct {
	Counts []CatCountResp
	// contains filtered or unexported fields
}

CatCountsResp represents the returned struct of the /_cat/count response

func (CatCountsResp) Inspect 

func (r CatCountsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatFieldDataItemResp 

type CatFieldDataItemResp struct {
	ID    string `json:"id"`
	Host  string `json:"host"`
	IP    string `json:"ip"`
	Node  string `json:"node"`
	Field string `json:"field"`
	Size  string `json:"size"`
}

CatFieldDataItemResp represents one index of the CatFieldDataResp

type CatFieldDataParams 

type CatFieldDataParams struct {
	Bytes string
	H     []string
	Sort  []string
	V     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatFieldDataParams represents possible parameters for the CatFieldDataReq

type CatFieldDataReq 

type CatFieldDataReq struct {
	FieldData []string
	Header    http.Header
	Params    CatFieldDataParams
}

CatFieldDataReq represent possible options for the /_cat/fielddata request

func (CatFieldDataReq) GetRequest 

func (r CatFieldDataReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatFieldDataResp 

type CatFieldDataResp struct {
	FieldData []CatFieldDataItemResp
	// contains filtered or unexported fields
}

CatFieldDataResp represents the returned struct of the /_cat/fielddata response

func (CatFieldDataResp) Inspect 

func (r CatFieldDataResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatHealthItemResp 

type CatHealthItemResp struct {
	Epoch                    int    `json:"epoch,string"`
	Timestamp                string `json:"timestamp"`
	Cluster                  string `json:"cluster"`
	Status                   string `json:"status"`
	NodeTotal                int    `json:"node.total,string"`
	NodeData                 int    `json:"node.data,string"`
	DiscoveredMaster         bool   `json:"discovered_master,string"`
	DiscoveredClusterManager bool   `json:"discovered_cluster_manager,string"`
	Shards                   int    `json:"shards,string"`
	Primary                  int    `json:"pri,string"`
	Relocating               int    `json:"relo,string"`
	Initializing             int    `json:"init,string"`
	Unassigned               int    `json:"unassign,string"`
	PendingTasks             int    `json:"pending_tasks,string"`
	MaxTaskWaitTime          string `json:"max_task_wait_time"`
	ActiveShardsPercent      string `json:"active_shards_percent"`
}

CatHealthItemResp represents one index of the CatHealthResp

type CatHealthParams 

type CatHealthParams struct {
	H    []string
	Sort []string
	Time string
	TS   *bool
	V    *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatHealthParams represents possible parameters for the CatHealthReq

type CatHealthReq 

type CatHealthReq struct {
	Header http.Header
	Params CatHealthParams
}

CatHealthReq represent possible options for the /_cat/health request

func (CatHealthReq) GetRequest 

func (r CatHealthReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatHealthResp 

type CatHealthResp struct {
	Health []CatHealthItemResp
	// contains filtered or unexported fields
}

CatHealthResp represents the returned struct of the /_cat/health response

func (CatHealthResp) Inspect 

func (r CatHealthResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatIndexResp 

type CatIndexResp struct {
	Health             string `json:"health"`
	Status             string `json:"status"`
	Index              string `json:"index"`
	UUID               string `json:"uuid"`
	Primary            *int   `json:"pri,string"`
	Replica            *int   `json:"rep,string"`
	DocsCount          *int   `json:"docs.count,string"`
	DocDeleted         *int   `json:"docs.deleted,string"`
	CreationDate       int    `json:"creation.date,string"`
	CreationDateString string `json:"creation.date.string"`
	// Pointer as newly created indices can return null
	StoreSize                            *string `json:"store.size"`
	PrimaryStoreSize                     *string `json:"pri.store.size"`
	CompletionSize                       *string `json:"completion.size"`
	PrimaryCompletionSize                *string `json:"pri.completion.size"`
	FieldDataMemorySize                  *string `json:"fielddata.memory_size"`
	PrimaryFieldDataMemorySize           *string `json:"pri.fielddata.memory_size"`
	FieldDataEvictions                   *int    `json:"fielddata.evictions,string"`
	PrimaryFieldDataEvictions            *int    `json:"pri.fielddata.evictions,string"`
	QueryCacheMemorySize                 *string `json:"query_cache.memory_size"`
	PrimaryQueryCacheMemorySize          *string `json:"pri.query_cache.memory_size"`
	QueryCacheEvictions                  *int    `json:"query_cache.evictions,string"`
	PrimaryQueryCacheEvictions           *int    `json:"pri.query_cache.evictions,string"`
	RequestCacheMemorySize               *string `json:"request_cache.memory_size"`
	PrimaryRequestCacheMemorySize        *string `json:"pri.request_cache.memory_size"`
	RequestCacheEvictions                *int    `json:"request_cache.evictions,string"`
	PrimaryRequestCacheEvictions         *int    `json:"pri.request_cache.evictions,string"`
	RequestCacheHitCount                 *int    `json:"request_cache.hit_count,string"`
	PrimaryRequestCacheHitCount          *int    `json:"pri.request_cache.hit_count,string"`
	RequestCacheMissCount                *int    `json:"request_cache.miss_count,string"`
	PrimaryRequestCacheMissCount         *int    `json:"pri.request_cache.miss_count,string"`
	FlushTotal                           *int    `json:"flush.total,string"`
	PrimaryFlushTotal                    *int    `json:"pri.flush.total,string"`
	FlushTime                            *string `json:"flush.total_time"`
	PrimaryFlushTime                     *string `json:"pri.flush.total_time"`
	GetCurrent                           *int    `json:"get.current,string"`
	PrimaryGetCurrent                    *int    `json:"pri.get.current,string"`
	GetTime                              *string `json:"get.time"`
	PrimaryGetTime                       *string `json:"pri.get.time"`
	GetTotal                             *int    `json:"get.total,string"`
	PrimaryGetTotal                      *int    `json:"pri.get.total,string"`
	GetExistsTime                        *string `json:"get.exists_time"`
	PrimaryGetExistsTime                 *string `json:"pri.get.exists_time"`
	GetExistsTotal                       *int    `json:"get.exists_total,string"`
	PrimaryGetExistsTotal                *int    `json:"pri.get.exists_total,string"`
	GetMissingTime                       *string `json:"get.missing_time"`
	PrimaryGetMissingTime                *string `json:"pri.get.missing_time"`
	GetMissingTotal                      *int    `json:"get.missing_total,string"`
	PrimaryGetMissingTotal               *int    `json:"pri.get.missing_total,string"`
	IndexingDeleteCurrent                *int    `json:"indexing.delete_current,string"`
	PrimaryIndexingDeleteCurrent         *int    `json:"pri.indexing.delete_current,string"`
	IndexingDeleteTime                   *string `json:"indexing.delete_time"`
	PrimaryIndexingDeleteTime            *string `json:"pri.indexing.delete_time"`
	IndexingDeleteTotal                  *int    `json:"indexing.delete_total,string"`
	PrimaryIndexingDeleteTotal           *int    `json:"pri.indexing.delete_total,string"`
	IndexingIndexCurrent                 *int    `json:"indexing.index_current,string"`
	PrimaryIndexingIndexCurrent          *int    `json:"pri.indexing.index_current,string"`
	IndexingIndexTime                    *string `json:"indexing.index_time"`
	PrimaryIndexingIndexTime             *string `json:"pri.indexing.index_time"`
	IndexingIndexTotal                   *int    `json:"indexing.index_total,string"`
	PrimaryIndexingIndexTotal            *int    `json:"pri.indexing.index_total,string"`
	IndexingIndexFailed                  *int    `json:"indexing.index_failed,string"`
	PrimaryIndexingIndexFailed           *int    `json:"pri.indexing.index_failed,string"`
	MergesCurrent                        *int    `json:"merges.current,string"`
	PrimaryMergesCurrent                 *int    `json:"pri.merges.current,string"`
	MergesCurrentDocs                    *int    `json:"merges.current_docs,string"`
	PrimaryMergesCurrentDocs             *int    `json:"pri.merges.current_docs,string"`
	MergesCurrentSize                    *string `json:"merges.current_size"`
	PrimaryMergesCurrentSize             *string `json:"pri.merges.current_size"`
	MergesTotal                          *int    `json:"merges.total,string"`
	PrimaryMergesTotal                   *int    `json:"pri.merges.total,string"`
	MergesTotalDocs                      *int    `json:"merges.total_docs,string"`
	PrimaryMergesTotalDocs               *int    `json:"pri.merges.total_docs,string"`
	MergesTotalSize                      *string `json:"merges.total_size"`
	PrimaryMergesTotalSize               *string `json:"pri.merges.total_size"`
	MergesTotalTime                      *string `json:"merges.total_time"`
	PrimaryMergesTotalTime               *string `json:"pri.merges.total_time"`
	RefreshTotal                         *int    `json:"refresh.total,string"`
	PrimaryRefreshTotal                  *int    `json:"pri.refresh.total,string"`
	RefreshTime                          *string `json:"refresh.time"`
	PrimaryRefreshTime                   *string `json:"pri.refresh.time"`
	RefreshExternalTotal                 *int    `json:"refresh.external_total,string"`
	PrimaryRefreshExternalTotal          *int    `json:"pri.refresh.external_total,string"`
	RefreshExternalTime                  *string `json:"refresh.external_time"`
	PrimaryRefreshExternalTime           *string `json:"pri.refresh.external_time"`
	RefreshListeners                     *int    `json:"refresh.listeners,string"`
	PrimaryRefreshListeners              *int    `json:"pri.refresh.listeners,string"`
	SearchFetchCurrent                   *int    `json:"search.fetch_current,string"`
	PrimarySearchFetchCurrent            *int    `json:"pri.search.fetch_current,string"`
	SearchFetchTime                      *string `json:"search.fetch_time"`
	PrimarySearchFetchTime               *string `json:"pri.search.fetch_time"`
	SearchFetchTotal                     *int    `json:"search.fetch_total,string"`
	PrimarySearchFetchTotal              *int    `json:"pri.search.fetch_total,string"`
	SearchOpenContexts                   *int    `json:"search.open_contexts,string"`
	PrimarySearchOpenContexts            *int    `json:"pri.search.open_contexts,string"`
	SearchQueryCurrent                   *int    `json:"search.query_current,string"`
	PrimarySearchQueryCurrent            *int    `json:"pri.search.query_current,string"`
	SearchQueryTime                      *string `json:"search.query_time"`
	PrimarySearchQueryTime               *string `json:"pri.search.query_time"`
	SearchQueryTotal                     *int    `json:"search.query_total,string"`
	PrimarySearchQueryTotal              *int    `json:"pri.search.query_total,string"`
	SearchConcurrentQueryCurrent         *int    `json:"search.concurrent_query_current,string"`
	PrimarySearchConcurrentQueryCurrent  *int    `json:"pri.search.concurrent_query_current,string"`
	SearchConcurrentQueryTime            *string `json:"search.concurrent_query_time"`
	PrimarySearchConcurrentQueryTime     *string `json:"pri.search.concurrent_query_time"`
	SearchConcurrentQueryTotal           *int    `json:"search.concurrent_query_total,string"`
	PrimarySearchConcurrentQueryTotal    *int    `json:"pri.search.concurrent_query_total,string"`
	SearchConcurrentAvgSliceCount        *string `json:"search.concurrent_avg_slice_count"`
	PrimarySearchConcurrentAvgSliceCount *string `json:"pri.search.concurrent_avg_slice_count"`
	SearchScrollCurrent                  *int    `json:"search.scroll_current,string"`
	PrimarySearchScrollCurrent           *int    `json:"pri.search.scroll_current,string"`
	SearchScrollTime                     *string `json:"search.scroll_time"`
	PrimarySearchScrollTime              *string `json:"pri.search.scroll_time"`
	SearchScrollTotal                    *int    `json:"search.scroll_total,string"`
	PrimarySearchScrollTotal             *int    `json:"pri.search.scroll_total,string"`
	SearchPointInTimeCurrent             *string `json:"search.point_in_time_current"`
	PrimarySearchPointInTimeCurrent      *string `json:"pri.search.point_in_time_current"`
	SearchPointInTimeTime                *string `json:"search.point_in_time_time"`
	PrimarySearchPointInTimeTime         *string `json:"pri.search.point_in_time_time"`
	SearchPointInTimeTotal               *int    `json:"search.point_in_time_total,string"`
	PrimarySearchPointInTimeTotal        *int    `json:"pri.search.point_in_time_total,string"`
	SegmentsCount                        *int    `json:"segments.count,string"`
	PrimarySegmentsCount                 *int    `json:"pri.segments.count,string"`
	SegmentsMemory                       *string `json:"segments.memory"`
	PrimarySegmentsMemory                *string `json:"pri.segments.memory"`
	SegmentsIndexWriteMemory             *string `json:"segments.index_writer_memory"`
	PrimarySegmentsIndexWriteMemory      *string `json:"pri.segments.index_writer_memory"`
	SegmentsVersionMapMemory             *string `json:"segments.version_map_memory"`
	PrimarySegmentsVersionMapMemory      *string `json:"pri.segments.version_map_memory"`
	SegmentsFixedBitsetMemory            *string `json:"segments.fixed_bitset_memory"`
	PrimarySegmentsFixedBitsetMemory     *string `json:"pri.segments.fixed_bitset_memory"`
	WarmerCurrent                        *int    `json:"warmer.current,string"`
	PrimaryWarmerCurrent                 *int    `json:"pri.warmer.current,string"`
	WarmerTotal                          *int    `json:"warmer.total,string"`
	PrimaryWarmerTotal                   *int    `json:"pri.warmer.total,string"`
	WarmerTotalTime                      *string `json:"warmer.total_time"`
	PrimaryWarmerTotalTime               *string `json:"pri.warmer.total_time"`
	SuggestCurrent                       *int    `json:"suggest.current,string"`
	PrimarySuggestCurrent                *int    `json:"pri.suggest.current,string"`
	SuggestTime                          *string `json:"suggest.time"`
	PrimarySuggestTime                   *string `json:"pri.suggest.time"`
	SuggestTotal                         *int    `json:"suggest.total,string"`
	PrimarySuggestTotal                  *int    `json:"pri.suggest.total,string"`
	MemoryTotal                          string  `json:"memory.total"`
	PrimaryMemoryTotal                   string  `json:"pri.memory.total"`
	SearchThrottled                      bool    `json:"search.throttled,string"`
}

CatIndexResp represents one index of the CatIndicesResp

type CatIndicesParams 

type CatIndicesParams struct {
	Bytes                   string
	ExpandWildcards         string
	H                       []string
	Health                  string
	IncludeUnloadedSegments *bool
	Local                   *bool
	MasterTimeout           time.Duration
	ClusterManagerTimeout   time.Duration
	Primary                 *bool
	Sort                    []string
	Time                    string
	V                       *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatIndicesParams represents possible parameters for the CatIndicesReq

type CatIndicesReq 

type CatIndicesReq struct {
	Indices []string
	Header  http.Header
	Params  CatIndicesParams
}

CatIndicesReq represent possible options for the /_cat/indices request

func (CatIndicesReq) GetRequest 

func (r CatIndicesReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatIndicesResp 

type CatIndicesResp struct {
	Indices []CatIndexResp
	// contains filtered or unexported fields
}

CatIndicesResp represents the returned struct of the /_cat/indices response

func (CatIndicesResp) Inspect 

func (r CatIndicesResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatMasterItemResp 

type CatMasterItemResp struct {
	ID   string `json:"id"`
	Host string `json:"host"`
	IP   string `json:"ip"`
	Node string `json:"node"`
}

CatMasterItemResp represents one index of the CatMasterResp

type CatMasterParams 

type CatMasterParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatMasterParams represents possible parameters for the CatMasterReq

type CatMasterReq 

type CatMasterReq struct {
	Header http.Header
	Params CatMasterParams
}

CatMasterReq represent possible options for the /_cat/master request

func (CatMasterReq) GetRequest 

func (r CatMasterReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatMasterResp 

type CatMasterResp struct {
	Master []CatMasterItemResp
	// contains filtered or unexported fields
}

CatMasterResp represents the returned struct of the /_cat/master response

func (CatMasterResp) Inspect 

func (r CatMasterResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatNodeAttrsItemResp 

type CatNodeAttrsItemResp struct {
	Node  string `json:"node"`
	ID    string `json:"id"`
	PID   *int   `json:"pid,string"`
	Host  string `json:"host"`
	IP    string `json:"ip"`
	Port  int    `json:"port,string"`
	Attr  string `json:"attr"`
	Value string `json:"value"`
}

CatNodeAttrsItemResp represents one index of the CatNodeAttrsResp

type CatNodeAttrsParams 

type CatNodeAttrsParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatNodeAttrsParams represents possible parameters for the CatNodeAttrsReq

type CatNodeAttrsReq 

type CatNodeAttrsReq struct {
	Header http.Header
	Params CatNodeAttrsParams
}

CatNodeAttrsReq represent possible options for the /_cat/nodeattrs request

func (CatNodeAttrsReq) GetRequest 

func (r CatNodeAttrsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatNodeAttrsResp 

type CatNodeAttrsResp struct {
	NodeAttrs []CatNodeAttrsItemResp
	// contains filtered or unexported fields
}

CatNodeAttrsResp represents the returned struct of the /_cat/nodeattrs response

func (CatNodeAttrsResp) Inspect 

func (r CatNodeAttrsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatNodesItemResp 

type CatNodesItemResp struct {
	ID                              string  `json:"id"`
	PID                             *string `json:"pid"`
	IP                              string  `json:"ip"`
	Port                            int     `json:"port,string"`
	HTTPAddress                     string  `json:"http_address"`
	Version                         string  `json:"version"`
	Type                            *string `json:"type"`
	Build                           *string `json:"build"`
	JDK                             *string `json:"jdk"`
	DiskTotal                       *string `json:"disk.total"`
	DiskUsed                        *string `json:"disk.used"`
	DiskAvail                       *string `json:"disk.avail"`
	DiskUsedPercent                 *string `json:"disk.used_percent"`
	HeapCurrent                     *string `json:"heap.current"`
	HeapPercent                     *int    `json:"heap.percent,string"`
	HeapMax                         *string `json:"heap.max"`
	RAMCurrent                      *string `json:"ram.current"`
	RAMPercent                      *int    `json:"ram.percent,string"`
	RAMMax                          *string `json:"ram.max"`
	FileDescCurrent                 *int    `json:"file_desc.current,string"`
	FileDescPercent                 *int    `json:"file_desc.percent,string"`
	FileDescMax                     *int    `json:"file_desc.max,string"`
	CPU                             *int    `json:"cpu,string"`
	Load1M                          *string `json:"load_1m"`
	Load5M                          *string `json:"load_5m"`
	Load15M                         *string `json:"load_15m"`
	Uptime                          *string `json:"uptime"`
	Role                            string  `json:"node.role"`
	Roles                           string  `json:"node.roles"`
	Master                          string  `json:"master"`
	ClusterManager                  string  `json:"cluster_manager"`
	Name                            string  `json:"name"`
	CompletionSize                  *string `json:"completion.size"`
	FieldDataMemorySize             *string `json:"fielddata.memory_size"`
	FileldDataEvictions             *int    `json:"fielddata.evictions,string"`
	QueryCacheMemorySize            *string `json:"query_cache.memory_size"`
	QueryCacheEvictions             *int    `json:"query_cache.evictions,string"`
	QueryCacheHitCount              *int    `json:"query_cache.hit_count,string"`
	QueryCacheMissCount             *int    `json:"query_cache.miss_count,string"`
	RequestCacheMemorySize          *string `json:"request_cache.memory_size"`
	RequestCacheEvictions           *int    `json:"request_cache.evictions,string"`
	RequestCacheHitCount            *int    `json:"request_cache.hit_count,string"`
	RequestCacheMissCount           *int    `json:"request_cache.miss_count,string"`
	FlushTotal                      *int    `json:"flush.total,string"`
	FlushTotalTime                  *string `json:"flush.total_time"`
	GetCurrent                      *int    `json:"get.current,string"`
	GetTime                         *string `json:"get.time"`
	GetTotal                        *int    `json:"get.total,string"`
	GetExistsTime                   *string `json:"get.exists_time"`
	GetExistsTotal                  *int    `json:"get.exists_total,string"`
	GetMissingTime                  *string `json:"get.missing_time"`
	GetMissingTotal                 *int    `json:"get.missing_total,string"`
	IndexingDeleteCurrent           *int    `json:"indexing.delete_current,string"`
	IndexingDeleteTime              *string `json:"indexing.delete_time"`
	IndexingDeleteTotal             *int    `json:"indexing.delete_total,string"`
	IndexingIndexCurrent            *int    `json:"indexing.index_current,string"`
	IndexingIndexTime               *string `json:"indexing.index_time"`
	IndexingIndexTotal              *int    `json:"indexing.index_total,string"`
	IndexingIndexFailed             *int    `json:"indexing.index_failed,string"`
	MergesCurrent                   *int    `json:"merges.current,string"`
	MergesCurrentDoc                *int    `json:"merges.current_docs,string"`
	MergesCurrentSize               *string `json:"merges.current_size"`
	MergesTotal                     *int    `json:"merges.total,string"`
	MergesTotalDocs                 *int    `json:"merges.total_docs,string"`
	MergesTotalSize                 *string `json:"merges.total_size"`
	MergesTotalTime                 *string `json:"merges.total_time"`
	RefreshTotal                    *int    `json:"refresh.total,string"`
	RefreshTime                     *string `json:"refresh.time"`
	RefreshExternalTotal            *int    `json:"refresh.external_total,string"`
	RefreshExternalTime             *string `json:"refresh.external_time"`
	RefreshListeners                *int    `json:"refresh.listeners,string"`
	ScriptCompilations              *int    `json:"script.compilations,string"`
	ScriptCacheEvictions            *int    `json:"script.cache_evictions,string"`
	ScriptCompilationLimitTriggered *int    `json:"script.compilation_limit_triggered,string"`
	SearchFetchCurrent              *int    `json:"search.fetch_current,string"`
	SearchFetchTime                 *string `json:"search.fetch_time"`
	SearchFetchTotal                *int    `json:"search.fetch_total,string"`
	SearchOpenContexts              *int    `json:"search.open_contexts,string"`
	SearchQueryCurrent              *int    `json:"search.query_current,string"`
	SearchQueryTime                 *string `json:"search.query_time"`
	SearchQueryTotal                *int    `json:"search.query_total,string"`
	SearchConcurrentQueryCurrent    *int    `json:"search.concurrent_query_current,string"`
	SearchConcurrentQueryTime       *string `json:"search.concurrent_query_time"`
	SearchConcurrentQueryTotal      *int    `json:"search.concurrent_query_total,string"`
	SearchConcurrentAvgSliceCount   *string `json:"search.concurrent_avg_slice_count"`
	SearchScrollCurrent             *int    `json:"search.scroll_current,string"`
	SearchScrollTime                *string `json:"search.scroll_time"`
	SearchScrollTotal               *int    `json:"search.scroll_total,string"`
	SearchPointInTimeCurrent        *int    `json:"search.point_in_time_current,string"`
	SearchPointInTimeTime           *string `json:"search.point_in_time_time"`
	SearchPointInTimeTotal          *int    `json:"search.point_in_time_total,string"`
	SegmentsCount                   *int    `json:"segments.count,string"`
	SegmentsMemory                  *string `json:"segments.memory"`
	SegmentsIndexWriteMemory        *string `json:"segments.index_writer_memory"`
	SegmentsVersionMapMemory        *string `json:"segments.version_map_memory"`
	SegmentsFixedBitsetMemory       *string `json:"segments.fixed_bitset_memory"`
	SuggestCurrent                  *int    `json:"suggest.current,string"`
	SuggestTime                     *string `json:"suggest.time"`
	SuggestTotal                    *int    `json:"suggest.total,string"`
}

CatNodesItemResp represents one index of the CatNodesResp

type CatNodesParams 

type CatNodesParams struct {
	Bytes                   string
	FullID                  *bool
	H                       []string
	IncludeUnloadedSegments *bool
	Local                   *bool
	MasterTimeout           time.Duration
	ClusterManagerTimeout   time.Duration
	Sort                    []string
	Time                    string
	V                       *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatNodesParams represents possible parameters for the CatNodesReq

type CatNodesReq 

type CatNodesReq struct {
	Header http.Header
	Params CatNodesParams
}

CatNodesReq represent possible options for the /_cat/nodes request

func (CatNodesReq) GetRequest 

func (r CatNodesReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatNodesResp 

type CatNodesResp struct {
	Nodes []CatNodesItemResp
	// contains filtered or unexported fields
}

CatNodesResp represents the returned struct of the /_cat/nodes response

func (CatNodesResp) Inspect 

func (r CatNodesResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatPendingTaskResp 

type CatPendingTaskResp struct {
	InsertOrder string `json:"insertOrder"`
	TimeInQueue string `json:"timeInQueue"`
	Priority    string `json:"priority"`
	Source      string `json:"source"`
}

CatPendingTaskResp represents one index of the CatPendingTasksResp

type CatPendingTasksParams 

type CatPendingTasksParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	Time                  string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatPendingTasksParams represents possible parameters for the CatPendingTasksReq

type CatPendingTasksReq 

type CatPendingTasksReq struct {
	Header http.Header
	Params CatPendingTasksParams
}

CatPendingTasksReq represent possible options for the /_cat/pending_tasks request

func (CatPendingTasksReq) GetRequest 

func (r CatPendingTasksReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatPendingTasksResp 

type CatPendingTasksResp struct {
	PendingTasks []CatPendingTaskResp
	// contains filtered or unexported fields
}

CatPendingTasksResp represents the returned struct of the /_cat/pending_tasks response

func (CatPendingTasksResp) Inspect 

func (r CatPendingTasksResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatPluginResp 

type CatPluginResp struct {
	ID          string `json:"id,omitempty"`
	Name        string `json:"name,omitempty"`
	Component   string `json:"component,omitempty"`
	Version     string `json:"version,omitempty"`
	Description string `json:"description,omitempty"`
}

CatPluginResp represents one index of the CatPluginsResp

type CatPluginsParams 

type CatPluginsParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatPluginsParams represents possible parameters for the CatPluginsReq

type CatPluginsReq 

type CatPluginsReq struct {
	Header http.Header
	Params CatPluginsParams
}

CatPluginsReq represent possible options for the /_cat/plugins request

func (CatPluginsReq) GetRequest 

func (r CatPluginsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatPluginsResp 

type CatPluginsResp struct {
	Plugins []CatPluginResp
	// contains filtered or unexported fields
}

CatPluginsResp represents the returned struct of the /_cat/plugins response

func (CatPluginsResp) Inspect 

func (r CatPluginsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatRecoveryItemResp 

type CatRecoveryItemResp struct {
	Index                string `json:"index"`
	Shard                int    `json:"shard,string"`
	StartTime            string `json:"start_time"`
	StartTimeMillis      int    `json:"start_time_millis,string"`
	StopTime             string `json:"stop_time"`
	StopTimeMillis       int    `json:"stop_time_millis,string"`
	Time                 string `json:"time"`
	Type                 string `json:"type"`
	Stage                string `json:"stage"`
	SourceHost           string `json:"source_host"`
	SourceNode           string `json:"source_node"`
	TargetHost           string `json:"target_host"`
	TargetNode           string `json:"target_node"`
	Repository           string `json:"repository"`
	Snapshot             string `json:"snapshot"`
	Files                int    `json:"files,string"`
	FilesRecovered       int    `json:"files_recovered,string"`
	FilesPercent         string `json:"files_percent"`
	FilesTotal           int    `json:"files_total,string"`
	Bytes                string `json:"bytes"`
	BytesRecovered       string `json:"bytes_recovered"`
	BytesPercent         string `json:"bytes_percent"`
	BytesTotal           string `json:"bytes_total"`
	TranslogOps          int    `json:"translog_ops,string"`
	TranslogOpsRecovered int    `json:"translog_ops_recovered,string"`
	TranslogOpsPercent   string `json:"translog_ops_percent"`
}

CatRecoveryItemResp represents one index of the CatRecoveryResp

type CatRecoveryParams 

type CatRecoveryParams struct {
	ActiveOnly *bool
	Bytes      string
	Detailed   *bool
	H          []string
	Sort       []string
	Time       string
	V          *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatRecoveryParams represents possible parameters for the CatRecoveryReq

type CatRecoveryReq 

type CatRecoveryReq struct {
	Indices []string
	Header  http.Header
	Params  CatRecoveryParams
}

CatRecoveryReq represent possible options for the /_cat/recovery request

func (CatRecoveryReq) GetRequest 

func (r CatRecoveryReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatRecoveryResp 

type CatRecoveryResp struct {
	Recovery []CatRecoveryItemResp
	// contains filtered or unexported fields
}

CatRecoveryResp represents the returned struct of the /_cat/recovery response

func (CatRecoveryResp) Inspect 

func (r CatRecoveryResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatRepositorieResp 

type CatRepositorieResp struct {
	ID   string `json:"id"`
	Type string `json:"type"`
}

CatRepositorieResp represents one index of the CatRepositoriesResp

type CatRepositoriesParams 

type CatRepositoriesParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatRepositoriesParams represents possible parameters for the CatRepositoriesReq

type CatRepositoriesReq 

type CatRepositoriesReq struct {
	Header http.Header
	Params CatRepositoriesParams
}

CatRepositoriesReq represent possible options for the /_cat/repositories request

func (CatRepositoriesReq) GetRequest 

func (r CatRepositoriesReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatRepositoriesResp 

type CatRepositoriesResp struct {
	Repositories []CatRepositorieResp
	// contains filtered or unexported fields
}

CatRepositoriesResp represents the returned struct of the /_cat/repositories response

func (CatRepositoriesResp) Inspect 

func (r CatRepositoriesResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatSegmentResp 

type CatSegmentResp struct {
	Index       string `json:"index"`
	Shard       int    `json:"shard,string"`
	Prirep      string `json:"prirep"`
	IP          string `json:"ip"`
	ID          string `json:"id"`
	Segment     string `json:"segment"`
	Generation  int    `json:"generation,string"`
	DocsCount   int    `json:"docs.count,string"`
	DocsDeleted int    `json:"docs.deleted,string"`
	Size        string `json:"size"`
	SizeMemory  string `json:"size.memory"`
	Committed   bool   `json:"committed,string"`
	Searchable  bool   `json:"searchable,string"`
	Version     string `json:"version"`
	Compound    bool   `json:"compound,string"`
}

CatSegmentResp represents one index of the CatSegmentsResp

type CatSegmentsParams 

type CatSegmentsParams struct {
	Bytes                 string
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatSegmentsParams represents possible parameters for the CatSegmentsReq

type CatSegmentsReq 

type CatSegmentsReq struct {
	Indices []string
	Header  http.Header
	Params  CatSegmentsParams
}

CatSegmentsReq represent possible options for the /_cat/segments request

func (CatSegmentsReq) GetRequest 

func (r CatSegmentsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatSegmentsResp 

type CatSegmentsResp struct {
	Segments []CatSegmentResp
	// contains filtered or unexported fields
}

CatSegmentsResp represents the returned struct of the /_cat/segments response

func (CatSegmentsResp) Inspect 

func (r CatSegmentsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatShardResp 

type CatShardResp struct {
	Index                          string  `json:"index"`
	Shard                          int     `json:"shard,string"`
	Prirep                         string  `json:"prirep"`
	State                          string  `json:"state"`
	Docs                           *string `json:"docs"`
	Store                          *string `json:"store"`
	IP                             *string `json:"ip"`
	ID                             *string `json:"id"`
	Node                           *string `json:"node"`
	SyncID                         *string `json:"sync_id"`
	UnassignedReason               *string `json:"unassigned.reason"`
	UnassignedAt                   *string `json:"unassigned.at"`
	UnassignedFor                  *string `json:"unassigned.for"`
	UnassignedDetails              *string `json:"unassigned.details"`
	RecoverysourceType             *string `json:"recoverysource.type"`
	CompletionSize                 *string `json:"completion.size"`
	FielddataMemorySize            *string `json:"fielddata.memory_size"`
	FielddataEvictions             *int    `json:"fielddata.evictions,string"`
	QueryCacheMemorySize           *string `json:"query_cache.memory_size"`
	QueryCacheEvictions            *int    `json:"query_cache.evictions,string"`
	FlushTotal                     *int    `json:"flush.total,string"`
	FlushTotalTime                 *string `json:"flush.total_time"`
	GetCurrent                     *int    `json:"get.current,string"`
	GetTime                        *string `json:"get.time"`
	GetTotal                       *int    `json:"get.total,string"`
	GetExistsTime                  *string `json:"get.exists_time"`
	GetExistsTotal                 *int    `json:"get.exists_total,string"`
	GetMissingTime                 *string `json:"get.missing_time"`
	GetMissingTotal                *int    `json:"get.missing_total,string"`
	IndexingDeleteCurrent          *int    `json:"indexing.delete_current,string"`
	IndexingDeleteTime             *string `json:"indexing.delete_time"`
	IndexingDeleteTotal            *string `json:"indexing.delete_total"`
	IndexingIndexCurrent           *int    `json:"indexing.index_current,string"`
	IndexingIndexTime              *string `json:"indexing.index_time"`
	IndexingIndexTotal             *int    `json:"indexing.index_total,string"`
	IndexingIndexFailed            *int    `json:"indexing.index_failed,string"`
	MergesCurrent                  *int    `json:"merges.current,string"`
	MergesCurrentDocs              *int    `json:"merges.current_docs,string"`
	MergesCurrentSize              *string `json:"merges.current_size"`
	MergesTotal                    *int    `json:"merges.total,string"`
	MergesTotalDocs                *int    `json:"merges.total_docs,string"`
	MergesTotalSize                *string `json:"merges.total_size"`
	MergesTotalTime                *string `json:"merges.total_time"`
	RefreshTotal                   *int    `json:"refresh.total,string"`
	RefreshTime                    *string `json:"refresh.time"`
	RefreshExternalTotal           *int    `json:"refresh.external_total,string"`
	RefreshExternalTime            *string `json:"refresh.external_time"`
	RefreshListeners               *int    `json:"refresh.listeners,string"`
	SearchFetchCurrent             *int    `json:"search.fetch_current,string"`
	SearchFetchTime                *string `json:"search.fetch_time"`
	SearchFetchTotal               *int    `json:"search.fetch_total,string"`
	SearchOpenContexts             *int    `json:"search.open_contexts,string"`
	SearchQueryCurrent             *int    `json:"search.query_current,string"`
	SearchQueryTime                *string `json:"search.query_time"`
	SearchQueryTotal               *int    `json:"search.query_total,string"`
	SearchConcurrentQueryCurrent   *int    `json:"search.concurrent_query_current,string"`
	SearchConcurrentQueryTime      *string `json:"search.concurrent_query_time"`
	SearchConcurrentQueryTotal     *int    `json:"search.concurrent_query_total,string"`
	SearchConcurrentAvgSliceCount  *string `json:"search.concurrent_avg_slice_count"`
	SearchScrollCurrent            *int    `json:"search.scroll_current,string"`
	SearchScrollTime               *string `json:"search.scroll_time"`
	SearchScrollTotal              *int    `json:"search.scroll_total,string"`
	SearchPointInTimeCurrent       *int    `json:"search.point_in_time_current,string"`
	SearchPointInTimeTime          *string `json:"search.point_in_time_time"`
	SearchPointInTimeTotal         *int    `json:"search.point_in_time_total,string"`
	SearchIdleReactivateCountTotal *int    `json:"search.search_idle_reactivate_count_total,string"`
	SegmentsCount                  *int    `json:"segments.count,string"`
	SegmentsMemory                 *string `json:"segments.memory"`
	SegmentsIndexWriterMemory      *string `json:"segments.index_writer_memory"`
	SegmentsVersionMapMemory       *string `json:"segments.version_map_memory"`
	SegmentsFixedBitsetMemory      *string `json:"segments.fixed_bitset_memory"`
	SeqNoMax                       *int    `json:"seq_no.max,string"`
	SeqNoLocalCheckpoint           *int    `json:"seq_no.local_checkpoint,string"`
	SeqNoGlobalCheckpoint          *int    `json:"seq_no.global_checkpoint,string"`
	WarmerCurrent                  *int    `json:"warmer.current,string"`
	WarmerTotal                    *int    `json:"warmer.total,string"`
	WarmerTotalTime                *string `json:"warmer.total_time"`
	PathData                       *string `json:"path.data"`
	PathState                      *string `json:"path.state"`
	DocsDeleted                    *int    `json:"docs.deleted,string"`
}

CatShardResp represents one index of the CatShardsResp

type CatShardsParams 

type CatShardsParams struct {
	Bytes                 string
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	Time                  string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatShardsParams represents possible parameters for the CatShardsReq

type CatShardsReq 

type CatShardsReq struct {
	Indices []string
	Header  http.Header
	Params  CatShardsParams
}

CatShardsReq represent possible options for the /_cat/shards request

func (CatShardsReq) GetRequest 

func (r CatShardsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatShardsResp 

type CatShardsResp struct {
	Shards []CatShardResp
	// contains filtered or unexported fields
}

CatShardsResp represents the returned struct of the /_cat/shards response

func (CatShardsResp) Inspect 

func (r CatShardsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatSnapshotResp 

type CatSnapshotResp struct {
	ID               string `json:"id"`
	Status           string `json:"status"`
	StartEpoch       int    `json:"start_epoch,string"`
	StartTime        string `json:"start_time"`
	EndEpoch         int    `json:"end_epoch,string"`
	EndTime          string `json:"end_time"`
	Duration         string `json:"duration"`
	Indices          int    `json:"indices,string"`
	SuccessfulShards int    `json:"successful_shards,string"`
	FailedShards     int    `json:"failed_shards,string"`
	TotalShards      int    `json:"total_shards,string"`
	Reason           string `json:"reason"`
}

CatSnapshotResp represents one index of the CatSnapshotsResp

type CatSnapshotsParams 

type CatSnapshotsParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	Time                  string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatSnapshotsParams represents possible parameters for the CatSnapshotsReq

type CatSnapshotsReq 

type CatSnapshotsReq struct {
	Repository string
	Header     http.Header
	Params     CatSnapshotsParams
}

CatSnapshotsReq represent possible options for the /_cat/snapshots request

func (CatSnapshotsReq) GetRequest 

func (r CatSnapshotsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatSnapshotsResp 

type CatSnapshotsResp struct {
	Snapshots []CatSnapshotResp
	// contains filtered or unexported fields
}

CatSnapshotsResp represents the returned struct of the /_cat/snapshots response

func (CatSnapshotsResp) Inspect 

func (r CatSnapshotsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatTaskResp 

type CatTaskResp struct {
	ID            string `json:"id"`
	Action        string `json:"action"`
	TaskID        string `json:"task_id"`
	ParentTaskID  string `json:"parent_task_id"`
	Type          string `json:"type"`
	StartTime     int    `json:"start_time,string"`
	Timestamp     string `json:"timestamp"`
	RunningTimeNs int    `json:"running_time_ns,string"`
	RunningTime   string `json:"running_time"`
	NodeID        string `json:"node_id"`
	IP            string `json:"ip"`
	Port          int    `json:"port,string"`
	Node          string `json:"node"`
	Version       string `json:"version"`
	XOpaqueID     string `json:"x_opaque_id"`
}

CatTaskResp represents one index of the CatTasksResp

type CatTasksParams 

type CatTasksParams struct {
	Actions      []string
	Detailed     *bool
	H            []string
	Nodes        []string
	ParentTaskID string
	Local        *bool
	Sort         []string
	Time         string
	V            *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatTasksParams represents possible parameters for the CatTasksReq

type CatTasksReq 

type CatTasksReq struct {
	Header http.Header
	Params CatTasksParams
}

CatTasksReq represent possible options for the /_cat/tasks request

func (CatTasksReq) GetRequest 

func (r CatTasksReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatTasksResp 

type CatTasksResp struct {
	Tasks []CatTaskResp
	// contains filtered or unexported fields
}

CatTasksResp represents the returned struct of the /_cat/tasks response

func (CatTasksResp) Inspect 

func (r CatTasksResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatTemplateResp 

type CatTemplateResp struct {
	Name          string  `json:"name"`
	IndexPatterns string  `json:"index_patterns"`
	Order         int     `json:"order,string"`
	Version       *string `json:"version"`
	ComposedOf    string  `json:"composed_of"`
}

CatTemplateResp represents one index of the CatTemplatesResp

type CatTemplatesParams 

type CatTemplatesParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatTemplatesParams represents possible parameters for the CatTemplatesReq

type CatTemplatesReq 

type CatTemplatesReq struct {
	Templates []string
	Header    http.Header
	Params    CatTemplatesParams
}

CatTemplatesReq represent possible options for the /_cat/templates request

func (CatTemplatesReq) GetRequest 

func (r CatTemplatesReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatTemplatesResp 

type CatTemplatesResp struct {
	Templates []CatTemplateResp
	// contains filtered or unexported fields
}

CatTemplatesResp represents the returned struct of the /_cat/templates response

func (CatTemplatesResp) Inspect 

func (r CatTemplatesResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type CatThreadPoolItemResp 

type CatThreadPoolItemResp struct {
	NodeName        string  `json:"node_name"`
	NodeID          string  `json:"node_id"`
	EphemeralNodeID string  `json:"ephemeral_node_id"`
	PID             int     `json:"pid,string"`
	Host            string  `json:"host"`
	IP              string  `json:"ip"`
	Port            int     `json:"port,string"`
	Name            string  `json:"name"`
	Type            string  `json:"type"`
	Active          int     `json:"active,string"`
	PoolSize        int     `json:"pool_size,string"`
	Queue           int     `json:"queue,string"`
	QueueSize       int     `json:"queue_size,string"`
	Rejected        int     `json:"rejected,string"`
	Largest         int     `json:"largest,string"`
	Completed       int     `json:"completed,string"`
	Core            *int    `json:"core,string"`
	Max             *int    `json:"max,string"`
	Size            *int    `json:"size,string"`
	KeepAlive       *string `json:"keep_alive"`
	TotalWaitTime   string  `json:"total_wait_time"`
}

CatThreadPoolItemResp represents one index of the CatThreadPoolResp

type CatThreadPoolParams 

type CatThreadPoolParams struct {
	H                     []string
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Sort                  []string
	V                     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

CatThreadPoolParams represents possible parameters for the CatThreadPoolReq

type CatThreadPoolReq 

type CatThreadPoolReq struct {
	Pools  []string
	Header http.Header
	Params CatThreadPoolParams
}

CatThreadPoolReq represent possible options for the /_cat/thread_pool request

func (CatThreadPoolReq) GetRequest 

func (r CatThreadPoolReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type CatThreadPoolResp 

type CatThreadPoolResp struct {
	ThreadPool []CatThreadPoolItemResp
	// contains filtered or unexported fields
}

CatThreadPoolResp represents the returned struct of the /_cat/thread_pool response

func (CatThreadPoolResp) Inspect 

func (r CatThreadPoolResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type Client 

type Client struct {
	Client            *opensearch.Client
	Cat               catClient
	Cluster           clusterClient
	Dangling          danglingClient
	Document          documentClient
	Indices           indicesClient
	Nodes             nodesClient
	Script            scriptClient
	ComponentTemplate componentTemplateClient
	IndexTemplate     indexTemplateClient
	// Deprecated: uses legacy API (/_template), correct API is /_index_template, use IndexTemplate instead
	Template    templateClient
	DataStream  dataStreamClient
	PointInTime pointInTimeClient
	Ingest      ingestClient
	Tasks       tasksClient
	Scroll      scrollClient
	Snapshot    snapshotClient
}

Client represents the opensearchapi Client summarizing all API calls

func NewClient 

func NewClient(config Config) (*Client, error)

NewClient returns a opensearchapi client

func NewDefaultClient 

func NewDefaultClient() (*Client, error)

NewDefaultClient returns a opensearchapi client using defaults

func (Client) Aliases 

func (c Client) Aliases(ctx context.Context, req AliasesReq) (*AliasesResp, error)

Aliases executes an /_aliases request with the required AliasesReq

func (Client) Bulk 

func (c Client) Bulk(ctx context.Context, req BulkReq) (*BulkResp, error)

Bulk executes a /_bulk request with the needed BulkReq

func (Client) Index 

func (c Client) Index(ctx context.Context, req IndexReq) (*IndexResp, error)

Index executes a /_doc request with the given IndexReq

func (Client) Info 

func (c Client) Info(ctx context.Context, req *InfoReq) (*InfoResp, error)

Info executes a / request with the optional InfoReq

func (Client) MGet 

func (c Client) MGet(ctx context.Context, req MGetReq) (*MGetResp, error)

MGet executes a /_mget request with the optional MGetReq

func (Client) MSearch 

func (c Client) MSearch(ctx context.Context, req MSearchReq) (*MSearchResp, error)

MSearch executes a /_msearch request with the optional MSearchReq

func (Client) MSearchTemplate 

func (c Client) MSearchTemplate(ctx context.Context, req MSearchTemplateReq) (*MSearchTemplateResp, error)

MSearchTemplate executes a /_msearch request with the optional MSearchTemplateReq

func (Client) MTermvectors 

func (c Client) MTermvectors(ctx context.Context, req MTermvectorsReq) (*MTermvectorsResp, error)

MTermvectors executes a /_mtermvectors request with the required MTermvectorsReq

func (Client) Ping 

func (c Client) Ping(ctx context.Context, req *PingReq) (*opensearch.Response, error)

Ping executes a / request with the optional PingReq

func (Client) RankEval 

func (c Client) RankEval(ctx context.Context, req RankEvalReq) (*RankEvalResp, error)

RankEval executes a /_rank_eval request with the required RankEvalReq

func (Client) Reindex 

func (c Client) Reindex(ctx context.Context, req ReindexReq) (*ReindexResp, error)

Reindex executes a / request with the optional ReindexReq

func (Client) ReindexRethrottle 

func (c Client) ReindexRethrottle(ctx context.Context, req ReindexRethrottleReq) (*ReindexRethrottleResp, error)

ReindexRethrottle executes a / request with the optional ReindexRethrottleReq

func (Client) RenderSearchTemplate 

func (c Client) RenderSearchTemplate(ctx context.Context, req RenderSearchTemplateReq) (*RenderSearchTemplateResp, error)

RenderSearchTemplate executes a /_render/template request with the required RenderSearchTemplateReq

func (Client) Search 

func (c Client) Search(ctx context.Context, req *SearchReq) (*SearchResp, error)

Search executes a /_search request with the optional SearchReq

func (Client) SearchShards 

func (c Client) SearchShards(ctx context.Context, req *SearchShardsReq) (*SearchShardsResp, error)

SearchShards executes a /_search request with the optional SearchShardsReq

func (Client) SearchTemplate 

func (c Client) SearchTemplate(ctx context.Context, req SearchTemplateReq) (*SearchTemplateResp, error)

SearchTemplate executes a /_search request with the optional SearchTemplateReq

func (Client) Termvectors 

func (c Client) Termvectors(ctx context.Context, req TermvectorsReq) (*TermvectorsResp, error)

Termvectors executes a /_termvectors request with the required TermvectorsReq

func (Client) Update 

func (c Client) Update(ctx context.Context, req UpdateReq) (*UpdateResp, error)

Update executes a /_update request with the optional UpdateReq

func (Client) UpdateByQuery 

func (c Client) UpdateByQuery(ctx context.Context, req UpdateByQueryReq) (*UpdateByQueryResp, error)

UpdateByQuery executes a /_update_by_query request with the optional UpdateByQueryReq

func (Client) UpdateByQueryRethrottle 

func (c Client) UpdateByQueryRethrottle(ctx context.Context, req UpdateByQueryRethrottleReq) (*UpdateByQueryRethrottleResp, error)

UpdateByQueryRethrottle executes a / request with the optional UpdateByQueryRethrottleReq

type ClusterAllocationCurrentNode 

type ClusterAllocationCurrentNode struct {
	NodeID           string `json:"id"`
	NodeName         string `json:"name"`
	TransportAddress string `json:"transport_address"`
	NodeAttributes   struct {
		ShardIndexingPressureEnabled string `json:"shard_indexing_pressure_enabled"`
	} `json:"attributes"`
	WeightRanking int `json:"weight_ranking"`
}

ClusterAllocationCurrentNode is a sub type of ClusterAllocationExplainResp containing information of the node the shard is on

type ClusterAllocationExplainBody 

type ClusterAllocationExplainBody struct {
	Index   string `json:"index"`
	Shard   int    `json:"shard"`
	Primary bool   `json:"primary"`
}

ClusterAllocationExplainBody represents the optional Body for the ClusterAllocationExplainReq

type ClusterAllocationExplainDeciders 

type ClusterAllocationExplainDeciders struct {
	Decider     string `json:"decider"`
	Decision    string `json:"decision"`
	Explanation string `json:"explanation"`
}

ClusterAllocationExplainDeciders is a sub type of ClusterAllocationExplainResp and ClusterAllocationNodeDecisions containing inforamtion about Deciders decissions

type ClusterAllocationExplainParams 

type ClusterAllocationExplainParams struct {
	IncludeDiskInfo     *bool
	IncludeYesDecisions *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterAllocationExplainParams represents possible parameters for the ClusterAllocationExplainReq

type ClusterAllocationExplainReq 

type ClusterAllocationExplainReq struct {
	Body   *ClusterAllocationExplainBody
	Header http.Header
	Params ClusterAllocationExplainParams
}

ClusterAllocationExplainReq represents possible options for the /_nodes request

func (ClusterAllocationExplainReq) GetRequest 

func (r ClusterAllocationExplainReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterAllocationExplainResp 

type ClusterAllocationExplainResp struct {
	Index          string                       `json:"index"`
	Shard          int                          `json:"shard"`
	Primary        bool                         `json:"primary"`
	CurrentState   string                       `json:"current_state"`
	CurrentNode    ClusterAllocationCurrentNode `json:"current_node"`
	UnassignedInfo struct {
		Reason               string `json:"reason"`
		At                   string `json:"at"`
		LastAllocationStatus string `json:"last_allocation_status"`
	} `json:"unassigned_info"`
	CanAllocate                  string                             `json:"can_allocate"`
	CanRemainOnCurrentNode       string                             `json:"can_remain_on_current_node"`
	CanRebalanceCluster          string                             `json:"can_rebalance_cluster"`
	CanRebalanceToOtherNode      string                             `json:"can_rebalance_to_other_node"`
	RebalanceExplanation         string                             `json:"rebalance_explanation"`
	AllocateExplanation          string                             `json:"allocate_explanation"`
	NodeAllocationDecisions      []ClusterAllocationNodeDecisions   `json:"node_allocation_decisions"`
	CanRebalanceClusterDecisions []ClusterAllocationExplainDeciders `json:"can_rebalance_cluster_decisions"`
	// contains filtered or unexported fields
}

ClusterAllocationExplainResp represents the returned struct of the /_nodes response

func (ClusterAllocationExplainResp) Inspect 

func (r ClusterAllocationExplainResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterAllocationNodeDecisions 

type ClusterAllocationNodeDecisions struct {
	NodeID           string `json:"node_id"`
	NodeName         string `json:"node_name"`
	TransportAddress string `json:"transport_address"`
	NodeAttributes   struct {
		ShardIndexingPressureEnabled string `json:"shard_indexing_pressure_enabled"`
	} `json:"node_attributes"`
	NodeDecision  string                             `json:"node_decision"`
	WeightRanking int                                `json:"weight_ranking"`
	Deciders      []ClusterAllocationExplainDeciders `json:"deciders"`
}

ClusterAllocationNodeDecisions is a sub type of ClusterAllocationExplainResp containing information of a node allocation decission

type ClusterDeleteDecommissionParams 

type ClusterDeleteDecommissionParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterDeleteDecommissionParams represents possible parameters for the ClusterDeleteDecommissionReq

type ClusterDeleteDecommissionReq 

type ClusterDeleteDecommissionReq struct {
	Header http.Header
	Params ClusterDeleteDecommissionParams
}

ClusterDeleteDecommissionReq represents possible options for the /_cluster/decommission/awareness request

func (ClusterDeleteDecommissionReq) GetRequest 

func (r ClusterDeleteDecommissionReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterDeleteDecommissionResp 

type ClusterDeleteDecommissionResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

ClusterDeleteDecommissionResp represents the returned struct of the /_cluster/decommission/awareness response

func (ClusterDeleteDecommissionResp) Inspect 

func (r ClusterDeleteDecommissionResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterDeleteVotingConfigExclusionsParams 

type ClusterDeleteVotingConfigExclusionsParams struct {
	WaitForRemoval *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterDeleteVotingConfigExclusionsParams represents possible parameters for the ClusterVotingConfigExclusionsReq

type ClusterDeleteVotingConfigExclusionsReq 

type ClusterDeleteVotingConfigExclusionsReq struct {
	Header http.Header
	Params ClusterDeleteVotingConfigExclusionsParams
}

ClusterDeleteVotingConfigExclusionsReq represents possible options for the /_cluster/voting_config_exclusions request

func (ClusterDeleteVotingConfigExclusionsReq) GetRequest 

func (r ClusterDeleteVotingConfigExclusionsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterGetDecommissionParams 

type ClusterGetDecommissionParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterGetDecommissionParams represents possible parameters for the ClusterGetDecommissionReq

type ClusterGetDecommissionReq 

type ClusterGetDecommissionReq struct {
	AwarenessAttrName string

	Header http.Header
	Params ClusterGetDecommissionParams
}

ClusterGetDecommissionReq represents possible options for the /_cluster/decommission/awareness request

func (ClusterGetDecommissionReq) GetRequest 

func (r ClusterGetDecommissionReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterGetDecommissionResp 

type ClusterGetDecommissionResp struct {
	Values map[string]string
	// contains filtered or unexported fields
}

ClusterGetDecommissionResp represents the returned struct of the /_cluster/decommission/awareness response

func (ClusterGetDecommissionResp) Inspect 

func (r ClusterGetDecommissionResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterGetSettingsParams 

type ClusterGetSettingsParams struct {
	FlatSettings          *bool
	IncludeDefaults       *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterGetSettingsParams represents possible parameters for the ClusterGetSettingsReq

type ClusterGetSettingsReq 

type ClusterGetSettingsReq struct {
	Header http.Header
	Params ClusterGetSettingsParams
}

ClusterGetSettingsReq represents possible options for the /_cluster/settings request

func (ClusterGetSettingsReq) GetRequest 

func (r ClusterGetSettingsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterGetSettingsResp 

type ClusterGetSettingsResp struct {
	Persistent json.RawMessage `json:"persistent"`
	Transient  json.RawMessage `json:"transient"`
	Defaults   json.RawMessage `json:"defaults"`
	// contains filtered or unexported fields
}

ClusterGetSettingsResp represents the returned struct of the ClusterGetSettingsReq response

func (ClusterGetSettingsResp) Inspect 

func (r ClusterGetSettingsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterHealthParams 

type ClusterHealthParams struct {
	ExpandWildcards             string
	Level                       string
	Local                       *bool
	MasterTimeout               time.Duration
	ClusterManagerTimeout       time.Duration
	Timeout                     time.Duration
	WaitForActiveShards         string
	WaitForEvents               string
	WaitForNoInitializingShards *bool
	WaitForNoRelocatingShards   *bool
	WaitForNodes                string
	WaitForStatus               string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterHealthParams represents possible parameters for the ClusterHealthReq

type ClusterHealthReq 

type ClusterHealthReq struct {
	Indices []string
	Header  http.Header
	Params  ClusterHealthParams
}

ClusterHealthReq represents possible options for the /_cluster/health request

func (ClusterHealthReq) GetRequest 

func (r ClusterHealthReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterHealthResp 

type ClusterHealthResp struct {
	ClusterName                 string  `json:"cluster_name"`
	Status                      string  `json:"status"`
	TimedOut                    bool    `json:"timed_out"`
	NumberOfNodes               int     `json:"number_of_nodes"`
	NumberOfDataNodes           int     `json:"number_of_data_nodes"`
	DiscoveredMaster            bool    `json:"discovered_master"`
	DiscoveredClusterManager    bool    `json:"discovered_cluster_manager"`
	ActivePrimaryShards         int     `json:"active_primary_shards"`
	ActiveShards                int     `json:"active_shards"`
	RelocatingShards            int     `json:"relocating_shards"`
	InitializingShards          int     `json:"initializing_shards"`
	UnassignedShards            int     `json:"unassigned_shards"`
	DelayedUnassignedShards     int     `json:"delayed_unassigned_shards"`
	NumberOfPendingTasks        int     `json:"number_of_pending_tasks"`
	NumberOfInFlightFetch       int     `json:"number_of_in_flight_fetch"`
	TaskMaxWaitingInQueueMillis int     `json:"task_max_waiting_in_queue_millis"`
	ActiveShardsPercentAsNumber float64 `json:"active_shards_percent_as_number"`
	// contains filtered or unexported fields
}

ClusterHealthResp represents the returned struct of the ClusterHealthReq response

func (ClusterHealthResp) Inspect 

func (r ClusterHealthResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterPendingTasksItem 

type ClusterPendingTasksItem struct {
	InsertOrder       int    `json:"insert_order"`
	Priority          string `json:"priority"`
	Source            string `json:"source"`
	TimeInQueueMillis int    `json:"time_in_queue_millis"`
	TimeInQueue       string `json:"time_in_queue"`
	Executing         bool   `json:"executing"`
}

ClusterPendingTasksItem is a sub type if ClusterPendingTasksResp containing information about a task

type ClusterPendingTasksParams 

type ClusterPendingTasksParams struct {
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Pretty                bool
	Human                 bool
	ErrorTrace            bool
	FilterPath            []string
}

ClusterPendingTasksParams represents possible parameters for the ClusterPendingTasksReq

type ClusterPendingTasksReq 

type ClusterPendingTasksReq struct {
	Header http.Header
	Params ClusterPendingTasksParams
}

ClusterPendingTasksReq represents possible options for the /_cluster/pending_tasks request

func (ClusterPendingTasksReq) GetRequest 

func (r ClusterPendingTasksReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterPendingTasksResp 

type ClusterPendingTasksResp struct {
	Tasks []ClusterPendingTasksItem `json:"tasks"`
	// contains filtered or unexported fields
}

ClusterPendingTasksResp represents the returned struct of the ClusterPendingTasksReq response

func (ClusterPendingTasksResp) Inspect 

func (r ClusterPendingTasksResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterPostVotingConfigExclusionsParams 

type ClusterPostVotingConfigExclusionsParams struct {
	NodeIds   string
	NodeNames string
	Timeout   time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterPostVotingConfigExclusionsParams represents possible parameters for the ClusterVotingConfigExclusionsReq

type ClusterPostVotingConfigExclusionsReq 

type ClusterPostVotingConfigExclusionsReq struct {
	Header http.Header
	Params ClusterPostVotingConfigExclusionsParams
}

ClusterPostVotingConfigExclusionsReq represents possible options for the /_cluster/voting_config_exclusions request

func (ClusterPostVotingConfigExclusionsReq) GetRequest 

func (r ClusterPostVotingConfigExclusionsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterPutDecommissionParams 

type ClusterPutDecommissionParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterPutDecommissionParams represents possible parameters for the ClusterPutDecommissionReq

type ClusterPutDecommissionReq 

type ClusterPutDecommissionReq struct {
	AwarenessAttrName  string
	AwarenessAttrValue string

	Header http.Header
	Params ClusterPutDecommissionParams
}

ClusterPutDecommissionReq represents possible options for the /_cluster/decommission/awareness request

func (ClusterPutDecommissionReq) GetRequest 

func (r ClusterPutDecommissionReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterPutDecommissionResp 

type ClusterPutDecommissionResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

ClusterPutDecommissionResp represents the returned struct of the /_cluster/decommission/awareness response

func (ClusterPutDecommissionResp) Inspect 

func (r ClusterPutDecommissionResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterPutSettingsParams 

type ClusterPutSettingsParams struct {
	FlatSettings          *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterPutSettingsParams represents possible parameters for the ClusterGetSettingsReq

type ClusterPutSettingsReq 

type ClusterPutSettingsReq struct {
	Body   io.Reader
	Header http.Header
	Params ClusterPutSettingsParams
}

ClusterPutSettingsReq represents possible options for the /_cluster/settings request

func (ClusterPutSettingsReq) GetRequest 

func (r ClusterPutSettingsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterPutSettingsResp 

type ClusterPutSettingsResp struct {
	Acknowledged bool            `json:"acknowledged"`
	Persistent   json.RawMessage `json:"persistent"`
	Transient    json.RawMessage `json:"transient"`
	// contains filtered or unexported fields
}

ClusterPutSettingsResp represents the returned struct of the /_cluster/settings response

func (ClusterPutSettingsResp) Inspect 

func (r ClusterPutSettingsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterRemoteInfoDetails 

type ClusterRemoteInfoDetails struct {
	Connected                bool     `json:"connected"`
	Mode                     string   `json:"mode"`
	Seeds                    []string `json:"seeds"`
	NumNodesConnected        int      `json:"num_nodes_connected"`
	MaxConnectionsPerCluster int      `json:"max_connections_per_cluster"`
	InitialConnectTimeout    string   `json:"initial_connect_timeout"`
	SkipUnavailable          bool     `json:"skip_unavailable"`
}

ClusterRemoteInfoDetails is a sub type of ClusterRemoteInfoResp contains information about a remote connection

type ClusterRemoteInfoParams 

type ClusterRemoteInfoParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterRemoteInfoParams represents possible parameters for the ClusterRemoteInfoReq

type ClusterRemoteInfoReq 

type ClusterRemoteInfoReq struct {
	Header http.Header
	Params ClusterRemoteInfoParams
}

ClusterRemoteInfoReq represents possible options for the /_remote/info request

func (ClusterRemoteInfoReq) GetRequest 

func (r ClusterRemoteInfoReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterRemoteInfoResp 

type ClusterRemoteInfoResp struct {
	Clusters map[string]ClusterRemoteInfoDetails
	// contains filtered or unexported fields
}

ClusterRemoteInfoResp represents the returned struct of the ClusterRemoteInfoReq response

func (ClusterRemoteInfoResp) Inspect 

func (r ClusterRemoteInfoResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterRerouteParams 

type ClusterRerouteParams struct {
	DryRun                *bool
	Explain               *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Metric                []string
	RetryFailed           *bool
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterRerouteParams represents possible parameters for the ClusterRerouteReq

type ClusterRerouteReq 

type ClusterRerouteReq struct {
	Body io.Reader

	Header http.Header
	Params ClusterRerouteParams
}

ClusterRerouteReq represents possible options for the /_cluster/reroute request

func (ClusterRerouteReq) GetRequest 

func (r ClusterRerouteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterRerouteResp 

type ClusterRerouteResp struct {
	Acknowledged bool                `json:"acknowledged"`
	State        ClusterRerouteState `json:"state"`
	// contains filtered or unexported fields
}

ClusterRerouteResp represents the returned struct of the ClusterRerouteReq response

func (ClusterRerouteResp) Inspect 

func (r ClusterRerouteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterRerouteState 

type ClusterRerouteState struct {
	ClusterUUID        string                       `json:"cluster_uuid"`
	Version            int                          `json:"version"`
	StateUUID          string                       `json:"state_uuid"`
	MasterNode         string                       `json:"master_node"`
	ClusterManagerNode string                       `json:"cluster_manager_node"`
	Blocks             json.RawMessage              `json:"blocks"`
	Nodes              map[string]ClusterStateNodes `json:"nodes"`
	RoutingTable       struct {
		Indices map[string]struct {
			Shards map[string][]ClusterStateRoutingIndex `json:"shards"`
		} `json:"indices"`
	} `json:"routing_table"`
	RoutingNodes      ClusterStateRoutingNodes `json:"routing_nodes"`
	RepositoryCleanup struct {
		RepositoryCleanup []json.RawMessage `json:"repository_cleanup"`
	} `json:"repository_cleanup"`
	SnapshotDeletions struct {
		SnapshotDeletions []json.RawMessage `json:"snapshot_deletions"`
	} `json:"snapshot_deletions"`
	Snapshots struct {
		Snapshots []json.RawMessage `json:"snapshots"`
	} `json:"snapshots"`
	Restore struct {
		Snapshots []json.RawMessage `json:"snapshots"`
	} `json:"restore"`
}

ClusterRerouteState is a sub type of ClusterRerouteResp containing information about the cluster and cluster routing

type ClusterStateBlocksIndex 

type ClusterStateBlocksIndex struct {
	Description string   `json:"description"`
	Retryable   bool     `json:"retryable"`
	Levels      []string `json:"levels"`
}

ClusterStateBlocksIndex is a sub type of ClusterStateResp

type ClusterStateMetaData 

type ClusterStateMetaData struct {
	ClusterUUID          string `json:"cluster_uuid"`
	ClusterUUIDCommitted bool   `json:"cluster_uuid_committed"`
	ClusterCoordination  struct {
		Term                   int      `json:"term"`
		LastCommittedConfig    []string `json:"last_committed_config"`
		LastAcceptedConfig     []string `json:"last_accepted_config"`
		VotingConfigExclusions []struct {
			NodeID   string `json:"node_id"`
			NodeName string `json:"node_name"`
		} `json:"voting_config_exclusions"`
	} `json:"cluster_coordination"`
	Templates      map[string]json.RawMessage           `json:"templates"`
	Indices        map[string]ClusterStateMetaDataIndex `json:"indices"`
	IndexGraveyard struct {
		Tombstones []struct {
			Index struct {
				IndexName string `json:"index_name"`
				IndexUUID string `json:"index_uuid"`
			} `json:"index"`
			DeleteDateInMillis int `json:"delete_date_in_millis"`
		} `json:"tombstones"`
	} `json:"index-graveyard"`
	Repositories map[string]struct {
		Type              string            `json:"type"`
		Settings          map[string]string `json:"settings"`
		Generation        int               `json:"generation"`
		PendingGeneration int               `json:"pending_generation"`
	} `json:"repositories"`
	ComponentTemplate struct {
		ComponentTemplate map[string]json.RawMessage `json:"component_template"`
	} `json:"component_template"`
	IndexTemplate struct {
		IndexTemplate map[string]json.RawMessage `json:"index_template"`
	} `json:"index_template"`
	StoredScripts map[string]struct {
		Lang   string `json:"lang"`
		Source string `json:"source"`
	} `json:"stored_scripts"`
	Ingest struct {
		Pipeline []struct {
			ID     string `json:"id"`
			Config struct {
				Description string          `json:"description"`
				Processors  json.RawMessage `json:"processors"`
			} `json:"config"`
		} `json:"pipeline"`
	} `json:"ingest"`
	DataStream struct {
		DataStream map[string]ClusterStateMetaDataStream `json:"data_stream"`
	} `json:"data_stream"`
}

ClusterStateMetaData is a sub type if ClusterStateResp containing metadata of the cluster

type ClusterStateMetaDataIndex 

type ClusterStateMetaDataIndex struct {
	Version           int                 `json:"version"`
	MappingVersion    int                 `json:"mapping_version"`
	SettingsVersion   int                 `json:"settings_version"`
	AliasesVersion    int                 `json:"aliases_version"`
	RoutingNumShards  int                 `json:"routing_num_shards"`
	State             string              `json:"state"`
	Settings          json.RawMessage     `json:"settings"`
	Mappings          json.RawMessage     `json:"mappings"`
	Aliases           []string            `json:"aliases"`
	PrimaryTerms      map[string]int      `json:"primary_terms"`
	InSyncAllocations map[string][]string `json:"in_sync_allocations"`
	RolloverInfo      map[string]struct {
		MetConditions map[string]string `json:"met_conditions"`
		Time          int               `json:"time"`
	} `json:"rollover_info"`
	System bool `json:"system"`
}

ClusterStateMetaDataIndex is a sub type of ClusterStateMetaData containing information about an index

type ClusterStateMetaDataStream 

type ClusterStateMetaDataStream struct {
	Name           string `json:"name"`
	TimestampField struct {
		Name string `json:"name"`
	} `json:"timestamp_field"`
	Indices []struct {
		IndexName string `json:"index_name"`
		IndexUUID string `json:"index_uuid"`
	} `json:"indices"`
	Generation int `json:"generation"`
}

ClusterStateMetaDataStream is a sub type of ClusterStateMetaData containing information about a data stream

type ClusterStateNodes 

type ClusterStateNodes struct {
	Name             string            `json:"name"`
	EphemeralID      string            `json:"ephemeral_id"`
	TransportAddress string            `json:"transport_address"`
	Attributes       map[string]string `json:"attributes"`
}

ClusterStateNodes is a sub type of ClusterStateResp

type ClusterStateParams 

type ClusterStateParams struct {
	AllowNoIndices         *bool
	ExpandWildcards        string
	FlatSettings           *bool
	IgnoreUnavailable      *bool
	Local                  *bool
	MasterTimeout          time.Duration
	ClusterManagerTimeout  time.Duration
	WaitForMetadataVersion *int
	WaitForTimeout         time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterStateParams represents possible parameters for the ClusterStateReq

type ClusterStateReq 

type ClusterStateReq struct {
	Metrics []string
	Indices []string

	Header http.Header
	Params ClusterStateParams
}

ClusterStateReq represents possible options for the /_cluster/state request

func (ClusterStateReq) GetRequest 

func (r ClusterStateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterStateResp 

type ClusterStateResp struct {
	ClusterName        string `json:"cluster_name"`
	ClusterUUID        string `json:"cluster_uuid"`
	Version            int    `json:"version"`
	StateUUID          string `json:"state_uuid"`
	MasterNode         string `json:"master_node"`
	ClusterManagerNode string `json:"cluster_manager_node"`
	Blocks             struct {
		Indices map[string]map[string]ClusterStateBlocksIndex `json:"indices"`
	} `json:"blocks"`
	Nodes    map[string]ClusterStateNodes `json:"nodes"`
	Metadata ClusterStateMetaData         `json:"metadata"`

	RoutingTable struct {
		Indices map[string]struct {
			Shards map[string][]ClusterStateRoutingIndex `json:"shards"`
		} `json:"indices"`
	} `json:"routing_table"`
	RoutingNodes ClusterStateRoutingNodes `json:"routing_nodes"`
	Snapshots    struct {
		Snapshots []json.RawMessage `json:"snapshots"`
	} `json:"snapshots"`
	SnapshotDeletions struct {
		SnapshotDeletions []json.RawMessage `json:"snapshot_deletions"`
	} `json:"snapshot_deletions"`
	RepositoryCleanup struct {
		RepositoryCleanup []json.RawMessage `json:"repository_cleanup"`
	} `json:"repository_cleanup"`
	Restore struct {
		Snapshots []json.RawMessage `json:"snapshots"`
	} `json:"restore"`
	// contains filtered or unexported fields
}

ClusterStateResp represents the returned struct of the ClusterStateReq response

func (ClusterStateResp) Inspect 

func (r ClusterStateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ClusterStateRoutingIndex 

type ClusterStateRoutingIndex struct {
	State                    string  `json:"state"`
	Primary                  bool    `json:"primary"`
	SearchOnly               bool    `json:"searchOnly"`
	Node                     *string `json:"node"`
	RelocatingNode           *string `json:"relocating_node"`
	Shard                    int     `json:"shard"`
	Index                    string  `json:"index"`
	ExpectedShardSizeInBytes int     `json:"expected_shard_size_in_bytes"`
	AllocationID             *struct {
		ID string `json:"id"`
	} `json:"allocation_id,omitempty"`
	RecoverySource *struct {
		Type string `json:"type"`
	} `json:"recovery_source,omitempty"`
	UnassignedInfo *struct {
		Reason           string `json:"reason"`
		At               string `json:"at"`
		Delayed          bool   `json:"delayed"`
		AllocationStatus string `json:"allocation_status"`
		Details          string `json:"details"`
	} `json:"unassigned_info,omitempty"`
}

ClusterStateRoutingIndex is a sub type of ClusterStateResp and ClusterStateRoutingNodes containing information about shard routing

type ClusterStateRoutingNodes 

type ClusterStateRoutingNodes struct {
	Unassigned []ClusterStateRoutingIndex            `json:"unassigned"`
	Nodes      map[string][]ClusterStateRoutingIndex `json:"nodes"`
}

ClusterStateRoutingNodes is a sub type of ClusterStateResp containing information about shard assigned to nodes

type ClusterStatsIndices 

type ClusterStatsIndices struct {
	Count  int `json:"count"`
	Shards struct {
		Total       int     `json:"total"`
		Primaries   int     `json:"primaries"`
		Replication float64 `json:"replication"`
		Index       struct {
			Shards struct {
				Min float64 `json:"min"`
				Max float64 `json:"max"`
				Avg float64 `json:"avg"`
			} `json:"shards"`
			Primaries struct {
				Min float64 `json:"min"`
				Max float64 `json:"max"`
				Avg float64 `json:"avg"`
			} `json:"primaries"`
			Replication struct {
				Min float64 `json:"min"`
				Max float64 `json:"max"`
				Avg float64 `json:"avg"`
			} `json:"replication"`
		} `json:"index"`
	} `json:"shards"`
	Docs struct {
		Count   int64 `json:"count"`
		Deleted int   `json:"deleted"`
	} `json:"docs"`
	Store struct {
		SizeInBytes     int64 `json:"size_in_bytes"`
		ReservedInBytes int   `json:"reserved_in_bytes"`
	} `json:"store"`
	Fielddata struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		Evictions         int `json:"evictions"`
	} `json:"fielddata"`
	QueryCache struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		TotalCount        int `json:"total_count"`
		HitCount          int `json:"hit_count"`
		MissCount         int `json:"miss_count"`
		CacheSize         int `json:"cache_size"`
		CacheCount        int `json:"cache_count"`
		Evictions         int `json:"evictions"`
	} `json:"query_cache"`
	Completion struct {
		SizeInBytes int `json:"size_in_bytes"`
	} `json:"completion"`
	Segments struct {
		Count                     int   `json:"count"`
		MemoryInBytes             int   `json:"memory_in_bytes"`
		TermsMemoryInBytes        int   `json:"terms_memory_in_bytes"`
		StoredFieldsMemoryInBytes int   `json:"stored_fields_memory_in_bytes"`
		TermVectorsMemoryInBytes  int   `json:"term_vectors_memory_in_bytes"`
		NormsMemoryInBytes        int   `json:"norms_memory_in_bytes"`
		PointsMemoryInBytes       int   `json:"points_memory_in_bytes"`
		DocValuesMemoryInBytes    int   `json:"doc_values_memory_in_bytes"`
		IndexWriterMemoryInBytes  int   `json:"index_writer_memory_in_bytes"`
		VersionMapMemoryInBytes   int   `json:"version_map_memory_in_bytes"`
		FixedBitSetMemoryInBytes  int64 `json:"fixed_bit_set_memory_in_bytes"`
		MaxUnsafeAutoIDTimestamp  int64 `json:"max_unsafe_auto_id_timestamp"`
		RemoteStore               struct {
			Upload struct {
				TotalUploadSize struct {
					StartedBytes   int `json:"started_bytes"`
					SucceededBytes int `json:"succeeded_bytes"`
					FailedBytes    int `json:"failed_bytes"`
				} `json:"total_upload_size"`
				RefreshSizeLag struct {
					TotalBytes int `json:"total_bytes"`
					MaxBytes   int `json:"max_bytes"`
				} `json:"refresh_size_lag"`
				MaxRefreshTimeLagInMillis int `json:"max_refresh_time_lag_in_millis"`
				TotalTimeSpentInMillis    int `json:"total_time_spent_in_millis"`
				Pressure                  struct {
					TotalRejections int `json:"total_rejections"`
				} `json:"pressure"`
			} `json:"upload"`
			Download struct {
				TotalDownloadSize struct {
					StartedBytes   int `json:"started_bytes"`
					SucceededBytes int `json:"succeeded_bytes"`
					FailedBytes    int `json:"failed_bytes"`
				} `json:"total_download_size"`
				TotalTimeSpentInMillis int `json:"total_time_spent_in_millis"`
			} `json:"download"`
		} `json:"remote_store"`
		SegmentReplication struct {
			// Type is json.RawMessage due to difference in opensearch versions from string to int
			MaxBytesBehind    json.RawMessage `json:"max_bytes_behind"`
			TotalBytesBehind  json.RawMessage `json:"total_bytes_behind"`
			MaxReplicationLag json.RawMessage `json:"max_replication_lag"`
		} `json:"segment_replication"`
		FileSizes json.RawMessage `json:"file_sizes"`
	} `json:"segments"`
	Mappings struct {
		FieldTypes []struct {
			Name       string `json:"name"`
			Count      int    `json:"count"`
			IndexCount int    `json:"index_count"`
		} `json:"field_types"`
	} `json:"mappings"`
	Analysis struct {
		CharFilterTypes    []json.RawMessage `json:"char_filter_types"`
		TokenizerTypes     []json.RawMessage `json:"tokenizer_types"`
		FilterTypes        []json.RawMessage `json:"filter_types"`
		AnalyzerTypes      []json.RawMessage `json:"analyzer_types"`
		BuiltInCharFilters []json.RawMessage `json:"built_in_char_filters"`
		BuiltInTokenizers  []json.RawMessage `json:"built_in_tokenizers"`
		BuiltInFilters     []json.RawMessage `json:"built_in_filters"`
		BuiltInAnalyzers   []json.RawMessage `json:"built_in_analyzers"`
	} `json:"analysis"`
	RepositoryCleanup struct {
		RepositoryCleanup []json.RawMessage `json:"repository_cleanup"`
	} `json:"repository_cleanup"`
}

ClusterStatsIndices is a sub type of ClusterStatsResp containing cluster information about indices

type ClusterStatsNodes 

type ClusterStatsNodes struct {
	Count struct {
		Total               int `json:"total"`
		ClusterManager      int `json:"cluster_manager"`
		CoordinatingOnly    int `json:"coordinating_only"`
		Data                int `json:"data"`
		Ingest              int `json:"ingest"`
		Master              int `json:"master"`
		RemoteClusterClient int `json:"remote_cluster_client"`
		Search              int `json:"search"`
		Warm                int `json:"warm"`
	} `json:"count"`
	Versions []string `json:"versions"`
	Os       struct {
		AvailableProcessors int `json:"available_processors"`
		AllocatedProcessors int `json:"allocated_processors"`
		Names               []struct {
			Name  string `json:"name"`
			Count int    `json:"count"`
		} `json:"names"`
		PrettyNames []struct {
			PrettyName string `json:"pretty_name"`
			Count      int    `json:"count"`
		} `json:"pretty_names"`
		Mem struct {
			TotalInBytes int64 `json:"total_in_bytes"`
			FreeInBytes  int64 `json:"free_in_bytes"`
			UsedInBytes  int64 `json:"used_in_bytes"`
			FreePercent  int   `json:"free_percent"`
			UsedPercent  int   `json:"used_percent"`
		} `json:"mem"`
	} `json:"os"`
	Process struct {
		CPU struct {
			Percent int `json:"percent"`
		} `json:"cpu"`
		OpenFileDescriptors struct {
			Min int `json:"min"`
			Max int `json:"max"`
			Avg int `json:"avg"`
		} `json:"open_file_descriptors"`
	} `json:"process"`
	Jvm struct {
		MaxUptimeInMillis int64 `json:"max_uptime_in_millis"`
		Versions          []struct {
			Version         string `json:"version"`
			VMName          string `json:"vm_name"`
			VMVersion       string `json:"vm_version"`
			VMVendor        string `json:"vm_vendor"`
			BundledJdk      bool   `json:"bundled_jdk"`
			UsingBundledJdk bool   `json:"using_bundled_jdk"`
			Count           int    `json:"count"`
		} `json:"versions"`
		Mem struct {
			HeapUsedInBytes int64 `json:"heap_used_in_bytes"`
			HeapMaxInBytes  int64 `json:"heap_max_in_bytes"`
		} `json:"mem"`
		Threads int `json:"threads"`
	} `json:"jvm"`
	Fs struct {
		TotalInBytes         int64 `json:"total_in_bytes"`
		FreeInBytes          int64 `json:"free_in_bytes"`
		AvailableInBytes     int64 `json:"available_in_bytes"`
		CacheReservedInBytes int   `json:"cache_reserved_in_bytes"`
	} `json:"fs"`
	Plugins []struct {
		Name                    string   `json:"name"`
		Version                 string   `json:"version"`
		OpensearchVersion       string   `json:"opensearch_version"`
		JavaVersion             string   `json:"java_version"`
		Description             string   `json:"description"`
		Classname               string   `json:"classname"`
		CustomFoldername        *string  `json:"custom_foldername"`
		ExtendedPlugins         []string `json:"extended_plugins"`
		OptionalExtendedPlugins []string `json:"optional_extended_plugins"`
		HasNativeController     bool     `json:"has_native_controller"`
	} `json:"plugins"`
	NetworkTypes struct {
		TransportTypes map[string]int `json:"transport_types"`
		HTTPTypes      map[string]int `json:"http_types"`
	} `json:"network_types"`
	DiscoveryTypes map[string]int `json:"discovery_types"`
	PackagingTypes []struct {
		Type  string `json:"type"`
		Count int    `json:"count"`
	} `json:"packaging_types"`
	Ingest struct {
		NumberOfPipelines int             `json:"number_of_pipelines"`
		ProcessorStats    json.RawMessage `json:"processor_stats"`
	} `json:"ingest"`
}

ClusterStatsNodes is a sub type of ClusterStatsResp containing information about node stats

type ClusterStatsParams 

type ClusterStatsParams struct {
	Timeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ClusterStatsParams represents possible parameters for the ClusterStatsReq

type ClusterStatsReq 

type ClusterStatsReq struct {
	NodeFilters []string

	Header http.Header
	Params ClusterStatsParams
}

ClusterStatsReq represents possible options for the /_cluster/stats request

func (ClusterStatsReq) GetRequest 

func (r ClusterStatsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ClusterStatsResp 

type ClusterStatsResp struct {
	NodesInfo struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresCause `json:"failures"`
	} `json:"_nodes"`
	ClusterName string              `json:"cluster_name"`
	ClusterUUID string              `json:"cluster_uuid"`
	Timestamp   int64               `json:"timestamp"`
	Status      string              `json:"status"`
	Indices     ClusterStatsIndices `json:"indices"`
	Nodes       ClusterStatsNodes   `json:"nodes"`
	// contains filtered or unexported fields
}

ClusterStatsResp represents the returned struct of the ClusterStatsReq response

func (ClusterStatsResp) Inspect 

func (r ClusterStatsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ComponentTemplateCreateParams 

type ComponentTemplateCreateParams struct {
	Create                *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ComponentTemplateCreateParams represents possible parameters for the ComponentTemplateCreateReq

type ComponentTemplateCreateReq 

type ComponentTemplateCreateReq struct {
	ComponentTemplate string

	Body io.Reader

	Header http.Header
	Params ComponentTemplateCreateParams
}

ComponentTemplateCreateReq represents possible options for the _component_template create request

func (ComponentTemplateCreateReq) GetRequest 

func (r ComponentTemplateCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ComponentTemplateCreateResp 

type ComponentTemplateCreateResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

ComponentTemplateCreateResp represents the returned struct of the index create response

func (ComponentTemplateCreateResp) Inspect 

func (r ComponentTemplateCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ComponentTemplateDeleteParams 

type ComponentTemplateDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ComponentTemplateDeleteParams represents possible parameters for the ComponentTemplateDeleteReq

type ComponentTemplateDeleteReq 

type ComponentTemplateDeleteReq struct {
	ComponentTemplate string

	Header http.Header
	Params ComponentTemplateDeleteParams
}

ComponentTemplateDeleteReq represents possible options for the _component_template delete request

func (ComponentTemplateDeleteReq) GetRequest 

func (r ComponentTemplateDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ComponentTemplateDeleteResp 

type ComponentTemplateDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

ComponentTemplateDeleteResp represents the returned struct of the _component_template delete response

func (ComponentTemplateDeleteResp) Inspect 

func (r ComponentTemplateDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ComponentTemplateExistsParams 

type ComponentTemplateExistsParams struct {
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ComponentTemplateExistsParams represents possible parameters for the ComponentTemplateExistsReq

type ComponentTemplateExistsReq 

type ComponentTemplateExistsReq struct {
	ComponentTemplate string

	Header http.Header
	Params ComponentTemplateExistsParams
}

ComponentTemplateExistsReq represents possible options for the _component_template exists request

func (ComponentTemplateExistsReq) GetRequest 

func (r ComponentTemplateExistsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ComponentTemplateGetDetails 

type ComponentTemplateGetDetails struct {
	Name              string `json:"name"`
	ComponentTemplate struct {
		Template struct {
			Mappings json.RawMessage `json:"mappings"`
			Settings json.RawMessage `json:"settings"`
			Aliases  json.RawMessage `json:"aliases"`
		} `json:"template"`
	} `json:"component_template"`
}

ComponentTemplateGetDetails is a sub type of ComponentTemplateGetResp containing information about component template

type ComponentTemplateGetParams 

type ComponentTemplateGetParams struct {
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ComponentTemplateGetParams represents possible parameters for the ComponentTemplateGetReq

type ComponentTemplateGetReq 

type ComponentTemplateGetReq struct {
	ComponentTemplate string

	Header http.Header
	Params ComponentTemplateGetParams
}

ComponentTemplateGetReq represents possible options for the _component_template get request

func (ComponentTemplateGetReq) GetRequest 

func (r ComponentTemplateGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ComponentTemplateGetResp 

type ComponentTemplateGetResp struct {
	ComponentTemplates []ComponentTemplateGetDetails `json:"component_templates"`
	// contains filtered or unexported fields
}

ComponentTemplateGetResp represents the returned struct of the index create response

func (ComponentTemplateGetResp) Inspect 

func (r ComponentTemplateGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type Config 

type Config struct {
	Client opensearch.Config
}

Config represents the client configuration

type DanglingDeleteParams 

type DanglingDeleteParams struct {
	AcceptDataLoss        *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DanglingDeleteParams represents possible parameters for the DanglingDeleteReq

type DanglingDeleteReq 

type DanglingDeleteReq struct {
	IndexUUID string

	Header http.Header
	Params DanglingDeleteParams
}

DanglingDeleteReq represents possible options for the delete dangling request

func (DanglingDeleteReq) GetRequest 

func (r DanglingDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DanglingDeleteResp 

type DanglingDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

DanglingDeleteResp represents the returned struct of the delete dangling response

func (DanglingDeleteResp) Inspect 

func (r DanglingDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DanglingGetParams 

type DanglingGetParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DanglingGetParams represents possible parameters for the DanglingGetReq

type DanglingGetReq 

type DanglingGetReq struct {
	Header http.Header
	Params DanglingGetParams
}

DanglingGetReq represents possible options for the dangling get request

func (DanglingGetReq) GetRequest 

func (r DanglingGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DanglingGetResp 

type DanglingGetResp struct {
	Nodes struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
		Failures   []struct {
			Type     string `json:"type"`
			Reason   string `json:"reason"`
			NodeID   string `json:"node_id"`
			CausedBy struct {
				Type   string `json:"type"`
				Reason string `json:"reason"`
			} `json:"caused_by"`
		} `json:"failures"`
	} `json:"_nodes"`
	ClusterName     string `json:"cluster_name"`
	DanglingIndices []struct {
		IndexName          string   `json:"index_name"`
		IndexUUID          string   `json:"index_uuid"`
		CreationDateMillis int64    `json:"creation_date_millis"`
		NodeIds            []string `json:"node_ids"`
	} `json:"dangling_indices"`
	// contains filtered or unexported fields
}

DanglingGetResp represents the returned struct of the dangling get response

func (DanglingGetResp) Inspect 

func (r DanglingGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DanglingImportParams 

type DanglingImportParams struct {
	AcceptDataLoss        *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DanglingImportParams represents possible parameters for the DanglingImportReq

type DanglingImportReq 

type DanglingImportReq struct {
	IndexUUID string

	Header http.Header
	Params DanglingImportParams
}

DanglingImportReq represents possible options for the dangling import request

func (DanglingImportReq) GetRequest 

func (r DanglingImportReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DanglingImportResp 

type DanglingImportResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

DanglingImportResp represents the returned struct of thedangling import response

func (DanglingImportResp) Inspect 

func (r DanglingImportResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DataStreamCreateParams 

type DataStreamCreateParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DataStreamCreateParams represents possible parameters for the DataStreamCreateReq

type DataStreamCreateReq 

type DataStreamCreateReq struct {
	DataStream string

	Header http.Header
	Params DataStreamCreateParams
}

DataStreamCreateReq represents possible options for the _data_stream create request

func (DataStreamCreateReq) GetRequest 

func (r DataStreamCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DataStreamCreateResp 

type DataStreamCreateResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

DataStreamCreateResp represents the returned struct of the _data_stream create response

func (DataStreamCreateResp) Inspect 

func (r DataStreamCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DataStreamDeleteParams 

type DataStreamDeleteParams struct {
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DataStreamDeleteParams represents possible parameters for the DataStreamDeleteReq

type DataStreamDeleteReq 

type DataStreamDeleteReq struct {
	DataStream string

	Header http.Header
	Params DataStreamDeleteParams
}

DataStreamDeleteReq represents possible options for the index _data_stream delete request

func (DataStreamDeleteReq) GetRequest 

func (r DataStreamDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DataStreamDeleteResp 

type DataStreamDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

DataStreamDeleteResp represents the returned struct of the _data_stream delete response

func (DataStreamDeleteResp) Inspect 

func (r DataStreamDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DataStreamGetDetails 

type DataStreamGetDetails struct {
	Name           string `json:"name"`
	TimestampField struct {
		Name string `json:"name"`
	} `json:"timestamp_field"`
	Indices    []DataStreamIndices `json:"indices"`
	Generation int                 `json:"generation"`
	Status     string              `json:"status"`
	Template   string              `json:"template"`
}

DataStreamGetDetails is a sub type if DataStreamGetResp containing information about a data stream

type DataStreamGetParams 

type DataStreamGetParams struct {
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DataStreamGetParams represents possible parameters for the DataStreamGetReq

type DataStreamGetReq 

type DataStreamGetReq struct {
	DataStreams []string

	Header http.Header
	Params DataStreamGetParams
}

DataStreamGetReq represents possible options for the _data_stream get request

func (DataStreamGetReq) GetRequest 

func (r DataStreamGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DataStreamGetResp 

type DataStreamGetResp struct {
	DataStreams []DataStreamGetDetails `json:"data_streams"`
	// contains filtered or unexported fields
}

DataStreamGetResp represents the returned struct of the _data_stream get response

func (DataStreamGetResp) Inspect 

func (r DataStreamGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DataStreamIndices 

type DataStreamIndices struct {
	Name string `json:"index_name"`
	UUID string `json:"index_uuid"`
}

DataStreamIndices is a sub type of DataStreamGetDetails containing information about an index

type DataStreamStatsDetails 

type DataStreamStatsDetails struct {
	DataStream       string `json:"data_stream"`
	BackingIndices   int    `json:"backing_indices"`
	StoreSizeBytes   int64  `json:"store_size_bytes"`
	MaximumTimestamp int64  `json:"maximum_timestamp"`
}

DataStreamStatsDetails is a sub type of DataStreamStatsResp containing information about a data stream

type DataStreamStatsParams 

type DataStreamStatsParams struct {
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DataStreamStatsParams represents possible parameters for the DataStreamCreateReq

type DataStreamStatsReq 

type DataStreamStatsReq struct {
	DataStreams []string

	Header http.Header
	Params DataStreamStatsParams
}

DataStreamStatsReq represents possible options for the _data_stream stats request

func (DataStreamStatsReq) GetRequest 

func (r DataStreamStatsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DataStreamStatsResp 

type DataStreamStatsResp struct {
	Shards struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
		Failures   []struct {
			Shard  int           `json:"shard"`
			Index  string        `json:"index"`
			Status string        `json:"status"`
			Reason FailuresCause `json:"reason"`
		} `json:"failures"`
	} `json:"_shards"`
	DataStreamCount     int                      `json:"data_stream_count"`
	BackingIndices      int                      `json:"backing_indices"`
	TotalStoreSizeBytes int64                    `json:"total_store_size_bytes"`
	DataStreams         []DataStreamStatsDetails `json:"data_streams"`
	// contains filtered or unexported fields
}

DataStreamStatsResp represents the returned struct of the _data_stream stats response

func (DataStreamStatsResp) Inspect 

func (r DataStreamStatsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DocumentCreateParams 

type DocumentCreateParams struct {
	Pipeline            string
	Refresh             string
	Routing             string
	Timeout             time.Duration
	Version             *int
	VersionType         string
	WaitForActiveShards string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentCreateParams represents possible parameters for the DocumentCreateReq

type DocumentCreateReq 

type DocumentCreateReq struct {
	Index      string
	DocumentID string

	Body io.Reader

	Header http.Header
	Params DocumentCreateParams
}

DocumentCreateReq represents possible options for the /<index>/_create request

func (DocumentCreateReq) GetRequest 

func (r DocumentCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentCreateResp 

type DocumentCreateResp struct {
	Index         string `json:"_index"`
	ID            string `json:"_id"`
	Version       int    `json:"_version"`
	Result        string `json:"result"`
	Type          string `json:"_type"` // Deprecated field
	ForcedRefresh bool   `json:"forced_refresh"`
	Shards        struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	SeqNo       int `json:"_seq_no"`
	PrimaryTerm int `json:"_primary_term"`
	// contains filtered or unexported fields
}

DocumentCreateResp represents the returned struct of the /_doc response

func (DocumentCreateResp) Inspect 

func (r DocumentCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DocumentDeleteByQueryParams 

type DocumentDeleteByQueryParams struct {
	AllowNoIndices      *bool
	Analyzer            string
	AnalyzeWildcard     *bool
	Conflicts           string
	DefaultOperator     string
	Df                  string
	ExpandWildcards     string
	From                *int
	IgnoreUnavailable   *bool
	Lenient             *bool
	MaxDocs             *int
	Preference          string
	Query               string
	Refresh             *bool
	RequestCache        *bool
	RequestsPerSecond   *int
	Routing             []string
	Scroll              time.Duration
	ScrollSize          *int
	SearchTimeout       time.Duration
	SearchType          string
	Size                *int
	Slices              interface{}
	Sort                []string
	Source              interface{}
	SourceExcludes      []string
	SourceIncludes      []string
	Stats               []string
	TerminateAfter      *int
	Timeout             time.Duration
	Version             *bool
	WaitForActiveShards string
	WaitForCompletion   *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentDeleteByQueryParams represents possible parameters for the DocumentDeleteByQueryReq

type DocumentDeleteByQueryReq 

type DocumentDeleteByQueryReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params DocumentDeleteByQueryParams
}

DocumentDeleteByQueryReq represents possible options for the /<index>/_delete_by_query request

func (DocumentDeleteByQueryReq) GetRequest 

func (r DocumentDeleteByQueryReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentDeleteByQueryResp 

type DocumentDeleteByQueryResp struct {
	Took             int  `json:"took"`
	TimedOut         bool `json:"timed_out"`
	Total            int  `json:"total"`
	Deleted          int  `json:"deleted"`
	Batches          int  `json:"batches"`
	VersionConflicts int  `json:"version_conflicts"`
	Noops            int  `json:"noops"`
	Retries          struct {
		Bulk   int `json:"bulk"`
		Search int `json:"search"`
	} `json:"retries"`
	ThrottledMillis      int               `json:"throttled_millis"`
	RequestsPerSecond    float32           `json:"requests_per_second"`
	ThrottledUntilMillis int               `json:"throttled_until_millis"`
	Failures             []json.RawMessage `json:"failures"`       // Unknow struct, open an issue with an example response so we can add it
	Task                 string            `json:"task,omitempty"` // Needed when wait_for_completion is set to false
	// contains filtered or unexported fields
}

DocumentDeleteByQueryResp represents the returned struct of the /<index>/_delete_by_query response

func (DocumentDeleteByQueryResp) Inspect 

func (r DocumentDeleteByQueryResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DocumentDeleteByQueryRethrottleParams 

type DocumentDeleteByQueryRethrottleParams struct {
	RequestsPerSecond *int

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentDeleteByQueryRethrottleParams represents possible parameters for the DocumentDeleteByQueryRethrottleReq

type DocumentDeleteByQueryRethrottleReq 

type DocumentDeleteByQueryRethrottleReq struct {
	TaskID string

	Header http.Header
	Params DocumentDeleteByQueryRethrottleParams
}

DocumentDeleteByQueryRethrottleReq represents possible options for the /_delete_by_query/<index>/_rethrottle request

func (DocumentDeleteByQueryRethrottleReq) GetRequest 

func (r DocumentDeleteByQueryRethrottleReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentDeleteByQueryRethrottleResourceInfo 

type DocumentDeleteByQueryRethrottleResourceInfo struct {
	CPUTimeInNanos int `json:"cpu_time_in_nanos"`
	MemoryInBytes  int `json:"memory_in_bytes"`
}

DocumentDeleteByQueryRethrottleResourceInfo is a sub type of DocumentDeleteByQueryRethrottleResp containing resource stats

type DocumentDeleteByQueryRethrottleResp 

type DocumentDeleteByQueryRethrottleResp struct {
	Nodes map[string]struct {
		Name             string            `json:"name"`
		TransportAddress string            `json:"transport_address"`
		Host             string            `json:"host"`
		IP               string            `json:"ip"`
		Roles            []string          `json:"roles"`
		Attributes       map[string]string `json:"attributes"`
		Tasks            map[string]struct {
			Node   string `json:"node"`
			ID     int    `json:"id"`
			Type   string `json:"type"`
			Action string `json:"action"`
			Status struct {
				Total            int `json:"total"`
				Updated          int `json:"updated"`
				Created          int `json:"created"`
				Deleted          int `json:"deleted"`
				Batches          int `json:"batches"`
				VersionConflicts int `json:"version_conflicts"`
				Noops            int `json:"noops"`
				Retries          struct {
					Bulk   int `json:"bulk"`
					Search int `json:"search"`
				} `json:"retries"`
				ThrottledMillis      int     `json:"throttled_millis"`
				RequestsPerSecond    float64 `json:"requests_per_second"`
				ThrottledUntilMillis int     `json:"throttled_until_millis"`
			} `json:"status"`
			Description        string          `json:"description"`
			StartTimeInMillis  int64           `json:"start_time_in_millis"`
			RunningTimeInNanos int             `json:"running_time_in_nanos"`
			Cancellable        bool            `json:"cancellable"`
			Cancelled          bool            `json:"cancelled"`
			Headers            json.RawMessage `json:"headers"`
			ResourceStats      struct {
				Average    DocumentDeleteByQueryRethrottleResourceInfo `json:"average"`
				Max        DocumentDeleteByQueryRethrottleResourceInfo `json:"max"`
				Min        DocumentDeleteByQueryRethrottleResourceInfo `json:"min"`
				Total      DocumentDeleteByQueryRethrottleResourceInfo `json:"total"`
				ThreadInfo struct {
					ActiveThreads    int `json:"active_threads"`
					ThreadExecutions int `json:"thread_executions"`
				} `json:"thread_info"`
			} `json:"resource_stats"`
		} `json:"tasks"`
	} `json:"nodes"`
	NodeFailures []FailuresCause `json:"node_failures"`
	// contains filtered or unexported fields
}

DocumentDeleteByQueryRethrottleResp represents the returned struct of the /_delete_by_query/<index>/_rethrottle response

func (DocumentDeleteByQueryRethrottleResp) Inspect 

func (r DocumentDeleteByQueryRethrottleResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DocumentDeleteParams 

type DocumentDeleteParams struct {
	IfPrimaryTerm       *int
	IfSeqNo             *int
	Refresh             string
	Routing             string
	Timeout             time.Duration
	Version             *int
	VersionType         string
	WaitForActiveShards string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentDeleteParams represents possible parameters for the DocumentDeleteReq

type DocumentDeleteReq 

type DocumentDeleteReq struct {
	Index      string
	DocumentID string

	Header http.Header
	Params DocumentDeleteParams
}

DocumentDeleteReq represents possible options for the /<index>/_doc/<DocID> delete request

func (DocumentDeleteReq) GetRequest 

func (r DocumentDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentDeleteResp 

type DocumentDeleteResp struct {
	Index   string `json:"_index"`
	ID      string `json:"_id"`
	Version int    `json:"_version"`
	Result  string `json:"result"`
	Type    string `json:"_type"` // Deprecated field
	Shards  struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	SeqNo       int `json:"_seq_no"`
	PrimaryTerm int `json:"_primary_term"`
	// contains filtered or unexported fields
}

DocumentDeleteResp represents the returned struct of the /<index>/_doc/<DocID> response

func (DocumentDeleteResp) Inspect 

func (r DocumentDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DocumentExistsParams 

type DocumentExistsParams struct {
	Preference     string
	Realtime       *bool
	Refresh        *bool
	Routing        string
	Source         interface{}
	SourceExcludes []string
	SourceIncludes []string
	StoredFields   []string
	Version        *int
	VersionType    string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentExistsParams represents possible parameters for the DocumentExistsReq

type DocumentExistsReq 

type DocumentExistsReq struct {
	Index      string
	DocumentID string

	Header http.Header
	Params DocumentExistsParams
}

DocumentExistsReq represents possible options for the document exists request

func (DocumentExistsReq) GetRequest 

func (r DocumentExistsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentExistsSourceParams 

type DocumentExistsSourceParams struct {
	Preference     string
	Realtime       *bool
	Refresh        *bool
	Routing        string
	Source         interface{}
	SourceExcludes []string
	SourceIncludes []string
	Version        *int
	VersionType    string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentExistsSourceParams represents possible parameters for the DocumentExistsSourceReq

type DocumentExistsSourceReq 

type DocumentExistsSourceReq struct {
	Index      string
	DocumentID string

	Header http.Header
	Params DocumentExistsSourceParams
}

DocumentExistsSourceReq represents possible options for the _source exists request

func (DocumentExistsSourceReq) GetRequest 

func (r DocumentExistsSourceReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentExplainDetails 

type DocumentExplainDetails struct {
	Value       float64                  `json:"value"`
	Description string                   `json:"description"`
	Details     []DocumentExplainDetails `json:"details"`
}

DocumentExplainDetails is a sub type of DocumentExplainResp containing information about why a query does what it does

type DocumentExplainParams 

type DocumentExplainParams struct {
	Analyzer        string
	AnalyzeWildcard *bool
	DefaultOperator string
	Df              string
	Lenient         *bool
	Preference      string
	Query           string
	Routing         string
	Source          interface{}
	SourceExcludes  []string
	SourceIncludes  []string
	StoredFields    []string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentExplainParams represents possible parameters for the DocumentExplainReq

type DocumentExplainReq 

type DocumentExplainReq struct {
	Index      string
	DocumentID string

	Body io.Reader

	Header http.Header
	Params DocumentExplainParams
}

DocumentExplainReq represents possible options for the /<Index>/_explain/<DocumentID> request

func (DocumentExplainReq) GetRequest 

func (r DocumentExplainReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentExplainResp 

type DocumentExplainResp struct {
	Index       string                 `json:"_index"`
	ID          string                 `json:"_id"`
	Type        string                 `json:"_type"` // Deprecated field
	Matched     bool                   `json:"matched"`
	Explanation DocumentExplainDetails `json:"explanation"`
	// contains filtered or unexported fields
}

DocumentExplainResp represents the returned struct of the /<Index>/_explain/<DocumentID> response

func (DocumentExplainResp) Inspect 

func (r DocumentExplainResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DocumentGetParams 

type DocumentGetParams struct {
	Preference     string
	Realtime       *bool
	Refresh        *bool
	Routing        string
	Source         interface{}
	SourceExcludes []string
	SourceIncludes []string
	StoredFields   []string
	Version        *int
	VersionType    string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentGetParams represents possible parameters for the DocumentGetReq

type DocumentGetReq 

type DocumentGetReq struct {
	Index      string
	DocumentID string

	Header http.Header
	Params DocumentGetParams
}

DocumentGetReq represents possible options for the /<Index>/_doc/<DocumentID> get request

func (DocumentGetReq) GetRequest 

func (r DocumentGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentGetResp 

type DocumentGetResp struct {
	Index       string          `json:"_index"`
	ID          string          `json:"_id"`
	Version     int             `json:"_version"`
	SeqNo       int             `json:"_seq_no"`
	PrimaryTerm int             `json:"_primary_term"`
	Found       bool            `json:"found"`
	Type        string          `json:"_type"` // Deprecated field
	Source      json.RawMessage `json:"_source"`
	Fields      json.RawMessage `json:"fields"`
	// contains filtered or unexported fields
}

DocumentGetResp represents the returned struct of the /<Index>/_doc/<DocumentID> get response

func (DocumentGetResp) Inspect 

func (r DocumentGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type DocumentSourceParams 

type DocumentSourceParams struct {
	Preference string
	Realtime   *bool
	Refresh    *bool
	Routing    string
	// Deprecated: This parameter is similar to SourceIncludes, please use that instead.
	Source         interface{}
	SourceExcludes []string
	SourceIncludes []string
	Version        *int
	VersionType    string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

DocumentSourceParams represents possible parameters for the DocumentSourceReq

type DocumentSourceReq 

type DocumentSourceReq struct {
	Index      string
	DocumentID string

	Header http.Header
	Params DocumentSourceParams
}

DocumentSourceReq represents possible options for the /<Index>/_source/<DocumentID> get request

func (DocumentSourceReq) GetRequest 

func (r DocumentSourceReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type DocumentSourceResp 

type DocumentSourceResp struct {
	Source json.RawMessage
	// contains filtered or unexported fields
}

DocumentSourceResp represents the returned struct of the /<Index>/_source/<DocumentID> get response

func (DocumentSourceResp) Inspect 

func (r DocumentSourceResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type FailuresCause 

type FailuresCause struct {
	Type   string `json:"type"`
	Reason string `json:"reason"`
	NodeID string `json:"node_id"`
	Cause  *struct {
		Type   string `json:"type"`
		Reason string `json:"reason"`
		Cause  *struct {
			Type   string  `json:"type"`
			Reason *string `json:"reason"`
		} `json:"caused_by,omitempty"`
	} `json:"caused_by,omitempty"`
}

FailuresCause contains information about failure cause

type FailuresShard 

type FailuresShard struct {
	Shard  int           `json:"shard"`
	Index  string        `json:"index"`
	Status string        `json:"status"`
	Reason FailuresCause `json:"reason"`
}

FailuresShard contains information about shard failures

type IndexParams 

type IndexParams struct {
	IfPrimaryTerm       *int
	IfSeqNo             *int
	OpType              string
	Pipeline            string
	Refresh             string
	RequireAlias        *bool
	Routing             string
	Timeout             time.Duration
	Version             *int
	VersionType         string
	WaitForActiveShards string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndexParams represents possible parameters for the IndexReq

type IndexReq 

type IndexReq struct {
	Index      string
	DocumentID string
	Body       io.Reader
	Header     http.Header
	Params     IndexParams
}

IndexReq represents possible options for the /_doc request

func (IndexReq) GetRequest 

func (r IndexReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndexResp 

type IndexResp struct {
	Index   string `json:"_index"`
	ID      string `json:"_id"`
	Version int    `json:"_version"`
	Result  string `json:"result"`
	Shards  struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	SeqNo       int    `json:"_seq_no"`
	PrimaryTerm int    `json:"_primary_term"`
	Type        string `json:"_type"` // Deprecated field
	// contains filtered or unexported fields
}

IndexResp represents the returned struct of the /_doc response

func (IndexResp) Inspect 

func (r IndexResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndexTemplateCreateParams 

type IndexTemplateCreateParams struct {
	Cause                 string
	Create                *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndexTemplateCreateParams represents possible parameters for the IndexTemplateCreateReq

type IndexTemplateCreateReq 

type IndexTemplateCreateReq struct {
	IndexTemplate string

	Body io.Reader

	Header http.Header
	Params IndexTemplateCreateParams
}

IndexTemplateCreateReq represents possible options for the index create request

func (IndexTemplateCreateReq) GetRequest 

func (r IndexTemplateCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndexTemplateCreateResp 

type IndexTemplateCreateResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

IndexTemplateCreateResp represents the returned struct of the index create response

func (IndexTemplateCreateResp) Inspect 

func (r IndexTemplateCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndexTemplateDeleteParams 

type IndexTemplateDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndexTemplateDeleteParams represents possible parameters for the IndexTemplateDeleteReq

type IndexTemplateDeleteReq 

type IndexTemplateDeleteReq struct {
	IndexTemplate string

	Header http.Header
	Params IndexTemplateDeleteParams
}

IndexTemplateDeleteReq represents possible options for the index create request

func (IndexTemplateDeleteReq) GetRequest 

func (r IndexTemplateDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndexTemplateDeleteResp 

type IndexTemplateDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

IndexTemplateDeleteResp represents the returned struct of the index create response

func (IndexTemplateDeleteResp) Inspect 

func (r IndexTemplateDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndexTemplateExistsParams 

type IndexTemplateExistsParams struct {
	FlatSettings          *bool
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndexTemplateExistsParams represents possible parameters for the IndexTemplateExistsReq

type IndexTemplateExistsReq 

type IndexTemplateExistsReq struct {
	IndexTemplate string

	Header http.Header
	Params IndexTemplateExistsParams
}

IndexTemplateExistsReq represents possible options for the index create request

func (IndexTemplateExistsReq) GetRequest 

func (r IndexTemplateExistsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndexTemplateGetDetails 

type IndexTemplateGetDetails struct {
	Name          string `json:"name"`
	IndexTemplate struct {
		IndexPatterns []string `json:"index_patterns"`
		Template      struct {
			Mappings json.RawMessage `json:"mappings"`
			Settings json.RawMessage `json:"settings"`
			Aliases  json.RawMessage `json:"aliases"`
		} `json:"template"`
		ComposedOf []string        `json:"composed_of"`
		Priority   int             `json:"priority"`
		Version    int             `json:"version"`
		DataStream json.RawMessage `json:"data_stream"`
	} `json:"index_template"`
}

IndexTemplateGetDetails is a sub type of IndexTemplateGetResp containing information about an index template

type IndexTemplateGetParams 

type IndexTemplateGetParams struct {
	FlatSettings          *bool
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndexTemplateGetParams represents possible parameters for the IndexTemplateGetReq

type IndexTemplateGetReq 

type IndexTemplateGetReq struct {
	IndexTemplates []string

	Header http.Header
	Params IndexTemplateGetParams
}

IndexTemplateGetReq represents possible options for the index create request

func (IndexTemplateGetReq) GetRequest 

func (r IndexTemplateGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndexTemplateGetResp 

type IndexTemplateGetResp struct {
	IndexTemplates []IndexTemplateGetDetails `json:"index_templates"`
	// contains filtered or unexported fields
}

IndexTemplateGetResp represents the returned struct of the index create response

func (IndexTemplateGetResp) Inspect 

func (r IndexTemplateGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndexTemplateSimulateIndexParams 

type IndexTemplateSimulateIndexParams struct {
	Cause                 string
	Create                *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndexTemplateSimulateIndexParams represents possible parameters for the IndexTemplateSimulateIndexReq

type IndexTemplateSimulateIndexReq 

type IndexTemplateSimulateIndexReq struct {
	Index string

	Body io.Reader

	Header http.Header
	Params IndexTemplateSimulateIndexParams
}

IndexTemplateSimulateIndexReq represents possible options for the index create request

func (IndexTemplateSimulateIndexReq) GetRequest 

func (r IndexTemplateSimulateIndexReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndexTemplateSimulateIndexResp 

type IndexTemplateSimulateIndexResp struct {
	Template struct {
		Mappings json.RawMessage `json:"mappings"`
		Settings json.RawMessage `json:"settings"`
		Aliases  json.RawMessage `json:"aliases"`
	} `json:"template"`
	Overlapping []struct {
		Name          string   `json:"name"`
		IndexPatterns []string `json:"index_patterns"`
	} `json:"overlapping"`
	// contains filtered or unexported fields
}

IndexTemplateSimulateIndexResp represents the returned struct of the index create response

func (IndexTemplateSimulateIndexResp) Inspect 

func (r IndexTemplateSimulateIndexResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndexTemplateSimulateParams 

type IndexTemplateSimulateParams struct {
	Cause                 string
	Create                *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndexTemplateSimulateParams represents possible parameters for the IndexTemplateSimulateReq

type IndexTemplateSimulateReq 

type IndexTemplateSimulateReq struct {
	IndexTemplate string

	Body io.Reader

	Header http.Header
	Params IndexTemplateSimulateParams
}

IndexTemplateSimulateReq represents possible options for the index create request

func (IndexTemplateSimulateReq) GetRequest 

func (r IndexTemplateSimulateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndexTemplateSimulateResp 

type IndexTemplateSimulateResp struct {
	Template struct {
		Mappings json.RawMessage `json:"mappings"`
		Settings json.RawMessage `json:"settings"`
		Aliases  json.RawMessage `json:"aliases"`
	} `json:"template"`
	Overlapping []struct {
		Name          string   `json:"name"`
		IndexPatterns []string `json:"index_patterns"`
	} `json:"overlapping"`
	// contains filtered or unexported fields
}

IndexTemplateSimulateResp represents the returned struct of the index create response

func (IndexTemplateSimulateResp) Inspect 

func (r IndexTemplateSimulateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesAnalyzeBody 

type IndicesAnalyzeBody struct {
	Analyzer   string   `json:"analyzer,omitempty"`
	Attributes []string `json:"attributes,omitempty"`
	CharFilter []string `json:"char_filter,omitempty"`
	Explain    bool     `json:"explain,omitempty"`
	Field      string   `json:"field,omitempty"`
	Filter     []string `json:"filter,omitempty"`
	Normalizer string   `json:"normalizer,omitempty"`
	Text       []string `json:"text"`
	Tokenizer  string   `json:"tokenizer,omitempty"`
}

IndicesAnalyzeBody represents the request body for the indices analyze request

type IndicesAnalyzeCharfilter 

type IndicesAnalyzeCharfilter struct {
	Name         string   `json:"name"`
	FilteredText []string `json:"filtered_text"`
}

IndicesAnalyzeCharfilter is a sub type of IndicesAnalyzerResp containing information about the char filter name and filtered text

type IndicesAnalyzeInfo 

type IndicesAnalyzeInfo struct {
	Name   string `json:"name"`
	Tokens []struct {
		Token          string `json:"token"`
		StartOffset    int    `json:"start_offset"`
		EndOffset      int    `json:"end_offset"`
		Type           string `json:"type"`
		Position       int    `json:"position"`
		Bytes          string `json:"bytes"`
		PositionLength int    `json:"positionLength"`
		TermFrequency  int    `json:"termFrequency"`
	} `json:"tokens"`
}

IndicesAnalyzeInfo is a sub type of IndicesAnalyzerResp containing information about the analyzer name and tokens

type IndicesAnalyzeParams 

type IndicesAnalyzeParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesAnalyzeParams represents possible parameters for the IndicesAnalyzeReq

type IndicesAnalyzeReq 

type IndicesAnalyzeReq struct {
	Index string
	Body  IndicesAnalyzeBody

	Header http.Header
	Params IndicesAnalyzeParams
}

IndicesAnalyzeReq represents possible options for the <indices>/_analyze request

func (IndicesAnalyzeReq) GetRequest 

func (r IndicesAnalyzeReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesAnalyzeResp 

type IndicesAnalyzeResp struct {
	Tokens []IndicesAnalyzeToken `json:"tokens"`
	Detail struct {
		CustomAnalyzer bool                         `json:"custom_analyzer"`
		Charfilters    []IndicesAnalyzeCharfilter   `json:"charfilters"`
		Tokenizer      IndicesAnalyzeTokenizer      `json:"tokenizer"`
		Tokenfilters   []IndicesAnalyzeTokenfilters `json:"tokenfilters"`
		Analyzer       IndicesAnalyzeInfo           `json:"analyzer"`
	} `json:"detail"`
	// contains filtered or unexported fields
}

IndicesAnalyzeResp represents the returned struct of the index create response

func (IndicesAnalyzeResp) Inspect 

func (r IndicesAnalyzeResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesAnalyzeToken 

type IndicesAnalyzeToken struct {
	Token       string `json:"token"`
	StartOffset int    `json:"start_offset"`
	EndOffset   int    `json:"end_offset"`
	Type        string `json:"type"`
	Position    int    `json:"position"`
}

IndicesAnalyzeToken is a sut type of IndicesAnalyzeResp containing information about analyzer token

type IndicesAnalyzeTokenfilters 

type IndicesAnalyzeTokenfilters struct {
	Name   string `json:"name"`
	Tokens []struct {
		Token       string `json:"token"`
		StartOffset int    `json:"start_offset"`
		EndOffset   int    `json:"end_offset"`
		Type        string `json:"type"`
		Position    int    `json:"position"`
		Keyword     bool   `json:"keyword"`
	} `json:"tokens"`
}

IndicesAnalyzeTokenfilters is a sub type of IndicesAnalyzerResp containing information about the token filers name and tokens

type IndicesAnalyzeTokenizer 

type IndicesAnalyzeTokenizer struct {
	Name   string                `json:"name"`
	Tokens []IndicesAnalyzeToken `json:"tokens"`
}

IndicesAnalyzeTokenizer is a sub type of IndicesAnalyzerResp containing information about the tokenizer name and tokens

type IndicesBlockParams 

type IndicesBlockParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	IgnoreUnavailable     *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesBlockParams represents possible parameters for the IndicesBlockReq

type IndicesBlockReq 

type IndicesBlockReq struct {
	Indices []string
	Block   string

	Header http.Header
	Params IndicesBlockParams
}

IndicesBlockReq represents possible options for the index create request

func (IndicesBlockReq) GetRequest 

func (r IndicesBlockReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesBlockResp 

type IndicesBlockResp struct {
	Acknowledged       bool `json:"acknowledged"`
	ShardsAcknowledged bool `json:"shards_acknowledged"`
	Indices            []struct {
		Name         string `json:"name"`
		Blocked      bool   `json:"blocked"`
		FailedShards []struct {
			ID       int             `json:"id"`
			Failures []FailuresShard `json:"failures"`
		} `json:"failed_shards"`
	} `json:"indices"`
	// contains filtered or unexported fields
}

IndicesBlockResp represents the returned struct of the index create response

func (IndicesBlockResp) Inspect 

func (r IndicesBlockResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesClearCacheParams 

type IndicesClearCacheParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	Fielddata         *bool
	Fields            []string
	IgnoreUnavailable *bool
	Query             *bool
	Request           *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesClearCacheParams represents possible parameters for the IndicesClearCacheReq

type IndicesClearCacheReq 

type IndicesClearCacheReq struct {
	Indices []string

	Header http.Header
	Params IndicesClearCacheParams
}

IndicesClearCacheReq represents possible options for the index clear cache request

func (IndicesClearCacheReq) GetRequest 

func (r IndicesClearCacheReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesClearCacheResp 

type IndicesClearCacheResp struct {
	Shards struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresShard `json:"failures"`
	} `json:"_shards"`
	// contains filtered or unexported fields
}

IndicesClearCacheResp represents the returned struct of the index clear cache response

func (IndicesClearCacheResp) Inspect 

func (r IndicesClearCacheResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesCloneParams 

type IndicesCloneParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesCloneParams represents possible parameters for the IndicesCloneReq

type IndicesCloneReq 

type IndicesCloneReq struct {
	Index  string
	Target string

	Body io.Reader

	Header http.Header
	Params IndicesCloneParams
}

IndicesCloneReq represents possible options for the index clone request

func (IndicesCloneReq) GetRequest 

func (r IndicesCloneReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesCloneResp 

type IndicesCloneResp struct {
	Acknowledged       bool   `json:"acknowledged"`
	ShardsAcknowledged bool   `json:"shards_acknowledged"`
	Index              string `json:"index"`
	// contains filtered or unexported fields
}

IndicesCloneResp represents the returned struct of the index clone response

func (IndicesCloneResp) Inspect 

func (r IndicesCloneResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesCloseParams 

type IndicesCloseParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	IgnoreUnavailable     *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesCloseParams represents possible parameters for the IndicesCloseReq

type IndicesCloseReq 

type IndicesCloseReq struct {
	Index string

	Header http.Header
	Params IndicesCloseParams
}

IndicesCloseReq represents possible options for the index close request

func (IndicesCloseReq) GetRequest 

func (r IndicesCloseReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesCloseResp 

type IndicesCloseResp struct {
	Acknowledged       bool `json:"acknowledged"`
	ShardsAcknowledged bool `json:"shards_acknowledged"`
	Indices            map[string]struct {
		Closed       bool `json:"closed"`
		FailedShards map[string]struct {
			Failures []FailuresShard `json:"failures"`
		} `json:"failed_shards"`
	} `json:"indices"`
	// contains filtered or unexported fields
}

IndicesCloseResp represents the returned struct of the index close response

func (IndicesCloseResp) Inspect 

func (r IndicesCloseResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesCountParams 

type IndicesCountParams struct {
	AllowNoIndices    *bool
	Analyzer          string
	AnalyzeWildcard   *bool
	DefaultOperator   string
	Df                string
	ExpandWildcards   string
	IgnoreThrottled   *bool
	IgnoreUnavailable *bool
	Lenient           *bool
	MinScore          *int
	Preference        string
	Query             string
	Routing           []string
	TerminateAfter    *int

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesCountParams represents possible parameters for the IndicesCountReq

type IndicesCountReq 

type IndicesCountReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params IndicesCountParams
}

IndicesCountReq represents possible options for the index shrink request

func (IndicesCountReq) GetRequest 

func (r IndicesCountReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesCountResp 

type IndicesCountResp struct {
	Shards struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Skipped    int `json:"skipped"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	Count int `json:"count"`
	// contains filtered or unexported fields
}

IndicesCountResp represents the returned struct of the index shrink response

func (IndicesCountResp) Inspect 

func (r IndicesCountResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesCreateParams 

type IndicesCreateParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesCreateParams represents possible parameters for the IndicesCreateReq

type IndicesCreateReq 

type IndicesCreateReq struct {
	Index  string
	Body   io.Reader
	Header http.Header
	Params IndicesCreateParams
}

IndicesCreateReq represents possible options for the index create request

func (IndicesCreateReq) GetRequest 

func (r IndicesCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesCreateResp 

type IndicesCreateResp struct {
	Acknowledged       bool   `json:"acknowledged"`
	ShardsAcknowledged bool   `json:"shards_acknowledged"`
	Index              string `json:"index"`
	// contains filtered or unexported fields
}

IndicesCreateResp represents the returned struct of the index create response

func (IndicesCreateResp) Inspect 

func (r IndicesCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesDeleteParams 

type IndicesDeleteParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	IgnoreUnavailable     *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesDeleteParams represents possible parameters for the IndicesDeleteReq

type IndicesDeleteReq 

type IndicesDeleteReq struct {
	Indices []string
	Header  http.Header
	Params  IndicesDeleteParams
}

IndicesDeleteReq represents possible options for the delete indices request

func (IndicesDeleteReq) GetRequest 

func (r IndicesDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesDeleteResp 

type IndicesDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

IndicesDeleteResp represents the returned struct of the delete indices response

func (IndicesDeleteResp) Inspect 

func (r IndicesDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesExistsParams 

type IndicesExistsParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	FlatSettings      *bool
	IgnoreUnavailable *bool
	IncludeDefaults   *bool
	Local             *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesExistsParams represents possible parameters for the IndicesExistsReq

type IndicesExistsReq 

type IndicesExistsReq struct {
	Indices []string
	Header  http.Header
	Params  IndicesExistsParams
}

IndicesExistsReq represents possible options for the index exists request

func (IndicesExistsReq) GetRequest 

func (r IndicesExistsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesFieldCapsParams 

type IndicesFieldCapsParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	Fields            []string
	IgnoreUnavailable *bool
	IncludeUnmapped   *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesFieldCapsParams represents possible parameters for the IndicesFieldCapsReq

type IndicesFieldCapsReq 

type IndicesFieldCapsReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params IndicesFieldCapsParams
}

IndicesFieldCapsReq represents possible options for the index shrink request

func (IndicesFieldCapsReq) GetRequest 

func (r IndicesFieldCapsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesFieldCapsResp 

type IndicesFieldCapsResp struct {
	Indices []string `json:"indices"`
	Fields  map[string]map[string]struct {
		Type         string   `json:"type"`
		Searchable   bool     `json:"searchable"`
		Aggregatable bool     `json:"aggregatable"`
		Indices      []string `json:"indices"`
	} `json:"fields"`
	// contains filtered or unexported fields
}

IndicesFieldCapsResp represents the returned struct of the index shrink response

func (IndicesFieldCapsResp) Inspect 

func (r IndicesFieldCapsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesFlushParams 

type IndicesFlushParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	Force             *bool
	IgnoreUnavailable *bool
	WaitIfOngoing     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesFlushParams represents possible parameters for the IndicesFlushReq

type IndicesFlushReq 

type IndicesFlushReq struct {
	Indices []string

	Header http.Header
	Params IndicesFlushParams
}

IndicesFlushReq represents possible options for the flush indices request

func (IndicesFlushReq) GetRequest 

func (r IndicesFlushReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesFlushResp 

type IndicesFlushResp struct {
	Shards struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresShard `json:"failures"`
	} `json:"_shards"`
	// contains filtered or unexported fields
}

IndicesFlushResp represents the returned struct of the flush indices response

func (IndicesFlushResp) Inspect 

func (r IndicesFlushResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesForcemergeParams 

type IndicesForcemergeParams struct {
	AllowNoIndices     *bool
	ExpandWildcards    string
	Flush              *bool
	IgnoreUnavailable  *bool
	MaxNumSegments     *int
	OnlyExpungeDeletes *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesForcemergeParams represents possible parameters for the IndicesForcemergeReq

type IndicesForcemergeReq 

type IndicesForcemergeReq struct {
	Indices []string

	Header http.Header
	Params IndicesForcemergeParams
}

IndicesForcemergeReq represents possible options for the <index>/_forcemerge request

func (IndicesForcemergeReq) GetRequest 

func (r IndicesForcemergeReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesForcemergeResp 

type IndicesForcemergeResp struct {
	Shards struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresShard `json:"failures"`
	} `json:"_shards"`
	// contains filtered or unexported fields
}

IndicesForcemergeResp represents the returned struct of the flush indices response

func (IndicesForcemergeResp) Inspect 

func (r IndicesForcemergeResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesGetParams 

type IndicesGetParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	FlatSettings          *bool
	IgnoreUnavailable     *bool
	IncludeDefaults       *bool
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesGetParams represents possible parameters for the IndicesGetReq

type IndicesGetReq 

type IndicesGetReq struct {
	Indices []string

	Header http.Header
	Params IndicesGetParams
}

IndicesGetReq represents possible options for the get indices request

func (IndicesGetReq) GetRequest 

func (r IndicesGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesGetResp 

type IndicesGetResp struct {
	Indices map[string]struct {
		DataStream *string             `json:"data_stream,omitempty"`
		Aliases    map[string]struct{} `json:"aliases"`
		Mappings   json.RawMessage     `json:"mappings"`
		Settings   json.RawMessage     `json:"settings"`
	}
	// contains filtered or unexported fields
}

IndicesGetResp represents the returned struct of the get indices response

func (IndicesGetResp) Inspect 

func (r IndicesGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesOpenParams 

type IndicesOpenParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	IgnoreUnavailable     *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesOpenParams represents possible parameters for the IndicesOpenReq

type IndicesOpenReq 

type IndicesOpenReq struct {
	Index string

	Header http.Header
	Params IndicesOpenParams
}

IndicesOpenReq represents possible options for the index open request

func (IndicesOpenReq) GetRequest 

func (r IndicesOpenReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesOpenResp 

type IndicesOpenResp struct {
	Acknowledged       bool `json:"acknowledged"`
	ShardsAcknowledged bool `json:"shards_acknowledged"`
	// contains filtered or unexported fields
}

IndicesOpenResp represents the returned struct of the index open response

func (IndicesOpenResp) Inspect 

func (r IndicesOpenResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesRecoveryNodeInfo 

type IndicesRecoveryNodeInfo struct {
	ID               string `json:"id"`
	Host             string `json:"host"`
	TransportAddress string `json:"transport_address"`
	IP               string `json:"ip"`
	Name             string `json:"name"`
}

IndicesRecoveryNodeInfo is a sub type of IndicesRecoveryResp represeing Node information

type IndicesRecoveryParams 

type IndicesRecoveryParams struct {
	ActiveOnly *bool
	Detailed   *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesRecoveryParams represents possible parameters for the IndicesShrinkReq

type IndicesRecoveryReq 

type IndicesRecoveryReq struct {
	Indices []string

	Header http.Header
	Params IndicesRecoveryParams
}

IndicesRecoveryReq represents possible options for the index shrink request

func (IndicesRecoveryReq) GetRequest 

func (r IndicesRecoveryReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesRecoveryResp 

type IndicesRecoveryResp struct {
	Indices map[string]struct {
		Shards []struct {
			ID                int                     `json:"id"`
			Type              string                  `json:"type"`
			Stage             string                  `json:"stage"`
			Primary           bool                    `json:"primary"`
			StartTimeInMillis int64                   `json:"start_time_in_millis"`
			StopTimeInMillis  int64                   `json:"stop_time_in_millis"`
			TotalTimeInMillis int                     `json:"total_time_in_millis"`
			Source            IndicesRecoveryNodeInfo `json:"source"`
			Target            IndicesRecoveryNodeInfo `json:"target"`
			Index             struct {
				Size struct {
					TotalInBytes     int    `json:"total_in_bytes"`
					ReusedInBytes    int    `json:"reused_in_bytes"`
					RecoveredInBytes int    `json:"recovered_in_bytes"`
					Percent          string `json:"percent"`
				} `json:"size"`
				Files struct {
					Total     int    `json:"total"`
					Reused    int    `json:"reused"`
					Recovered int    `json:"recovered"`
					Percent   string `json:"percent"`
				} `json:"files"`
				TotalTimeInMillis          int `json:"total_time_in_millis"`
				SourceThrottleTimeInMillis int `json:"source_throttle_time_in_millis"`
				TargetThrottleTimeInMillis int `json:"target_throttle_time_in_millis"`
			} `json:"index"`
			Translog struct {
				Recovered         int    `json:"recovered"`
				Total             int    `json:"total"`
				Percent           string `json:"percent"`
				TotalOnStart      int    `json:"total_on_start"`
				TotalTimeInMillis int    `json:"total_time_in_millis"`
			} `json:"translog"`
			VerifyIndex struct {
				CheckIndexTimeInMillis int `json:"check_index_time_in_millis"`
				TotalTimeInMillis      int `json:"total_time_in_millis"`
			} `json:"verify_index"`
		} `json:"shards"`
	}
	// contains filtered or unexported fields
}

IndicesRecoveryResp represents the returned struct of the index shrink response

func (IndicesRecoveryResp) Inspect 

func (r IndicesRecoveryResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesRefreshParams 

type IndicesRefreshParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	IgnoreUnavailable *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesRefreshParams represents possible parameters for the IndicesRefreshReq

type IndicesRefreshReq 

type IndicesRefreshReq struct {
	Indices []string

	Header http.Header
	Params IndicesRefreshParams
}

IndicesRefreshReq represents possible options for the <index>/_refresh request

func (IndicesRefreshReq) GetRequest 

func (r IndicesRefreshReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesRefreshResp 

type IndicesRefreshResp struct {
	Shards struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	// contains filtered or unexported fields
}

IndicesRefreshResp represents the returned struct of the index shrink response

func (IndicesRefreshResp) Inspect 

func (r IndicesRefreshResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesResolveParams 

type IndicesResolveParams struct {
	ExpandWildcards string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesResolveParams represents possible parameters for the IndicesResolveReq

type IndicesResolveReq 

type IndicesResolveReq struct {
	Indices []string

	Header http.Header
	Params IndicesResolveParams
}

IndicesResolveReq represents possible options for the get indices request

func (IndicesResolveReq) GetRequest 

func (r IndicesResolveReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesResolveResp 

type IndicesResolveResp struct {
	Indices []struct {
		Name       string   `json:"name"`
		Attributes []string `json:"attributes"`
		Aliases    []string `json:"aliases"`
	} `json:"indices"`
	Aliases []struct {
		Name    string   `json:"name"`
		Indices []string `json:"indices"`
	} `json:"aliases"`
	DataStreams []struct {
		Name           string   `json:"name"`
		BackingIndices []string `json:"backing_indices"`
		TimestampField string   `json:"timestamp_field"`
	} `json:"data_streams"`
	// contains filtered or unexported fields
}

IndicesResolveResp represents the returned struct of the get indices response

func (IndicesResolveResp) Inspect 

func (r IndicesResolveResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesRolloverParams 

type IndicesRolloverParams struct {
	DryRun                *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesRolloverParams represents possible parameters for the IndicesRolloverReq

type IndicesRolloverReq 

type IndicesRolloverReq struct {
	Alias string
	Index string

	Body io.Reader

	Header http.Header
	Params IndicesRolloverParams
}

IndicesRolloverReq represents possible options for the index shrink request

func (IndicesRolloverReq) GetRequest 

func (r IndicesRolloverReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesRolloverResp 

type IndicesRolloverResp struct {
	Acknowledged       bool            `json:"acknowledged"`
	ShardsAcknowledged bool            `json:"shards_acknowledged"`
	OldIndex           string          `json:"old_index"`
	NewIndex           string          `json:"new_index"`
	RolledOver         bool            `json:"rolled_over"`
	DryRun             bool            `json:"dry_run"`
	Conditions         map[string]bool `json:"conditions"`
	// contains filtered or unexported fields
}

IndicesRolloverResp represents the returned struct of the index shrink response

func (IndicesRolloverResp) Inspect 

func (r IndicesRolloverResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesSegmentsDetails 

type IndicesSegmentsDetails struct {
	Generation    int    `json:"generation"`
	NumDocs       int    `json:"num_docs"`
	DeletedDocs   int    `json:"deleted_docs"`
	SizeInBytes   int64  `json:"size_in_bytes"`
	MemoryInBytes int    `json:"memory_in_bytes"`
	Committed     bool   `json:"committed"`
	Search        bool   `json:"search"`
	Version       string `json:"version"`
	Compound      bool   `json:"compound"`
	MergeID       string `json:"merge_id"`
	Sort          []struct {
		Field   string `json:"field"`
		Mode    string `json:"mode"`
		Missing string `json:"missing"`
		Reverse bool   `json:"reverse"`
	} `json:"sort"`
	Attributes map[string]string `json:"attributes"`
}

IndicesSegmentsDetails is a sub type of IndicesSegmentsShards containing information about a segment

type IndicesSegmentsParams 

type IndicesSegmentsParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	IgnoreUnavailable *bool
	Verbose           *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesSegmentsParams represents possible parameters for the IndicesSegmentsReq

type IndicesSegmentsReq 

type IndicesSegmentsReq struct {
	Indices []string

	Header http.Header
	Params IndicesSegmentsParams
}

IndicesSegmentsReq represents possible options for the index shrink request

func (IndicesSegmentsReq) GetRequest 

func (r IndicesSegmentsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesSegmentsResp 

type IndicesSegmentsResp struct {
	Shards struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresShard `json:"failures"`
	} `json:"_shards"`
	Indices map[string]struct {
		Shards map[string][]IndicesSegmentsShards `json:"shards"`
	} `json:"indices"`
	// contains filtered or unexported fields
}

IndicesSegmentsResp represents the returned struct of the index shrink response

func (IndicesSegmentsResp) Inspect 

func (r IndicesSegmentsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesSegmentsShards 

type IndicesSegmentsShards struct {
	Routing struct {
		State   string `json:"state"`
		Primary bool   `json:"primary"`
		Node    string `json:"node"`
	} `json:"routing"`
	NumCommittedSegments int                               `json:"num_committed_segments"`
	NumSearchSegments    int                               `json:"num_search_segments"`
	Segments             map[string]IndicesSegmentsDetails `json:"segments"`
}

IndicesSegmentsShards is a sub type of IndicesSegmentsResp containing information about a shard

type IndicesShardStoresParams 

type IndicesShardStoresParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	IgnoreUnavailable *bool
	Status            []string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesShardStoresParams represents possible parameters for the IndicesShardStoresReq

type IndicesShardStoresReq 

type IndicesShardStoresReq struct {
	Indices []string

	Header http.Header
	Params IndicesShardStoresParams
}

IndicesShardStoresReq represents possible options for the index shrink request

func (IndicesShardStoresReq) GetRequest 

func (r IndicesShardStoresReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesShardStoresResp 

type IndicesShardStoresResp struct {
	Indices map[string]struct {
		Shards map[string]struct {
			Stores []json.RawMessage `json:"stores"`
		} `json:"shards"`
	} `json:"indices"`
	Failures []FailuresShard `json:"failures"`
	// contains filtered or unexported fields
}

IndicesShardStoresResp represents the returned struct of the index shrink response

func (IndicesShardStoresResp) Inspect 

func (r IndicesShardStoresResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesShrinkParams 

type IndicesShrinkParams struct {
	CopySettings          *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesShrinkParams represents possible parameters for the IndicesShrinkReq

type IndicesShrinkReq 

type IndicesShrinkReq struct {
	Index  string
	Target string

	Body io.Reader

	Header http.Header
	Params IndicesShrinkParams
}

IndicesShrinkReq represents possible options for the index shrink request

func (IndicesShrinkReq) GetRequest 

func (r IndicesShrinkReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesShrinkResp 

type IndicesShrinkResp struct {
	Acknowledged       bool   `json:"acknowledged"`
	ShardsAcknowledged bool   `json:"shards_acknowledged"`
	Index              string `json:"index"`
	// contains filtered or unexported fields
}

IndicesShrinkResp represents the returned struct of the index shrink response

func (IndicesShrinkResp) Inspect 

func (r IndicesShrinkResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesSplitParams 

type IndicesSplitParams struct {
	CopySettings          *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesSplitParams represents possible parameters for the IndicesSplitReq

type IndicesSplitReq 

type IndicesSplitReq struct {
	Index  string
	Target string

	Body io.Reader

	Header http.Header
	Params IndicesSplitParams
}

IndicesSplitReq represents possible options for the index split request

func (IndicesSplitReq) GetRequest 

func (r IndicesSplitReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesSplitResp 

type IndicesSplitResp struct {
	Acknowledged       bool   `json:"acknowledged"`
	ShardsAcknowledged bool   `json:"shards_acknowledged"`
	Index              string `json:"index"`
	// contains filtered or unexported fields
}

IndicesSplitResp represents the returned struct of the index split response

func (IndicesSplitResp) Inspect 

func (r IndicesSplitResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesStatsAll 

type IndicesStatsAll struct {
	Primaries IndicesStatsInfo `json:"primaries"`
	Total     IndicesStatsInfo `json:"total"`
}

IndicesStatsAll is a sub type of IndicesStatsResp containing information about docs stats from all indices

type IndicesStatsCompletion 

type IndicesStatsCompletion struct {
	SizeInBytes int `json:"size_in_bytes"`
}

IndicesStatsCompletion is a sub type of IndicesStatsInfo containing stats about index completion

type IndicesStatsDetails 

type IndicesStatsDetails struct {
	UUID      string           `json:"uuid"`
	Primaries IndicesStatsInfo `json:"primaries"`
	Total     IndicesStatsInfo `json:"total"`
}

IndicesStatsDetails is a sub type of IndicesStatsIndices containing the information about the index uuid and index stats

type IndicesStatsDocs 

type IndicesStatsDocs struct {
	Count   int `json:"count"`
	Deleted int `json:"deleted"`
}

IndicesStatsDocs is a sub type of IndicesStatsInfo containing stats about the index documents

type IndicesStatsFielddata 

type IndicesStatsFielddata struct {
	MemorySizeInBytes int `json:"memory_size_in_bytes"`
	Evictions         int `json:"evictions"`
}

IndicesStatsFielddata is a sub type of IndicesStatsInfo containing stats about index fielddata

type IndicesStatsFlush 

type IndicesStatsFlush struct {
	Total             int `json:"total"`
	Periodic          int `json:"periodic"`
	TotalTimeInMillis int `json:"total_time_in_millis"`
}

IndicesStatsFlush is a sub type of IndicesStatsInfo containing stats about index flush

type IndicesStatsGet 

type IndicesStatsGet struct {
	Total               int    `json:"total"`
	TimeInMillis        int    `json:"time_in_millis"`
	ExistsTotal         int    `json:"exists_total"`
	ExistsTimeInMillis  int    `json:"exists_time_in_millis"`
	MissingTotal        int    `json:"missing_total"`
	MissingTimeInMillis int    `json:"missing_time_in_millis"`
	Current             int    `json:"current"`
	GetTime             string `json:"getTime"`
}

IndicesStatsGet is a sub type of IndicesStatsInfo containing stats about index get

type IndicesStatsIndexing 

type IndicesStatsIndexing struct {
	IndexTotal           int            `json:"index_total"`
	IndexTimeInMillis    int            `json:"index_time_in_millis"`
	IndexCurrent         int            `json:"index_current"`
	IndexFailed          int            `json:"index_failed"`
	DeleteTotal          int            `json:"delete_total"`
	DeleteTimeInMillis   int            `json:"delete_time_in_millis"`
	DeleteCurrent        int            `json:"delete_current"`
	NoopUpdateTotal      int            `json:"noop_update_total"`
	IsThrottled          bool           `json:"is_throttled"`
	ThrottleTimeInMillis int            `json:"throttle_time_in_millis"`
	DocStatus            map[string]int `json:"doc_status"`
}

IndicesStatsIndexing is a sub type of IndicesStatsInfo containing stats about document indexing

type IndicesStatsIndices 

type IndicesStatsIndices map[string]IndicesStatsDetails

IndicesStatsIndices is a sub type of IndicesStatsResp containing information about docs stats from specific indices

type IndicesStatsInfo 

type IndicesStatsInfo struct {
	Docs         IndicesStatsDocs         `json:"docs"`
	Store        IndicesStatsStore        `json:"store"`
	Indexing     IndicesStatsIndexing     `json:"indexing"`
	Get          IndicesStatsGet          `json:"get"`
	Search       IndicesStatsSearch       `json:"search"`
	Merges       IndicesStatsMerges       `json:"merges"`
	Refresh      IndicesStatsRefresh      `json:"refresh"`
	Flush        IndicesStatsFlush        `json:"flush"`
	Warmer       IndicesStatsWarmer       `json:"warmer"`
	QueryCache   IndicesStatsQueryCache   `json:"query_cache"`
	Fielddata    IndicesStatsFielddata    `json:"fielddata"`
	Completion   IndicesStatsCompletion   `json:"completion"`
	Segments     IndicesStatsSegments     `json:"segments"`
	Translog     IndicesStatsTranslog     `json:"translog"`
	RequestCache IndicesStatsRequestCache `json:"request_cache"`
	Recovery     IndicesStatsRecovery     `json:"recovery"`
}

IndicesStatsInfo is a sub type of IndicesStatsAll, IndicesStatsDetails aggregating all document stats

type IndicesStatsMerges 

type IndicesStatsMerges struct {
	Current                           int   `json:"current"`
	CurrentDocs                       int   `json:"current_docs"`
	CurrentSizeInBytes                int   `json:"current_size_in_bytes"`
	Total                             int   `json:"total"`
	TotalTimeInMillis                 int   `json:"total_time_in_millis"`
	TotalDocs                         int   `json:"total_docs"`
	TotalSizeInBytes                  int64 `json:"total_size_in_bytes"`
	TotalStoppedTimeInMillis          int   `json:"total_stopped_time_in_millis"`
	TotalThrottledTimeInMillis        int   `json:"total_throttled_time_in_millis"`
	TotalAutoThrottleInBytes          int   `json:"total_auto_throttle_in_bytes"`
	UnreferencedFileCleanupsPerformed int   `json:"unreferenced_file_cleanups_performed"`
}

IndicesStatsMerges is a sub type of IndicesStatsInfo containing stats about index merges

type IndicesStatsParams 

type IndicesStatsParams struct {
	CopySettings          *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WaitForActiveShards   string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesStatsParams represents possible parameters for the IndicesStatsReq

type IndicesStatsQueryCache 

type IndicesStatsQueryCache struct {
	MemorySizeInBytes int `json:"memory_size_in_bytes"`
	TotalCount        int `json:"total_count"`
	HitCount          int `json:"hit_count"`
	MissCount         int `json:"miss_count"`
	CacheSize         int `json:"cache_size"`
	CacheCount        int `json:"cache_count"`
	Evictions         int `json:"evictions"`
}

IndicesStatsQueryCache is a sub type of IndicesStatsInfo containing stats about index query cache

type IndicesStatsRecovery 

type IndicesStatsRecovery struct {
	CurrentAsSource      int `json:"current_as_source"`
	CurrentAsTarget      int `json:"current_as_target"`
	ThrottleTimeInMillis int `json:"throttle_time_in_millis"`
}

IndicesStatsRecovery is a sub type of IndicesStatsInfo containing stats about index recovery

type IndicesStatsRefresh 

type IndicesStatsRefresh struct {
	Total                     int `json:"total"`
	TotalTimeInMillis         int `json:"total_time_in_millis"`
	ExternalTotal             int `json:"external_total"`
	ExternalTotalTimeInMillis int `json:"external_total_time_in_millis"`
	Listeners                 int `json:"listeners"`
}

IndicesStatsRefresh is a sub type of IndicesStatsInfo containing stats about index refresh

type IndicesStatsReq 

type IndicesStatsReq struct {
	Indices []string
	Metrics []string

	Header http.Header
	Params IndicesStatsParams
}

IndicesStatsReq represents possible options for the index shrink request

func (IndicesStatsReq) GetRequest 

func (r IndicesStatsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesStatsRequestCache 

type IndicesStatsRequestCache struct {
	MemorySizeInBytes int `json:"memory_size_in_bytes"`
	Evictions         int `json:"evictions"`
	HitCount          int `json:"hit_count"`
	MissCount         int `json:"miss_count"`
}

IndicesStatsRequestCache is a sub type of IndicesStatsInfo containing stats about index request cache

type IndicesStatsResp 

type IndicesStatsResp struct {
	Shards  IndicesStatsShards  `json:"_shards"`
	All     IndicesStatsAll     `json:"_all"`
	Indices IndicesStatsIndices `json:"indices"`
	// contains filtered or unexported fields
}

IndicesStatsResp represents the returned struct of the index shrink response

func (IndicesStatsResp) Inspect 

func (r IndicesStatsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IndicesStatsSearch 

type IndicesStatsSearch struct {
	OpenContexts                int     `json:"open_contexts"`
	QueryTotal                  int     `json:"query_total"`
	QueryTimeInMillis           int     `json:"query_time_in_millis"`
	QueryCurrent                int     `json:"query_current"`
	ConcurrentQueryTotal        int     `json:"concurrent_query_total"`
	ConcurrentQueryTimeInMillis int     `json:"concurrent_query_time_in_millis"`
	ConcurrentQueryCurrent      int     `json:"concurrent_query_current"`
	ConcurrentAVGSliceCount     float32 `json:"concurrent_avg_slice_count"`
	FetchTotal                  int     `json:"fetch_total"`
	FetchTimeInMillis           int     `json:"fetch_time_in_millis"`
	FetchCurrent                int     `json:"fetch_current"`
	ScrollTotal                 int     `json:"scroll_total"`
	ScrollTimeInMillis          int     `json:"scroll_time_in_millis"`
	ScrollCurrent               int     `json:"scroll_current"`
	PointInTimeTotal            int     `json:"point_in_time_total"`
	PointInTimeTimeInMillis     int     `json:"point_in_time_time_in_millis"`
	PointInTimeCurrent          int     `json:"point_in_time_current"`
	SuggestTotal                int     `json:"suggest_total"`
	SuggestTimeInMillis         int     `json:"suggest_time_in_millis"`
	SuggestCurrent              int     `json:"suggest_current"`
	IdleReactivateCountTotal    int     `json:"search_idle_reactivate_count_total"`
}

IndicesStatsSearch is a sub type of IndicesStatsInfo containing stats about index search

type IndicesStatsSegments 

type IndicesStatsSegments struct {
	Count                     int   `json:"count"`
	MemoryInBytes             int   `json:"memory_in_bytes"`
	TermsMemoryInBytes        int   `json:"terms_memory_in_bytes"`
	StoredFieldsMemoryInBytes int   `json:"stored_fields_memory_in_bytes"`
	TermVectorsMemoryInBytes  int   `json:"term_vectors_memory_in_bytes"`
	NormsMemoryInBytes        int   `json:"norms_memory_in_bytes"`
	PointsMemoryInBytes       int   `json:"points_memory_in_bytes"`
	DocValuesMemoryInBytes    int   `json:"doc_values_memory_in_bytes"`
	IndexWriterMemoryInBytes  int   `json:"index_writer_memory_in_bytes"`
	VersionMapMemoryInBytes   int   `json:"version_map_memory_in_bytes"`
	FixedBitSetMemoryInBytes  int   `json:"fixed_bit_set_memory_in_bytes"`
	MaxUnsafeAutoIDTimestamp  int64 `json:"max_unsafe_auto_id_timestamp"`
	RemoteStore               struct {
		Upload struct {
			TotalUploadSize struct {
				StartedBytes   int `json:"started_bytes"`
				SucceededBytes int `json:"succeeded_bytes"`
				FailedBytes    int `json:"failed_bytes"`
			} `json:"total_upload_size"`
			RefreshSizeLag struct {
				TotalBytes int `json:"total_bytes"`
				MaxBytes   int `json:"max_bytes"`
			} `json:"refresh_size_lag"`
			MaxRefreshTimeLagInMillis int `json:"max_refresh_time_lag_in_millis"`
			TotalTimeSpentInMillis    int `json:"total_time_spent_in_millis"`
			Pressure                  struct {
				TotalRejections int `json:"total_rejections"`
			} `json:"pressure"`
		} `json:"upload"`
		Download struct {
			TotalDownloadSize struct {
				StartedBytes   int `json:"started_bytes"`
				SucceededBytes int `json:"succeeded_bytes"`
				FailedBytes    int `json:"failed_bytes"`
			} `json:"total_download_size"`
			TotalTimeSpentInMillis int `json:"total_time_spent_in_millis"`
		} `json:"download"`
	} `json:"remote_store"`
	SegmentReplication struct {
		// Type is json.RawMessage due to difference in opensearch versions from string to int
		MaxBytesBehind    json.RawMessage `json:"max_bytes_behind"`
		TotalBytesBehind  json.RawMessage `json:"total_bytes_behind"`
		MaxReplicationLag json.RawMessage `json:"max_replication_lag"`
	} `json:"segment_replication"`
	FileSizes json.RawMessage `json:"file_sizes"`
}

IndicesStatsSegments is a sub type of IndicesStatsInfo containing stats about index segments

type IndicesStatsShards 

type IndicesStatsShards struct {
	Total      int             `json:"total"`
	Successful int             `json:"successful"`
	Failed     int             `json:"failed"`
	Failures   []FailuresShard `json:"failures"`
}

IndicesStatsShards is a sub type of IndicesStatsResp containing information about how many shards got requested

type IndicesStatsStore 

type IndicesStatsStore struct {
	SizeInBytes     int64 `json:"size_in_bytes"`
	ReservedInBytes int   `json:"reserved_in_bytes"`
}

IndicesStatsStore is a sub type of IndicesStatsInfo containing stats about index storage

type IndicesStatsTranslog 

type IndicesStatsTranslog struct {
	Operations              int `json:"operations"`
	SizeInBytes             int `json:"size_in_bytes"`
	UncommittedOperations   int `json:"uncommitted_operations"`
	UncommittedSizeInBytes  int `json:"uncommitted_size_in_bytes"`
	EarliestLastModifiedAge int `json:"earliest_last_modified_age"`
	RemoteStore             struct {
		Upload struct {
			TotalUploads struct {
				Started   int `json:"started"`
				Failed    int `json:"failed"`
				Succeeded int `json:"succeeded"`
			} `json:"total_uploads"`
			TotalUploadSize struct {
				StartedBytes   int `json:"started_bytes"`
				FailedBytes    int `json:"failed_bytes"`
				SucceededBytes int `json:"succeeded_bytes"`
			} `json:"total_upload_size"`
		} `json:"upload"`
	} `json:"remote_store"`
}

IndicesStatsTranslog is a sub type of IndicesStatsInfo containing stats about index translog

type IndicesStatsWarmer 

type IndicesStatsWarmer struct {
	Current           int `json:"current"`
	Total             int `json:"total"`
	TotalTimeInMillis int `json:"total_time_in_millis"`
}

IndicesStatsWarmer is a sub type of IndicesStatsInfo containing stats about index warmer

type IndicesValidateQueryParams 

type IndicesValidateQueryParams struct {
	AllowNoIndices    *bool
	AllShards         *bool
	Analyzer          string
	AnalyzeWildcard   *bool
	DefaultOperator   string
	Df                string
	ExpandWildcards   string
	Explain           *bool
	IgnoreUnavailable *bool
	Lenient           *bool
	Query             string
	Rewrite           *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IndicesValidateQueryParams represents possible parameters for the IndicesValidateQueryReq

type IndicesValidateQueryReq 

type IndicesValidateQueryReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params IndicesValidateQueryParams
}

IndicesValidateQueryReq represents possible options for the index shrink request

func (IndicesValidateQueryReq) GetRequest 

func (r IndicesValidateQueryReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IndicesValidateQueryResp 

type IndicesValidateQueryResp struct {
	Shards struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresShard `json:"failures"`
	} `json:"_shards"`
	Valid        bool    `json:"valid"`
	Error        *string `json:"error"`
	Explanations []struct {
		Index       string  `json:"index"`
		Shard       int     `json:"shard"`
		Valid       bool    `json:"valid"`
		Explanation *string `json:"explanation"`
		Error       *string `json:"error"`
	} `json:"explanations"`
	// contains filtered or unexported fields
}

IndicesValidateQueryResp represents the returned struct of the index shrink response

func (IndicesValidateQueryResp) Inspect 

func (r IndicesValidateQueryResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type InfoParams 

type InfoParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

InfoParams represents possible parameters for the InfoReq

type InfoReq 

type InfoReq struct {
	Header http.Header
	Params InfoParams
}

InfoReq represents possible options for the / request

func (InfoReq) GetRequest 

func (r InfoReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type InfoResp 

type InfoResp struct {
	Name        string `json:"name"`
	ClusterName string `json:"cluster_name"`
	ClusterUUID string `json:"cluster_uuid"`
	Version     struct {
		Distribution                     string `json:"distribution"`
		Number                           string `json:"number"`
		BuildType                        string `json:"build_type"`
		BuildHash                        string `json:"build_hash"`
		BuildDate                        string `json:"build_date"`
		BuildSnapshot                    bool   `json:"build_snapshot"`
		LuceneVersion                    string `json:"lucene_version"`
		MinimumWireCompatibilityVersion  string `json:"minimum_wire_compatibility_version"`
		MinimumIndexCompatibilityVersion string `json:"minimum_index_compatibility_version"`
	} `json:"version"`
	Tagline string `json:"tagline"`
	// contains filtered or unexported fields
}

InfoResp represents the returned struct of the / response

func (InfoResp) Inspect 

func (r InfoResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IngestCreateParams 

type IngestCreateParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IngestCreateParams represents possible parameters for the IngestCreateReq

type IngestCreateReq 

type IngestCreateReq struct {
	PipelineID string

	Body io.Reader

	Header http.Header
	Params IngestCreateParams
}

IngestCreateReq represents possible options for the index create request

func (IngestCreateReq) GetRequest 

func (r IngestCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IngestCreateResp 

type IngestCreateResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

IngestCreateResp represents the returned struct of the index create response

func (IngestCreateResp) Inspect 

func (r IngestCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IngestDeleteParams 

type IngestDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IngestDeleteParams represents possible parameters for the IngestDeleteReq

type IngestDeleteReq 

type IngestDeleteReq struct {
	PipelineID string

	Header http.Header
	Params IngestDeleteParams
}

IngestDeleteReq represents possible options for the index create request

func (IngestDeleteReq) GetRequest 

func (r IngestDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IngestDeleteResp 

type IngestDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

IngestDeleteResp represents the returned struct of the index create response

func (IngestDeleteResp) Inspect 

func (r IngestDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IngestGetParams 

type IngestGetParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Summary               *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IngestGetParams represents possible parameters for the IngestGetReq

type IngestGetReq 

type IngestGetReq struct {
	PipelineIDs []string

	Header http.Header
	Params IngestGetParams
}

IngestGetReq represents possible options for the index create request

func (IngestGetReq) GetRequest 

func (r IngestGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IngestGetResp 

type IngestGetResp struct {
	Pipelines map[string]struct {
		Description string                       `json:"description"`
		Processors  []map[string]json.RawMessage `json:"processors"`
	}
	// contains filtered or unexported fields
}

IngestGetResp represents the returned struct of the index create response

func (IngestGetResp) Inspect 

func (r IngestGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IngestGrokParams 

type IngestGrokParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IngestGrokParams represents possible parameters for the IngestGrokReq

type IngestGrokReq 

type IngestGrokReq struct {
	Header http.Header
	Params IngestGrokParams
}

IngestGrokReq represents possible options for the index create request

func (IngestGrokReq) GetRequest 

func (r IngestGrokReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IngestGrokResp 

type IngestGrokResp struct {
	Patterns map[string]string `json:"patterns"`
	// contains filtered or unexported fields
}

IngestGrokResp represents the returned struct of the index create response

func (IngestGrokResp) Inspect 

func (r IngestGrokResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type IngestSimulateParams 

type IngestSimulateParams struct {
	Verbose *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

IngestSimulateParams represents possible parameters for the IngestSimulateReq

type IngestSimulateReq 

type IngestSimulateReq struct {
	PipelineID string

	Body io.Reader

	Header http.Header
	Params IngestSimulateParams
}

IngestSimulateReq represents possible options for the index create request

func (IngestSimulateReq) GetRequest 

func (r IngestSimulateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type IngestSimulateResp 

type IngestSimulateResp struct {
	Docs []json.RawMessage `json:"docs"`
	// contains filtered or unexported fields
}

IngestSimulateResp represents the returned struct of the index create response

func (IngestSimulateResp) Inspect 

func (r IngestSimulateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type Inspect 

type Inspect struct {
	Response *opensearch.Response
}

Inspect represents the struct returned by Inspect() func, its main use is to return the opensearch.Response to the user

type MGetParams 

type MGetParams struct {
	Preference     string
	Realtime       *bool
	Refresh        *bool
	Routing        string
	Source         interface{}
	SourceExcludes []string
	SourceIncludes []string
	StoredFields   []string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

MGetParams represents possible parameters for the MGetReq

type MGetReq 

type MGetReq struct {
	Index string

	Body io.Reader

	Header http.Header
	Params MGetParams
}

MGetReq represents possible options for the /_mget request

func (MGetReq) GetRequest 

func (r MGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type MGetResp 

type MGetResp struct {
	Docs []struct {
		Index       string          `json:"_index"`
		ID          string          `json:"_id"`
		Version     int             `json:"_version"`
		SeqNo       int             `json:"_seq_no"`
		PrimaryTerm int             `json:"_primary_term"`
		Found       bool            `json:"found"`
		Type        string          `json:"_type"`
		Source      json.RawMessage `json:"_source"`
	} `json:"docs"`
	// contains filtered or unexported fields
}

MGetResp represents the returned struct of the /_mget response

func (MGetResp) Inspect 

func (r MGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type MSearchParams 

type MSearchParams struct {
	CcsMinimizeRoundtrips      *bool
	MaxConcurrentSearches      *int
	MaxConcurrentShardRequests *int
	PreFilterShardSize         *int
	RestTotalHitsAsInt         *bool
	SearchType                 string
	TypedKeys                  *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

MSearchParams represents possible parameters for the MSearchReq

type MSearchReq 

type MSearchReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params MSearchParams
}

MSearchReq represents possible options for the /_msearch request

func (MSearchReq) GetRequest 

func (r MSearchReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type MSearchResp 

type MSearchResp struct {
	Took      int `json:"took"`
	Responses []struct {
		Took    int            `json:"took"`
		Timeout bool           `json:"timed_out"`
		Shards  ResponseShards `json:"_shards"`
		Hits    struct {
			Total struct {
				Value    int    `json:"value"`
				Relation string `json:"relation"`
			} `json:"total"`
			MaxScore *float32    `json:"max_score"`
			Hits     []SearchHit `json:"hits"`
		} `json:"hits"`
		Status       int             `json:"status"`
		Aggregations json.RawMessage `json:"aggregations"`
	} `json:"responses"`
	// contains filtered or unexported fields
}

MSearchResp represents the returned struct of the /_msearch response

func (MSearchResp) Inspect 

func (r MSearchResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type MSearchTemplateParams 

type MSearchTemplateParams struct {
	CcsMinimizeRoundtrips *bool
	MaxConcurrentSearches *int
	RestTotalHitsAsInt    *bool
	SearchType            string
	TypedKeys             *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

MSearchTemplateParams represents possible parameters for the MSearchTemplateReq

type MSearchTemplateReq 

type MSearchTemplateReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params MSearchTemplateParams
}

MSearchTemplateReq represents possible options for the /_msearch request

func (MSearchTemplateReq) GetRequest 

func (r MSearchTemplateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type MSearchTemplateResp 

type MSearchTemplateResp struct {
	Took      int `json:"took"`
	Responses []struct {
		Took    int            `json:"took"`
		Timeout bool           `json:"timed_out"`
		Shards  ResponseShards `json:"_shards"`
		Hits    struct {
			Total struct {
				Value    int    `json:"value"`
				Relation string `json:"relation"`
			} `json:"total"`
			MaxScore *float32    `json:"max_score"`
			Hits     []SearchHit `json:"hits"`
		} `json:"hits"`
		Status int `json:"status"`
	} `json:"responses"`
	// contains filtered or unexported fields
}

MSearchTemplateResp represents the returned struct of the /_msearch response

func (MSearchTemplateResp) Inspect 

func (r MSearchTemplateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type MTermvectorsParams 

type MTermvectorsParams struct {
	Fields          []string
	FieldStatistics *bool
	Ids             []string
	Offsets         *bool
	Payloads        *bool
	Positions       *bool
	Preference      string
	Realtime        *bool
	Routing         string
	TermStatistics  *bool
	Version         *int
	VersionType     string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

MTermvectorsParams represents possible parameters for the MTermvectorsReq

type MTermvectorsReq 

type MTermvectorsReq struct {
	Index string

	Body io.Reader

	Header http.Header
	Params MTermvectorsParams
}

MTermvectorsReq represents possible options for the /_mtermvectors request

func (MTermvectorsReq) GetRequest 

func (r MTermvectorsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type MTermvectorsResp 

type MTermvectorsResp struct {
	Docs []struct {
		Index       string          `json:"_index"`
		ID          string          `json:"_id"`
		Version     int             `json:"_version"`
		Found       bool            `json:"found"`
		Took        int             `json:"took"`
		Type        string          `json:"_type"` // Deprecated field
		TermVectors json.RawMessage `json:"term_vectors"`
	} `json:"docs"`
	// contains filtered or unexported fields
}

MTermvectorsResp represents the returned struct of the /_mtermvectors response

func (MTermvectorsResp) Inspect 

func (r MTermvectorsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type MappingFieldReq 

type MappingFieldReq struct {
	Indices []string
	Fields  []string

	Header http.Header
	Params MappingPutParams
}

MappingFieldReq represents possible options for the mapping field request

func (MappingFieldReq) GetRequest 

func (r MappingFieldReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type MappingFieldResp 

type MappingFieldResp struct {
	Indices map[string]struct {
		Mappings json.RawMessage `json:"mappings"`
	}
	// contains filtered or unexported fields
}

MappingFieldResp represents the returned struct of the mapping field response

func (MappingFieldResp) Inspect 

func (r MappingFieldResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type MappingGetParams 

type MappingGetParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	IgnoreUnavailable     *bool
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

MappingGetParams represents possible parameters for the MappingGetReq

type MappingGetReq 

type MappingGetReq struct {
	Indices []string

	Header http.Header
	Params MappingGetParams
}

MappingGetReq represents possible options for the mapping get request

func (MappingGetReq) GetRequest 

func (r MappingGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type MappingGetResp 

type MappingGetResp struct {
	Indices map[string]struct {
		Mappings json.RawMessage `json:"mappings"`
	}
	// contains filtered or unexported fields
}

MappingGetResp represents the returned struct of the mapping get response

func (MappingGetResp) Inspect 

func (r MappingGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type MappingPutParams 

type MappingPutParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	IgnoreUnavailable     *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	WriteIndexOnly        *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

MappingPutParams represents possible parameters for the MappingPutReq

type MappingPutReq 

type MappingPutReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params MappingPutParams
}

MappingPutReq represents possible options for the mapping put request

func (MappingPutReq) GetRequest 

func (r MappingPutReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type MappingPutResp 

type MappingPutResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

MappingPutResp represents the returned struct of the mapping put response

func (MappingPutResp) Inspect 

func (r MappingPutResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type NodeStatsRemoteStore 

type NodeStatsRemoteStore struct {
	LastSuccessfulFetchOfPinnedTimestamps int `json:"last_successful_fetch_of_pinned_timestamps"`
}

NodeStatsRemoteStore is a sub type of NodesStats

type NodesHotThreadsParams 

type NodesHotThreadsParams struct {
	IgnoreIdleThreads *bool
	Interval          time.Duration
	Snapshots         *int
	Threads           *int
	Timeout           time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

NodesHotThreadsParams represents possible parameters for the NodesHotThreadsReq

type NodesHotThreadsReq 

type NodesHotThreadsReq struct {
	NodeID []string

	Header http.Header
	Params NodesHotThreadsParams
}

NodesHotThreadsReq represents possible options for the /_nodes request

func (NodesHotThreadsReq) GetRequest 

func (r NodesHotThreadsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type NodesInfo 

type NodesInfo struct {
	Name                       string                         `json:"name"`
	TransportAddress           string                         `json:"transport_address"`
	Host                       string                         `json:"host"`
	IP                         string                         `json:"ip"`
	Version                    string                         `json:"version"`
	BuildType                  string                         `json:"build_type"`
	BuildHash                  string                         `json:"build_hash"`
	TotalIndexingBuffer        int64                          `json:"total_indexing_buffer"`
	TotalIndexingBufferInBytes int64                          `json:"total_indexing_buffer_in_bytes"`
	Roles                      []string                       `json:"roles"`
	Attributes                 map[string]string              `json:"attributes"`
	Settings                   json.RawMessage                `json:"settings"` // Won't parse as it may contain fields that we can't know
	OS                         NodesInfoOS                    `json:"os"`
	Process                    NodesInfoProcess               `json:"process"`
	JVM                        NodesInfoJVM                   `json:"jvm"`
	ThreadPool                 map[string]NodesInfoThreadPool `json:"thread_pool"`
	Transport                  NodesInfoTransport             `json:"transport"`
	HTTP                       NodesInfoHTTP                  `json:"http"`
	Plugins                    []NodesInfoPlugin              `json:"plugins"`
	Modules                    []NodesInfoPlugin              `json:"modules"`
	Ingest                     NodesInfoIngest                `json:"ingest"`
	Aggregations               map[string]NodesInfoAgg        `json:"aggregations"`
	SearchPipelines            NodesInfoSearchPipelines       `json:"search_pipelines"`
}

NodesInfo is a sub type of NodesInfoResp containing information about nodes and their stats

type NodesInfoAgg 

type NodesInfoAgg struct {
	Types []string `json:"types"`
}

NodesInfoAgg is a sub type of NodesInfo containing information about aggregations

type NodesInfoHTTP 

type NodesInfoHTTP struct {
	BoundAddress            []string `json:"bound_address"`
	PublishAddress          string   `json:"publish_address"`
	MaxContentLengthInBytes int64    `json:"max_content_length_in_bytes"`
}

NodesInfoHTTP is a sub type of NodesInfo containing information about the nodes http settings

type NodesInfoIngest 

type NodesInfoIngest struct {
	Processors []NodesInfoType `json:"processors"`
}

NodesInfoIngest is a sub type of NodesInfo containing information about ingest processors

type NodesInfoJVM 

type NodesInfoJVM struct {
	PID               int    `json:"pid"`
	Version           string `json:"version"`
	VMName            string `json:"vm_name"`
	VMVersion         string `json:"vm_version"`
	VMVendor          string `json:"vm_vendor"`
	BundledJDK        bool   `json:"bundled_jdk"`
	UsingBundledJDK   bool   `json:"using_bundled_jdk"`
	StartTimeInMillis int64  `json:"start_time_in_millis"`
	Mem               struct {
		HeapInitInBytes    int64 `json:"heap_init_in_bytes"`
		HeapMaxInBytes     int64 `json:"heap_max_in_bytes"`
		NonHeapInitInBytes int   `json:"non_heap_init_in_bytes"`
		NonHeapMaxInBytes  int   `json:"non_heap_max_in_bytes"`
		DirectMaxInBytes   int   `json:"direct_max_in_bytes"`
	} `json:"mem"`
	GcCollectors                          []string `json:"gc_collectors"`
	MemoryPools                           []string `json:"memory_pools"`
	UsingCompressedOrdinaryObjectPointers string   `json:"using_compressed_ordinary_object_pointers"`
	InputArguments                        []string `json:"input_arguments"`
}

NodesInfoJVM is a sub type of NodesInfo containing information and stats about JVM

type NodesInfoOS 

type NodesInfoOS struct {
	RefreshIntervalInMillis int    `json:"refresh_interval_in_millis"`
	Name                    string `json:"name"`
	PrettyName              string `json:"pretty_name"`
	Arch                    string `json:"arch"`
	Version                 string `json:"version"`
	AvailableProcessors     int    `json:"available_processors"`
	AllocatedProcessors     int    `json:"allocated_processors"`
}

NodesInfoOS is a sub type of NodesInfo containing information about the Operating System

type NodesInfoParams 

type NodesInfoParams struct {
	FlatSettings *bool
	Timeout      time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

NodesInfoParams represents possible parameters for the NodesInfoReq

type NodesInfoPlugin 

type NodesInfoPlugin struct {
	Name                    string   `json:"name"`
	Version                 string   `json:"version"`
	OpensearchVersion       string   `json:"opensearch_version"`
	JavaVersion             string   `json:"java_version"`
	Description             string   `json:"description"`
	Classname               string   `json:"classname"`
	CustomFoldername        *string  `json:"custom_foldername"`
	ExtendedPlugins         []string `json:"extended_plugins"`
	HasNativeController     bool     `json:"has_native_controller"`
	OptionalExtendedPlugins []string `json:"optional_extended_plugins"`
}

NodesInfoPlugin is a sub type of NodesInfo containing information about a plugin

type NodesInfoProcess 

type NodesInfoProcess struct {
	RefreshIntervalInMillis int  `json:"refresh_interval_in_millis"`
	ID                      int  `json:"id"`
	Mlockall                bool `json:"mlockall"`
}

NodesInfoProcess is a sub type of NodesInfo containing information about the nodes process

type NodesInfoReq 

type NodesInfoReq struct {
	Metrics []string
	NodeID  []string

	Header http.Header
	Params NodesInfoParams
}

NodesInfoReq represents possible options for the /_nodes request

func (NodesInfoReq) GetRequest 

func (r NodesInfoReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type NodesInfoResp 

type NodesInfoResp struct {
	NodesInfo struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresCause `json:"failures"`
	} `json:"_nodes"`
	ClusterName string               `json:"cluster_name"`
	Nodes       map[string]NodesInfo `json:"nodes"`
	// contains filtered or unexported fields
}

NodesInfoResp represents the returned struct of the /_nodes response

func (NodesInfoResp) Inspect 

func (r NodesInfoResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type NodesInfoSearchPipelines 

type NodesInfoSearchPipelines struct {
	RequestProcessors  []NodesInfoType `json:"request_processors"`
	ResponseProcessors []NodesInfoType `json:"response_processors"`
	Processors         []NodesInfoType `json:"processors,omitempty"` // Deprecated field only available in 2.7.0
}

NodesInfoSearchPipelines is a sub type of NodesInfo containing information about search pipelines

type NodesInfoThreadPool 

type NodesInfoThreadPool struct {
	Type      string `json:"type"`
	Size      int    `json:"size"`
	QueueSize int    `json:"queue_size"`
	KeepAlive string `json:"keep_alive"`
	Max       int    `json:"max"`
	Core      int    `json:"core"`
}

NodesInfoThreadPool is a sub type of NodesInfo containing information about a thread pool

type NodesInfoTransport 

type NodesInfoTransport struct {
	BoundAddress   []string        `json:"bound_address"`
	PublishAddress string          `json:"publish_address"`
	Profiles       json.RawMessage `json:"profiles"` // Unknown content
}

NodesInfoTransport is a sub type of NodesInfo containing information about the nodes transport settings

type NodesInfoType 

type NodesInfoType struct {
	Type string `json:"type"`
}

NodesInfoType is a sub type of NodesInfoIngest, NodesInfoSearchPipelines containing information about a type

type NodesReloadSecurityParams 

type NodesReloadSecurityParams struct {
	Timeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

NodesReloadSecurityParams represents possible parameters for the NodesReloadSecurityReq

type NodesReloadSecurityReq 

type NodesReloadSecurityReq struct {
	NodeID []string

	Body io.Reader

	Header http.Header
	Params NodesReloadSecurityParams
}

NodesReloadSecurityReq represents possible options for the /_nodes request

func (NodesReloadSecurityReq) GetRequest 

func (r NodesReloadSecurityReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type NodesReloadSecurityResp 

type NodesReloadSecurityResp struct {
	NodesInfo struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresCause `json:"failures"`
	} `json:"_nodes"`
	ClusterName string `json:"cluster_name"`
	Nodes       map[string]struct {
		Name string `json:"name"`
	} `json:"nodes"`
	// contains filtered or unexported fields
}

NodesReloadSecurityResp represents the returned struct of the /_nodes response

func (NodesReloadSecurityResp) Inspect 

func (r NodesReloadSecurityResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type NodesStats 

type NodesStats struct {
	Timestamp                      int                                      `json:"timestamp"`
	Name                           string                                   `json:"name"`
	TransportAddress               string                                   `json:"transport_address"`
	Host                           string                                   `json:"host"`
	IP                             string                                   `json:"ip"`
	Roles                          []string                                 `json:"roles"`
	Attributes                     map[string]string                        `json:"attributes"`
	Indices                        NodesStatsIndices                        `json:"indices"`
	OS                             NodesStatsOS                             `json:"os"`
	Process                        NodesStatsProcess                        `json:"process"`
	JVM                            NodesStatsJVM                            `json:"jvm"`
	ThreadPool                     NodesStatsThreadPool                     `json:"thread_pool"`
	FS                             NodesStatsFS                             `json:"fs"`
	Transport                      NodesStatsTransport                      `json:"transport"`
	HTTP                           NodesStatsHTTP                           `json:"http"`
	Breakers                       NodesStatsBreakers                       `json:"breakers"`
	Scripts                        NodesStatsScript                         `json:"script"`
	Discovery                      NodesStatsDiscovery                      `json:"discovery"`
	Ingest                         NodesStatsIngest                         `json:"ingest"`
	AdaptiveSelection              NodesStatsAdaptiveSelection              `json:"adaptive_selection"`
	ScriptCache                    NodesStatsScriptCache                    `json:"script_cache"`
	IndexingPressure               NodesStatsIndexingPressure               `json:"indexing_pressure"`
	ShardIndexingPressure          NodesStatsShardIndexingPressure          `json:"shard_indexing_pressure"`
	SearchBackpressure             NodesStatsSearchBackpressure             `json:"search_backpressure"`
	ClusterManagerThrottling       NodesStatsClusterManagerThrottling       `json:"cluster_manager_throttling"`
	WeightedRouting                NodesStatsWeightedRouting                `json:"weighted_routing"`
	SearchPipeline                 NodesStatsSearchPipeline                 `json:"search_pipeline"`
	TaskCancellation               NodesStatsTaskCancellation               `json:"task_cancellation"`
	ResourceUsageStats             map[string]NodesStatsResourceUsageStats  `json:"resource_usage_stats"`
	SegmentReplicationBackpressure NodesStatsSegmentReplicationBackpressure `json:"segment_replication_backpressure"`
	Repositories                   []json.RawMessage                        `json:"repositories"`
	AdmissionControl               NodesStatsAdmissionControl               `json:"admission_control"`
	Caches                         NodesStatsCaches                         `json:"caches"`
	RemoteStore                    NodeStatsRemoteStore                     `json:"remote_store"`
}

NodesStats is a map item of NodesStatsResp representing all values of a node

type NodesStatsAdaptiveSelection 

type NodesStatsAdaptiveSelection map[string]struct {
	OutgoingSearches  int    `json:"outgoing_searches"`
	AvgQueueSize      int    `json:"avg_queue_size"`
	AvgServiceTimeNs  int    `json:"avg_service_time_ns"`
	AvgResponseTimeNs int    `json:"avg_response_time_ns"`
	Rank              string `json:"rank"`
}

NodesStatsAdaptiveSelection is a sub type of NodesStats representing adaptive selection information of the node

type NodesStatsAdmissionControl 

type NodesStatsAdmissionControl struct {
	GlobalCPUUsage struct {
		Transport struct {
			RejectionCount json.RawMessage `json:"rejection_count"`
		} `json:"transport"`
	} `json:"global_cpu_usage"`
	GlobalIOUsage struct {
		Transport struct {
			RejectionCount json.RawMessage `json:"rejection_count"`
		} `json:"transport"`
	} `json:"global_io_usage"`
}

NodesStatsAdmissionControl is a sub type of NodesStats

type NodesStatsBreaker 

type NodesStatsBreaker struct {
	LimitSizeInBytes     int     `json:"limit_size_in_bytes"`
	LimitSize            string  `json:"limit_size"`
	EstimatedSizeInBytes int     `json:"estimated_size_in_bytes"`
	EstimatedSize        string  `json:"estimated_size"`
	Overhead             float64 `json:"overhead"`
	Tripped              int     `json:"tripped"`
}

NodesStatsBreaker is a sub type of NodesStatsBreakers containing all information a breaker can have

type NodesStatsBreakers 

type NodesStatsBreakers struct {
	Accounting       NodesStatsBreaker `json:"accounting"`
	Request          NodesStatsBreaker `json:"request"`
	Fielddata        NodesStatsBreaker `json:"fielddata"`
	InFlightRequests NodesStatsBreaker `json:"in_flight_requests"`
	Parent           NodesStatsBreaker `json:"parent"`
}

NodesStatsBreakers is a sub type of NodesStats representing breakers information of the node

type NodesStatsCaches 

type NodesStatsCaches struct {
	RequestCache struct {
		SizeInBytes int    `json:"size_in_bytes"`
		Evictions   int    `json:"evictions"`
		HitCount    int    `json:"hit_count"`
		MissCount   int    `json:"miss_count"`
		ItemCount   int    `json:"item_count"`
		StoreName   string `json:"store_name"`
	} `json:"request_cache"`
}

NodesStatsCaches is a sub type of NodesStats

type NodesStatsClusterManagerThrottling 

type NodesStatsClusterManagerThrottling struct {
	Stats struct {
		TotalThrottledTasks       int             `json:"total_throttled_tasks"`
		ThrottledTasksPerTaskType json.RawMessage `json:"throttled_tasks_per_task_type"` // Unknow struct, no example in doc
	} `json:"stats"`
}

NodesStatsClusterManagerThrottling is a sub type of NodesStats representing cluster manager throttling information of the node

type NodesStatsDiscovery 

type NodesStatsDiscovery struct {
	ClusterStateQueue struct {
		Total     int `json:"total"`
		Pending   int `json:"pending"`
		Committed int `json:"committed"`
	} `json:"cluster_state_queue"`
	PublishedClusterStates struct {
		FullStates        int `json:"full_states"`
		IncompatibleDiffs int `json:"incompatible_diffs"`
		CompatibleDiffs   int `json:"compatible_diffs"`
	} `json:"published_cluster_states"`
	ClusterStateStats struct {
		Overall struct {
			UpdateCount       int `json:"update_count"`
			TotalTimeInMillis int `json:"total_time_in_millis"`
			FailedCount       int `json:"failed_count"`
		} `json:"overall"`
	} `json:"cluster_state_stats"`
}

NodesStatsDiscovery is a sub type of NodesStats representing discovery information of the node

type NodesStatsFS 

type NodesStatsFS struct {
	Timestamp int `json:"timestamp"`
	Total     struct {
		TotalInBytes         int `json:"total_in_bytes"`
		FreeInBytes          int `json:"free_in_bytes"`
		AvailableInBytes     int `json:"available_in_bytes"`
		CacheReservedInBytes int `json:"cache_reserved_in_bytes"`
	} `json:"total"`
	Data []struct {
		Path                 string `json:"path"`
		Mount                string `json:"mount"`
		Type                 string `json:"type"`
		TotalInBytes         int    `json:"total_in_bytes"`
		FreeInBytes          int    `json:"free_in_bytes"`
		AvailableInBytes     int    `json:"available_in_bytes"`
		CacheReservedInBytes int    `json:"cache_reserved_in_bytes"`
	} `json:"data"`
	IoStats struct {
		Devices []struct {
			DeviceName      string `json:"device_name"`
			Operations      int    `json:"operations"`
			ReadOperations  int    `json:"read_operations"`
			WriteOperations int    `json:"write_operations"`
			ReadKilobytes   int    `json:"read_kilobytes"`
			WriteKilobytes  int    `json:"write_kilobytes"`
		} `json:"devices"`
		Total struct {
			Operations      int `json:"operations"`
			ReadOperations  int `json:"read_operations"`
			WriteOperations int `json:"write_operations"`
			ReadKilobytes   int `json:"read_kilobytes"`
			WriteKilobytes  int `json:"write_kilobytes"`
		} `json:"total"`
	} `json:"io_stats"`
}

NodesStatsFS is a sub type of NodesStats representing filesystem information of the node

type NodesStatsHTTP 

type NodesStatsHTTP struct {
	CurrentOpen int `json:"current_open"`
	TotalOpened int `json:"total_opened"`
}

NodesStatsHTTP is a sub type of NodesStats representing http information of the node

type NodesStatsIndexingPressure 

type NodesStatsIndexingPressure struct {
	Memory struct {
		Current struct {
			CombinedCoordinatingAndPrimaryInBytes int `json:"combined_coordinating_and_primary_in_bytes"`
			CoordinatingInBytes                   int `json:"coordinating_in_bytes"`
			PrimaryInBytes                        int `json:"primary_in_bytes"`
			ReplicaInBytes                        int `json:"replica_in_bytes"`
			AllInBytes                            int `json:"all_in_bytes"`
		} `json:"current"`
		Total struct {
			CombinedCoordinatingAndPrimaryInBytes int `json:"combined_coordinating_and_primary_in_bytes"`
			CoordinatingInBytes                   int `json:"coordinating_in_bytes"`
			PrimaryInBytes                        int `json:"primary_in_bytes"`
			ReplicaInBytes                        int `json:"replica_in_bytes"`
			AllInBytes                            int `json:"all_in_bytes"`
			CoordinatingRejections                int `json:"coordinating_rejections"`
			PrimaryRejections                     int `json:"primary_rejections"`
			ReplicaRejections                     int `json:"replica_rejections"`
		} `json:"total"`
		LimitInBytes int `json:"limit_in_bytes"`
	} `json:"memory"`
}

NodesStatsIndexingPressure is a sub type of NodesStats representing indexing pressure information of the node

type NodesStatsIndices 

type NodesStatsIndices struct {
	Docs struct {
		Count   int `json:"count"`
		Deleted int `json:"deleted"`
	} `json:"docs"`
	Store struct {
		SizeInBytes     int `json:"size_in_bytes"`
		ReservedInBytes int `json:"reserved_in_bytes"`
	} `json:"store"`
	Indexing struct {
		IndexTotal           int            `json:"index_total"`
		IndexTimeInMillis    int            `json:"index_time_in_millis"`
		IndexCurrent         int            `json:"index_current"`
		IndexFailed          int            `json:"index_failed"`
		DeleteTotal          int            `json:"delete_total"`
		DeleteTimeInMillis   int            `json:"delete_time_in_millis"`
		DeleteCurrent        int            `json:"delete_current"`
		NoopUpdateTotal      int            `json:"noop_update_total"`
		IsThrottled          bool           `json:"is_throttled"`
		ThrottleTimeInMillis int            `json:"throttle_time_in_millis"`
		DocStatus            map[string]int `json:"doc_status"`
	} `json:"indexing"`
	Get struct {
		Total               int    `json:"total"`
		TimeInMillis        int    `json:"time_in_millis"`
		ExistsTotal         int    `json:"exists_total"`
		ExistsTimeInMillis  int    `json:"exists_time_in_millis"`
		MissingTotal        int    `json:"missing_total"`
		MissingTimeInMillis int    `json:"missing_time_in_millis"`
		Current             int    `json:"current"`
		GetTime             string `json:"getTime"`
	} `json:"get"`
	Search struct {
		OpenContexts                int     `json:"open_contexts"`
		QueryTotal                  int     `json:"query_total"`
		QueryTimeInMillis           int     `json:"query_time_in_millis"`
		QueryCurrent                int     `json:"query_current"`
		ConcurrentQueryTotal        int     `json:"concurrent_query_total"`
		ConcurrentQueryTimeInMillis int     `json:"concurrent_query_time_in_millis"`
		ConcurrentQueryCurrent      int     `json:"concurrent_query_current"`
		ConcurrentAVGSliceCount     float32 `json:"concurrent_avg_slice_count"`
		FetchTotal                  int     `json:"fetch_total"`
		FetchTimeInMillis           int     `json:"fetch_time_in_millis"`
		FetchCurrent                int     `json:"fetch_current"`
		ScrollTotal                 int     `json:"scroll_total"`
		ScrollTimeInMillis          int     `json:"scroll_time_in_millis"`
		ScrollCurrent               int     `json:"scroll_current"`
		PointInTimeTotal            int     `json:"point_in_time_total"`
		PointInTimeTimeInMillis     int     `json:"point_in_time_time_in_millis"`
		PointInTimeCurrent          int     `json:"point_in_time_current"`
		SuggestTotal                int     `json:"suggest_total"`
		SuggestTimeInMillis         int     `json:"suggest_time_in_millis"`
		SuggestCurrent              int     `json:"suggest_current"`
		IdleReactivateCountTotal    int     `json:"search_idle_reactivate_count_total"`
		Request                     struct {
			DfsPreQuery NodesStatsIndicesSearchRequest `json:"dfs_pre_query"`
			Query       NodesStatsIndicesSearchRequest `json:"query"`
			Fetch       NodesStatsIndicesSearchRequest `json:"fetch"`
			DfsQuery    NodesStatsIndicesSearchRequest `json:"dfs_query"`
			Expand      NodesStatsIndicesSearchRequest `json:"expand"`
			CanMatch    NodesStatsIndicesSearchRequest `json:"can_match"`
			Took        NodesStatsIndicesSearchRequest `json:"took"`
		} `json:"request"`
	} `json:"search"`
	Merges struct {
		Current                           int `json:"current"`
		CurrentDocs                       int `json:"current_docs"`
		CurrentSizeInBytes                int `json:"current_size_in_bytes"`
		Total                             int `json:"total"`
		TotalTimeInMillis                 int `json:"total_time_in_millis"`
		TotalDocs                         int `json:"total_docs"`
		TotalSizeInBytes                  int `json:"total_size_in_bytes"`
		TotalStoppedTimeInMillis          int `json:"total_stopped_time_in_millis"`
		TotalThrottledTimeInMillis        int `json:"total_throttled_time_in_millis"`
		TotalAutoThrottleInBytes          int `json:"total_auto_throttle_in_bytes"`
		UnreferencedFileCleanupsPerformed int `json:"unreferenced_file_cleanups_performed"`
	} `json:"merges"`
	Refresh struct {
		Total                     int `json:"total"`
		TotalTimeInMillis         int `json:"total_time_in_millis"`
		ExternalTotal             int `json:"external_total"`
		ExternalTotalTimeInMillis int `json:"external_total_time_in_millis"`
		Listeners                 int `json:"listeners"`
	} `json:"refresh"`
	Flush struct {
		Total             int `json:"total"`
		Periodic          int `json:"periodic"`
		TotalTimeInMillis int `json:"total_time_in_millis"`
	} `json:"flush"`
	Warmer struct {
		Current           int `json:"current"`
		Total             int `json:"total"`
		TotalTimeInMillis int `json:"total_time_in_millis"`
	} `json:"warmer"`
	QueryCache struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		TotalCount        int `json:"total_count"`
		HitCount          int `json:"hit_count"`
		MissCount         int `json:"miss_count"`
		CacheSize         int `json:"cache_size"`
		CacheCount        int `json:"cache_count"`
		Evictions         int `json:"evictions"`
	} `json:"query_cache"`
	Fielddata struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		Evictions         int `json:"evictions"`
	} `json:"fielddata"`
	Completion struct {
		SizeInBytes int `json:"size_in_bytes"`
	} `json:"completion"`
	Segments struct {
		Count                     int `json:"count"`
		MemoryInBytes             int `json:"memory_in_bytes"`
		TermsMemoryInBytes        int `json:"terms_memory_in_bytes"`
		StoredFieldsMemoryInBytes int `json:"stored_fields_memory_in_bytes"`
		TermVectorsMemoryInBytes  int `json:"term_vectors_memory_in_bytes"`
		NormsMemoryInBytes        int `json:"norms_memory_in_bytes"`
		PointsMemoryInBytes       int `json:"points_memory_in_bytes"`
		DocValuesMemoryInBytes    int `json:"doc_values_memory_in_bytes"`
		IndexWriterMemoryInBytes  int `json:"index_writer_memory_in_bytes"`
		VersionMapMemoryInBytes   int `json:"version_map_memory_in_bytes"`
		FixedBitSetMemoryInBytes  int `json:"fixed_bit_set_memory_in_bytes"`
		MaxUnsafeAutoIDTimestamp  int `json:"max_unsafe_auto_id_timestamp"`
		RemoteStore               struct {
			Upload struct {
				TotalUploadSize struct {
					StartedBytes   int `json:"started_bytes"`
					SucceededBytes int `json:"succeeded_bytes"`
					FailedBytes    int `json:"failed_bytes"`
				} `json:"total_upload_size"`
				RefreshSizeLag struct {
					TotalBytes int `json:"total_bytes"`
					MaxBytes   int `json:"max_bytes"`
				} `json:"refresh_size_lag"`
				MaxRefreshTimeLagInMillis int `json:"max_refresh_time_lag_in_millis"`
				TotalTimeSpentInMillis    int `json:"total_time_spent_in_millis"`
				Pressure                  struct {
					TotalRejections int `json:"total_rejections"`
				} `json:"pressure"`
			} `json:"upload"`
			Download struct {
				TotalDownloadSize struct {
					StartedBytes   int `json:"started_bytes"`
					SucceededBytes int `json:"succeeded_bytes"`
					FailedBytes    int `json:"failed_bytes"`
				} `json:"total_download_size"`
				TotalTimeSpentInMillis int `json:"total_time_spent_in_millis"`
			} `json:"download"`
		} `json:"remote_store"`
		SegmentReplication struct {
			// Type is json.RawMessage due to difference in opensearch versions from string to int
			MaxBytesBehind    json.RawMessage `json:"max_bytes_behind"`
			TotalBytesBehind  json.RawMessage `json:"total_bytes_behind"`
			MaxReplicationLag json.RawMessage `json:"max_replication_lag"`
		} `json:"segment_replication"`
		FileSizes json.RawMessage `json:"file_sizes"`
	} `json:"segments"`
	Translog struct {
		Operations              int `json:"operations"`
		SizeInBytes             int `json:"size_in_bytes"`
		UncommittedOperations   int `json:"uncommitted_operations"`
		UncommittedSizeInBytes  int `json:"uncommitted_size_in_bytes"`
		EarliestLastModifiedAge int `json:"earliest_last_modified_age"`
		RemoteStore             struct {
			Upload struct {
				TotalUploads struct {
					Started   int `json:"started"`
					Failed    int `json:"failed"`
					Succeeded int `json:"succeeded"`
				} `json:"total_uploads"`
				TotalUploadSize struct {
					StartedBytes   int `json:"started_bytes"`
					FailedBytes    int `json:"failed_bytes"`
					SucceededBytes int `json:"succeeded_bytes"`
				} `json:"total_upload_size"`
			} `json:"upload"`
		} `json:"remote_store"`
	} `json:"translog"`
	RequestCache struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		Evictions         int `json:"evictions"`
		HitCount          int `json:"hit_count"`
		MissCount         int `json:"miss_count"`
	} `json:"request_cache"`
	Recovery struct {
		CurrentAsSource      int `json:"current_as_source"`
		CurrentAsTarget      int `json:"current_as_target"`
		ThrottleTimeInMillis int `json:"throttle_time_in_millis"`
	} `json:"recovery"`
}

NodesStatsIndices is a sub type of NodesStats representing Indices information of the node

type NodesStatsIndicesSearchRequest 

type NodesStatsIndicesSearchRequest struct {
	TimeInMillis int `json:"time_in_millis"`
	Current      int `json:"current"`
	Total        int `json:"total"`
}

NodesStatsIndicesSearchRequest is a sub type of NodesStatsIndices containing stats about search requests

type NodesStatsIngest 

type NodesStatsIngest struct {
	Total struct {
		Count        int `json:"count"`
		TimeInMillis int `json:"time_in_millis"`
		Current      int `json:"current"`
		Failed       int `json:"failed"`
	} `json:"total"`
	Pipelines map[string]NodesStatsIngestDetails `json:"pipelines"`
}

NodesStatsIngest is a sub type of NodesStats representing ingest pipelines information of the node

type NodesStatsIngestDetails 

type NodesStatsIngestDetails struct {
	Count        int               `json:"count"`
	TimeInMillis int               `json:"time_in_millis"`
	Failed       int               `json:"failed"`
	Current      int               `json:"current"`
	Processors   []json.RawMessage `json:"processors"`
}

NodesStatsIngestDetails is a sub map type of NodsStatsIngest containing all information of ingest pipelines

type NodesStatsJVM 

type NodesStatsJVM struct {
	Timestamp      int `json:"timestamp"`
	UptimeInMillis int `json:"uptime_in_millis"`
	Mem            struct {
		HeapUsedInBytes         int `json:"heap_used_in_bytes"`
		HeapUsedPercent         int `json:"heap_used_percent"`
		HeapCommittedInBytes    int `json:"heap_committed_in_bytes"`
		HeapMaxInBytes          int `json:"heap_max_in_bytes"`
		NonHeapUsedInBytes      int `json:"non_heap_used_in_bytes"`
		NonHeapCommittedInBytes int `json:"non_heap_committed_in_bytes"`
		Pools                   struct {
			Young    NodesStatsJVMPool `json:"young"`
			Old      NodesStatsJVMPool `json:"old"`
			Survivor NodesStatsJVMPool `json:"survivor"`
		} `json:"pools"`
	} `json:"mem"`
	Threads struct {
		Count     int `json:"count"`
		PeakCount int `json:"peak_count"`
	} `json:"threads"`
	Gc struct {
		Collectors map[string]NodesStatsJVMGCCollectors `json:"collectors"`
	} `json:"gc"`
	// Not parsing each field directly as one of them contains singe quotes which are not allowed as tag in golang json
	// https://github.com/golang/go/issues/22518
	BufferPools map[string]NodesStatsJVMBufferPool `json:"buffer_pools"`
	Classes     struct {
		CurrentLoadedCount int `json:"current_loaded_count"`
		TotalLoadedCount   int `json:"total_loaded_count"`
		TotalUnloadedCount int `json:"total_unloaded_count"`
	} `json:"classes"`
}

NodesStatsJVM is a sub type of NodesStats representing java virtual maschine information of the node

type NodesStatsJVMBufferPool 

type NodesStatsJVMBufferPool struct {
	Count                int `json:"count"`
	UsedInBytes          int `json:"used_in_bytes"`
	TotalCapacityInBytes int `json:"total_capacity_in_bytes"`
}

NodesStatsJVMBufferPool is a sub map type represeting all information a buffer pool can have

type NodesStatsJVMGCCollectors 

type NodesStatsJVMGCCollectors struct {
	CollectionCount        int `json:"collection_count"`
	CollectionTimeInMillis int `json:"collection_time_in_millis"`
}

NodesStatsJVMGCCollectors is a sub type of NodesStatsJVM containing collector information

type NodesStatsJVMPool 

type NodesStatsJVMPool struct {
	UsedInBytes     int `json:"used_in_bytes"`
	MaxInBytes      int `json:"max_in_bytes"`
	PeakUsedInBytes int `json:"peak_used_in_bytes"`
	PeakMaxInBytes  int `json:"peak_max_in_bytes"`
	LastGcStats     struct {
		UsedInBytes  int `json:"used_in_bytes"`
		MaxInBytes   int `json:"max_in_bytes"`
		UsagePercent int `json:"usage_percent"`
	} `json:"last_gc_stats"`
}

NodesStatsJVMPool is a sub type of NodesStatsJVM represeting all information a pool can have

type NodesStatsOS 

type NodesStatsOS struct {
	Timestamp int `json:"timestamp"`
	CPU       struct {
		Percent     int `json:"percent"`
		LoadAverage struct {
			OneM  float64 `json:"1m"`
			FiveM float64 `json:"5m"`
			One5M float64 `json:"15m"`
		} `json:"load_average"`
	} `json:"cpu"`
	Mem struct {
		TotalInBytes int `json:"total_in_bytes"`
		FreeInBytes  int `json:"free_in_bytes"`
		UsedInBytes  int `json:"used_in_bytes"`
		FreePercent  int `json:"free_percent"`
		UsedPercent  int `json:"used_percent"`
	} `json:"mem"`
	Swap struct {
		TotalInBytes int `json:"total_in_bytes"`
		FreeInBytes  int `json:"free_in_bytes"`
		UsedInBytes  int `json:"used_in_bytes"`
	} `json:"swap"`
}

NodesStatsOS is a sub type of NodesStats representing operating system information of the node

type NodesStatsParams 

type NodesStatsParams struct {
	CompletionFields        []string
	FielddataFields         []string
	Fields                  []string
	Groups                  *bool
	IncludeSegmentFileSizes *bool
	IncludeUnloadedSegments *bool
	Level                   string
	Timeout                 time.Duration
	Types                   []string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

NodesStatsParams represents possible parameters for the NodesStatsReq

type NodesStatsProcess 

type NodesStatsProcess struct {
	Timestamp           int `json:"timestamp"`
	OpenFileDescriptors int `json:"open_file_descriptors"`
	MaxFileDescriptors  int `json:"max_file_descriptors"`
	CPU                 struct {
		Percent       int `json:"percent"`
		TotalInMillis int `json:"total_in_millis"`
	} `json:"cpu"`
	Mem struct {
		TotalVirtualInBytes int `json:"total_virtual_in_bytes"`
	} `json:"mem"`
}

NodesStatsProcess is a sub type of NodesStats representing processor information of the node

type NodesStatsReq 

type NodesStatsReq struct {
	IndexMetric []string
	Metric      []string
	NodeID      []string
	Header      http.Header
	Params      NodesStatsParams
}

NodesStatsReq represents possible options for the /_nodes request

func (NodesStatsReq) GetRequest 

func (r NodesStatsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type NodesStatsResourceUsageStats 

type NodesStatsResourceUsageStats struct {
	Timestamp                int64  `json:"timestamp"`
	CPUUtilizationPercent    string `json:"cpu_utilization_percent"`
	MemoryUtilizationPercent string `json:"memory_utilization_percent"`
	IOUsageStats             struct {
		MaxIOUtilizationPercent string `json:"max_io_utilization_percent"`
	} `json:"io_usage_stats"`
}

NodesStatsResourceUsageStats is a sub type of NodesStats containing nodes resource information

type NodesStatsResp 

type NodesStatsResp struct {
	NodesInfo struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresCause `json:"failures"`
	} `json:"_nodes"`
	ClusterName string                `json:"cluster_name"`
	Nodes       map[string]NodesStats `json:"nodes"`
	// contains filtered or unexported fields
}

NodesStatsResp represents the returned struct of the /_nodes response

func (NodesStatsResp) Inspect 

func (r NodesStatsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type NodesStatsScript 

type NodesStatsScript struct {
	Compilations              int `json:"compilations"`
	CacheEvictions            int `json:"cache_evictions"`
	CompilationLimitTriggered int `json:"compilation_limit_triggered"`
}

NodesStatsScript is a sub type of NodesStats representing script information of the node

type NodesStatsScriptCache 

type NodesStatsScriptCache struct {
	Sum struct {
		Compilations              int `json:"compilations"`
		CacheEvictions            int `json:"cache_evictions"`
		CompilationLimitTriggered int `json:"compilation_limit_triggered"`
	} `json:"sum"`
	Contexts []struct {
		Context                   string `json:"context"`
		Compilations              int    `json:"compilations"`
		CacheEvictions            int    `json:"cache_evictions"`
		CompilationLimitTriggered int    `json:"compilation_limit_triggered"`
	} `json:"contexts"`
}

NodesStatsScriptCache is a sub type of NodesStats representing script cache information of the node

type NodesStatsSearchBackpressure 

type NodesStatsSearchBackpressure struct {
	SearchTask struct {
		ResourceTrackerStats struct {
			CPUUsageTracker    NodesStatsSearchBackpressureTracker `json:"cpu_usage_tracker"`
			ElapsedTimeTracker NodesStatsSearchBackpressureTracker `json:"elapsed_time_tracker"`
			HeapUsageTracker   struct {
				CancellationCount int `json:"cancellation_count"`
				CurrentMaxBytes   int `json:"current_max_bytes"`
				CurrentAvgBytes   int `json:"current_avg_bytes"`
				RollingAvgBytes   int `json:"rolling_avg_bytes"`
			} `json:"heap_usage_tracker"`
		} `json:"resource_tracker_stats"`
		CancellationStats struct {
			CancellationCount             int `json:"cancellation_count"`
			CancellationLimitReachedCount int `json:"cancellation_limit_reached_count"`
		} `json:"cancellation_stats"`
		CompletionCount int `json:"completion_count"`
	} `json:"search_task"`
	SearchShardTask struct {
		ResourceTrackerStats struct {
			CPUUsageTracker    NodesStatsSearchBackpressureTracker `json:"cpu_usage_tracker"`
			ElapsedTimeTracker NodesStatsSearchBackpressureTracker `json:"elapsed_time_tracker"`
			HeapUsageTracker   struct {
				CancellationCount int `json:"cancellation_count"`
				CurrentMaxBytes   int `json:"current_max_bytes"`
				CurrentAvgBytes   int `json:"current_avg_bytes"`
				RollingAvgBytes   int `json:"rolling_avg_bytes"`
			} `json:"heap_usage_tracker"`
		} `json:"resource_tracker_stats"`
		CancellationStats struct {
			CancellationCount             int `json:"cancellation_count"`
			CancellationLimitReachedCount int `json:"cancellation_limit_reached_count"`
		} `json:"cancellation_stats"`
		CompletionCount int `json:"completion_count"`
	} `json:"search_shard_task"`
	Mode string `json:"mode"`
}

NodesStatsSearchBackpressure is a sub type of NodesStats representing search packbressure information of a node

type NodesStatsSearchBackpressureTracker 

type NodesStatsSearchBackpressureTracker struct {
	CancellationCount int `json:"cancellation_count"`
	CurrentMaxMillis  int `json:"current_max_millis"`
	CurrentAvgMillis  int `json:"current_avg_millis"`
}

NodesStatsSearchBackpressureTracker is a sub type of NodesStatsSearchBrackpressure containing all information of a tracker

type NodesStatsSearchPipeline 

type NodesStatsSearchPipeline struct {
	TotalRequest struct {
		Count        int `json:"count"`
		TimeInMillis int `json:"time_in_millis"`
		Current      int `json:"current"`
		Failed       int `json:"failed"`
	} `json:"total_request"`
	TotalResponse struct {
		Count        int `json:"count"`
		TimeInMillis int `json:"time_in_millis"`
		Current      int `json:"current"`
		Failed       int `json:"failed"`
	} `json:"total_response"`
	Pipelines json.RawMessage `json:"pipelines"`
}

NodesStatsSearchPipeline is a sub type of NodesStats containing stats about search pipelines

type NodesStatsSegmentReplicationBackpressure 

type NodesStatsSegmentReplicationBackpressure struct {
	TotalRejectedRequests int `json:"total_rejected_requests"`
}

NodesStatsSegmentReplicationBackpressure is a sub type of NodesStats containing information about segment replication backpressure

type NodesStatsShardIndexingPressure 

type NodesStatsShardIndexingPressure struct {
	Stats                            json.RawMessage `json:"stats"` // Unknown, can be added if you have an example
	TotalRejectionsBreakupShadowMode struct {
		NodeLimits                  int `json:"node_limits"`
		NoSuccessfulRequestLimits   int `json:"no_successful_request_limits"`
		ThroughputDegradationLimits int `json:"throughput_degradation_limits"`
	} `json:"total_rejections_breakup_shadow_mode"`
	Enabled  bool `json:"enabled"`
	Enforced bool `json:"enforced"`
}

NodesStatsShardIndexingPressure is a sub type of NodesStats representing shard indexing pressure information of the node

type NodesStatsTaskCancellation 

type NodesStatsTaskCancellation struct {
	SearchTask      NodesStatsTaskCancellationValues `json:"search_task"`
	SearchShardTask NodesStatsTaskCancellationValues `json:"search_shard_task"`
}

NodesStatsTaskCancellation is a sub type of NodesStats containing stats about canceled tasks

type NodesStatsTaskCancellationValues 

type NodesStatsTaskCancellationValues struct {
	CurrentCountPostCancel int `json:"current_count_post_cancel"`
	TotalCountPostCancel   int `json:"total_count_post_cancel"`
}

NodesStatsTaskCancellationValues is a sub type of NodesStatsTaskCancellation

type NodesStatsThreadPool 

type NodesStatsThreadPool map[string]NodesStatsThreadPoolValues

NodesStatsThreadPool is a sub type of NodesStats representing thread pool information of the node

type NodesStatsThreadPoolValues 

type NodesStatsThreadPoolValues struct {
	Threads              int    `json:"threads"`
	Queue                int    `json:"queue"`
	Active               int    `json:"active"`
	Rejected             int    `json:"rejected"`
	Largest              int    `json:"largest"`
	Completed            int    `json:"completed"`
	TotalWaitTimeInNanos *int64 `json:"total_wait_time_in_nanos,omitempty"`
}

NodesStatsThreadPoolValues is a sub type of NodesStatsThreadPool representing all information a thread pool can have

type NodesStatsTransport 

type NodesStatsTransport struct {
	ServerOpen               int `json:"server_open"`
	TotalOutboundConnections int `json:"total_outbound_connections"`
	RxCount                  int `json:"rx_count"`
	RxSizeInBytes            int `json:"rx_size_in_bytes"`
	TxCount                  int `json:"tx_count"`
	TxSizeInBytes            int `json:"tx_size_in_bytes"`
}

NodesStatsTransport is a sub type of NodesStats representing network transport information of the node

type NodesStatsWeightedRouting 

type NodesStatsWeightedRouting struct {
	Stats struct {
		FailOpenCount int `json:"fail_open_count"`
	} `json:"stats"`
}

NodesStatsWeightedRouting is a sub type of NodesStats representing weighted routing information of the node

type NodesUsage 

type NodesUsage struct {
	Timestamp    int64           `json:"timestamp"`
	Since        int64           `json:"since"`
	RestActions  map[string]int  `json:"rest_actions"`
	Aggregations json.RawMessage `json:"aggregations"` // Can contain unknow fields
}

NodesUsage is a sub type of NodesUsageResp containing stats about rest api actions

type NodesUsageParams 

type NodesUsageParams struct {
	Timeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

NodesUsageParams represents possible parameters for the NodesUsageReq

type NodesUsageReq 

type NodesUsageReq struct {
	Metrics []string
	NodeID  []string

	Header http.Header
	Params NodesUsageParams
}

NodesUsageReq represents possible options for the /_nodes request

func (NodesUsageReq) GetRequest 

func (r NodesUsageReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type NodesUsageResp 

type NodesUsageResp struct {
	NodesUsage struct {
		Total      int             `json:"total"`
		Successful int             `json:"successful"`
		Failed     int             `json:"failed"`
		Failures   []FailuresCause `json:"failures"`
	} `json:"_nodes"`
	ClusterName string                `json:"cluster_name"`
	Nodes       map[string]NodesUsage `json:"nodes"`
	// contains filtered or unexported fields
}

NodesUsageResp represents the returned struct of the /_nodes response

func (NodesUsageResp) Inspect 

func (r NodesUsageResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type PhaseTook 

type PhaseTook struct {
	DFSPreQuery int `json:"dfs_pre_query"`
	Query       int `json:"query"`
	Fetch       int `json:"fetch"`
	DFSQuery    int `json:"dfs_query"`
	Expand      int `json:"expand"`
	CanMatch    int `json:"can_match"`
}

PhaseTook is the phase-level took time values in milliseconds

type PingParams 

type PingParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

PingParams represents possible parameters for the PingReq

type PingReq 

type PingReq struct {
	Header http.Header
	Params PingParams
}

PingReq represents possible options for the / request

func (PingReq) GetRequest 

func (r PingReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type PointInTimeCreateParams 

type PointInTimeCreateParams struct {
	KeepAlive               time.Duration
	Preference              string
	Routing                 string
	ExpandWildcards         string
	AllowPartialPitCreation bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

PointInTimeCreateParams represents possible parameters for the PointInTimeCreateReq

type PointInTimeCreateReq 

type PointInTimeCreateReq struct {
	Indices []string

	Header http.Header
	Params PointInTimeCreateParams
}

PointInTimeCreateReq represents possible options for the index create request

func (PointInTimeCreateReq) GetRequest 

func (r PointInTimeCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type PointInTimeCreateResp 

type PointInTimeCreateResp struct {
	PitID  string `json:"pit_id"`
	Shards struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Skipped    int `json:"skipped"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	CreationTime int64 `json:"creation_time"`
	// contains filtered or unexported fields
}

PointInTimeCreateResp represents the returned struct of the index create response

func (PointInTimeCreateResp) Inspect 

func (r PointInTimeCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type PointInTimeDeleteParams 

type PointInTimeDeleteParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

PointInTimeDeleteParams represents possible parameters for the PointInTimeDeleteReq

type PointInTimeDeleteReq 

type PointInTimeDeleteReq struct {
	PitID []string

	Header http.Header
	Params PointInTimeDeleteParams
}

PointInTimeDeleteReq represents possible options for the index create request

func (PointInTimeDeleteReq) GetRequest 

func (r PointInTimeDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type PointInTimeDeleteRequestBody 

type PointInTimeDeleteRequestBody struct {
	PitID []string `json:"pit_id"`
}

PointInTimeDeleteRequestBody is used to from the delete request body

type PointInTimeDeleteResp 

type PointInTimeDeleteResp struct {
	Pits []struct {
		PitID      string `json:"pit_id"`
		Successful bool   `json:"successful"`
	} `json:"pits"`
	// contains filtered or unexported fields
}

PointInTimeDeleteResp represents the returned struct of the index create response

func (PointInTimeDeleteResp) Inspect 

func (r PointInTimeDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type PointInTimeGetParams 

type PointInTimeGetParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

PointInTimeGetParams represents possible parameters for the PointInTimeGetReq

type PointInTimeGetReq 

type PointInTimeGetReq struct {
	Header http.Header
	Params PointInTimeGetParams
}

PointInTimeGetReq represents possible options for the index create request

func (PointInTimeGetReq) GetRequest 

func (r PointInTimeGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type PointInTimeGetResp 

type PointInTimeGetResp struct {
	Pits []struct {
		PitID        string `json:"pit_id"`
		CreationTime int    `json:"creation_time"`
		KeepAlive    int64  `json:"keep_alive"`
	} `json:"pits"`
	// contains filtered or unexported fields
}

PointInTimeGetResp represents the returned struct of the index create response

func (PointInTimeGetResp) Inspect 

func (r PointInTimeGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type RankEvalParams 

type RankEvalParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	IgnoreUnavailable *bool
	SearchType        string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

RankEvalParams represents possible parameters for the RankEvalReq

type RankEvalReq 

type RankEvalReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params RankEvalParams
}

RankEvalReq represents possible options for the /_rank_eval request

func (RankEvalReq) GetRequest 

func (r RankEvalReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type RankEvalResp 

type RankEvalResp struct {
	MetricScore float64         `json:"metric_score"`
	Details     json.RawMessage `json:"details"`
	Failures    json.RawMessage `json:"failures"`
	// contains filtered or unexported fields
}

RankEvalResp represents the returned struct of the /_rank_eval response

func (RankEvalResp) Inspect 

func (r RankEvalResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ReindexParams 

type ReindexParams struct {
	MaxDocs             *int
	Refresh             *bool
	RequestsPerSecond   *int
	Scroll              time.Duration
	Slices              interface{}
	Timeout             time.Duration
	WaitForActiveShards string
	WaitForCompletion   *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ReindexParams represents possible parameters for the ReindexReq

type ReindexReq 

type ReindexReq struct {
	Body io.Reader

	Header http.Header
	Params ReindexParams
}

ReindexReq represents possible options for the / request

func (ReindexReq) GetRequest 

func (r ReindexReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ReindexResp 

type ReindexResp struct {
	Took             int  `json:"took"`
	TimedOut         bool `json:"timed_out"`
	Total            int  `json:"total"`
	Updated          int  `json:"updated"`
	Created          int  `json:"created"`
	Deleted          int  `json:"deleted"`
	Batches          int  `json:"batches"`
	VersionConflicts int  `json:"version_conflicts"`
	Noops            int  `json:"noops"`
	Retries          struct {
		Bulk   int `json:"bulk"`
		Search int `json:"search"`
	} `json:"retries"`
	ThrottledMillis      int               `json:"throttled_millis"`
	RequestsPerSecond    float64           `json:"requests_per_second"`
	ThrottledUntilMillis int               `json:"throttled_until_millis"`
	Failures             []json.RawMessage `json:"failures"`
	Task                 string            `json:"task"`
	// contains filtered or unexported fields
}

ReindexResp represents the returned struct of the / response

func (ReindexResp) Inspect 

func (r ReindexResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ReindexRethrottleParams 

type ReindexRethrottleParams struct {
	RequestsPerSecond *int

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ReindexRethrottleParams represents possible parameters for the ReindexRethrottleReq

type ReindexRethrottleReq 

type ReindexRethrottleReq struct {
	TaskID string

	Header http.Header
	Params ReindexRethrottleParams
}

ReindexRethrottleReq represents possible options for the / request

func (ReindexRethrottleReq) GetRequest 

func (r ReindexRethrottleReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ReindexRethrottleResp 

type ReindexRethrottleResp struct {
	Nodes map[string]struct {
		Name             string            `json:"name"`
		TransportAddress string            `json:"transport_address"`
		Host             string            `json:"host"`
		IP               string            `json:"ip"`
		Roles            []string          `json:"roles"`
		Attributes       map[string]string `json:"attributes"`
		Tasks            map[string]struct {
			Node   string `json:"node"`
			ID     int    `json:"id"`
			Type   string `json:"type"`
			Action string `json:"action"`
			Status struct {
				Total            int `json:"total"`
				Updated          int `json:"updated"`
				Created          int `json:"created"`
				Deleted          int `json:"deleted"`
				Batches          int `json:"batches"`
				VersionConflicts int `json:"version_conflicts"`
				Noops            int `json:"noops"`
				Retries          struct {
					Bulk   int `json:"bulk"`
					Search int `json:"search"`
				} `json:"retries"`
				ThrottledMillis      int     `json:"throttled_millis"`
				RequestsPerSecond    float64 `json:"requests_per_second"`
				ThrottledUntilMillis int     `json:"throttled_until_millis"`
			} `json:"status"`
			Description        string          `json:"description"`
			StartTimeInMillis  int64           `json:"start_time_in_millis"`
			RunningTimeInNanos int             `json:"running_time_in_nanos"`
			Cancellable        bool            `json:"cancellable"`
			Cancelled          bool            `json:"cancelled"`
			Headers            json.RawMessage `json:"headers"`
			ResourceStats      struct {
				Average struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"average"`
				Total struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"total"`
				Min struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"min"`
				Max struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"max"`
				ThreadInfo struct {
					ThreadExecutions int `json:"thread_executions"`
					ActiveThreads    int `json:"active_threads"`
				} `json:"thread_info"`
			} `json:"resource_stats"`
		} `json:"tasks"`
	} `json:"nodes"`
	NodeFailures []FailuresCause `json:"node_failures"`
	// contains filtered or unexported fields
}

ReindexRethrottleResp represents the returned struct of the / response

func (ReindexRethrottleResp) Inspect 

func (r ReindexRethrottleResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type RenderSearchTemplateParams 

type RenderSearchTemplateParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

RenderSearchTemplateParams represents possible parameters for the RenderSearchTemplateReq

type RenderSearchTemplateReq 

type RenderSearchTemplateReq struct {
	TemplateID string

	Body io.Reader

	Header http.Header
	Params RenderSearchTemplateParams
}

RenderSearchTemplateReq represents possible options for the /_render/template request

func (RenderSearchTemplateReq) GetRequest 

func (r RenderSearchTemplateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type RenderSearchTemplateResp 

type RenderSearchTemplateResp struct {
	TemplateOutput json.RawMessage `json:"template_output"`
	// contains filtered or unexported fields
}

RenderSearchTemplateResp represents the returned struct of the /_render/template response

func (RenderSearchTemplateResp) Inspect 

func (r RenderSearchTemplateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ResponseShards 

type ResponseShards struct {
	Total      int                     `json:"total"`
	Successful int                     `json:"successful"`
	Failed     int                     `json:"failed"`
	Failures   []ResponseShardsFailure `json:"failures"`
	Skipped    int                     `json:"skipped"`
}

ResponseShards is a sub type of api repsonses containing information about shards

type ResponseShardsFailure 

type ResponseShardsFailure struct {
	Shard  int    `json:"shard"`
	Index  any    `json:"index"`
	Node   string `json:"node"`
	Reason struct {
		Type   string `json:"type"`
		Reason string `json:"reason"`
	} `json:"reason"`
}

ResponseShardsFailure is a sub type of ResponseShards containing information about a failed shard

type ScriptContextParams 

type ScriptContextParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScriptContextParams represents possible parameters for the ScriptContextReq

type ScriptContextReq 

type ScriptContextReq struct {
	Header http.Header
	Params ScriptContextParams
}

ScriptContextReq represents possible options for the delete script request

func (ScriptContextReq) GetRequest 

func (r ScriptContextReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScriptContextResp 

type ScriptContextResp struct {
	Contexts []struct {
		Name    string `json:"name"`
		Methods []struct {
			Name       string `json:"name"`
			ReturnType string `json:"return_type"`
			Params     []struct {
				Name string `json:"name"`
				Type string `json:"type"`
			} `json:"params"`
		} `json:"methods"`
	} `json:"contexts"`
	// contains filtered or unexported fields
}

ScriptContextResp represents the returned struct of the delete script response

func (ScriptContextResp) Inspect 

func (r ScriptContextResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ScriptDeleteParams 

type ScriptDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScriptDeleteParams represents possible parameters for the ScriptDeleteReq

type ScriptDeleteReq 

type ScriptDeleteReq struct {
	ScriptID string

	Header http.Header
	Params ScriptDeleteParams
}

ScriptDeleteReq represents possible options for the delete script request

func (ScriptDeleteReq) GetRequest 

func (r ScriptDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScriptDeleteResp 

type ScriptDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

ScriptDeleteResp represents the returned struct of the delete script response

func (ScriptDeleteResp) Inspect 

func (r ScriptDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ScriptGetParams 

type ScriptGetParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScriptGetParams represents possible parameters for the ScriptGetReq

type ScriptGetReq 

type ScriptGetReq struct {
	ScriptID string

	Header http.Header
	Params ScriptGetParams
}

ScriptGetReq represents possible options for the get script request

func (ScriptGetReq) GetRequest 

func (r ScriptGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScriptGetResp 

type ScriptGetResp struct {
	ID     string `json:"_id"`
	Found  bool   `json:"found"`
	Script struct {
		Lang   string `json:"lang"`
		Source string `json:"source"`
	} `json:"script"`
	// contains filtered or unexported fields
}

ScriptGetResp represents the returned struct of the get script response

func (ScriptGetResp) Inspect 

func (r ScriptGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ScriptLanguageParams 

type ScriptLanguageParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScriptLanguageParams represents possible parameters for the ScriptLanguageReq

type ScriptLanguageReq 

type ScriptLanguageReq struct {
	Header http.Header
	Params ScriptLanguageParams
}

ScriptLanguageReq represents possible options for the delete script request

func (ScriptLanguageReq) GetRequest 

func (r ScriptLanguageReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScriptLanguageResp 

type ScriptLanguageResp struct {
	TypesAllowed     []string `json:"types_allowed"`
	LanguageContexts []struct {
		Language string   `json:"language"`
		Contexts []string `json:"contexts"`
	} `json:"language_contexts"`
	// contains filtered or unexported fields
}

ScriptLanguageResp represents the returned struct of the delete script response

func (ScriptLanguageResp) Inspect 

func (r ScriptLanguageResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ScriptPainlessExecuteParams 

type ScriptPainlessExecuteParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScriptPainlessExecuteParams represents possible parameters for the ScriptPainlessExecuteReq

type ScriptPainlessExecuteReq 

type ScriptPainlessExecuteReq struct {
	Body io.Reader

	Header http.Header
	Params ScriptPainlessExecuteParams
}

ScriptPainlessExecuteReq represents possible options for the delete script request

func (ScriptPainlessExecuteReq) GetRequest 

func (r ScriptPainlessExecuteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScriptPainlessExecuteResp 

type ScriptPainlessExecuteResp struct {
	Result json.RawMessage `json:"result"`
	// contains filtered or unexported fields
}

ScriptPainlessExecuteResp represents the returned struct of the delete script response

func (ScriptPainlessExecuteResp) Inspect 

func (r ScriptPainlessExecuteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ScriptPutParams 

type ScriptPutParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScriptPutParams represents possible parameters for the ScriptPutReq

type ScriptPutReq 

type ScriptPutReq struct {
	ScriptID      string
	ScriptContext string

	Body io.Reader

	Header http.Header
	Params ScriptPutParams
}

ScriptPutReq represents possible options for the put script request

func (ScriptPutReq) GetRequest 

func (r ScriptPutReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScriptPutResp 

type ScriptPutResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

ScriptPutResp represents the returned struct of the put script response

func (ScriptPutResp) Inspect 

func (r ScriptPutResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ScrollDeleteParams 

type ScrollDeleteParams struct {
	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScrollDeleteParams represents possible parameters for the ScrollDeleteReq

type ScrollDeleteReq 

type ScrollDeleteReq struct {
	ScrollIDs []string

	Body io.Reader

	Header http.Header
	Params ScrollDeleteParams
}

ScrollDeleteReq represents possible options for the index create request

func (ScrollDeleteReq) GetRequest 

func (r ScrollDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScrollDeleteResp 

type ScrollDeleteResp struct {
	NumFreed  int  `json:"num_freed"`
	Succeeded bool `json:"succeeded"`
	// contains filtered or unexported fields
}

ScrollDeleteResp represents the returned struct of the index create response

func (ScrollDeleteResp) Inspect 

func (r ScrollDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type ScrollGetParams 

type ScrollGetParams struct {
	RestTotalHitsAsInt *bool
	Scroll             time.Duration
	ScrollID           string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

ScrollGetParams represents possible parameters for the ScrollGetReq

type ScrollGetReq 

type ScrollGetReq struct {
	ScrollID string

	Header http.Header
	Params ScrollGetParams
}

ScrollGetReq represents possible options for the index create request

func (ScrollGetReq) GetRequest 

func (r ScrollGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type ScrollGetResp 

type ScrollGetResp struct {
	Took    int            `json:"took"`
	Timeout bool           `json:"timed_out"`
	Shards  ResponseShards `json:"_shards"`
	Hits    struct {
		Total struct {
			Value    int    `json:"value"`
			Relation string `json:"relation"`
		} `json:"total"`
		MaxScore *float32    `json:"max_score"`
		Hits     []SearchHit `json:"hits"`
	} `json:"hits"`
	ScrollID        *string  `json:"_scroll_id,omitempty"`
	TerminatedEarly bool     `json:"terminated_early"`
	MaxScore        *float32 `json:"max_score"`
	// contains filtered or unexported fields
}

ScrollGetResp represents the returned struct of the index create response

func (ScrollGetResp) Inspect 

func (r ScrollGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SearchHit 

type SearchHit struct {
	Index     string          `json:"_index"`
	ID        string          `json:"_id"`
	Routing   string          `json:"_routing"`
	Score     float32         `json:"_score"`
	Source    json.RawMessage `json:"_source"`
	Fields    json.RawMessage `json:"fields"`
	InnerHits map[string]struct {
		Hits SearchHits `json:"hits"`
	} `json:"inner_hits"`
	Type           string                  `json:"_type"` // Deprecated field
	Sort           []any                   `json:"sort"`
	Explanation    *DocumentExplainDetails `json:"_explanation"`
	SeqNo          *int                    `json:"_seq_no"`
	PrimaryTerm    *int                    `json:"_primary_term"`
	Highlight      map[string][]string     `json:"highlight"`
	MatchedQueries []string                `json:"matched_queries"`
}

SearchHit is a sub type of SearchResp containing information of the search hit with an unparsed Source field

type SearchHits 

type SearchHits struct {
	Total struct {
		Value    int    `json:"value"`
		Relation string `json:"relation"`
	} `json:"total"`
	MaxScore *float32    `json:"max_score"`
	Hits     []SearchHit `json:"hits"`
}

SearchHits is a list of SearchHit with Total and MaxScore fields

type SearchParams 

type SearchParams struct {
	AllowNoIndices             *bool
	AllowPartialSearchResults  *bool
	Analyzer                   string
	AnalyzeWildcard            *bool
	BatchedReduceSize          *int
	CcsMinimizeRoundtrips      *bool
	DefaultOperator            string
	Df                         string
	DocvalueFields             []string
	ExpandWildcards            string
	Explain                    *bool
	From                       *int
	IgnoreThrottled            *bool
	IgnoreUnavailable          *bool
	Lenient                    *bool
	MaxConcurrentShardRequests *int
	MinCompatibleShardNode     string
	Preference                 string
	PreFilterShardSize         *int
	Query                      string
	RequestCache               *bool
	RestTotalHitsAsInt         *bool
	Routing                    []string
	Scroll                     time.Duration
	SearchPipeline             string
	SearchType                 string
	SeqNoPrimaryTerm           *bool
	Size                       *int
	Sort                       []string
	Source                     interface{}
	SourceExcludes             []string
	SourceIncludes             []string
	Stats                      []string
	StoredFields               []string
	SuggestField               string
	SuggestMode                string
	SuggestSize                *int
	SuggestText                string
	TerminateAfter             *int
	Timeout                    time.Duration
	TrackScores                *bool
	TrackTotalHits             interface{}
	TypedKeys                  *bool
	Version                    *bool
	PhaseTook                  bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SearchParams represents possible parameters for the SearchReq

type SearchReq 

type SearchReq struct {
	Indices []string
	Body    io.Reader

	Header http.Header
	Params SearchParams
}

SearchReq represents possible options for the /_search request

func (SearchReq) GetRequest 

func (r SearchReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SearchResp 

type SearchResp struct {
	Took         int                  `json:"took"`
	PhaseTook    *PhaseTook           `json:"phase_took,omitempty"`
	Timeout      bool                 `json:"timed_out"`
	Shards       ResponseShards       `json:"_shards"`
	Hits         SearchHits           `json:"hits"`
	Errors       bool                 `json:"errors"`
	Aggregations json.RawMessage      `json:"aggregations"`
	ScrollID     *string              `json:"_scroll_id,omitempty"`
	Suggest      map[string][]Suggest `json:"suggest,omitempty"`
	// contains filtered or unexported fields
}

SearchResp represents the returned struct of the /_search response

func (SearchResp) Inspect 

func (r SearchResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SearchShardsParams 

type SearchShardsParams struct {
	AllowNoIndices    *bool
	ExpandWildcards   string
	IgnoreUnavailable *bool
	Local             *bool
	Preference        string
	Routing           string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SearchShardsParams represents possible parameters for the SearchShardsReq

type SearchShardsReq 

type SearchShardsReq struct {
	Indices []string

	Header http.Header
	Params SearchShardsParams
}

SearchShardsReq represents possible options for the /_search request

func (SearchShardsReq) GetRequest 

func (r SearchShardsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SearchShardsResp 

type SearchShardsResp struct {
	Nodes map[string]struct {
		Name             string            `json:"name"`
		EphemeralID      string            `json:"ephemeral_id"`
		TransportAddress string            `json:"transport_address"`
		Attributes       map[string]string `json:"attributes"`
	} `json:"nodes"`
	Indices map[string]json.RawMessage `json:"indices"`
	Shards  [][]struct {
		State                    string  `json:"state"`
		Primary                  bool    `json:"primary"`
		SearchOnly               bool    `json:"searchOnly"`
		Node                     string  `json:"node"`
		RelocatingNode           *string `json:"relocating_node"`
		Shard                    int     `json:"shard"`
		Index                    string  `json:"index"`
		ExpectedShardSizeInBytes int     `json:"expected_shard_size_in_bytes"`
		RecoverySource           struct {
			Type string `json:"type"`
		} `json:"recovery_source"`
		UnassignedInfo struct {
			Reason           string `json:"reason"`
			At               string `json:"at"`
			Delayed          bool   `json:"delayed"`
			AllocationStatus string `json:"allocation_status"`
		} `json:"unassigned_info"`
		AllocationID struct {
			ID string `json:"id"`
		} `json:"allocation_id"`
	} `json:"shards"`
	// contains filtered or unexported fields
}

SearchShardsResp represents the returned struct of the /_search response

func (SearchShardsResp) Inspect 

func (r SearchShardsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SearchTemplateParams 

type SearchTemplateParams struct {
	AllowNoIndices        *bool
	CcsMinimizeRoundtrips *bool
	ExpandWildcards       string
	Explain               *bool
	IgnoreThrottled       *bool
	IgnoreUnavailable     *bool
	Preference            string
	Profile               *bool
	RestTotalHitsAsInt    *bool
	Routing               []string
	Scroll                time.Duration
	SearchType            string
	TypedKeys             *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SearchTemplateParams represents possible parameters for the SearchTemplateReq

type SearchTemplateReq 

type SearchTemplateReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params SearchTemplateParams
}

SearchTemplateReq represents possible options for the /_search request

func (SearchTemplateReq) GetRequest 

func (r SearchTemplateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SearchTemplateResp 

type SearchTemplateResp struct {
	Took    int            `json:"took"`
	Timeout bool           `json:"timed_out"`
	Shards  ResponseShards `json:"_shards"`
	Status  int            `json:"status"`
	Hits    struct {
		Total struct {
			Value    int    `json:"value"`
			Relation string `json:"relation"`
		} `json:"total"`
		MaxScore *float32    `json:"max_score"`
		Hits     []SearchHit `json:"hits"`
	} `json:"hits"`
	// contains filtered or unexported fields
}

SearchTemplateResp represents the returned struct of the /_search response

func (SearchTemplateResp) Inspect 

func (r SearchTemplateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SettingsGetParams 

type SettingsGetParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	FlatSettings          *bool
	IgnoreUnavailable     *bool
	IncludeDefaults       *bool
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SettingsGetParams represents possible parameters for the SettingsGetReq

type SettingsGetReq 

type SettingsGetReq struct {
	Indices  []string
	Settings []string

	Header http.Header
	Params SettingsGetParams
}

SettingsGetReq represents possible options for the settings get request

func (SettingsGetReq) GetRequest 

func (r SettingsGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SettingsGetResp 

type SettingsGetResp struct {
	Indices map[string]struct {
		Settings json.RawMessage `json:"settings"`
	}
	// contains filtered or unexported fields
}

SettingsGetResp represents the returned struct of the settings get response

func (SettingsGetResp) Inspect 

func (r SettingsGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SettingsPutParams 

type SettingsPutParams struct {
	AllowNoIndices        *bool
	ExpandWildcards       string
	FlatSettings          *bool
	IgnoreUnavailable     *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	PreserveExisting      *bool
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SettingsPutParams represents possible parameters for the SettingsPutReq

type SettingsPutReq 

type SettingsPutReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params SettingsPutParams
}

SettingsPutReq represents possible options for the settings put request

func (SettingsPutReq) GetRequest 

func (r SettingsPutReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SettingsPutResp 

type SettingsPutResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

SettingsPutResp represents the returned struct of the settings put response

func (SettingsPutResp) Inspect 

func (r SettingsPutResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotCloneParams 

type SnapshotCloneParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotCloneParams represents possible parameters for the SnapshotCloneReq

type SnapshotCloneReq 

type SnapshotCloneReq struct {
	Repo           string
	Snapshot       string
	TargetSnapshot string

	Body io.Reader

	Header http.Header
	Params SnapshotCloneParams
}

SnapshotCloneReq represents possible options for the index create request

func (SnapshotCloneReq) GetRequest 

func (r SnapshotCloneReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotCloneResp 

type SnapshotCloneResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

SnapshotCloneResp represents the returned struct of the index create response

func (SnapshotCloneResp) Inspect 

func (r SnapshotCloneResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotCreateParams 

type SnapshotCreateParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	WaitForCompletion     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotCreateParams represents possible parameters for the SnapshotCreateReq

type SnapshotCreateReq 

type SnapshotCreateReq struct {
	Repo     string
	Snapshot string

	Body io.Reader

	Header http.Header
	Params SnapshotCreateParams
}

SnapshotCreateReq represents possible options for the index create request

func (SnapshotCreateReq) GetRequest 

func (r SnapshotCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotCreateResp 

type SnapshotCreateResp struct {
	Accepted bool `json:"accepted"`
	Snapshot struct {
		Snapshot                    string            `json:"snapshot"`
		UUID                        string            `json:"uuid"`
		VersionID                   int               `json:"version_id"`
		Version                     string            `json:"version"`
		RemoteStoreIndexShallowCopy bool              `json:"remote_store_index_shallow_copy"`
		Indices                     []string          `json:"indices"`
		DataStreams                 []json.RawMessage `json:"data_streams"`
		IncludeGlobalState          bool              `json:"include_global_state"`
		Metadata                    map[string]string `json:"metadata"`
		State                       string            `json:"state"`
		StartTime                   string            `json:"start_time"`
		StartTimeInMillis           int64             `json:"start_time_in_millis"`
		EndTime                     string            `json:"end_time"`
		EndTimeInMillis             int64             `json:"end_time_in_millis"`
		DurationInMillis            int               `json:"duration_in_millis"`
		Failures                    []json.RawMessage `json:"failures"`
		Shards                      struct {
			Total      int `json:"total"`
			Failed     int `json:"failed"`
			Successful int `json:"successful"`
		} `json:"shards"`
	} `json:"snapshot"`
	// contains filtered or unexported fields
}

SnapshotCreateResp represents the returned struct of the index create response

func (SnapshotCreateResp) Inspect 

func (r SnapshotCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotDeleteParams 

type SnapshotDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotDeleteParams represents possible parameters for the SnapshotDeleteReq

type SnapshotDeleteReq 

type SnapshotDeleteReq struct {
	Repo      string
	Snapshots []string

	Header http.Header
	Params SnapshotDeleteParams
}

SnapshotDeleteReq represents possible options for the index create request

func (SnapshotDeleteReq) GetRequest 

func (r SnapshotDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotDeleteResp 

type SnapshotDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

SnapshotDeleteResp represents the returned struct of the index create response

func (SnapshotDeleteResp) Inspect 

func (r SnapshotDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotGet 

type SnapshotGet struct {
	Snapshot                    string            `json:"snapshot"`
	UUID                        string            `json:"uuid"`
	VersionID                   int               `json:"version_id"`
	Version                     string            `json:"version"`
	RemoteStoreIndexShallowCopy bool              `json:"remote_store_index_shallow_copy"`
	Indices                     []string          `json:"indices"`
	DataStreams                 []json.RawMessage `json:"data_streams"`
	IncludeGlobalState          bool              `json:"include_global_state"`
	Metadata                    map[string]string `json:"metadata"`
	State                       string            `json:"state"`
	StartTime                   string            `json:"start_time"`
	StartTimeInMillis           int64             `json:"start_time_in_millis"`
	EndTime                     string            `json:"end_time"`
	EndTimeInMillis             int64             `json:"end_time_in_millis"`
	DurationInMillis            int               `json:"duration_in_millis"`
	Failures                    []json.RawMessage `json:"failures"`
	Shards                      SnapshotGetShards `json:"shards"`
}

SnapshotGet is a sub type of SnapshotGetResp represeting a single snapshot

type SnapshotGetParams 

type SnapshotGetParams struct {
	IgnoreUnavailable     *bool
	IncludeRepository     *bool
	IndexDetails          *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Verbose               *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotGetParams represents possible parameters for the SnapshotGetReq

type SnapshotGetReq 

type SnapshotGetReq struct {
	Repo      string
	Snapshots []string

	Body io.Reader

	Header http.Header
	Params SnapshotGetParams
}

SnapshotGetReq represents possible options for the index create request

func (SnapshotGetReq) GetRequest 

func (r SnapshotGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotGetResp 

type SnapshotGetResp struct {
	Snapshots []SnapshotGet `json:"snapshots"`
	// contains filtered or unexported fields
}

SnapshotGetResp represents the returned struct of the index create response

func (SnapshotGetResp) Inspect 

func (r SnapshotGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotGetShards 

type SnapshotGetShards struct {
	Total      int `json:"total"`
	Failed     int `json:"failed"`
	Successful int `json:"successful"`
}

SnapshotGetShards is a sub type of SnapshotGet containing shard numbers

type SnapshotRepositoryCleanupParams 

type SnapshotRepositoryCleanupParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotRepositoryCleanupParams represents possible parameters for the SnapshotRepositoryCleanupReq

type SnapshotRepositoryCleanupReq 

type SnapshotRepositoryCleanupReq struct {
	Repo string

	Header http.Header
	Params SnapshotRepositoryCleanupParams
}

SnapshotRepositoryCleanupReq represents possible options for the index create request

func (SnapshotRepositoryCleanupReq) GetRequest 

func (r SnapshotRepositoryCleanupReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotRepositoryCleanupResp 

type SnapshotRepositoryCleanupResp struct {
	Results struct {
		DeletedBytes int `json:"deleted_bytes"`
		DeletedBlobs int `json:"deleted_blobs"`
	} `json:"results"`
	// contains filtered or unexported fields
}

SnapshotRepositoryCleanupResp represents the returned struct of the index create response

func (SnapshotRepositoryCleanupResp) Inspect 

func (r SnapshotRepositoryCleanupResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotRepositoryCreateParams 

type SnapshotRepositoryCreateParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration
	Verify                *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotRepositoryCreateParams represents possible parameters for the SnapshotRepositoryCreateReq

type SnapshotRepositoryCreateReq 

type SnapshotRepositoryCreateReq struct {
	Repo string

	Body io.Reader

	Header http.Header
	Params SnapshotRepositoryCreateParams
}

SnapshotRepositoryCreateReq represents possible options for the index create request

func (SnapshotRepositoryCreateReq) GetRequest 

func (r SnapshotRepositoryCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotRepositoryCreateResp 

type SnapshotRepositoryCreateResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

SnapshotRepositoryCreateResp represents the returned struct of the index create response

func (SnapshotRepositoryCreateResp) Inspect 

func (r SnapshotRepositoryCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotRepositoryDeleteParams 

type SnapshotRepositoryDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotRepositoryDeleteParams represents possible parameters for the SnapshotRepositoryDeleteReq

type SnapshotRepositoryDeleteReq 

type SnapshotRepositoryDeleteReq struct {
	Repos []string

	Header http.Header
	Params SnapshotRepositoryDeleteParams
}

SnapshotRepositoryDeleteReq represents possible options for the index create request

func (SnapshotRepositoryDeleteReq) GetRequest 

func (r SnapshotRepositoryDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotRepositoryDeleteResp 

type SnapshotRepositoryDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

SnapshotRepositoryDeleteResp represents the returned struct of the index create response

func (SnapshotRepositoryDeleteResp) Inspect 

func (r SnapshotRepositoryDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotRepositoryGetParams 

type SnapshotRepositoryGetParams struct {
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotRepositoryGetParams represents possible parameters for the SnapshotRepositoryGetReq

type SnapshotRepositoryGetReq 

type SnapshotRepositoryGetReq struct {
	Repos []string

	Header http.Header
	Params SnapshotRepositoryGetParams
}

SnapshotRepositoryGetReq represents possible options for the index create request

func (SnapshotRepositoryGetReq) GetRequest 

func (r SnapshotRepositoryGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotRepositoryGetResp 

type SnapshotRepositoryGetResp struct {
	Repos map[string]struct {
		Type     string            `json:"type"`
		Settings map[string]string `json:"settings"`
	}
	// contains filtered or unexported fields
}

SnapshotRepositoryGetResp represents the returned struct of the index create response

func (SnapshotRepositoryGetResp) Inspect 

func (r SnapshotRepositoryGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotRepositoryVerifyParams 

type SnapshotRepositoryVerifyParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotRepositoryVerifyParams represents possible parameters for the SnapshotRepositoryVerifyReq

type SnapshotRepositoryVerifyReq 

type SnapshotRepositoryVerifyReq struct {
	Repo string

	Header http.Header
	Params SnapshotRepositoryVerifyParams
}

SnapshotRepositoryVerifyReq represents possible options for the index create request

func (SnapshotRepositoryVerifyReq) GetRequest 

func (r SnapshotRepositoryVerifyReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotRepositoryVerifyResp 

type SnapshotRepositoryVerifyResp struct {
	Nodes map[string]struct {
		Name string `json:"name"`
	} `json:"nodes"`
	// contains filtered or unexported fields
}

SnapshotRepositoryVerifyResp represents the returned struct of the index create response

func (SnapshotRepositoryVerifyResp) Inspect 

func (r SnapshotRepositoryVerifyResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotRestoreParams 

type SnapshotRestoreParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	WaitForCompletion     *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotRestoreParams represents possible parameters for the SnapshotRestoreReq

type SnapshotRestoreReq 

type SnapshotRestoreReq struct {
	Repo     string
	Snapshot string

	Body io.Reader

	Header http.Header
	Params SnapshotRestoreParams
}

SnapshotRestoreReq represents possible options for the index create request

func (SnapshotRestoreReq) GetRequest 

func (r SnapshotRestoreReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotRestoreResp 

type SnapshotRestoreResp struct {
	Accepted bool `json:"accepted"`
	Snapshot struct {
		Snapshot string   `json:"snapshot"`
		Indices  []string `json:"indices"`
		Shards   struct {
			Total      int `json:"total"`
			Failed     int `json:"failed"`
			Successful int `json:"successful"`
		} `json:"shards"`
	} `json:"snapshot"`
	// contains filtered or unexported fields
}

SnapshotRestoreResp represents the returned struct of the index create response

func (SnapshotRestoreResp) Inspect 

func (r SnapshotRestoreResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotStatusParams 

type SnapshotStatusParams struct {
	IgnoreUnavailable     *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

SnapshotStatusParams represents possible parameters for the SnapshotStatusReq

type SnapshotStatusReq 

type SnapshotStatusReq struct {
	Repo      string
	Snapshots []string

	Header http.Header
	Params SnapshotStatusParams
}

SnapshotStatusReq represents possible options for the index create request

func (SnapshotStatusReq) GetRequest 

func (r SnapshotStatusReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type SnapshotStatusResp 

type SnapshotStatusResp struct {
	Accepted  bool `json:"accepted"`
	Snapshots []struct {
		Snapshot           string                    `json:"snapshot"`
		Repository         string                    `json:"repository"`
		UUID               string                    `json:"uuid"`
		State              string                    `json:"state"`
		IncludeGlobalState bool                      `json:"include_global_state"`
		ShardsStats        SnapshotStatusShardsStats `json:"shards_stats"`
		Stats              SnapshotStatusStats       `json:"stats"`
		Indices            map[string]struct {
			ShardsStats SnapshotStatusShardsStats `json:"shards_stats"`
			Stats       SnapshotStatusStats       `json:"stats"`
			Shards      map[string]struct {
				Stage string              `json:"stage"`
				Stats SnapshotStatusStats `json:"stats"`
			} `json:"shards"`
		} `json:"indices"`
	} `json:"snapshots"`
	// contains filtered or unexported fields
}

SnapshotStatusResp represents the returned struct of the index create response

func (SnapshotStatusResp) Inspect 

func (r SnapshotStatusResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type SnapshotStatusShardsStats 

type SnapshotStatusShardsStats struct {
	Initializing int `json:"initializing"`
	Started      int `json:"started"`
	Finalizing   int `json:"finalizing"`
	Done         int `json:"done"`
	Failed       int `json:"failed"`
	Total        int `json:"total"`
}

SnapshotStatusShardsStats is a sub type of SnapshotStatusResp containing information about shard stats

type SnapshotStatusStats 

type SnapshotStatusStats struct {
	Incremental struct {
		FileCount   int   `json:"file_count"`
		SizeInBytes int64 `json:"size_in_bytes"`
	} `json:"incremental"`
	Total struct {
		FileCount   int   `json:"file_count"`
		SizeInBytes int64 `json:"size_in_bytes"`
	} `json:"total"`
	StartTimeInMillis int64 `json:"start_time_in_millis"`
	TimeInMillis      int   `json:"time_in_millis"`
}

SnapshotStatusStats is a sub type of SnapshotStatusResp containing information about snapshot stats

type Suggest 

type Suggest struct {
	Text    string           `json:"text"`
	Offset  int              `json:"offset"`
	Length  int              `json:"length"`
	Options []SuggestOptions `json:"options"`
}

Suggest is a sub type of SearchResp containing information of the suggest field

type SuggestOptions 

type SuggestOptions struct {
	Text            string              `json:"text"`
	Index           string              `json:"_index"`
	Type            string              `json:"_type"`
	ID              string              `json:"_id"`
	Score           float64             `json:"score"`  // term suggesters uses "score"
	ScoreUnderscore float64             `json:"_score"` // completion and context suggesters uses "_score"
	Freq            int                 `json:"freq"`
	Highlighted     string              `json:"highlighted"`
	CollateMatch    bool                `json:"collate_match"`
	Source          json.RawMessage     `json:"_source"`
	Contexts        map[string][]string `json:"contexts,omitempty"`
}

SuggestOptions is a sub type of Suggest field containing information about suggest options

type TaskCancel 

type TaskCancel struct {
	Name             string                    `json:"name"`
	TransportAddress string                    `json:"transport_address"`
	Host             string                    `json:"host"`
	IP               string                    `json:"ip"`
	Roles            []string                  `json:"roles"`
	Attributes       map[string]string         `json:"attributes"`
	Tasks            map[string]TaskCancelInfo `json:"tasks"`
}

TaskCancel is a sub type of TaskCancelResp containing information about a node the task was running on

type TaskCancelInfo 

type TaskCancelInfo struct {
	Node                   string          `json:"node"`
	ID                     int             `json:"id"`
	Type                   string          `json:"type"`
	Action                 string          `json:"action"`
	StartTimeInMillis      int64           `json:"start_time_in_millis"`
	RunningTimeInNanos     int             `json:"running_time_in_nanos"`
	CancellationTimeMillis int64           `json:"cancellation_time_millis"`
	Cancellable            bool            `json:"cancellable"`
	Cancelled              bool            `json:"cancelled"`
	Headers                json.RawMessage `json:"headers"`
}

TaskCancelInfo is a sub type of TaskCancle containing information about the canceled task

type TasksCancelParams 

type TasksCancelParams struct {
	Actions           []string
	Nodes             []string
	ParentTaskID      string
	WaitForCompletion *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TasksCancelParams represents possible parameters for the TasksCancelReq

type TasksCancelReq 

type TasksCancelReq struct {
	TaskID string

	Header http.Header
	Params TasksCancelParams
}

TasksCancelReq represents possible options for the index create request

func (TasksCancelReq) GetRequest 

func (r TasksCancelReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TasksCancelResp 

type TasksCancelResp struct {
	Nodes        map[string]TaskCancel `json:"nodes"`
	NodeFailures []FailuresCause       `json:"node_failures"`
	// contains filtered or unexported fields
}

TasksCancelResp represents the returned struct of the index create response

func (TasksCancelResp) Inspect 

func (r TasksCancelResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type TasksGetDetails 

type TasksGetDetails struct {
	Order         int64           `json:"order"`
	Version       int64           `json:"version"`
	IndexPatterns []string        `json:"index_patterns"`
	Mappings      json.RawMessage `json:"mappings"`
	Settings      json.RawMessage `json:"settings"`
	Aliases       json.RawMessage `json:"aliases"`
}

TasksGetDetails is a sub type of TasksGetResp containing information about an index template

type TasksGetParams 

type TasksGetParams struct {
	Timeout           time.Duration
	WaitForCompletion *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TasksGetParams represents possible parameters for the TasksGetReq

type TasksGetReq 

type TasksGetReq struct {
	TaskID string

	Header http.Header
	Params TasksGetParams
}

TasksGetReq represents possible options for the index create request

func (TasksGetReq) GetRequest 

func (r TasksGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TasksGetResp 

type TasksGetResp struct {
	Completed bool `json:"completed"`
	Task      struct {
		Node               string          `json:"node"`
		ID                 int             `json:"id"`
		Type               string          `json:"type"`
		Action             string          `json:"action"`
		Description        string          `json:"description"`
		StartTimeInMillis  int64           `json:"start_time_in_millis"`
		RunningTimeInNanos int64           `json:"running_time_in_nanos"`
		Cancellable        bool            `json:"cancellable"`
		Cancelled          bool            `json:"cancelled"`
		Headers            json.RawMessage `json:"headers"`
		ResourceStats      struct {
			Average struct {
				CPUTimeInNanos int `json:"cpu_time_in_nanos"`
				MemoryInBytes  int `json:"memory_in_bytes"`
			} `json:"average"`
			Total struct {
				CPUTimeInNanos int `json:"cpu_time_in_nanos"`
				MemoryInBytes  int `json:"memory_in_bytes"`
			} `json:"total"`
			Min struct {
				CPUTimeInNanos int `json:"cpu_time_in_nanos"`
				MemoryInBytes  int `json:"memory_in_bytes"`
			} `json:"min"`
			Max struct {
				CPUTimeInNanos int `json:"cpu_time_in_nanos"`
				MemoryInBytes  int `json:"memory_in_bytes"`
			} `json:"max"`
			ThreadInfo struct {
				ThreadExecutions int `json:"thread_executions"`
				ActiveThreads    int `json:"active_threads"`
			} `json:"thread_info"`
		} `json:"resource_stats"`
	} `json:"task"`
	// contains filtered or unexported fields
}

TasksGetResp represents the returned struct of the index create response

func (TasksGetResp) Inspect 

func (r TasksGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type TasksListNodes 

type TasksListNodes struct {
	Name             string                   `json:"name"`
	TransportAddress string                   `json:"transport_address"`
	Host             string                   `json:"host"`
	IP               string                   `json:"ip"`
	Roles            []string                 `json:"roles"`
	Attributes       map[string]string        `json:"attributes"`
	Tasks            map[string]TasksListTask `json:"tasks"`
}

TasksListNodes is a sub type of TaskListResp containing information about a node and the tasks running on it

type TasksListParams 

type TasksListParams struct {
	Actions           []string
	Detailed          *bool
	GroupBy           string
	Nodes             []string
	ParentTaskID      string
	Timeout           time.Duration
	WaitForCompletion *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TasksListParams represents possible parameters for the TasksListReq

type TasksListReq 

type TasksListReq struct {
	Header http.Header
	Params TasksListParams
}

TasksListReq represents possible options for the index create request

func (TasksListReq) GetRequest 

func (r TasksListReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TasksListResourceStats 

type TasksListResourceStats struct {
	Average struct {
		CPUTimeInNanos int `json:"cpu_time_in_nanos"`
		MemoryInBytes  int `json:"memory_in_bytes"`
	} `json:"average"`
	Total struct {
		CPUTimeInNanos int `json:"cpu_time_in_nanos"`
		MemoryInBytes  int `json:"memory_in_bytes"`
	} `json:"total"`
	Min struct {
		CPUTimeInNanos int `json:"cpu_time_in_nanos"`
		MemoryInBytes  int `json:"memory_in_bytes"`
	} `json:"min"`
	Max struct {
		CPUTimeInNanos int `json:"cpu_time_in_nanos"`
		MemoryInBytes  int `json:"memory_in_bytes"`
	} `json:"max"`
	ThreadInfo struct {
		ThreadExecutions int `json:"thread_executions"`
		ActiveThreads    int `json:"active_threads"`
	} `json:"thread_info"`
}

TasksListResourceStats is a sub type of TaskListTask containing information about task stats

type TasksListResp 

type TasksListResp struct {
	Nodes        map[string]TasksListNodes `json:"nodes"`
	Tasks        map[string]TasksListTask  `json:"tasks"` // tasks is returned when group_by is set to none or parents
	NodeFailures []FailuresCause           `json:"node_failures"`
	// contains filtered or unexported fields
}

TasksListResp represents the returned struct of the index create response

func (TasksListResp) Inspect 

func (r TasksListResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type TasksListTask 

type TasksListTask struct {
	Node               string                 `json:"node"`
	ID                 int                    `json:"id"`
	Type               string                 `json:"type"`
	Action             string                 `json:"action"`
	Description        string                 `json:"description"`
	StartTimeInMillis  int64                  `json:"start_time_in_millis"`
	RunningTimeInNanos int64                  `json:"running_time_in_nanos"`
	Cancellable        bool                   `json:"cancellable"`
	Cancelled          bool                   `json:"cancelled"`
	Headers            map[string]string      `json:"headers"`
	ResourceStats      TasksListResourceStats `json:"resource_stats"`
	ParentTaskID       string                 `json:"parent_task_id"`
	Children           []TasksListTask        `json:"children,omitempty"`
}

TasksListTask is a sub type of TaskListResp, TaskListNodes containing information about a task

type TemplateCreateParams 

type TemplateCreateParams struct {
	Create                *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Order                 *int

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TemplateCreateParams represents possible parameters for the TemplateCreateReq

type TemplateCreateReq 

type TemplateCreateReq struct {
	Template string

	Body io.Reader

	Header http.Header
	Params TemplateCreateParams
}

TemplateCreateReq represents possible options for the index create request

func (TemplateCreateReq) GetRequest 

func (r TemplateCreateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TemplateCreateResp 

type TemplateCreateResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

TemplateCreateResp represents the returned struct of the index create response

func (TemplateCreateResp) Inspect 

func (r TemplateCreateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type TemplateDeleteParams 

type TemplateDeleteParams struct {
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration
	Timeout               time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TemplateDeleteParams represents possible parameters for the TemplateDeleteReq

type TemplateDeleteReq 

type TemplateDeleteReq struct {
	Template string

	Header http.Header
	Params TemplateDeleteParams
}

TemplateDeleteReq represents possible options for the index create request

func (TemplateDeleteReq) GetRequest 

func (r TemplateDeleteReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TemplateDeleteResp 

type TemplateDeleteResp struct {
	Acknowledged bool `json:"acknowledged"`
	// contains filtered or unexported fields
}

TemplateDeleteResp represents the returned struct of the index create response

func (TemplateDeleteResp) Inspect 

func (r TemplateDeleteResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type TemplateExistsParams 

type TemplateExistsParams struct {
	FlatSettings          *bool
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TemplateExistsParams represents possible parameters for the TemplateExistsReq

type TemplateExistsReq 

type TemplateExistsReq struct {
	Template string

	Header http.Header
	Params TemplateExistsParams
}

TemplateExistsReq represents possible options for the index create request

func (TemplateExistsReq) GetRequest 

func (r TemplateExistsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TemplateGetDetails 

type TemplateGetDetails struct {
	Order         int64           `json:"order"`
	Version       int64           `json:"version"`
	IndexPatterns []string        `json:"index_patterns"`
	Mappings      json.RawMessage `json:"mappings"`
	Settings      json.RawMessage `json:"settings"`
	Aliases       json.RawMessage `json:"aliases"`
}

TemplateGetDetails is a sub type of TemplateGetResp containing information about an index template

type TemplateGetParams 

type TemplateGetParams struct {
	FlatSettings          *bool
	Local                 *bool
	MasterTimeout         time.Duration
	ClusterManagerTimeout time.Duration

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TemplateGetParams represents possible parameters for the TemplateGetReq

type TemplateGetReq 

type TemplateGetReq struct {
	Templates []string

	Header http.Header
	Params TemplateGetParams
}

TemplateGetReq represents possible options for the index create request

func (TemplateGetReq) GetRequest 

func (r TemplateGetReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TemplateGetResp 

type TemplateGetResp struct {
	Templates map[string]TemplateGetDetails
	// contains filtered or unexported fields
}

TemplateGetResp represents the returned struct of the index create response

func (TemplateGetResp) Inspect 

func (r TemplateGetResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type TermvectorsParams 

type TermvectorsParams struct {
	Fields          []string
	FieldStatistics *bool
	Offsets         *bool
	Payloads        *bool
	Positions       *bool
	Preference      string
	Realtime        *bool
	Routing         string
	TermStatistics  *bool
	Version         *int
	VersionType     string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

TermvectorsParams represents possible parameters for the TermvectorsReq

type TermvectorsReq 

type TermvectorsReq struct {
	Index      string
	DocumentID string

	Body io.Reader

	Header http.Header
	Params TermvectorsParams
}

TermvectorsReq represents possible options for the /_termvectors request

func (TermvectorsReq) GetRequest 

func (r TermvectorsReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type TermvectorsResp 

type TermvectorsResp struct {
	Index       string          `json:"_index"`
	ID          string          `json:"_id"`
	Version     int             `json:"_version"`
	Found       bool            `json:"found"`
	Took        int             `json:"took"`
	Type        string          `json:"_type"` // Deprecated field
	TermVectors json.RawMessage `json:"term_vectors"`
	// contains filtered or unexported fields
}

TermvectorsResp represents the returned struct of the /_termvectors response

func (TermvectorsResp) Inspect 

func (r TermvectorsResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type UpdateByQueryParams 

type UpdateByQueryParams struct {
	AllowNoIndices      *bool
	Analyzer            string
	AnalyzeWildcard     *bool
	Conflicts           string
	DefaultOperator     string
	Df                  string
	ExpandWildcards     string
	From                *int
	IgnoreUnavailable   *bool
	Lenient             *bool
	MaxDocs             *int
	Pipeline            string
	Preference          string
	Query               string
	Refresh             *bool
	RequestCache        *bool
	RequestsPerSecond   *int
	Routing             []string
	Scroll              time.Duration
	ScrollSize          *int
	SearchTimeout       time.Duration
	SearchType          string
	Size                *int
	Slices              interface{}
	Sort                []string
	Source              interface{}
	SourceExcludes      []string
	SourceIncludes      []string
	Stats               []string
	TerminateAfter      *int
	Timeout             time.Duration
	Version             *bool
	VersionType         *bool
	WaitForActiveShards string
	WaitForCompletion   *bool

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

UpdateByQueryParams represents possible parameters for the UpdateByQueryReq

type UpdateByQueryReq 

type UpdateByQueryReq struct {
	Indices []string

	Body io.Reader

	Header http.Header
	Params UpdateByQueryParams
}

UpdateByQueryReq represents possible options for the /_update_by_query request

func (UpdateByQueryReq) GetRequest 

func (r UpdateByQueryReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type UpdateByQueryResp 

type UpdateByQueryResp struct {
	Took             int  `json:"took"`
	TimedOut         bool `json:"timed_out"`
	Total            int  `json:"total"`
	Updated          int  `json:"updated"`
	Deleted          int  `json:"deleted"`
	Batches          int  `json:"batches"`
	VersionConflicts int  `json:"version_conflicts"`
	Noops            int  `json:"noops"`
	Retries          struct {
		Bulk   int `json:"bulk"`
		Search int `json:"search"`
	} `json:"retries"`
	ThrottledMillis      int               `json:"throttled_millis"`
	RequestsPerSecond    float32           `json:"requests_per_second"`
	ThrottledUntilMillis int               `json:"throttled_until_millis"`
	Failures             []json.RawMessage `json:"failures"`
	Type                 string            `json:"_type"` // Deprecated field
	Task                 string            `json:"task"`
	// contains filtered or unexported fields
}

UpdateByQueryResp represents the returned struct of the /_update_by_query response

func (UpdateByQueryResp) Inspect 

func (r UpdateByQueryResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type UpdateByQueryRethrottleParams 

type UpdateByQueryRethrottleParams struct {
	RequestsPerSecond *int

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

UpdateByQueryRethrottleParams represents possible parameters for the UpdateByQueryRethrottleReq

type UpdateByQueryRethrottleReq 

type UpdateByQueryRethrottleReq struct {
	TaskID string

	Header http.Header
	Params UpdateByQueryRethrottleParams
}

UpdateByQueryRethrottleReq represents possible options for the / request

func (UpdateByQueryRethrottleReq) GetRequest 

func (r UpdateByQueryRethrottleReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type UpdateByQueryRethrottleResp 

type UpdateByQueryRethrottleResp struct {
	Nodes map[string]struct {
		Name             string            `json:"name"`
		TransportAddress string            `json:"transport_address"`
		Host             string            `json:"host"`
		IP               string            `json:"ip"`
		Roles            []string          `json:"roles"`
		Attributes       map[string]string `json:"attributes"`
		Tasks            map[string]struct {
			Node   string `json:"node"`
			ID     int    `json:"id"`
			Type   string `json:"type"`
			Action string `json:"action"`
			Status struct {
				Total            int `json:"total"`
				Updated          int `json:"updated"`
				Created          int `json:"created"`
				Deleted          int `json:"deleted"`
				Batches          int `json:"batches"`
				VersionConflicts int `json:"version_conflicts"`
				Noops            int `json:"noops"`
				Retries          struct {
					Bulk   int `json:"bulk"`
					Search int `json:"search"`
				} `json:"retries"`
				ThrottledMillis      int     `json:"throttled_millis"`
				RequestsPerSecond    float64 `json:"requests_per_second"`
				ThrottledUntilMillis int     `json:"throttled_until_millis"`
			} `json:"status"`
			Description        string          `json:"description"`
			StartTimeInMillis  int64           `json:"start_time_in_millis"`
			RunningTimeInNanos int             `json:"running_time_in_nanos"`
			Cancellable        bool            `json:"cancellable"`
			Cancelled          bool            `json:"cancelled"`
			Headers            json.RawMessage `json:"headers"`
			ResourceStats      struct {
				Average struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"average"`
				Total struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"total"`
				Min struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"min"`
				Max struct {
					CPUTimeInNanos int `json:"cpu_time_in_nanos"`
					MemoryInBytes  int `json:"memory_in_bytes"`
				} `json:"max"`
				ThreadInfo struct {
					ThreadExecutions int `json:"thread_executions"`
					ActiveThreads    int `json:"active_threads"`
				} `json:"thread_info"`
			} `json:"resource_stats"`
		} `json:"tasks"`
	} `json:"nodes"`
	NodeFailures []FailuresCause `json:"node_failures"`
	// contains filtered or unexported fields
}

UpdateByQueryRethrottleResp represents the returned struct of the / response

func (UpdateByQueryRethrottleResp) Inspect 

func (r UpdateByQueryRethrottleResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

type UpdateParams 

type UpdateParams struct {
	IfPrimaryTerm       *int
	IfSeqNo             *int
	Lang                string
	Refresh             string
	RequireAlias        *bool
	RetryOnConflict     *int
	Routing             string
	Source              interface{}
	SourceExcludes      []string
	SourceIncludes      []string
	Timeout             time.Duration
	WaitForActiveShards string

	Pretty     bool
	Human      bool
	ErrorTrace bool
	FilterPath []string
}

UpdateParams represents possible parameters for the UpdateReq

type UpdateReq 

type UpdateReq struct {
	Index      string
	DocumentID string

	Body io.Reader

	Header http.Header
	Params UpdateParams
}

UpdateReq represents possible options for the /_update request

func (UpdateReq) GetRequest 

func (r UpdateReq) GetRequest() (*http.Request, error)

GetRequest returns the *http.Request that gets executed by the client

type UpdateResp 

type UpdateResp struct {
	Index   string `json:"_index"`
	ID      string `json:"_id"`
	Version int    `json:"_version"`
	Result  string `json:"result"`
	Shards  struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
	SeqNo       int    `json:"_seq_no"`
	PrimaryTerm int    `json:"_primary_term"`
	Type        string `json:"_type"` // Deprecated field
	// contains filtered or unexported fields
}

UpdateResp represents the returned struct of the /_update response

func (UpdateResp) Inspect 

func (r UpdateResp) Inspect() Inspect

Inspect returns the Inspect type containing the raw *opensearch.Response

Source Files

View all Source files

Directories

Path Synopsis
internal
test

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
⌂ 换网址