ec1f89217a
Full Mattermost server source with integrated Community Enterprise features. Includes vendor directory for offline/air-gapped builds. Structure: - enterprise-impl/: Enterprise feature implementations - enterprise-community/: Init files that register implementations - enterprise/: Bridge imports (community_imports.go) - vendor/: All dependencies for offline builds Build (online): go build ./cmd/mattermost Build (offline/air-gapped): go build -mod=vendor ./cmd/mattermost 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
138 lines
6.8 KiB
Go
138 lines
6.8 KiB
Go
// 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.
|
|
|
|
package opensearchapi
|
|
|
|
import (
|
|
"net/http"
|
|
"strings"
|
|
|
|
"github.com/opensearch-project/opensearch-go/v4"
|
|
)
|
|
|
|
// CatShardsReq represent possible options for the /_cat/shards request
|
|
type CatShardsReq struct {
|
|
Indices []string
|
|
Header http.Header
|
|
Params CatShardsParams
|
|
}
|
|
|
|
// GetRequest returns the *http.Request that gets executed by the client
|
|
func (r CatShardsReq) GetRequest() (*http.Request, error) {
|
|
indices := strings.Join(r.Indices, ",")
|
|
var path strings.Builder
|
|
path.Grow(len("/_cat/shards/") + len(indices))
|
|
path.WriteString("/_cat/shards")
|
|
if len(r.Indices) > 0 {
|
|
path.WriteString("/")
|
|
path.WriteString(indices)
|
|
}
|
|
return opensearch.BuildRequest(
|
|
"GET",
|
|
path.String(),
|
|
nil,
|
|
r.Params.get(),
|
|
r.Header,
|
|
)
|
|
}
|
|
|
|
// CatShardsResp represents the returned struct of the /_cat/shards response
|
|
type CatShardsResp struct {
|
|
Shards []CatShardResp
|
|
response *opensearch.Response
|
|
}
|
|
|
|
// CatShardResp represents one index of the CatShardsResp
|
|
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"`
|
|
}
|
|
|
|
// Inspect returns the Inspect type containing the raw *opensearch.Reponse
|
|
func (r CatShardsResp) Inspect() Inspect {
|
|
return Inspect{
|
|
Response: r.response,
|
|
}
|
|
}
|