Versions in this module Expand all Collapse all v2 v2.0.4 Jun 16, 2020 v2.0.3 Jun 16, 2020 v2.0.2 Jun 16, 2020 v2.0.1 Jan 27, 2020 Changes in this version + const ShardAllocExcludeSetting + type CatShardsResponse []CatShardsResponseRow + type CatShardsResponseRow struct + CompletionSize *string + Docs *int + FieldDataEvictions *int + FieldDataMemorySize *string + FlushTotal *int + FlushTotalTime *string + GetCurrent *int + GetExistsTime *string + GetExistsTotal *int + GetMissingTime *string + GetMissingTotal *int + GetTime *string + GetTotal *int + ID *string + IP *string + Index string + IndexingDeleteCurrent *int + IndexingDeleteTime *string + IndexingDeleteTotal *int + IndexingIndexCurrent *int + IndexingIndexFailed *int + IndexingIndexTime *string + IndexingIndexTotal *int + MergesCurrent *int + MergesCurrentDocs *int + MergesCurrentSize *string + MergesTotal *int + MergesTotalDocs *int + MergesTotalSize *string + MergesTotalTime *string + Node *string + PrimaryOrReplica string + QueryCacheEvictions *int + QueryCacheMemorySize *string + RecoverySourceType *string + RefreshListeners *int + RefreshTime *string + RefreshTotal *int + SearchFetchCurrent *int + SearchFetchTime *string + SearchFetchTotal *int + SearchOpenContexts *int + SearchQueryCurrent *int + SearchQueryTime *string + SearchQueryTotal *int + SearchScrollCurrent *int + SearchScrollTime *string + SearchScrollTotal *int + SegmentsCount *int + SegmentsFixedBitsetMemory *string + SegmentsIndexWriterMemory *string + SegmentsMemory *string + SegmentsVersionMapMemory *string + SequenceNumberGlobalCheckpoint *string + SequenceNumberLocalCheckpoint *string + SequenceNumberMax *string + Shard string + State string + Store *string + SyncID *string + UnassignedAt *time.Time + UnassignedDeatils *string + UnassignedFor *string + UnassignedReason *string + WarmerCurrent *int + WarmerTotal *int + WarmerTotalTime *string + type CatShardsService struct + func NewCatShardsService(client *elastic.Client) *CatShardsService + func (s *CatShardsService) Bytes(bytes string) *CatShardsService + func (s *CatShardsService) Columns(columns ...string) *CatShardsService + func (s *CatShardsService) Do(ctx context.Context) (CatShardsResponse, error) + func (s *CatShardsService) Index(index string) *CatShardsService + func (s *CatShardsService) Local(local bool) *CatShardsService + func (s *CatShardsService) MasterTimeout(masterTimeout string) *CatShardsService + func (s *CatShardsService) Pretty(pretty bool) *CatShardsService + func (s *CatShardsService) Sort(fields ...string) *CatShardsService + type ClusterDeleteVotingConfigExclusion struct + func NewClusterDeleteVotingConfigExclusion(c *elastic.Client) *ClusterDeleteVotingConfigExclusion + func (s *ClusterDeleteVotingConfigExclusion) Do(ctx context.Context) (*ClusterDeleteVotingConfigExclusionResponse, error) + func (s *ClusterDeleteVotingConfigExclusion) Validate() error + func (s *ClusterDeleteVotingConfigExclusion) Wait(wait bool) *ClusterDeleteVotingConfigExclusion + type ClusterDeleteVotingConfigExclusionResponse struct + type ClusterGetSettingsResponse struct + Defaults *gjson.Result + Persistent *gjson.Result + Transient *gjson.Result + type ClusterGetSettingsService struct + func NewClusterGetSettingsService(client *elastic.Client) *ClusterGetSettingsService + func (s *ClusterGetSettingsService) Defaults(include bool) *ClusterGetSettingsService + func (s *ClusterGetSettingsService) Do(ctx context.Context) (*ClusterGetSettingsResponse, error) + func (s *ClusterGetSettingsService) FilterPath(filterPath ...string) *ClusterGetSettingsService + func (s *ClusterGetSettingsService) Human(human bool) *ClusterGetSettingsService + func (s *ClusterGetSettingsService) Pretty(pretty bool) *ClusterGetSettingsService + func (s *ClusterGetSettingsService) Validate() error + type ClusterPostVotingConfigExclusion struct + func NewClusterPostVotingConfigExclusion(c *elastic.Client) *ClusterPostVotingConfigExclusion + func (s *ClusterPostVotingConfigExclusion) Do(ctx context.Context) (*ClusterPostVotingConfigExclusionResponse, error) + func (s *ClusterPostVotingConfigExclusion) Node(node string) *ClusterPostVotingConfigExclusion + func (s *ClusterPostVotingConfigExclusion) Timeout(timeout string) *ClusterPostVotingConfigExclusion + func (s *ClusterPostVotingConfigExclusion) Validate() error + type ClusterPostVotingConfigExclusionResponse struct + type ClusterPutSettingsResponse struct + Persistent *gjson.Result + Transient *gjson.Result + type ClusterPutSettingsService struct + func NewClusterPutSettingsService(client *elastic.Client) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) BodyJSON(body interface{}) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) BodyString(body string) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) Do(ctx context.Context) (*ClusterPutSettingsResponse, error) + func (s *ClusterPutSettingsService) FlatSettings(flatSettings bool) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) MasterTimeout(masterTimeout string) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) Persistent(setting string, value interface{}) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) Pretty(pretty bool) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) Transient(setting string, value interface{}) *ClusterPutSettingsService + func (s *ClusterPutSettingsService) Validate() error + type IndicesRecoveryResponse map[string]IndicesRecoveryResponseIndex + type IndicesRecoveryResponseIndex struct + Shards []*IndicesRecoveryResponseShard + type IndicesRecoveryResponseShard struct + ID int + Index IndicesRecoveryResponseShardIndex + Primary bool + Source map[string]interface{} + Stage string + StartTime *time.Time + StartTimeInMillis int64 + StopTime *time.Time + StopTimeInMillis int64 + Target IndicesRecoveryResponseShardTarget + TotalTime string + TotalTimeInMillis int64 + Translog IndicesRecoveryResponseShardTranslog + Type string + VerifyIndex IndicesRecoveryResponseShardVerifyIndex + type IndicesRecoveryResponseShardIndex struct + Files IndicesRecoveryResponseShardIndexFiles + Size IndicesRecoveryResponseShardIndexSize + SourceThrottleTime string + SourceThrottleTimeInMillis int64 + TargetThrottleTime string + TargetThrottleTimeInMillis int64 + TotalTime string + TotalTimeInMillis int64 + type IndicesRecoveryResponseShardIndexFiles struct + Details []struct{ ... } + Percent string + Recovered int64 + Reused int + Total int + type IndicesRecoveryResponseShardIndexSize struct + Percent string + Recovered string + RecoveredInBytes int64 + Reused string + ReusedInBytes int64 + Total string + TotalInBytes int64 + type IndicesRecoveryResponseShardTarget struct + Host string + ID string + IP string + Name string + TransportAddress string + type IndicesRecoveryResponseShardTranslog struct + Percent string + Recovered int + Total int + TotalOnStart int + TotalTime string + TotalTimeInMillis int64 + type IndicesRecoveryResponseShardVerifyIndex struct + CheckIndexTime int + CheckIndexTimeInMillis int64 + TotalTime string + TotalTimeInMillis int64 + type IndicesRecoveryService struct + func NewIndicesRecoveryService(client *elastic.Client) *IndicesRecoveryService + func (s *IndicesRecoveryService) ActiveOnly(activeOnly bool) *IndicesRecoveryService + func (s *IndicesRecoveryService) Detailed(detailed bool) *IndicesRecoveryService + func (s *IndicesRecoveryService) Do(ctx context.Context) (IndicesRecoveryResponse, error) + func (s *IndicesRecoveryService) Index(index ...string) *IndicesRecoveryService + func (s *IndicesRecoveryService) Validate() error + type ShardAllocationExcludeSettings struct + Attr map[string][]string + Host []string + IP []string + Name []string + func NewShardAllocationExcludeSettings(settings *gjson.Result) *ShardAllocationExcludeSettings + func (s *ShardAllocationExcludeSettings) HasAttr(attr, value string) bool + func (s *ShardAllocationExcludeSettings) HasHost(host string) bool + func (s *ShardAllocationExcludeSettings) HasIP(ip string) bool + func (s *ShardAllocationExcludeSettings) HasName(name string) bool + func (s *ShardAllocationExcludeSettings) Map() map[string]*string Other modules containing this package github.com/mintel/elasticsearch-asg
Go to main page