Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

api

package

Go to main page

Versions in this module

v9

v9.0.1

Aug 24, 2026

v9.0.0

Aug 8, 2026

Changes in this version

+ type AddBlockParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Timeout string

+ func (p *AddBlockParams) ToMap() map[string]string

+ type AddBlockRequest struct

+ Block string

+ Indices []string

+ Params *AddBlockParams

+ func (r *AddBlockRequest) Validate() error

+ type AliasInfo struct

+ Filter map[string]any

+ IndexRouting string

+ IsHidden *bool

+ IsWriteIndex *bool

+ SearchRouting string

+ type AliasParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *AliasParams) ToMap() map[string]string

+ type AnalyzeToken struct

+ Bytes string

+ EndOffset int

+ Keyword bool

+ Position int

+ PositionLength int

+ StartOffset int

+ Token string

+ Type string

+ type AsyncSearchGetParams struct

+ Common *CommonParams

+ KeepAlive string

+ TypedKeys *bool

+ WaitForCompletionTimeout string

+ func (p *AsyncSearchGetParams) ToMap() map[string]string

+ type AsyncSearchResponse struct

+ ExpirationTimeInMillis int64

+ Id string

+ IsPartial bool

+ IsRunning bool

+ Response *querydsl.SearchResult

+ StartTimeInMillis int64

+ type AsyncSearchService interface

+ Delete func(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, id string, params *AsyncSearchGetParams) (*AsyncSearchResponse, error)

+ Status func(ctx context.Context, id string) (*AsyncSearchStatusResponse, error)

+ Submit func(ctx context.Context, req *AsyncSearchSubmitRequest) (*AsyncSearchResponse, error)

+ func NewAsyncSearchService(client *resty.Client, logger *logrus.Entry) AsyncSearchService

+ type AsyncSearchStatusResponse struct

+ ExpirationTimeInMillis int64

+ Id string

+ IsPartial bool

+ IsRunning bool

+ Shards ...

+ StartTimeInMillis int64

+ type AsyncSearchSubmitParams struct

+ AllowNoIndices *bool

+ AllowPartialSearchResults *bool

+ AnalyzeWildcard *bool

+ Analyzer string

+ BatchedReduceSize *int

+ Common *CommonParams

+ DefaultOperator DefaultOperator

+ Df string

+ ExpandWildcards ExpandWildcards

+ Explain *bool

+ From *int

+ IgnoreThrottled *bool

+ IgnoreUnavailable *bool

+ KeepAlive string

+ KeepOnCompletion *bool

+ Lenient *bool

+ Preference string

+ Q string

+ RequestCache *bool

+ Routing string

+ SearchType SearchType

+ Size *int

+ Sort []string

+ Source string

+ SourceExcludes []string

+ SourceIncludes []string

+ Stats []string

+ StoredFields []string

+ SuggestField string

+ SuggestMode SuggestMode

+ SuggestSize *int

+ SuggestText string

+ TerminateAfter *int

+ Timeout string

+ TrackScores *bool

+ TrackTotalHits string

+ TypedKeys *bool

+ WaitForCompletionTimeout string

+ func (p *AsyncSearchSubmitParams) ToMap() map[string]string

+ type AsyncSearchSubmitRequest struct

+ Body any

+ Indices []string

+ Params *AsyncSearchSubmitParams

+ type AutoscalingService interface

+ DeletePolicy func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ GetCapacity func(ctx context.Context) (json.RawMessage, error)

+ GetPolicy func(ctx context.Context, name string) (json.RawMessage, error)

+ PutPolicy func(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ func NewAutoscalingService(client *resty.Client, logger *logrus.Entry) AutoscalingService

+ type BulkIndexByScrollResponse struct

+ Batches int64

+ Canceled string

+ Created int64

+ Deleted int64

+ Failures []map[string]any

+ Header http.Header

+ Noops int64

+ RequestsPerSecond float64

+ Retries struct{ ... }

+ SliceId *int64

+ Throttled string

+ ThrottledMillis int64

+ ThrottledUntil string

+ ThrottledUntilMillis int64

+ TimedOut bool

+ Took int64

+ Total int64

+ Updated int64

+ VersionConflicts int64

+ type BulkParams struct

+ Common *CommonParams

+ ListExecutedPipelines []string

+ Pipeline string

+ Refresh Refresh

+ RequireAlias *bool

+ Routing string

+ Source string

+ SourceExcludes []string

+ SourceIncludes []string

+ Timeout string

+ WaitForActiveShards string

+ func (p *BulkParams) ToMap() map[string]string

+ type BulkRequest struct

+ Body string

+ Index string

+ Params *BulkParams

+ func (r *BulkRequest) Validate() error

+ type BulkResponse struct

+ Errors bool

+ Items []map[string]*BulkResponseItem

+ Took int64

+ type BulkResponseItem struct

+ Error *types.ElasticsearchErrorDetails

+ ForcedRefresh bool

+ Id string

+ Index string

+ PrimaryTerm int64

+ Result string

+ SeqNo int64

+ Shards *types.ShardsInfo

+ Status int

+ Version int64

+ type BytesFormat string

+ const BytesB

+ const BytesGb

+ const BytesKb

+ const BytesMb

+ const BytesPb

+ const BytesTb

+ type CapabilitiesRequest struct

+ Common *CommonParams

+ Local *bool

+ Method string

+ Parameters []string

+ Path string

+ type CapabilitiesResponse struct

+ Capabilities map[string]any

+ type CatAliasesParams struct

+ ExpandWildcards ExpandWildcards

+ func (p *CatAliasesParams) ToMap() map[string]string

+ type CatAliasesResponse []CatAliasesRow

+ type CatAliasesRow struct

+ Alias string

+ Filter string

+ Index string

+ IsWriteIndex string

+ RoutingIndex string

+ RoutingSearch string

+ type CatAllocationParams struct

+ Bytes BytesFormat

+ func (p *CatAllocationParams) ToMap() map[string]string

+ type CatAllocationResponse []CatAllocationRow

+ type CatAllocationRow struct

+ Disk string

+ DiskAvail string

+ DiskIndex string

+ DiskPercent string

+ DiskTotal string

+ DiskUsed string

+ Host string

+ IP string

+ Node string

+ Shards int

+ type CatCircuitBreakerParams struct

+ Bytes BytesFormat

+ func (p *CatCircuitBreakerParams) ToMap() map[string]string

+ type CatCircuitBreakerResponse []CatCircuitBreakerRow

+ type CatCircuitBreakerRow struct

+ Breaker string

+ EstimatedSize string

+ Field string

+ Limit string

+ LimitSize string

+ Node string

+ Overhead string

+ Tripped string

+ type CatComponentTemplatesParams struct

+ func (p *CatComponentTemplatesParams) ToMap() map[string]string

+ type CatComponentTemplatesResponse []CatComponentTemplatesRow

+ type CatComponentTemplatesRow struct

+ Name string

+ Version string

+ type CatCountParams struct

+ func (p *CatCountParams) ToMap() map[string]string

+ type CatCountResponse []CatCountRow

+ type CatCountRow struct

+ Count string

+ Epoch string

+ Timestamp string

+ type CatFielddataParams struct

+ Bytes BytesFormat

+ func (p *CatFielddataParams) ToMap() map[string]string

+ type CatFielddataResponse []CatFielddataRow

+ type CatFielddataRow struct

+ Field string

+ Node string

+ Size string

+ type CatFormat string

+ const CatFormatJSON

+ const CatFormatText

+ type CatHealthParams struct

+ Ts *bool

+ func (p *CatHealthParams) ToMap() map[string]string

+ type CatHealthResponse []CatHealthRow

+ type CatHealthRow struct

+ ActiveShardsPercent string

+ Cluster string

+ Epoch string

+ Init string

+ MaxTaskWait string

+ NodeData string

+ NodeTotal string

+ PendingTasks string

+ Pri string

+ Relo string

+ Shards string

+ Status string

+ Timestamp string

+ Unassign string

+ type CatIndicesParams struct

+ Bytes BytesFormat

+ ExpandWildcards ExpandWildcards

+ Health HealthStatus

+ IncludeUnloadedSegments *bool

+ Pri *bool

+ func (p *CatIndicesParams) ToMap() map[string]string

+ type CatIndicesResponse []CatIndicesRow

+ type CatIndicesRow struct

+ DocsCount string

+ DocsDeleted string

+ Health string

+ Index string

+ Pri string

+ PriStoreSize string

+ Rep string

+ Status string

+ StoreSize string

+ UUID string

+ type CatMLDataFrameAnalyticsParams struct

+ AllowNoMatch *bool

+ Bytes BytesFormat

+ From *int

+ Size *int

+ Time string

+ func (p *CatMLDataFrameAnalyticsParams) ToMap() map[string]string

+ type CatMLDataFrameAnalyticsResponse []CatMLDataFrameAnalyticsRow

+ type CatMLDataFrameAnalyticsRow struct

+ ID string

+ Progress string

+ State string

+ type CatMLDatafeedsParams struct

+ AllowNoMatch *bool

+ From *int

+ Size *int

+ Time string

+ func (p *CatMLDatafeedsParams) ToMap() map[string]string

+ type CatMLDatafeedsResponse []CatMLDatafeedsRow

+ type CatMLDatafeedsRow struct

+ Assignment string

+ ID string

+ State string

+ type CatMLJobsParams struct

+ AllowNoMatch *bool

+ Bytes BytesFormat

+ From *int

+ Size *int

+ func (p *CatMLJobsParams) ToMap() map[string]string

+ type CatMLJobsResponse []CatMLJobsRow

+ type CatMLJobsRow struct

+ ID string

+ OpenedTime string

+ State string

+ type CatMLTrainedModelsParams struct

+ AllowNoMatch *bool

+ Bytes BytesFormat

+ From *int

+ Size *int

+ func (p *CatMLTrainedModelsParams) ToMap() map[string]string

+ type CatMLTrainedModelsResponse []CatMLTrainedModelsRow

+ type CatMLTrainedModelsRow struct

+ Algorithm string

+ ID string

+ Type string

+ type CatMasterParams struct

+ func (p *CatMasterParams) ToMap() map[string]string

+ type CatMasterResponse []CatMasterRow

+ type CatMasterRow struct

+ Host string

+ ID string

+ IP string

+ Node string

+ type CatNodeAttrsParams struct

+ func (p *CatNodeAttrsParams) ToMap() map[string]string

+ type CatNodeAttrsResponse []CatNodeAttrsRow

+ type CatNodeAttrsRow struct

+ Attr string

+ Node string

+ Value string

+ type CatNodesParams struct

+ Bytes BytesFormat

+ FullId *bool

+ Time string

+ func (p *CatNodesParams) ToMap() map[string]string

+ type CatNodesResponse []CatNodesRow

+ type CatNodesRow struct

+ CPU string

+ HeapPercent string

+ IP string

+ Load15m string

+ Load1m string

+ Load5m string

+ Master string

+ Name string

+ NodeRole string

+ RamPercent string

+ type CatPendingTasksParams struct

+ func (p *CatPendingTasksParams) ToMap() map[string]string

+ type CatPendingTasksResponse []CatPendingTasksRow

+ type CatPendingTasksRow struct

+ InsertOrder string

+ Priority string

+ Source string

+ TimeInQueue string

+ type CatPluginsParams struct

+ func (p *CatPluginsParams) ToMap() map[string]string

+ type CatPluginsResponse []CatPluginsRow

+ type CatPluginsRow struct

+ Description string

+ ElasticsearchVersion string

+ Name string

+ Version string

+ type CatRecoveryParams struct

+ ActiveOnly *bool

+ Bytes BytesFormat

+ Detailed *bool

+ func (p *CatRecoveryParams) ToMap() map[string]string

+ type CatRecoveryResponse []CatRecoveryRow

+ type CatRecoveryRow struct

+ Bytes string

+ BytesPercent string

+ BytesRecovered string

+ Files string

+ FilesPercent string

+ FilesRecovered string

+ Index string

+ Repository string

+ Shard string

+ Snapshot string

+ Source string

+ Stage string

+ StartTime string

+ StartTimeMillis string

+ StopTime string

+ StopTimeMillis string

+ Target string

+ TotalTime string

+ TotalTimeMillis string

+ Type string

+ type CatRepositoriesParams struct

+ func (p *CatRepositoriesParams) ToMap() map[string]string

+ type CatRepositoriesResponse []CatRepositoriesRow

+ type CatRepositoriesRow struct

+ ID string

+ Type string

+ type CatSegmentsParams struct

+ Bytes BytesFormat

+ Verbose *bool

+ func (p *CatSegmentsParams) ToMap() map[string]string

+ type CatSegmentsResponse []CatSegmentsRow

+ type CatSegmentsRow struct

+ Committed string

+ Compound string

+ DocsCount string

+ DocsDeleted string

+ Generation string

+ IP string

+ Index string

+ Prirep string

+ Searchable string

+ Segment string

+ Shard string

+ Size string

+ SizeMemory string

+ Version string

+ type CatService interface

+ Aliases func(ctx context.Context, names []string, p *CatAliasesParams) (CatAliasesResponse, error)

+ Allocation func(ctx context.Context, nodeIds []string, p *CatAllocationParams) (CatAllocationResponse, error)

+ CircuitBreaker func(ctx context.Context, p *CatCircuitBreakerParams) (CatCircuitBreakerResponse, error)

+ ComponentTemplates func(ctx context.Context, name string, p *CatComponentTemplatesParams) (CatComponentTemplatesResponse, error)

+ Count func(ctx context.Context, indices []string, p *CatCountParams) (CatCountResponse, error)

+ Fielddata func(ctx context.Context, fields []string, p *CatFielddataParams) (CatFielddataResponse, error)

+ Health func(ctx context.Context, p *CatHealthParams) (CatHealthResponse, error)

+ Help func(ctx context.Context) (string, error)

+ Indices func(ctx context.Context, indices []string, p *CatIndicesParams) (CatIndicesResponse, error)

+ MLDataFrameAnalytics func(ctx context.Context, id string, p *CatMLDataFrameAnalyticsParams) (CatMLDataFrameAnalyticsResponse, error)

+ MLDatafeeds func(ctx context.Context, datafeedId string, p *CatMLDatafeedsParams) (CatMLDatafeedsResponse, error)

+ MLJobs func(ctx context.Context, jobId string, p *CatMLJobsParams) (CatMLJobsResponse, error)

+ MLTrainedModels func(ctx context.Context, modelId string, p *CatMLTrainedModelsParams) (CatMLTrainedModelsResponse, error)

+ Master func(ctx context.Context, p *CatMasterParams) (CatMasterResponse, error)

+ NodeAttrs func(ctx context.Context, p *CatNodeAttrsParams) (CatNodeAttrsResponse, error)

+ Nodes func(ctx context.Context, p *CatNodesParams) (CatNodesResponse, error)

+ PendingTasks func(ctx context.Context, p *CatPendingTasksParams) (CatPendingTasksResponse, error)

+ Plugins func(ctx context.Context, p *CatPluginsParams) (CatPluginsResponse, error)

+ Recovery func(ctx context.Context, indices []string, p *CatRecoveryParams) (CatRecoveryResponse, error)

+ Repositories func(ctx context.Context, p *CatRepositoriesParams) (CatRepositoriesResponse, error)

+ Segments func(ctx context.Context, indices []string, p *CatSegmentsParams) (CatSegmentsResponse, error)

+ Shards func(ctx context.Context, indices []string, p *CatShardsParams) (CatShardsResponse, error)

+ Snapshots func(ctx context.Context, repository string, p *CatSnapshotsParams) (CatSnapshotsResponse, error)

+ Tasks func(ctx context.Context, p *CatTasksParams) (CatTasksResponse, error)

+ Templates func(ctx context.Context, name string, p *CatTemplatesParams) (CatTemplatesResponse, error)

+ ThreadPool func(ctx context.Context, patterns []string, p *CatThreadPoolParams) (CatThreadPoolResponse, error)

+ Transforms func(ctx context.Context, transformId string, p *CatTransformsParams) (CatTransformsResponse, error)

+ func NewCatService(client *resty.Client, logger *logrus.Entry) CatService

+ type CatShardsParams struct

+ Bytes BytesFormat

+ func (p *CatShardsParams) ToMap() map[string]string

+ type CatShardsResponse []CatShardsRow

+ type CatShardsRow struct

+ Docs string

+ IP string

+ Index string

+ Node string

+ Prirep string

+ Shard string

+ State string

+ Store string

+ type CatSnapshotsParams struct

+ IgnoreUnavailable *bool

+ Time string

+ func (p *CatSnapshotsParams) ToMap() map[string]string

+ type CatSnapshotsResponse []CatSnapshotsRow

+ type CatSnapshotsRow struct

+ Duration string

+ EndEpoch string

+ EndTime string

+ ID string

+ Indices string

+ Repository string

+ StartEpoch string

+ StartTime string

+ Status string

+ type CatTasksParams struct

+ Actions []string

+ Detailed *bool

+ NodeId []string

+ ParentTaskId string

+ func (p *CatTasksParams) ToMap() map[string]string

+ type CatTasksResponse []CatTasksRow

+ type CatTasksRow struct

+ Action string

+ ID string

+ Node string

+ Parent string

+ StartEpoch string

+ StartTime string

+ TaskType string

+ type CatTemplatesParams struct

+ func (p *CatTemplatesParams) ToMap() map[string]string

+ type CatTemplatesResponse []CatTemplatesRow

+ type CatTemplatesRow struct

+ IndexPatterns string

+ Name string

+ Order string

+ Version string

+ type CatThreadPoolParams struct

+ Size *int

+ Time string

+ func (p *CatThreadPoolParams) ToMap() map[string]string

+ type CatThreadPoolResponse []CatThreadPoolRow

+ type CatThreadPoolRow struct

+ Active string

+ Completed string

+ Name string

+ NodeName string

+ Queue string

+ Rejected string

+ type CatTransformsParams struct

+ AllowNoMatch *bool

+ From *int

+ Size *int

+ Time string

+ func (p *CatTransformsParams) ToMap() map[string]string

+ type CatTransformsResponse []CatTransformsRow

+ type CatTransformsRow struct

+ Checkpoint string

+ ID string

+ State string

+ type CcrFollowInfoResponse struct

+ Indices []struct{ ... }

+ type CcrFollowParams struct

+ Common *CommonParams

+ WaitForActiveShards string

+ func (p *CcrFollowParams) ToMap() map[string]string

+ type CcrFollowResponse struct

+ FollowIndex string

+ FollowIndexCreated bool

+ FollowIndexShardsAcknowledged bool

+ ShardsAcknowledged bool

+ type CcrFollowStatsResponse struct

+ Indices []struct{ ... }

+ type CcrForgetFollowerResponse struct

+ Shards *types.ShardsInfo

+ type CcrGetAutoFollowPatternResponse struct

+ Patterns []struct{ ... }

+ type CcrService interface

+ DeleteAutoFollowPattern func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ Follow func(ctx context.Context, index string, body any, params *CcrFollowParams) (*CcrFollowResponse, error)

+ FollowInfo func(ctx context.Context, indices []string) (*CcrFollowInfoResponse, error)

+ FollowStats func(ctx context.Context, indices []string) (*CcrFollowStatsResponse, error)

+ ForgetFollower func(ctx context.Context, index string, body any) (*CcrForgetFollowerResponse, error)

+ GetAutoFollowPattern func(ctx context.Context, names []string) (*CcrGetAutoFollowPatternResponse, error)

+ PauseAutoFollowPattern func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ PauseFollow func(ctx context.Context, index string) (*types.AcknowledgedResponse, error)

+ PutAutoFollowPattern func(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ ResumeAutoFollowPattern func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ ResumeFollow func(ctx context.Context, index string, body any) (*types.AcknowledgedResponse, error)

+ Stats func(ctx context.Context) (*CcrStatsResponse, error)

+ Unfollow func(ctx context.Context, index string) (*types.AcknowledgedResponse, error)

+ func NewCcrService(client *resty.Client, logger *logrus.Entry) CcrService

+ type CcrStatsResponse struct

+ AutoFollowStats map[string]any

+ FollowStats map[string]any

+ type CloneParams = ShrinkParams

+ type CloneRequest struct

+ Body any

+ Params *CloneParams

+ Source string

+ Target string

+ func (r *CloneRequest) Validate() error

+ type ClosePITResponse struct

+ NumFreed int

+ Succeeded bool

+ type ClusterAllocationExplainParams struct

+ Common *CommonParams

+ IncludeDiskInfo *bool

+ IncludeYesDecisions *bool

+ func (p *ClusterAllocationExplainParams) ToMap() map[string]string

+ type ClusterAllocationExplainResponse struct

+ AllocateExplanation string

+ AllocationDelay string

+ AllocationDelayInMillis int64

+ CanAllocate string

+ ConfiguredDelay string

+ ConfiguredDelayInMillis int64

+ CurrentNode map[string]any

+ CurrentState string

+ Index string

+ Primary bool

+ RemainingDelay string

+ Shard int

+ UnassignedInfo map[string]any

+ type ClusterDeleteComponentTemplateParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *ClusterDeleteComponentTemplateParams) ToMap() map[string]string

+ type ClusterDeleteVotingConfigExclusionsParams struct

+ Common *CommonParams

+ WaitForRemoval *bool

+ func (p *ClusterDeleteVotingConfigExclusionsParams) ToMap() map[string]string

+ type ClusterGetComponentTemplateParams struct

+ Common *CommonParams

+ FlatSettings *bool

+ Local *bool

+ func (p *ClusterGetComponentTemplateParams) ToMap() map[string]string

+ type ClusterGetComponentTemplateResponse struct

+ ComponentTemplates []struct{ ... }

+ type ClusterGetSettingsParams struct

+ Common *CommonParams

+ FlatSettings *bool

+ IncludeDefaults *bool

+ Timeout string

+ func (p *ClusterGetSettingsParams) ToMap() map[string]string

+ type ClusterGetSettingsResponse struct

+ Defaults map[string]any

+ Persistent map[string]any

+ Transient map[string]any

+ type ClusterHealthParams struct

+ Common *CommonParams

+ Level Level

+ Local *bool

+ Timeout string

+ WaitForActiveShards string

+ WaitForEvents string

+ WaitForNoInitializingShards *bool

+ WaitForNoRelocatingShards *bool

+ WaitForNodes string

+ WaitForStatus WaitForStatus

+ func (p *ClusterHealthParams) ToMap() map[string]string

+ type ClusterHealthResponse struct

+ ActivePrimaryShards int

+ ActiveShards int

+ ActiveShardsPercentAsNumber float64

+ ClusterName string

+ DelayedUnassignedShards int

+ Indices map[string]ClusterIndexHealth

+ InitializingShards int

+ NumberOfDataNodes int

+ NumberOfInFlightFetch int

+ NumberOfNodes int

+ NumberOfPendingTasks int

+ RelocatingShards int

+ Status string

+ TaskMaxWaitingInQueueMillis int

+ TimedOut bool

+ UnassignedShards int

+ type ClusterIndexHealth struct

+ ActivePrimaryShards int

+ ActiveShards int

+ InitializingShards int

+ NumberOfReplicas int

+ NumberOfShards int

+ RelocatingShards int

+ Status string

+ UnassignedShards int

+ type ClusterInfoResponse map[string]any

+ type ClusterPendingTasksParams struct

+ Common *CommonParams

+ Local *bool

+ func (p *ClusterPendingTasksParams) ToMap() map[string]string

+ type ClusterPendingTasksResponse struct

+ Tasks []struct{ ... }

+ type ClusterPutSettingsParams struct

+ Common *CommonParams

+ FlatSettings *bool

+ Timeout string

+ func (p *ClusterPutSettingsParams) ToMap() map[string]string

+ type ClusterPutSettingsResponse struct

+ Acknowledged bool

+ Persistent map[string]any

+ Transient map[string]any

+ type ClusterRemoteInfoResponse map[string]struct

+ type ClusterRerouteParams struct

+ Common *CommonParams

+ DryRun *bool

+ Explain *bool

+ Metric []string

+ RetryFailed *bool

+ Timeout string

+ func (p *ClusterRerouteParams) ToMap() map[string]string

+ type ClusterRerouteResponse struct

+ Acknowledged bool

+ Explanations []map[string]any

+ State map[string]any

+ type ClusterService interface

+ AllocationExplain func(ctx context.Context, body any, params *ClusterAllocationExplainParams) (*ClusterAllocationExplainResponse, error)

+ DeleteComponentTemplate func(ctx context.Context, name string, params *ClusterDeleteComponentTemplateParams) (*types.AcknowledgedResponse, error)

+ DeleteVotingConfigExclusions func(ctx context.Context, params *ClusterDeleteVotingConfigExclusionsParams) error

+ ExistsComponentTemplate func(ctx context.Context, name string) (bool, error)

+ GetComponentTemplate func(ctx context.Context, names []string, params *ClusterGetComponentTemplateParams) (*ClusterGetComponentTemplateResponse, error)

+ GetSettings func(ctx context.Context, params *ClusterGetSettingsParams) (*ClusterGetSettingsResponse, error)

+ Health func(ctx context.Context, indices []string, params *ClusterHealthParams) (*ClusterHealthResponse, error)

+ Info func(ctx context.Context, features []string) (*ClusterInfoResponse, error)

+ PendingTasks func(ctx context.Context, params *ClusterPendingTasksParams) (*ClusterPendingTasksResponse, error)

+ PostVotingConfigExclusions func(ctx context.Context, params *ClusterVotingConfigExclusionsParams) error

+ PutComponentTemplate func(ctx context.Context, req *PutComponentTemplateRequest) (*types.AcknowledgedResponse, error)

+ PutSettings func(ctx context.Context, body any, params *ClusterPutSettingsParams) (*ClusterPutSettingsResponse, error)

+ RemoteInfo func(ctx context.Context) (*ClusterRemoteInfoResponse, error)

+ Reroute func(ctx context.Context, body any, params *ClusterRerouteParams) (*ClusterRerouteResponse, error)

+ State func(ctx context.Context, req *ClusterStateRequest) (*ClusterStateResponse, error)

+ Stats func(ctx context.Context, nodeIds []string, params *ClusterStatsParams) (*ClusterStatsResponse, error)

+ func NewClusterService(client *resty.Client, logger *logrus.Entry) ClusterService

+ type ClusterStateParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ FlatSettings *bool

+ IgnoreUnavailable *bool

+ Local *bool

+ WaitForMetadataVersion *int64

+ WaitForTimeout string

+ func (p *ClusterStateParams) ToMap() map[string]string

+ type ClusterStateRequest struct

+ Indices []string

+ Metrics []string

+ Params *ClusterStateParams

+ type ClusterStateResponse struct

+ Blocks map[string]any

+ ClusterName string

+ ClusterUUID string

+ MasterNode string

+ Metadata map[string]any

+ Nodes map[string]any

+ RoutingNodes map[string]any

+ RoutingTable map[string]any

+ StateUUID string

+ Version int64

+ type ClusterStatsParams struct

+ Common *CommonParams

+ FlatSettings *bool

+ Timeout string

+ func (p *ClusterStatsParams) ToMap() map[string]string

+ type ClusterStatsResponse struct

+ ClusterName string

+ ClusterUUID string

+ Indices map[string]any

+ Nodes map[string]any

+ Status string

+ Timestamp int64

+ type ClusterVotingConfigExclusionsParams struct

+ Common *CommonParams

+ NodeIds []string

+ NodeNames []string

+ Timeout string

+ func (p *ClusterVotingConfigExclusionsParams) ToMap() map[string]string

+ type CommonParams = types.CommonParams

+ type Conflicts string

+ const ConflictsAbort

+ const ConflictsProceed

+ type CountParams struct

+ AllowNoIndices *bool

+ AnalyzeWildcard *bool

+ Analyzer string

+ Common *CommonParams

+ DefaultOperator DefaultOperator

+ Df string

+ ExpandWildcards ExpandWildcards

+ IgnoreThrottled *bool

+ IgnoreUnavailable *bool

+ Lenient *bool

+ MinScore *float64

+ Preference string

+ Q string

+ Routing string

+ TerminateAfter *int

+ func (p *CountParams) ToMap() map[string]string

+ type CountRequest struct

+ Body any

+ Indices []string

+ Params *CountParams

+ type CreateParams = IndexParams

+ type CreateRequest struct

+ Body any

+ Id string

+ Index string

+ Params *CreateParams

+ func (r *CreateRequest) Validate() error

+ type DanglingIndicesImportParams struct

+ AcceptDataLoss *bool

+ Common *CommonParams

+ func (p *DanglingIndicesImportParams) ToMap() map[string]string

+ type DanglingIndicesListResponse struct

+ DanglingIndices []struct{ ... }

+ type DanglingIndicesService interface

+ Delete func(ctx context.Context, indexUUID string, params *DanglingIndicesImportParams) (*types.AcknowledgedResponse, error)

+ Import func(ctx context.Context, indexUUID string, params *DanglingIndicesImportParams) (*types.AcknowledgedResponse, error)

+ List func(ctx context.Context) (*DanglingIndicesListResponse, error)

+ func NewDanglingIndicesService(client *resty.Client, logger *logrus.Entry) DanglingIndicesService

+ type DataStream struct

+ AllowCustomRouting bool

+ Generation int

+ Hidden bool

+ Indices []DataStreamIndex

+ Name string

+ Replicated bool

+ Status string

+ System bool

+ Template string

+ TimestampField DataStreamField

+ type DataStreamField struct

+ Field string

+ type DataStreamIndex struct

+ Index string

+ IndexUUID string

+ IsBackingIndex bool

+ IsHidden bool

+ type DefaultAsyncSearchService struct

+ func (s *DefaultAsyncSearchService) Delete(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultAsyncSearchService) Get(ctx context.Context, id string, params *AsyncSearchGetParams) (*AsyncSearchResponse, error)

+ func (s *DefaultAsyncSearchService) Status(ctx context.Context, id string) (*AsyncSearchStatusResponse, error)

+ func (s *DefaultAsyncSearchService) Submit(ctx context.Context, req *AsyncSearchSubmitRequest) (*AsyncSearchResponse, error)

+ type DefaultAutoscalingService struct

+ func (s *DefaultAutoscalingService) DeletePolicy(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultAutoscalingService) GetCapacity(ctx context.Context) (json.RawMessage, error)

+ func (s *DefaultAutoscalingService) GetPolicy(ctx context.Context, name string) (json.RawMessage, error)

+ func (s *DefaultAutoscalingService) PutPolicy(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ type DefaultCatService struct

+ func (s *DefaultCatService) Aliases(ctx context.Context, names []string, p *CatAliasesParams) (CatAliasesResponse, error)

+ func (s *DefaultCatService) Allocation(ctx context.Context, nodeIds []string, p *CatAllocationParams) (CatAllocationResponse, error)

+ func (s *DefaultCatService) CircuitBreaker(ctx context.Context, p *CatCircuitBreakerParams) (CatCircuitBreakerResponse, error)

+ func (s *DefaultCatService) ComponentTemplates(ctx context.Context, name string, p *CatComponentTemplatesParams) (CatComponentTemplatesResponse, error)

+ func (s *DefaultCatService) Count(ctx context.Context, indices []string, p *CatCountParams) (CatCountResponse, error)

+ func (s *DefaultCatService) Fielddata(ctx context.Context, fields []string, p *CatFielddataParams) (CatFielddataResponse, error)

+ func (s *DefaultCatService) Health(ctx context.Context, p *CatHealthParams) (CatHealthResponse, error)

+ func (s *DefaultCatService) Help(ctx context.Context) (string, error)

+ func (s *DefaultCatService) Indices(ctx context.Context, indices []string, p *CatIndicesParams) (CatIndicesResponse, error)

+ func (s *DefaultCatService) MLDataFrameAnalytics(ctx context.Context, id string, p *CatMLDataFrameAnalyticsParams) (CatMLDataFrameAnalyticsResponse, error)

+ func (s *DefaultCatService) MLDatafeeds(ctx context.Context, datafeedId string, p *CatMLDatafeedsParams) (CatMLDatafeedsResponse, error)

+ func (s *DefaultCatService) MLJobs(ctx context.Context, jobId string, p *CatMLJobsParams) (CatMLJobsResponse, error)

+ func (s *DefaultCatService) MLTrainedModels(ctx context.Context, modelId string, p *CatMLTrainedModelsParams) (CatMLTrainedModelsResponse, error)

+ func (s *DefaultCatService) Master(ctx context.Context, p *CatMasterParams) (CatMasterResponse, error)

+ func (s *DefaultCatService) NodeAttrs(ctx context.Context, p *CatNodeAttrsParams) (CatNodeAttrsResponse, error)

+ func (s *DefaultCatService) Nodes(ctx context.Context, p *CatNodesParams) (CatNodesResponse, error)

+ func (s *DefaultCatService) PendingTasks(ctx context.Context, p *CatPendingTasksParams) (CatPendingTasksResponse, error)

+ func (s *DefaultCatService) Plugins(ctx context.Context, p *CatPluginsParams) (CatPluginsResponse, error)

+ func (s *DefaultCatService) Recovery(ctx context.Context, indices []string, p *CatRecoveryParams) (CatRecoveryResponse, error)

+ func (s *DefaultCatService) Repositories(ctx context.Context, p *CatRepositoriesParams) (CatRepositoriesResponse, error)

+ func (s *DefaultCatService) Segments(ctx context.Context, indices []string, p *CatSegmentsParams) (CatSegmentsResponse, error)

+ func (s *DefaultCatService) Shards(ctx context.Context, indices []string, p *CatShardsParams) (CatShardsResponse, error)

+ func (s *DefaultCatService) Snapshots(ctx context.Context, repository string, p *CatSnapshotsParams) (CatSnapshotsResponse, error)

+ func (s *DefaultCatService) Tasks(ctx context.Context, p *CatTasksParams) (CatTasksResponse, error)

+ func (s *DefaultCatService) Templates(ctx context.Context, name string, p *CatTemplatesParams) (CatTemplatesResponse, error)

+ func (s *DefaultCatService) ThreadPool(ctx context.Context, patterns []string, p *CatThreadPoolParams) (CatThreadPoolResponse, error)

+ func (s *DefaultCatService) Transforms(ctx context.Context, transformId string, p *CatTransformsParams) (CatTransformsResponse, error)

+ type DefaultCcrService struct

+ func (s *DefaultCcrService) DeleteAutoFollowPattern(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultCcrService) Follow(ctx context.Context, index string, body any, params *CcrFollowParams) (*CcrFollowResponse, error)

+ func (s *DefaultCcrService) FollowInfo(ctx context.Context, indices []string) (*CcrFollowInfoResponse, error)

+ func (s *DefaultCcrService) FollowStats(ctx context.Context, indices []string) (*CcrFollowStatsResponse, error)

+ func (s *DefaultCcrService) ForgetFollower(ctx context.Context, index string, body any) (*CcrForgetFollowerResponse, error)

+ func (s *DefaultCcrService) GetAutoFollowPattern(ctx context.Context, names []string) (*CcrGetAutoFollowPatternResponse, error)

+ func (s *DefaultCcrService) PauseAutoFollowPattern(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultCcrService) PauseFollow(ctx context.Context, index string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultCcrService) PutAutoFollowPattern(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultCcrService) ResumeAutoFollowPattern(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultCcrService) ResumeFollow(ctx context.Context, index string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultCcrService) Stats(ctx context.Context) (*CcrStatsResponse, error)

+ func (s *DefaultCcrService) Unfollow(ctx context.Context, index string) (*types.AcknowledgedResponse, error)

+ type DefaultClusterService struct

+ func (s *DefaultClusterService) AllocationExplain(ctx context.Context, body any, params *ClusterAllocationExplainParams) (*ClusterAllocationExplainResponse, error)

+ func (s *DefaultClusterService) DeleteComponentTemplate(ctx context.Context, name string, params *ClusterDeleteComponentTemplateParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultClusterService) DeleteVotingConfigExclusions(ctx context.Context, params *ClusterDeleteVotingConfigExclusionsParams) error

+ func (s *DefaultClusterService) ExistsComponentTemplate(ctx context.Context, name string) (bool, error)

+ func (s *DefaultClusterService) GetComponentTemplate(ctx context.Context, names []string, params *ClusterGetComponentTemplateParams) (*ClusterGetComponentTemplateResponse, error)

+ func (s *DefaultClusterService) GetSettings(ctx context.Context, params *ClusterGetSettingsParams) (*ClusterGetSettingsResponse, error)

+ func (s *DefaultClusterService) Health(ctx context.Context, indices []string, params *ClusterHealthParams) (*ClusterHealthResponse, error)

+ func (s *DefaultClusterService) Info(ctx context.Context, features []string) (*ClusterInfoResponse, error)

+ func (s *DefaultClusterService) PendingTasks(ctx context.Context, params *ClusterPendingTasksParams) (*ClusterPendingTasksResponse, error)

+ func (s *DefaultClusterService) PostVotingConfigExclusions(ctx context.Context, params *ClusterVotingConfigExclusionsParams) error

+ func (s *DefaultClusterService) PutComponentTemplate(ctx context.Context, req *PutComponentTemplateRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultClusterService) PutSettings(ctx context.Context, body any, params *ClusterPutSettingsParams) (*ClusterPutSettingsResponse, error)

+ func (s *DefaultClusterService) RemoteInfo(ctx context.Context) (*ClusterRemoteInfoResponse, error)

+ func (s *DefaultClusterService) Reroute(ctx context.Context, body any, params *ClusterRerouteParams) (*ClusterRerouteResponse, error)

+ func (s *DefaultClusterService) State(ctx context.Context, req *ClusterStateRequest) (*ClusterStateResponse, error)

+ func (s *DefaultClusterService) Stats(ctx context.Context, nodeIds []string, params *ClusterStatsParams) (*ClusterStatsResponse, error)

+ type DefaultDanglingIndicesService struct

+ func (s *DefaultDanglingIndicesService) Delete(ctx context.Context, indexUUID string, params *DanglingIndicesImportParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultDanglingIndicesService) Import(ctx context.Context, indexUUID string, params *DanglingIndicesImportParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultDanglingIndicesService) List(ctx context.Context) (*DanglingIndicesListResponse, error)

+ type DefaultDocumentService struct

+ func (s *DefaultDocumentService) Bulk(ctx context.Context, req *BulkRequest) (*BulkResponse, error)

+ func (s *DefaultDocumentService) Create(ctx context.Context, req *CreateRequest) (*IndexResponse, error)

+ func (s *DefaultDocumentService) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

+ func (s *DefaultDocumentService) DeleteByQuery(ctx context.Context, req *DeleteByQueryRequest) (*BulkIndexByScrollResponse, error)

+ func (s *DefaultDocumentService) DeleteByQueryRethrottle(ctx context.Context, req *RethrottleRequest) (*TasksListResponse, error)

+ func (s *DefaultDocumentService) Exists(ctx context.Context, index, id string, params *GetParams) (bool, error)

+ func (s *DefaultDocumentService) ExistsSource(ctx context.Context, index, id string, params *GetSourceParams) (bool, error)

+ func (s *DefaultDocumentService) Explain(ctx context.Context, req *ExplainRequest) (*ExplainResponse, error)

+ func (s *DefaultDocumentService) Get(ctx context.Context, req *GetRequest) (*GetResult, error)

+ func (s *DefaultDocumentService) GetSource(ctx context.Context, req *GetSourceRequest) (json.RawMessage, error)

+ func (s *DefaultDocumentService) Index(ctx context.Context, req *IndexRequest) (*IndexResponse, error)

+ func (s *DefaultDocumentService) MultiGet(ctx context.Context, req *MgetRequest) (*MgetResponse, error)

+ func (s *DefaultDocumentService) MultiTermVectors(ctx context.Context, req *MtermvectorsRequest) (*MultiTermvectorResponse, error)

+ func (s *DefaultDocumentService) Reindex(ctx context.Context, req *ReindexRequest) (*BulkIndexByScrollResponse, error)

+ func (s *DefaultDocumentService) ReindexRethrottle(ctx context.Context, req *RethrottleRequest) (*TasksListResponse, error)

+ func (s *DefaultDocumentService) TermVectors(ctx context.Context, req *TermVectorsRequest) (*TermvectorsResponse, error)

+ func (s *DefaultDocumentService) TermsEnum(ctx context.Context, req *TermsEnumRequest) (*TermsEnumResponse, error)

+ func (s *DefaultDocumentService) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)

+ func (s *DefaultDocumentService) UpdateByQuery(ctx context.Context, req *UpdateByQueryRequest) (*BulkIndexByScrollResponse, error)

+ func (s *DefaultDocumentService) UpdateByQueryRethrottle(ctx context.Context, req *RethrottleRequest) (*TasksListResponse, error)

+ type DefaultEnrichService struct

+ func (s *DefaultEnrichService) DeletePolicy(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultEnrichService) ExecutePolicy(ctx context.Context, name string, params *EnrichWaitForCompletionParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultEnrichService) GetPolicy(ctx context.Context, names []string) (json.RawMessage, error)

+ func (s *DefaultEnrichService) PutPolicy(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultEnrichService) Stats(ctx context.Context) (json.RawMessage, error)

+ type DefaultEqlService struct

+ func (s *DefaultEqlService) Delete(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultEqlService) Get(ctx context.Context, id string) (*EqlSearchResponse, error)

+ func (s *DefaultEqlService) GetStatus(ctx context.Context, id string) (json.RawMessage, error)

+ func (s *DefaultEqlService) Search(ctx context.Context, index string, body any, params *EqlSearchParams) (*EqlSearchResponse, error)

+ type DefaultFeaturesService struct

+ func (s *DefaultFeaturesService) GetFeatures(ctx context.Context) (*FeaturesGetResponse, error)

+ func (s *DefaultFeaturesService) ResetFeatures(ctx context.Context) (*types.AcknowledgedResponse, error)

+ type DefaultFleetService struct

+ func (s *DefaultFleetService) GlobalCheckpoints(ctx context.Context, index string, params *FleetGlobalCheckpointsParams) (*FleetGlobalCheckpointsResponse, error)

+ type DefaultGraphService struct

+ func (s *DefaultGraphService) Explore(ctx context.Context, index string, body any, params *GraphExploreParams) (*GraphExploreResponse, error)

+ type DefaultHealthReportService struct

+ func (s *DefaultHealthReportService) Get(ctx context.Context, feature string, params *HealthReportParams) (*HealthReportResponse, error)

+ type DefaultIlmService struct

+ func (s *DefaultIlmService) DeleteLifecycle(ctx context.Context, policy string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIlmService) ExplainLifecycle(ctx context.Context, indices []string, params *IlmExplainParams) (*IlmExplainResponse, error)

+ func (s *DefaultIlmService) GetLifecycle(ctx context.Context, policies []string) (map[string]*IlmPolicy, error)

+ func (s *DefaultIlmService) GetStatus(ctx context.Context) (*IlmStatusResponse, error)

+ func (s *DefaultIlmService) MigrateToDataTiers(ctx context.Context, dryRun *bool) (*IlmMigrateToDataTiersResponse, error)

+ func (s *DefaultIlmService) MoveToStep(ctx context.Context, index string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIlmService) PutLifecycle(ctx context.Context, policy string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIlmService) RemovePolicy(ctx context.Context, indices []string) (*IlmRemovePolicyResponse, error)

+ func (s *DefaultIlmService) Retry(ctx context.Context, indices []string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIlmService) Start(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIlmService) Stop(ctx context.Context) (*types.AcknowledgedResponse, error)

+ type DefaultIndicesService struct

+ func (s *DefaultIndicesService) AddBlock(ctx context.Context, req *AddBlockRequest) (*IndicesBlockResponse, error)

+ func (s *DefaultIndicesService) Analyze(ctx context.Context, index string, body any) (*IndicesAnalyzeResponse, error)

+ func (s *DefaultIndicesService) ClearCache(ctx context.Context, indices []string, params *IndicesClearCacheParams) (*types.BroadcastResponse, error)

+ func (s *DefaultIndicesService) Clone(ctx context.Context, req *CloneRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) Close(ctx context.Context, indices []string, params *IndicesCloseParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) Create(ctx context.Context, index string, body any, params *IndicesCreateParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) CreateDataStream(ctx context.Context, name string, body any, ...) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) DataStreamStats(ctx context.Context, names []string) (*IndicesDataStreamsStatsResponse, error)

+ func (s *DefaultIndicesService) Delete(ctx context.Context, indices []string, params *IndicesDeleteParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) DeleteAlias(ctx context.Context, req *DeleteAliasRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) DeleteDataStream(ctx context.Context, names []string, params *IndicesDeleteDataStreamParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) DeleteIndexTemplate(ctx context.Context, name string, params *IndicesDeleteIndexTemplateParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) DeleteTemplate(ctx context.Context, name string, params *IndicesDeleteTemplateParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) Downsample(ctx context.Context, index, targetIndex string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) Exists(ctx context.Context, indices []string, params *IndicesExistsParams) (bool, error)

+ func (s *DefaultIndicesService) ExistsAlias(ctx context.Context, req *ExistsAliasRequest) (bool, error)

+ func (s *DefaultIndicesService) ExistsIndexTemplate(ctx context.Context, name string) (bool, error)

+ func (s *DefaultIndicesService) ExistsTemplate(ctx context.Context, name string) (bool, error)

+ func (s *DefaultIndicesService) Flush(ctx context.Context, indices []string, params *IndicesFlushParams) (*types.BroadcastResponse, error)

+ func (s *DefaultIndicesService) ForceMerge(ctx context.Context, indices []string, params *IndicesForceMergeParams) (*types.BroadcastResponse, error)

+ func (s *DefaultIndicesService) Get(ctx context.Context, indices []string, params *IndicesGetParams) (map[string]*IndicesGetResponse, error)

+ func (s *DefaultIndicesService) GetAlias(ctx context.Context, req *GetAliasRequest) (map[string]*IndicesGetAliasResponse, error)

+ func (s *DefaultIndicesService) GetDataStream(ctx context.Context, names []string, params *IndicesGetDataStreamParams) (*IndicesDataStreamGetResponse, error)

+ func (s *DefaultIndicesService) GetFieldMapping(ctx context.Context, req *GetFieldMappingRequest) (map[string]any, error)

+ func (s *DefaultIndicesService) GetIndexTemplate(ctx context.Context, names []string, params *IndicesGetIndexTemplateParams) (*IndicesGetIndexTemplateResponse, error)

+ func (s *DefaultIndicesService) GetMapping(ctx context.Context, indices []string, params *IndicesGetMappingParams) (map[string]*IndicesGetMappingResponse, error)

+ func (s *DefaultIndicesService) GetSettings(ctx context.Context, req *GetSettingsRequest) (map[string]*IndicesGetSettingsResponse, error)

+ func (s *DefaultIndicesService) GetTemplate(ctx context.Context, names []string, params *IndicesGetTemplateParams) (map[string]*IndicesGetTemplateResponse, error)

+ func (s *DefaultIndicesService) MigrateToDataStream(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) ModifyDataStream(ctx context.Context, req *ModifyDataStreamRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) Open(ctx context.Context, indices []string, params *IndicesOpenParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) PromoteDataStream(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) PutAlias(ctx context.Context, req *PutAliasRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) PutIndexTemplate(ctx context.Context, req *PutIndexTemplateRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) PutMapping(ctx context.Context, req *PutMappingRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) PutSettings(ctx context.Context, indices []string, body any, ...) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) PutTemplate(ctx context.Context, req *PutTemplateRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) Recovery(ctx context.Context, indices []string, params *IndicesRecoveryParams) (*IndicesRecoveryResponse, error)

+ func (s *DefaultIndicesService) Refresh(ctx context.Context, indices []string, params *IndicesRefreshParams) (*RefreshResult, error)

+ func (s *DefaultIndicesService) ReloadSearchAnalyzers(ctx context.Context, indices []string, params *IndicesReloadAnalyzersParams) (*IndicesReloadAnalyzersResponse, error)

+ func (s *DefaultIndicesService) ResolveCluster(ctx context.Context, names []string, params *IndicesResolveClusterParams) (map[string]*ResolveClusterInfo, error)

+ func (s *DefaultIndicesService) ResolveIndex(ctx context.Context, name string, params *IndicesResolveIndexParams) (*IndicesResolveIndexResponse, error)

+ func (s *DefaultIndicesService) Rollover(ctx context.Context, req *RolloverRequest) (*IndicesRolloverResponse, error)

+ func (s *DefaultIndicesService) Segments(ctx context.Context, indices []string, params *IndicesSegmentsParams) (*IndicesSegmentsResponse, error)

+ func (s *DefaultIndicesService) ShardStores(ctx context.Context, indices []string, params *IndicesShardStoresParams) (*IndicesShardStoresResponse, error)

+ func (s *DefaultIndicesService) Shrink(ctx context.Context, req *ShrinkRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) SimulateIndexTemplate(ctx context.Context, req *SimulateIndexTemplateRequest) (*IndicesSimulateTemplateResponse, error)

+ func (s *DefaultIndicesService) SimulateTemplate(ctx context.Context, req *SimulateTemplateRequest) (*IndicesSimulateTemplateResponse, error)

+ func (s *DefaultIndicesService) Split(ctx context.Context, req *SplitRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIndicesService) Stats(ctx context.Context, req *IndicesStatsRequest) (*IndicesStatsResponse, error)

+ func (s *DefaultIndicesService) UpdateAliases(ctx context.Context, body any, params *IndicesUpdateAliasesParams) (*types.AcknowledgedResponse, error)

+ type DefaultInferenceService struct

+ func (s *DefaultInferenceService) Completion(ctx context.Context, inferenceId string, body any) (json.RawMessage, error)

+ func (s *DefaultInferenceService) Delete(ctx context.Context, taskType, inferenceId string, ...) (*types.AcknowledgedResponse, error)

+ func (s *DefaultInferenceService) Get(ctx context.Context, inferenceId, taskType string) (json.RawMessage, error)

+ func (s *DefaultInferenceService) Inference(ctx context.Context, inferenceId string, body any) (json.RawMessage, error)

+ func (s *DefaultInferenceService) Put(ctx context.Context, taskType, inferenceId string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultInferenceService) Rerank(ctx context.Context, inferenceId string, body any) (json.RawMessage, error)

+ func (s *DefaultInferenceService) Update(ctx context.Context, inferenceId string, body any) (*types.AcknowledgedResponse, error)

+ type DefaultInfoService struct

+ func (s *DefaultInfoService) Capabilities(ctx context.Context, req *CapabilitiesRequest) (*CapabilitiesResponse, error)

+ func (s *DefaultInfoService) Info(ctx context.Context) (*InfoResponse, error)

+ func (s *DefaultInfoService) Ping(ctx context.Context) (bool, error)

+ type DefaultIngestService struct

+ func (s *DefaultIngestService) DeletePipeline(ctx context.Context, id string, params *IngestDeletePipelineParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIngestService) GetPipeline(ctx context.Context, ids []string, params *IngestGetPipelineParams) (map[string]*IngestPipeline, error)

+ func (s *DefaultIngestService) ProcessorGrok(ctx context.Context) (*IngestGrokResponse, error)

+ func (s *DefaultIngestService) PutPipeline(ctx context.Context, req *IngestPutPipelineRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultIngestService) Simulate(ctx context.Context, req *IngestSimulatePipelineRequest) (*IngestSimulateResponse, error)

+ type DefaultLicenseService struct

+ func (s *DefaultLicenseService) Delete(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func (s *DefaultLicenseService) Get(ctx context.Context, params *LicenseGetParams) (*LicenseGetResponse, error)

+ func (s *DefaultLicenseService) GetBasicStatus(ctx context.Context) (json.RawMessage, error)

+ func (s *DefaultLicenseService) GetTrialStatus(ctx context.Context) (json.RawMessage, error)

+ func (s *DefaultLicenseService) Post(ctx context.Context, body any, params *LicensePostParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultLicenseService) PostStartBasic(ctx context.Context, params *LicensePostParams) (json.RawMessage, error)

+ func (s *DefaultLicenseService) PostStartTrial(ctx context.Context, params *LicenseStartTrialParams) (json.RawMessage, error)

+ type DefaultLogstashService struct

+ func (s *DefaultLogstashService) DeletePipeline(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultLogstashService) GetPipeline(ctx context.Context, ids []string) (map[string]map[string]any, error)

+ func (s *DefaultLogstashService) PutPipeline(ctx context.Context, id string, body any) (*types.AcknowledgedResponse, error)

+ type DefaultMigrationService struct

+ func (s *DefaultMigrationService) Deprecations(ctx context.Context, index string) (*MigrationDeprecationsResponse, error)

+ func (s *DefaultMigrationService) GetFeatureUpgradeStatus(ctx context.Context) (*MigrationFeatureUpgradeStatusResponse, error)

+ func (s *DefaultMigrationService) PostFeatureUpgrade(ctx context.Context) (json.RawMessage, error)

+ type DefaultMlService struct

+ func (s *DefaultMlService) CloseJob(ctx context.Context, jobId string, params *MlCloseJobParams) (*MlCloseJobResponse, error)

+ func (s *DefaultMlService) DeleteDatafeed(ctx context.Context, datafeedId string, params *MlDeleteDatafeedParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultMlService) DeleteJob(ctx context.Context, jobId string, params *MlDeleteJobParams) (*MlDeleteJobResponse, error)

+ func (s *DefaultMlService) FlushJob(ctx context.Context, jobId string, body any, params *MlFlushJobParams) (*MlFlushJobResponse, error)

+ func (s *DefaultMlService) GetDatafeeds(ctx context.Context, datafeedIds []string, params *MlGetDatafeedsParams) (*MlGetDatafeedsResponse, error)

+ func (s *DefaultMlService) GetFilters(ctx context.Context, filterId string, params *MlGetFiltersParams) (*MlGetFiltersResponse, error)

+ func (s *DefaultMlService) GetJobs(ctx context.Context, jobIds []string, params *MlGetJobsParams) (*MlGetJobsResponse, error)

+ func (s *DefaultMlService) GetTrainedModels(ctx context.Context, modelIds []string, params *MlGetTrainedModelsParams) (*MlGetTrainedModelsResponse, error)

+ func (s *DefaultMlService) InferTrainedModel(ctx context.Context, modelId string, body any, ...) (json.RawMessage, error)

+ func (s *DefaultMlService) OpenJob(ctx context.Context, jobId string, params *MlOpenJobParams) (*MlOpenJobResponse, error)

+ func (s *DefaultMlService) PutDatafeed(ctx context.Context, datafeedId string, body any) (*MlDatafeedConfig, error)

+ func (s *DefaultMlService) PutJob(ctx context.Context, jobId string, body any) (*MlJobConfig, error)

+ func (s *DefaultMlService) ResetJob(ctx context.Context, jobId string, params *MlResetJobParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultMlService) StartDatafeed(ctx context.Context, datafeedId string, body any, ...) (*MlStartDatafeedResponse, error)

+ func (s *DefaultMlService) StopDatafeed(ctx context.Context, datafeedId string, params *MlStopDatafeedParams) (*MlStopDatafeedResponse, error)

+ type DefaultNodesService struct

+ func (s *DefaultNodesService) HotThreads(ctx context.Context, nodeIds []string, params *NodesHotThreadsParams) (string, error)

+ func (s *DefaultNodesService) Info(ctx context.Context, req *NodesInfoRequest) (*NodesInfoResponse, error)

+ func (s *DefaultNodesService) ReloadSecureSettings(ctx context.Context, nodeIds []string, body any, ...) (*NodesReloadSecureSettingsResponse, error)

+ func (s *DefaultNodesService) Stats(ctx context.Context, req *NodesStatsRequest) (*NodesStatsResponse, error)

+ func (s *DefaultNodesService) Usage(ctx context.Context, req *NodesUsageRequest) (*NodesUsageResponse, error)

+ type DefaultOperator string

+ const DefaultOperatorAnd

+ const DefaultOperatorOr

+ type DefaultQueryRulesService struct

+ func (s *DefaultQueryRulesService) DeleteRuleset(ctx context.Context, rulesetId string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultQueryRulesService) GetRuleset(ctx context.Context, rulesetId string) (json.RawMessage, error)

+ func (s *DefaultQueryRulesService) ListRulesets(ctx context.Context, params *QueryRulesListParams) (json.RawMessage, error)

+ func (s *DefaultQueryRulesService) PutRuleset(ctx context.Context, rulesetId string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultQueryRulesService) Test(ctx context.Context, rulesetId string, body any, params *QueryRulesTestParams) (json.RawMessage, error)

+ type DefaultScriptService struct

+ func (s *DefaultScriptService) Delete(ctx context.Context, id string, params *ScriptDeleteParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultScriptService) Get(ctx context.Context, id string, params *ScriptGetParams) (*ScriptGetResponse, error)

+ func (s *DefaultScriptService) GetContext(ctx context.Context) (*ScriptContextResponse, error)

+ func (s *DefaultScriptService) GetLanguages(ctx context.Context) (*ScriptLanguagesResponse, error)

+ func (s *DefaultScriptService) Put(ctx context.Context, req *ScriptPutRequest) (*types.AcknowledgedResponse, error)

+ type DefaultSearchApplicationService struct

+ func (s *DefaultSearchApplicationService) Delete(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSearchApplicationService) DeleteBehavioralAnalytics(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSearchApplicationService) Get(ctx context.Context, name string) (json.RawMessage, error)

+ func (s *DefaultSearchApplicationService) GetBehavioralAnalytics(ctx context.Context, name string) (json.RawMessage, error)

+ func (s *DefaultSearchApplicationService) List(ctx context.Context, params *SearchApplicationListParams) (json.RawMessage, error)

+ func (s *DefaultSearchApplicationService) Put(ctx context.Context, name string, body any, params *SearchApplicationPutParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSearchApplicationService) PutBehavioralAnalytics(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSearchApplicationService) Search(ctx context.Context, name string, body any) (*querydsl.SearchResult, error)

+ type DefaultSearchService struct

+ func (s *DefaultSearchService) ClearScroll(ctx context.Context, scrollIds []string) (*querydsl.ClearScrollResponse, error)

+ func (s *DefaultSearchService) ClosePointInTime(ctx context.Context, pitIds []string) (*ClosePITResponse, error)

+ func (s *DefaultSearchService) Count(ctx context.Context, req *CountRequest) (int64, error)

+ func (s *DefaultSearchService) FieldCaps(ctx context.Context, req *FieldCapsRequest) (*querydsl.FieldCapsResponse, error)

+ func (s *DefaultSearchService) MultiSearch(ctx context.Context, req *MultiSearchRequest) (*querydsl.MultiSearchResult, error)

+ func (s *DefaultSearchService) MultiSearchTemplate(ctx context.Context, req *MultiSearchTemplateRequest) (*querydsl.MultiSearchResult, error)

+ func (s *DefaultSearchService) OpenPointInTime(ctx context.Context, req *OpenPITRequest) (*OpenPITResponse, error)

+ func (s *DefaultSearchService) RankEval(ctx context.Context, req *RankEvalRequest) (*querydsl.RankEvalResponse, error)

+ func (s *DefaultSearchService) RenderSearchTemplate(ctx context.Context, req *RenderSearchTemplateRequest) (*querydsl.RenderSearchTemplateResponse, error)

+ func (s *DefaultSearchService) ScriptsPainlessExec(ctx context.Context, body any) (json.RawMessage, error)

+ func (s *DefaultSearchService) Scroll(ctx context.Context, req *ScrollRequest) (*querydsl.SearchResult, error)

+ func (s *DefaultSearchService) Search(ctx context.Context, req *SearchRequest) (*querydsl.SearchResult, error)

+ func (s *DefaultSearchService) SearchMVT(ctx context.Context, req *SearchMVTRequest) (json.RawMessage, error)

+ func (s *DefaultSearchService) SearchShards(ctx context.Context, req *SearchShardsRequest) (*querydsl.SearchShardsResponse, error)

+ func (s *DefaultSearchService) SearchTemplate(ctx context.Context, req *SearchTemplateRequest) (*querydsl.SearchResult, error)

+ func (s *DefaultSearchService) Validate(ctx context.Context, req *ValidateQueryRequest) (*querydsl.ValidateResponse, error)

+ type DefaultSearchableSnapshotsService struct

+ func (s *DefaultSearchableSnapshotsService) CacheStats(ctx context.Context, nodeIds []string) (json.RawMessage, error)

+ func (s *DefaultSearchableSnapshotsService) ClearCache(ctx context.Context, indices []string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSearchableSnapshotsService) Mount(ctx context.Context, repository, snapshot string, body any, ...) (json.RawMessage, error)

+ func (s *DefaultSearchableSnapshotsService) RepositoryStats(ctx context.Context, repository string) (json.RawMessage, error)

+ func (s *DefaultSearchableSnapshotsService) Stats(ctx context.Context, indices []string, params *SearchableSnapshotsStatsParams) (json.RawMessage, error)

+ type DefaultSecurityService struct

+ func (s *DefaultSecurityService) Authenticate(ctx context.Context) (*SecurityAuthenticateResponse, error)

+ func (s *DefaultSecurityService) ChangePassword(ctx context.Context, username string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) ClearRealmCache(ctx context.Context, realms []string, params *SecurityClearRealmCacheParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) ClearRoleCache(ctx context.Context, names []string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) CreateAPIKey(ctx context.Context, body any) (*SecurityCreateAPIKeyResponse, error)

+ func (s *DefaultSecurityService) DeletePrivileges(ctx context.Context, application, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) DeleteRole(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) DeleteRoleMapping(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) DeleteUser(ctx context.Context, username string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) DisableUser(ctx context.Context, username string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) EnableUser(ctx context.Context, username string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSecurityService) GetAPIKey(ctx context.Context, params *SecurityGetAPIKeyParams) (*SecurityGetAPIKeyResponse, error)

+ func (s *DefaultSecurityService) GetPrivileges(ctx context.Context, application, name string) (map[string]any, error)

+ func (s *DefaultSecurityService) GetRole(ctx context.Context, names []string) (map[string]*SecurityRole, error)

+ func (s *DefaultSecurityService) GetRoleMapping(ctx context.Context, names []string) (map[string]*SecurityRoleMapping, error)

+ func (s *DefaultSecurityService) GetToken(ctx context.Context, body any) (*SecurityGetTokenResponse, error)

+ func (s *DefaultSecurityService) GetUser(ctx context.Context, usernames []string) (map[string]*SecurityUser, error)

+ func (s *DefaultSecurityService) GetUserPrivileges(ctx context.Context) (map[string]any, error)

+ func (s *DefaultSecurityService) HasPrivileges(ctx context.Context, body any) (*SecurityHasPrivilegesResponse, error)

+ func (s *DefaultSecurityService) InvalidateAPIKey(ctx context.Context, body any) (*SecurityInvalidateAPIKeyResponse, error)

+ func (s *DefaultSecurityService) InvalidateToken(ctx context.Context, body any) (*SecurityInvalidateTokenResponse, error)

+ func (s *DefaultSecurityService) PutPrivileges(ctx context.Context, body any) (*SecurityPutPrivilegesResponse, error)

+ func (s *DefaultSecurityService) PutRole(ctx context.Context, name string, body any) (*SecurityCreateResponse, error)

+ func (s *DefaultSecurityService) PutRoleMapping(ctx context.Context, name string, body any) (*SecurityRoleMappingCreateResponse, error)

+ func (s *DefaultSecurityService) PutUser(ctx context.Context, username string, body any) (*SecurityCreateResponse, error)

+ func (s *DefaultSecurityService) UpdateAPIKey(ctx context.Context, id string, body any) (*SecurityUpdateAPIKeyResponse, error)

+ type DefaultShutdownService struct

+ func (s *DefaultShutdownService) DeleteNode(ctx context.Context, nodeId string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultShutdownService) GetNode(ctx context.Context, nodeId string) (*ShutdownGetNodeResponse, error)

+ func (s *DefaultShutdownService) PutNode(ctx context.Context, nodeId string, body any) (*types.AcknowledgedResponse, error)

+ type DefaultSlmService struct

+ func (s *DefaultSlmService) DeleteLifecycle(ctx context.Context, policyId string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSlmService) ExecuteLifecycle(ctx context.Context, policyId string) (*SlmExecuteResponse, error)

+ func (s *DefaultSlmService) ExecuteRetention(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSlmService) GetLifecycle(ctx context.Context, policyIds []string) (map[string]*SlmPolicy, error)

+ func (s *DefaultSlmService) GetStats(ctx context.Context) (*SlmStatsResponse, error)

+ func (s *DefaultSlmService) GetStatus(ctx context.Context) (*SlmStatusResponse, error)

+ func (s *DefaultSlmService) PutLifecycle(ctx context.Context, policyId string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSlmService) Start(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSlmService) Stop(ctx context.Context) (*types.AcknowledgedResponse, error)

+ type DefaultSnapshotService struct

+ func (s *DefaultSnapshotService) CleanupRepository(ctx context.Context, name string, params *SnapshotCleanupRepositoryParams) (*SnapshotCleanupRepositoryResponse, error)

+ func (s *DefaultSnapshotService) Clone(ctx context.Context, req *SnapshotCloneRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSnapshotService) Create(ctx context.Context, req *SnapshotCreateRequest) (*SnapshotCreateResponse, error)

+ func (s *DefaultSnapshotService) CreateRepository(ctx context.Context, name string, body any, ...) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSnapshotService) Delete(ctx context.Context, req *SnapshotDeleteRequest) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSnapshotService) DeleteRepository(ctx context.Context, names []string, params *SnapshotDeleteRepositoryParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSnapshotService) Get(ctx context.Context, req *SnapshotGetRequest) (*SnapshotGetResponse, error)

+ func (s *DefaultSnapshotService) GetRepository(ctx context.Context, names []string, params *SnapshotGetRepositoryParams) (map[string]*SnapshotRepository, error)

+ func (s *DefaultSnapshotService) RepositoryAnalyze(ctx context.Context, name string, params *SnapshotRepositoryAnalyzeParams) (*SnapshotRepositoryAnalyzeResponse, error)

+ func (s *DefaultSnapshotService) RepositoryVerifyIntegrity(ctx context.Context, name string, ...) (*SnapshotRepositoryVerifyIntegrityResponse, error)

+ func (s *DefaultSnapshotService) Restore(ctx context.Context, req *SnapshotRestoreRequest) (*SnapshotRestoreResponse, error)

+ func (s *DefaultSnapshotService) Status(ctx context.Context, req *SnapshotStatusRequest) (*SnapshotStatusResponse, error)

+ func (s *DefaultSnapshotService) VerifyRepository(ctx context.Context, name string, params *SnapshotVerifyRepositoryParams) (*SnapshotVerifyRepositoryResponse, error)

+ type DefaultSqlService struct

+ func (s *DefaultSqlService) ClearCursor(ctx context.Context, body any) (*SqlClearCursorResponse, error)

+ func (s *DefaultSqlService) DeleteAsync(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSqlService) GetAsync(ctx context.Context, id string, params *SqlGetAsyncParams) (*SqlQueryResponse, error)

+ func (s *DefaultSqlService) GetAsyncStatus(ctx context.Context, id string) (*SqlAsyncStatusResponse, error)

+ func (s *DefaultSqlService) Query(ctx context.Context, body any, params *SqlQueryParams) (*SqlQueryResponse, error)

+ func (s *DefaultSqlService) Translate(ctx context.Context, body any) (*SqlTranslateResponse, error)

+ type DefaultSslService struct

+ func (s *DefaultSslService) Certificates(ctx context.Context) (SslCertificatesResponse, error)

+ type DefaultStreamsService struct

+ func (s *DefaultStreamsService) LogsDisable(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func (s *DefaultStreamsService) LogsEnable(ctx context.Context, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultStreamsService) Status(ctx context.Context) (json.RawMessage, error)

+ type DefaultSynonymsService struct

+ func (s *DefaultSynonymsService) DeleteSynonym(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSynonymsService) DeleteSynonymRule(ctx context.Context, id, ruleId string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSynonymsService) GetSynonym(ctx context.Context, id string, params *SynonymsGetParams) (*SynonymRulesResponse, error)

+ func (s *DefaultSynonymsService) GetSynonymRule(ctx context.Context, id, ruleId string) (*SynonymRule, error)

+ func (s *DefaultSynonymsService) GetSynonymsSets(ctx context.Context, params *SynonymsListParams) (*SynonymsSetsResponse, error)

+ func (s *DefaultSynonymsService) PutSynonym(ctx context.Context, id string, body any) (*types.AcknowledgedResponse, error)

+ func (s *DefaultSynonymsService) PutSynonymRule(ctx context.Context, id, ruleId string, body any) (*types.AcknowledgedResponse, error)

+ type DefaultTasksService struct

+ func (s *DefaultTasksService) Cancel(ctx context.Context, taskId string, params *TasksCancelParams) (*TasksListResponse, error)

+ func (s *DefaultTasksService) Get(ctx context.Context, taskId string, params *TasksGetParams) (*TaskGetResponse, error)

+ func (s *DefaultTasksService) List(ctx context.Context, params *TasksListParams) (*TasksListResponse, error)

+ type DefaultTextStructureService struct

+ func (s *DefaultTextStructureService) FindFieldStructure(ctx context.Context, index, field string, params *TextStructureFindParams) (json.RawMessage, error)

+ func (s *DefaultTextStructureService) FindMessageStructure(ctx context.Context, index string, params *TextStructureFindParams) (json.RawMessage, error)

+ func (s *DefaultTextStructureService) FindStructure(ctx context.Context, body any, params *TextStructureFindParams) (*TextStructureResponse, error)

+ func (s *DefaultTextStructureService) TestGrokPattern(ctx context.Context, body any, params *TextStructureFindParams) (json.RawMessage, error)

+ type DefaultTransformService struct

+ func (s *DefaultTransformService) Delete(ctx context.Context, transformId string, params *TransformDeleteParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultTransformService) Get(ctx context.Context, transformIds []string, params *TransformGetParams) (*TransformGetResponse, error)

+ func (s *DefaultTransformService) GetNodeStats(ctx context.Context) (*TransformNodeStatsResponse, error)

+ func (s *DefaultTransformService) GetStats(ctx context.Context, transformIds []string, params *TransformGetStatsParams) (*TransformStatsResponse, error)

+ func (s *DefaultTransformService) Preview(ctx context.Context, transformId string, body any, ...) (*TransformPreviewResponse, error)

+ func (s *DefaultTransformService) Put(ctx context.Context, transformId string, body any, params *TransformPutParams) (*TransformPutResponse, error)

+ func (s *DefaultTransformService) Reset(ctx context.Context, transformId string, params *TransformResetParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultTransformService) ScheduleNow(ctx context.Context, transformId string) (*types.AcknowledgedResponse, error)

+ func (s *DefaultTransformService) Start(ctx context.Context, transformId string, params *TransformStartParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultTransformService) Stop(ctx context.Context, transformId string, params *TransformStopParams) (*types.AcknowledgedResponse, error)

+ func (s *DefaultTransformService) Upgrade(ctx context.Context, params *TransformUpgradeParams) (*TransformUpgradeResponse, error)

+ type DefaultWatcherService struct

+ func (s *DefaultWatcherService) AckWatch(ctx context.Context, id, actionId string) (*WatcherAckWatchResponse, error)

+ func (s *DefaultWatcherService) ActivateWatch(ctx context.Context, id string) (*WatcherActivateWatchResponse, error)

+ func (s *DefaultWatcherService) DeactivateWatch(ctx context.Context, id string) (*WatcherActivateWatchResponse, error)

+ func (s *DefaultWatcherService) DeleteWatch(ctx context.Context, id string) (*WatcherDeleteWatchResponse, error)

+ func (s *DefaultWatcherService) ExecuteWatch(ctx context.Context, id string, body any, params *WatcherExecuteWatchParams) (*WatcherExecuteWatchResponse, error)

+ func (s *DefaultWatcherService) GetWatch(ctx context.Context, id string) (*WatcherGetWatchResponse, error)

+ func (s *DefaultWatcherService) PutWatch(ctx context.Context, id string, body any, params *WatcherPutWatchParams) (*WatcherPutWatchResponse, error)

+ func (s *DefaultWatcherService) QueryWatches(ctx context.Context, body any) (*WatcherQueryWatchesResponse, error)

+ func (s *DefaultWatcherService) Start(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func (s *DefaultWatcherService) Stats(ctx context.Context, metrics []string, params *WatcherStatsParams) (*WatcherStatsResponse, error)

+ func (s *DefaultWatcherService) Stop(ctx context.Context) (*types.AcknowledgedResponse, error)

+ type DefaultXpackService struct

+ func (s *DefaultXpackService) Info(ctx context.Context, params *XpackInfoParams) (*XpackInfoResponse, error)

+ func (s *DefaultXpackService) Usage(ctx context.Context) (XpackUsageResponse, error)

+ type DeleteAliasRequest struct

+ Indices []string

+ Names []string

+ Params *AliasParams

+ func (r *DeleteAliasRequest) Validate() error

+ type DeleteByQueryParams struct

+ AnalyzeWildcard *bool

+ Analyzer string

+ Common *CommonParams

+ Conflicts Conflicts

+ DefaultOperator DefaultOperator

+ Df string

+ ExpandWildcards ExpandWildcards

+ From *int

+ IgnoreUnavailable *bool

+ Lenient *bool

+ MaxDocs *int

+ Preference string

+ Q string

+ Refresh *bool

+ RequestCache *bool

+ RequestsPerSecond *float64

+ Routing string

+ Scroll string

+ ScrollSize *int

+ SearchTimeout string

+ SearchType SearchType

+ SliceId string

+ SliceMax *int

+ Slices string

+ Sort []string

+ Stats []string

+ TerminateAfter *int

+ Timeout string

+ Version *bool

+ WaitForActiveShards string

+ WaitForCompletion *bool

+ func (p *DeleteByQueryParams) ToMap() map[string]string

+ type DeleteByQueryRequest struct

+ Body any

+ Indices []string

+ Params *DeleteByQueryParams

+ func (r *DeleteByQueryRequest) Validate() error

+ type DeleteParams struct

+ Common *CommonParams

+ IfPrimaryTerm *int64

+ IfSeqNo *int64

+ Refresh Refresh

+ Routing string

+ Timeout string

+ Version *int64

+ VersionType VersionType

+ func (p *DeleteParams) ToMap() map[string]string

+ type DeleteRequest struct

+ Id string

+ Index string

+ Params *DeleteParams

+ func (r *DeleteRequest) Validate() error

+ type DeleteResponse struct

+ ForcedRefresh bool

+ Id string

+ Index string

+ PrimaryTerm int64

+ Result string

+ SeqNo int64

+ Shards *types.ShardsInfo

+ Status int

+ Version int64

+ type DocumentService interface

+ Bulk func(ctx context.Context, req *BulkRequest) (*BulkResponse, error)

+ Create func(ctx context.Context, req *CreateRequest) (*IndexResponse, error)

+ Delete func(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

+ DeleteByQuery func(ctx context.Context, req *DeleteByQueryRequest) (*BulkIndexByScrollResponse, error)

+ DeleteByQueryRethrottle func(ctx context.Context, req *RethrottleRequest) (*TasksListResponse, error)

+ Exists func(ctx context.Context, index, id string, params *GetParams) (bool, error)

+ ExistsSource func(ctx context.Context, index, id string, params *GetSourceParams) (bool, error)

+ Explain func(ctx context.Context, req *ExplainRequest) (*ExplainResponse, error)

+ Get func(ctx context.Context, req *GetRequest) (*GetResult, error)

+ GetSource func(ctx context.Context, req *GetSourceRequest) (json.RawMessage, error)

+ Index func(ctx context.Context, req *IndexRequest) (*IndexResponse, error)

+ MultiGet func(ctx context.Context, req *MgetRequest) (*MgetResponse, error)

+ MultiTermVectors func(ctx context.Context, req *MtermvectorsRequest) (*MultiTermvectorResponse, error)

+ Reindex func(ctx context.Context, req *ReindexRequest) (*BulkIndexByScrollResponse, error)

+ ReindexRethrottle func(ctx context.Context, req *RethrottleRequest) (*TasksListResponse, error)

+ TermVectors func(ctx context.Context, req *TermVectorsRequest) (*TermvectorsResponse, error)

+ TermsEnum func(ctx context.Context, req *TermsEnumRequest) (*TermsEnumResponse, error)

+ Update func(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)

+ UpdateByQuery func(ctx context.Context, req *UpdateByQueryRequest) (*BulkIndexByScrollResponse, error)

+ UpdateByQueryRethrottle func(ctx context.Context, req *RethrottleRequest) (*TasksListResponse, error)

+ func NewDocumentService(client *resty.Client, logger *logrus.Entry) DocumentService

+ type EnrichService interface

+ DeletePolicy func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ ExecutePolicy func(ctx context.Context, name string, params *EnrichWaitForCompletionParams) (*types.AcknowledgedResponse, error)

+ GetPolicy func(ctx context.Context, names []string) (json.RawMessage, error)

+ PutPolicy func(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ Stats func(ctx context.Context) (json.RawMessage, error)

+ func NewEnrichService(client *resty.Client, logger *logrus.Entry) EnrichService

+ type EnrichWaitForCompletionParams struct

+ Common *CommonParams

+ WaitForCompletion *bool

+ func (p *EnrichWaitForCompletionParams) ToMap() map[string]string

+ type EqlSearchParams struct

+ Common *CommonParams

+ KeepAlive string

+ KeepOnCompletion *bool

+ WaitForCompletionTimeout string

+ func (p *EqlSearchParams) ToMap() map[string]string

+ type EqlSearchResponse struct

+ Hits map[string]any

+ ID string

+ IsPartial bool

+ IsRunning bool

+ TimedOut bool

+ Took int64

+ type EqlService interface

+ Delete func(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, id string) (*EqlSearchResponse, error)

+ GetStatus func(ctx context.Context, id string) (json.RawMessage, error)

+ Search func(ctx context.Context, index string, body any, params *EqlSearchParams) (*EqlSearchResponse, error)

+ func NewEqlService(client *resty.Client, logger *logrus.Entry) EqlService

+ type ExistsAliasRequest struct

+ Indices []string

+ Names []string

+ Params *GetAliasParams

+ func (r *ExistsAliasRequest) Validate() error

+ type ExpandWildcards string

+ const ExpandWildcardAll

+ const ExpandWildcardClosed

+ const ExpandWildcardHidden

+ const ExpandWildcardNone

+ const ExpandWildcardOpen

+ type ExplainParams struct

+ AnalyzeWildcard *bool

+ Analyzer string

+ Common *CommonParams

+ DefaultOperator DefaultOperator

+ Df string

+ Lenient *bool

+ Preference string

+ Q string

+ Routing string

+ Source string

+ SourceExcludes []string

+ SourceIncludes []string

+ StoredFields []string

+ func (p *ExplainParams) ToMap() map[string]string

+ type ExplainRequest struct

+ Body any

+ Id string

+ Index string

+ Params *ExplainParams

+ func (r *ExplainRequest) Validate() error

+ type ExplainResponse struct

+ Explanation map[string]any

+ Id string

+ Index string

+ Matched bool

+ type FeaturesGetResponse struct

+ Features []struct{ ... }

+ type FeaturesService interface

+ GetFeatures func(ctx context.Context) (*FeaturesGetResponse, error)

+ ResetFeatures func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func NewFeaturesService(client *resty.Client, logger *logrus.Entry) FeaturesService

+ type FieldCapsParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ Fields []string

+ IgnoreUnavailable *bool

+ IncludeUnmapped *bool

+ func (p *FieldCapsParams) ToMap() map[string]string

+ type FieldCapsRequest struct

+ Body any

+ Indices []string

+ Params *FieldCapsParams

+ type FieldStatistics struct

+ DocCount int64

+ SumDocFreq int64

+ SumTtf int64

+ type FleetGlobalCheckpointsParams struct

+ Checkpoints []string

+ Common *CommonParams

+ Timeout string

+ WaitForAdvance *bool

+ WaitForIndex *bool

+ func (p *FleetGlobalCheckpointsParams) ToMap() map[string]string

+ type FleetGlobalCheckpointsResponse struct

+ GlobalCheckpoints []int64

+ TimedOut bool

+ type FleetService interface

+ GlobalCheckpoints func(ctx context.Context, index string, params *FleetGlobalCheckpointsParams) (*FleetGlobalCheckpointsResponse, error)

+ func NewFleetService(client *resty.Client, logger *logrus.Entry) FleetService

+ type GetAliasParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Local *bool

+ func (p *GetAliasParams) ToMap() map[string]string

+ type GetAliasRequest struct

+ Indices []string

+ Names []string

+ Params *GetAliasParams

+ type GetFieldMappingParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ IncludeDefaults *bool

+ Local *bool

+ func (p *GetFieldMappingParams) ToMap() map[string]string

+ type GetFieldMappingRequest struct

+ Fields []string

+ Indices []string

+ Params *GetFieldMappingParams

+ func (r *GetFieldMappingRequest) Validate() error

+ type GetParams struct

+ Common *CommonParams

+ ForceSyntheticSource *bool

+ Preference string

+ Realtime *bool

+ Refresh *bool

+ Routing string

+ Source string

+ SourceExcludes []string

+ SourceIncludes []string

+ StoredFields []string

+ Version *int64

+ VersionType VersionType

+ func (p *GetParams) ToMap() map[string]string

+ type GetRequest struct

+ Id string

+ Index string

+ Params *GetParams

+ func (r *GetRequest) Validate() error

+ type GetResult struct

+ Error *types.ElasticsearchErrorDetails

+ Fields map[string]any

+ Found bool

+ Id string

+ Index string

+ PrimaryTerm *int64

+ SeqNo *int64

+ Source json.RawMessage

+ Version *int64

+ type GetSettingsParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ FlatSettings *bool

+ IgnoreUnavailable *bool

+ IncludeDefaults *bool

+ Local *bool

+ func (p *GetSettingsParams) ToMap() map[string]string

+ type GetSettingsRequest struct

+ Indices []string

+ Names []string

+ Params *GetSettingsParams

+ type GetSourceParams = GetParams

+ type GetSourceRequest struct

+ Id string

+ Index string

+ Params *GetSourceParams

+ func (r *GetSourceRequest) Validate() error

+ type GraphExploreParams struct

+ Common *CommonParams

+ Routing string

+ Timeout string

+ func (p *GraphExploreParams) ToMap() map[string]string

+ type GraphExploreResponse struct

+ Connections []map[string]any

+ Failures []map[string]any

+ TimeOut bool

+ Took int64

+ Vertices []map[string]any

+ type GraphService interface

+ Explore func(ctx context.Context, index string, body any, params *GraphExploreParams) (*GraphExploreResponse, error)

+ func NewGraphService(client *resty.Client, logger *logrus.Entry) GraphService

+ type GroupBy string

+ const GroupByNodes

+ const GroupByNone

+ const GroupByParents

+ type HealthIndicator struct

+ Detail string

+ Diagnoses []struct{ ... }

+ Impacts []struct{ ... }

+ Status string

+ Summary string

+ UserActions []struct{ ... }

+ type HealthReportParams struct

+ Common *CommonParams

+ Size *int

+ Time string

+ Verbose *bool

+ func (p *HealthReportParams) ToMap() map[string]string

+ type HealthReportResponse struct

+ ClusterName string

+ Indicators map[string]HealthIndicator

+ Status string

+ type HealthReportService interface

+ Get func(ctx context.Context, feature string, params *HealthReportParams) (*HealthReportResponse, error)

+ func NewHealthReportService(client *resty.Client, logger *logrus.Entry) HealthReportService

+ type HealthStatus string

+ const HealthStatusGreen

+ const HealthStatusRed

+ const HealthStatusYellow

+ type IlmExplainParams struct

+ Common *CommonParams

+ OnlyErrors *bool

+ OnlyManaged *bool

+ func (p *IlmExplainParams) ToMap() map[string]string

+ type IlmExplainResponse struct

+ Indices map[string]struct{ ... }

+ type IlmMigrateToDataTiersResponse struct

+ DryRun bool

+ MigratedComponentTemplates []string

+ MigratedComposableTemplates []string

+ MigratedIlmPolicies []string

+ MigratedIndices []string

+ MigratedLegacyTemplates []string

+ RemovedClusterSettings []string

+ RemovedIndexSettings []string

+ RemovedLegacyTemplate []string

+ type IlmPolicy struct

+ InUse bool

+ ModifiedDate string

+ ModifiedDateMillis int64

+ Policy map[string]any

+ Version int

+ type IlmRemovePolicyResponse struct

+ FailedIndexes []string

+ HasFailures bool

+ type IlmService interface

+ DeleteLifecycle func(ctx context.Context, policy string) (*types.AcknowledgedResponse, error)

+ ExplainLifecycle func(ctx context.Context, indices []string, params *IlmExplainParams) (*IlmExplainResponse, error)

+ GetLifecycle func(ctx context.Context, policies []string) (map[string]*IlmPolicy, error)

+ GetStatus func(ctx context.Context) (*IlmStatusResponse, error)

+ MigrateToDataTiers func(ctx context.Context, dryRun *bool) (*IlmMigrateToDataTiersResponse, error)

+ MoveToStep func(ctx context.Context, index string, body any) (*types.AcknowledgedResponse, error)

+ PutLifecycle func(ctx context.Context, policy string, body any) (*types.AcknowledgedResponse, error)

+ RemovePolicy func(ctx context.Context, indices []string) (*IlmRemovePolicyResponse, error)

+ Retry func(ctx context.Context, indices []string) (*types.AcknowledgedResponse, error)

+ Start func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ Stop func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func NewIlmService(client *resty.Client, logger *logrus.Entry) IlmService

+ type IlmStatusResponse struct

+ OperationMode string

+ type IndexParams struct

+ Common *CommonParams

+ IfPrimaryTerm *int64

+ IfSeqNo *int64

+ OpType OpType

+ Pipeline string

+ Refresh Refresh

+ RequireAlias *bool

+ Timeout string

+ Version *int64

+ VersionType VersionType

+ WaitForActiveShards string

+ func (p *IndexParams) ToMap() map[string]string

+ type IndexRecovery struct

+ Shards []ShardRecovery

+ type IndexRequest struct

+ Body any

+ Id string

+ Index string

+ Params *IndexParams

+ func (r *IndexRequest) Validate() error

+ type IndexResponse struct

+ ForcedRefresh bool

+ Id string

+ Index string

+ PrimaryTerm int64

+ Result string

+ SeqNo int64

+ Shards *types.ShardsInfo

+ Status int

+ Version int64

+ type IndexSegmentRouting struct

+ Node string

+ Primary bool

+ State string

+ type IndexSegmentShard struct

+ NumCommittedSegments int

+ NumSearchSegments int

+ Routing IndexSegmentRouting

+ Segments map[string]Segment

+ type IndexShardStores struct

+ Stores []ShardStore

+ type IndexStats struct

+ Primaries *IndexStatsDetail

+ Total *IndexStatsDetail

+ type IndexStatsDetail struct

+ Completion map[string]any

+ Docs map[string]any

+ Fielddata map[string]any

+ Flush map[string]any

+ Get map[string]any

+ Indexing map[string]any

+ Merges map[string]any

+ QueryCache map[string]any

+ Recovery map[string]any

+ Refresh map[string]any

+ RequestCache map[string]any

+ Search map[string]any

+ Segments map[string]any

+ Store map[string]any

+ Translog map[string]any

+ Warmer map[string]any

+ type IndexTemplate struct

+ AllowAutoCreate *bool

+ ComposedOf []string

+ DataStream map[string]any

+ IndexPatterns []string

+ Priority *int

+ Template TemplateBody

+ Version *int

+ type IndexTemplateItem struct

+ IndexTemplate IndexTemplate

+ Name string

+ type IndicesAnalyzeResponse struct

+ Tokens []AnalyzeToken

+ type IndicesBlockResponse struct

+ Acknowledged bool

+ Indices []map[string]any

+ Shards *types.ShardsInfo

+ type IndicesClearCacheParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ Fielddata *bool

+ Fields []string

+ IgnoreUnavailable *bool

+ Query *bool

+ func (p *IndicesClearCacheParams) ToMap() map[string]string

+ type IndicesCloseParams = IndicesOpenParams

+ type IndicesCreateDataStreamParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *IndicesCreateDataStreamParams) ToMap() map[string]string

+ type IndicesCreateParams struct

+ Common *CommonParams

+ WaitForActiveShards string

+ func (p *IndicesCreateParams) ToMap() map[string]string

+ type IndicesDataStreamGetResponse struct

+ DataStreams []DataStream

+ type IndicesDataStreamsStatsResponse struct

+ BackingIndices int

+ DataStreamCount int

+ DataStreams []struct{ ... }

+ Shards *types.ShardsInfo

+ TotalStoreSizeBytes int64

+ type IndicesDeleteDataStreamParams struct

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ func (p *IndicesDeleteDataStreamParams) ToMap() map[string]string

+ type IndicesDeleteIndexTemplateParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *IndicesDeleteIndexTemplateParams) ToMap() map[string]string

+ type IndicesDeleteParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ func (p *IndicesDeleteParams) ToMap() map[string]string

+ type IndicesDeleteTemplateParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *IndicesDeleteTemplateParams) ToMap() map[string]string

+ type IndicesExistsParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ FlatSettings *bool

+ IgnoreUnavailable *bool

+ IncludeDefaults *bool

+ Local *bool

+ func (p *IndicesExistsParams) ToMap() map[string]string

+ type IndicesFlushParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ Force *bool

+ IgnoreUnavailable *bool

+ WaitIfOngoing *bool

+ func (p *IndicesFlushParams) ToMap() map[string]string

+ type IndicesForceMergeParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ Flush *bool

+ IgnoreUnavailable *bool

+ MaxNumSegments *int

+ OnlyExpungeDeletes *bool

+ func (p *IndicesForceMergeParams) ToMap() map[string]string

+ type IndicesGetAliasResponse struct

+ Aliases map[string]AliasInfo

+ type IndicesGetDataStreamParams struct

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IncludeDefaults *bool

+ func (p *IndicesGetDataStreamParams) ToMap() map[string]string

+ type IndicesGetIndexTemplateParams struct

+ Common *CommonParams

+ FlatSettings *bool

+ Local *bool

+ func (p *IndicesGetIndexTemplateParams) ToMap() map[string]string

+ type IndicesGetIndexTemplateResponse struct

+ IndexTemplates []IndexTemplateItem

+ type IndicesGetMappingParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Local *bool

+ func (p *IndicesGetMappingParams) ToMap() map[string]string

+ type IndicesGetMappingResponse struct

+ Mappings map[string]any

+ type IndicesGetParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ Features []string

+ FlatSettings *bool

+ IgnoreUnavailable *bool

+ IncludeDefaults *bool

+ Local *bool

+ func (p *IndicesGetParams) ToMap() map[string]string

+ type IndicesGetResponse struct

+ Aliases map[string]AliasInfo

+ DataStream string

+ Defaults map[string]any

+ Mappings map[string]any

+ Settings map[string]any

+ System bool

+ type IndicesGetSettingsResponse struct

+ Defaults map[string]any

+ Settings map[string]any

+ type IndicesGetTemplateParams struct

+ Common *CommonParams

+ FlatSettings *bool

+ Local *bool

+ func (p *IndicesGetTemplateParams) ToMap() map[string]string

+ type IndicesGetTemplateResponse struct

+ Aliases map[string]any

+ Deprecated bool

+ IndexPatterns []string

+ Mappings map[string]any

+ Order int

+ Settings map[string]any

+ Version int

+ type IndicesOpenParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Timeout string

+ WaitForActiveShards string

+ func (p *IndicesOpenParams) ToMap() map[string]string

+ type IndicesPutSettingsParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ FlatSettings *bool

+ IgnoreUnavailable *bool

+ PreserveExisting *bool

+ Timeout string

+ func (p *IndicesPutSettingsParams) ToMap() map[string]string

+ type IndicesRecoveryParams struct

+ ActiveOnly *bool

+ Common *CommonParams

+ Detailed *bool

+ func (p *IndicesRecoveryParams) ToMap() map[string]string

+ type IndicesRecoveryResponse map[string]IndexRecovery

+ type IndicesRefreshParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ func (p *IndicesRefreshParams) ToMap() map[string]string

+ type IndicesReloadAnalyzersParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ func (p *IndicesReloadAnalyzersParams) ToMap() map[string]string

+ type IndicesReloadAnalyzersResponse struct

+ ReloadDetails []ReloadDetails

+ Shards *types.ShardsInfo

+ type IndicesResolveClusterParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ func (p *IndicesResolveClusterParams) ToMap() map[string]string

+ type IndicesResolveIndexParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ func (p *IndicesResolveIndexParams) ToMap() map[string]string

+ type IndicesResolveIndexResponse struct

+ Aliases []ResolveAliasInfo

+ DataStreams []ResolveDataStreamInfo

+ Indices []ResolveIndexInfo

+ type IndicesRolloverResponse struct

+ Acknowledged bool

+ Conditions map[string]bool

+ DryRun bool

+ NewIndex string

+ OldIndex string

+ RolledOver bool

+ Shards *types.ShardsInfo

+ ShardsAcknowledged bool

+ type IndicesSegmentsParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Verbose *bool

+ func (p *IndicesSegmentsParams) ToMap() map[string]string

+ type IndicesSegmentsResponse struct

+ Indices map[string]struct{ ... }

+ Shards *types.ShardsInfo

+ type IndicesService interface

+ AddBlock func(ctx context.Context, req *AddBlockRequest) (*IndicesBlockResponse, error)

+ Analyze func(ctx context.Context, index string, body any) (*IndicesAnalyzeResponse, error)

+ ClearCache func(ctx context.Context, indices []string, params *IndicesClearCacheParams) (*types.BroadcastResponse, error)

+ Clone func(ctx context.Context, req *CloneRequest) (*types.AcknowledgedResponse, error)

+ Close func(ctx context.Context, indices []string, params *IndicesCloseParams) (*types.AcknowledgedResponse, error)

+ Create func(ctx context.Context, index string, body any, params *IndicesCreateParams) (*types.AcknowledgedResponse, error)

+ CreateDataStream func(ctx context.Context, name string, body any, ...) (*types.AcknowledgedResponse, error)

+ DataStreamStats func(ctx context.Context, names []string) (*IndicesDataStreamsStatsResponse, error)

+ Delete func(ctx context.Context, indices []string, params *IndicesDeleteParams) (*types.AcknowledgedResponse, error)

+ DeleteAlias func(ctx context.Context, req *DeleteAliasRequest) (*types.AcknowledgedResponse, error)

+ DeleteDataStream func(ctx context.Context, names []string, params *IndicesDeleteDataStreamParams) (*types.AcknowledgedResponse, error)

+ DeleteIndexTemplate func(ctx context.Context, name string, params *IndicesDeleteIndexTemplateParams) (*types.AcknowledgedResponse, error)

+ DeleteTemplate func(ctx context.Context, name string, params *IndicesDeleteTemplateParams) (*types.AcknowledgedResponse, error)

+ Downsample func(ctx context.Context, index, targetIndex string, body any) (*types.AcknowledgedResponse, error)

+ Exists func(ctx context.Context, indices []string, params *IndicesExistsParams) (bool, error)

+ ExistsAlias func(ctx context.Context, req *ExistsAliasRequest) (bool, error)

+ ExistsIndexTemplate func(ctx context.Context, name string) (bool, error)

+ ExistsTemplate func(ctx context.Context, name string) (bool, error)

+ Flush func(ctx context.Context, indices []string, params *IndicesFlushParams) (*types.BroadcastResponse, error)

+ ForceMerge func(ctx context.Context, indices []string, params *IndicesForceMergeParams) (*types.BroadcastResponse, error)

+ Get func(ctx context.Context, indices []string, params *IndicesGetParams) (map[string]*IndicesGetResponse, error)

+ GetAlias func(ctx context.Context, req *GetAliasRequest) (map[string]*IndicesGetAliasResponse, error)

+ GetDataStream func(ctx context.Context, names []string, params *IndicesGetDataStreamParams) (*IndicesDataStreamGetResponse, error)

+ GetFieldMapping func(ctx context.Context, req *GetFieldMappingRequest) (map[string]any, error)

+ GetIndexTemplate func(ctx context.Context, names []string, params *IndicesGetIndexTemplateParams) (*IndicesGetIndexTemplateResponse, error)

+ GetMapping func(ctx context.Context, indices []string, params *IndicesGetMappingParams) (map[string]*IndicesGetMappingResponse, error)

+ GetSettings func(ctx context.Context, req *GetSettingsRequest) (map[string]*IndicesGetSettingsResponse, error)

+ GetTemplate func(ctx context.Context, names []string, params *IndicesGetTemplateParams) (map[string]*IndicesGetTemplateResponse, error)

+ MigrateToDataStream func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ ModifyDataStream func(ctx context.Context, req *ModifyDataStreamRequest) (*types.AcknowledgedResponse, error)

+ Open func(ctx context.Context, indices []string, params *IndicesOpenParams) (*types.AcknowledgedResponse, error)

+ PromoteDataStream func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ PutAlias func(ctx context.Context, req *PutAliasRequest) (*types.AcknowledgedResponse, error)

+ PutIndexTemplate func(ctx context.Context, req *PutIndexTemplateRequest) (*types.AcknowledgedResponse, error)

+ PutMapping func(ctx context.Context, req *PutMappingRequest) (*types.AcknowledgedResponse, error)

+ PutSettings func(ctx context.Context, indices []string, body any, ...) (*types.AcknowledgedResponse, error)

+ PutTemplate func(ctx context.Context, req *PutTemplateRequest) (*types.AcknowledgedResponse, error)

+ Recovery func(ctx context.Context, indices []string, params *IndicesRecoveryParams) (*IndicesRecoveryResponse, error)

+ Refresh func(ctx context.Context, indices []string, params *IndicesRefreshParams) (*RefreshResult, error)

+ ReloadSearchAnalyzers func(ctx context.Context, indices []string, params *IndicesReloadAnalyzersParams) (*IndicesReloadAnalyzersResponse, error)

+ ResolveCluster func(ctx context.Context, names []string, params *IndicesResolveClusterParams) (map[string]*ResolveClusterInfo, error)

+ ResolveIndex func(ctx context.Context, name string, params *IndicesResolveIndexParams) (*IndicesResolveIndexResponse, error)

+ Rollover func(ctx context.Context, req *RolloverRequest) (*IndicesRolloverResponse, error)

+ Segments func(ctx context.Context, indices []string, params *IndicesSegmentsParams) (*IndicesSegmentsResponse, error)

+ ShardStores func(ctx context.Context, indices []string, params *IndicesShardStoresParams) (*IndicesShardStoresResponse, error)

+ Shrink func(ctx context.Context, req *ShrinkRequest) (*types.AcknowledgedResponse, error)

+ SimulateIndexTemplate func(ctx context.Context, req *SimulateIndexTemplateRequest) (*IndicesSimulateTemplateResponse, error)

+ SimulateTemplate func(ctx context.Context, req *SimulateTemplateRequest) (*IndicesSimulateTemplateResponse, error)

+ Split func(ctx context.Context, req *SplitRequest) (*types.AcknowledgedResponse, error)

+ Stats func(ctx context.Context, req *IndicesStatsRequest) (*IndicesStatsResponse, error)

+ UpdateAliases func(ctx context.Context, body any, params *IndicesUpdateAliasesParams) (*types.AcknowledgedResponse, error)

+ func NewIndicesService(client *resty.Client, logger *logrus.Entry) IndicesService

+ type IndicesShardStoresParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Status []string

+ func (p *IndicesShardStoresParams) ToMap() map[string]string

+ type IndicesShardStoresResponse struct

+ Indices map[string]struct{ ... }

+ type IndicesSimulateTemplateResponse struct

+ Overlapping []struct{ ... }

+ Template TemplateBody

+ type IndicesStatsParams struct

+ Common *CommonParams

+ CompletionFields []string

+ ExpandWildcards ExpandWildcards

+ FielddataFields []string

+ Fields []string

+ ForbidClosedIndices *bool

+ Groups []string

+ IncludeSegmentFileSizes *bool

+ IncludeUnloadedSegments *bool

+ Level Level

+ func (p *IndicesStatsParams) ToMap() map[string]string

+ type IndicesStatsRequest struct

+ Indices []string

+ Metrics []string

+ Params *IndicesStatsParams

+ type IndicesStatsResponse struct

+ All *IndexStats

+ DataStreams map[string]any

+ Indices map[string]*IndexStats

+ Shards *types.ShardsInfo

+ type IndicesUpdateAliasesParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *IndicesUpdateAliasesParams) ToMap() map[string]string

+ type InferenceDeleteParams struct

+ Common *CommonParams

+ DryRun *bool

+ Force *bool

+ func (p *InferenceDeleteParams) ToMap() map[string]string

+ type InferenceGetResponse struct

+ InferenceID string

+ Service string

+ ServiceSettings map[string]any

+ TaskSettings map[string]any

+ TaskType string

+ type InferenceService interface

+ Completion func(ctx context.Context, inferenceId string, body any) (json.RawMessage, error)

+ Delete func(ctx context.Context, taskType, inferenceId string, ...) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, inferenceId, taskType string) (json.RawMessage, error)

+ Inference func(ctx context.Context, inferenceId string, body any) (json.RawMessage, error)

+ Put func(ctx context.Context, taskType, inferenceId string, body any) (*types.AcknowledgedResponse, error)

+ Rerank func(ctx context.Context, inferenceId string, body any) (json.RawMessage, error)

+ Update func(ctx context.Context, inferenceId string, body any) (*types.AcknowledgedResponse, error)

+ func NewInferenceService(client *resty.Client, logger *logrus.Entry) InferenceService

+ type InfoResponse struct

+ ClusterName string

+ ClusterUUID string

+ Name string

+ Tagline string

+ Version *InfoVersion

+ type InfoService interface

+ Capabilities func(ctx context.Context, req *CapabilitiesRequest) (*CapabilitiesResponse, error)

+ Info func(ctx context.Context) (*InfoResponse, error)

+ Ping func(ctx context.Context) (bool, error)

+ func NewInfoService(client *resty.Client, logger *logrus.Entry) InfoService

+ type InfoVersion struct

+ BuildDate string

+ BuildFlavor string

+ BuildHash string

+ BuildSnapshot bool

+ BuildType string

+ LuceneVersion string

+ MinimumIndexCompat string

+ MinimumWireCompat string

+ Number string

+ type IngestDeletePipelineParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *IngestDeletePipelineParams) ToMap() map[string]string

+ type IngestGetPipelineParams struct

+ Common *CommonParams

+ Summary *bool

+ func (p *IngestGetPipelineParams) ToMap() map[string]string

+ type IngestGrokResponse struct

+ Patterns map[string]string

+ type IngestPipeline struct

+ Deprecated bool

+ Description string

+ OnFailure []map[string]any

+ Processors []map[string]any

+ Version int

+ type IngestPutPipelineParams struct

+ Common *CommonParams

+ IfVersion *int

+ Timeout string

+ func (p *IngestPutPipelineParams) ToMap() map[string]string

+ type IngestPutPipelineRequest struct

+ Body any

+ Id string

+ Params *IngestPutPipelineParams

+ func (r *IngestPutPipelineRequest) Validate() error

+ type IngestService interface

+ DeletePipeline func(ctx context.Context, id string, params *IngestDeletePipelineParams) (*types.AcknowledgedResponse, error)

+ GetPipeline func(ctx context.Context, ids []string, params *IngestGetPipelineParams) (map[string]*IngestPipeline, error)

+ ProcessorGrok func(ctx context.Context) (*IngestGrokResponse, error)

+ PutPipeline func(ctx context.Context, req *IngestPutPipelineRequest) (*types.AcknowledgedResponse, error)

+ Simulate func(ctx context.Context, req *IngestSimulatePipelineRequest) (*IngestSimulateResponse, error)

+ func NewIngestService(client *resty.Client, logger *logrus.Entry) IngestService

+ type IngestSimulatePipelineParams struct

+ Common *CommonParams

+ Verbose *bool

+ func (p *IngestSimulatePipelineParams) ToMap() map[string]string

+ type IngestSimulatePipelineRequest struct

+ Body any

+ Id string

+ Params *IngestSimulatePipelineParams

+ func (r *IngestSimulatePipelineRequest) Validate() error

+ type IngestSimulateResponse struct

+ Docs []struct{ ... }

+ type Level string

+ const LevelCluster

+ const LevelIndices

+ const LevelShards

+ type LicenseGetParams struct

+ Common *CommonParams

+ Local *bool

+ func (p *LicenseGetParams) ToMap() map[string]string

+ type LicenseGetResponse struct

+ License LicenseInfo

+ type LicenseInfo struct

+ ExpiryDate string

+ ExpiryDateInMillis int64

+ IssueDate string

+ IssueDateInMillis int64

+ IssuedTo string

+ Issuer string

+ MaxNodes int

+ Signature string

+ StartDate string

+ StartDateInMillis int64

+ Status string

+ Type string

+ UID string

+ type LicensePostParams struct

+ Acknowledge *bool

+ Common *CommonParams

+ func (p *LicensePostParams) ToMap() map[string]string

+ type LicenseService interface

+ Delete func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, params *LicenseGetParams) (*LicenseGetResponse, error)

+ GetBasicStatus func(ctx context.Context) (json.RawMessage, error)

+ GetTrialStatus func(ctx context.Context) (json.RawMessage, error)

+ Post func(ctx context.Context, body any, params *LicensePostParams) (*types.AcknowledgedResponse, error)

+ PostStartBasic func(ctx context.Context, params *LicensePostParams) (json.RawMessage, error)

+ PostStartTrial func(ctx context.Context, params *LicenseStartTrialParams) (json.RawMessage, error)

+ func NewLicenseService(client *resty.Client, logger *logrus.Entry) LicenseService

+ type LicenseStartTrialParams struct

+ Acknowledge *bool

+ Common *CommonParams

+ Type string

+ func (p *LicenseStartTrialParams) ToMap() map[string]string

+ type LogstashService interface

+ DeletePipeline func(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ GetPipeline func(ctx context.Context, ids []string) (map[string]map[string]any, error)

+ PutPipeline func(ctx context.Context, id string, body any) (*types.AcknowledgedResponse, error)

+ func NewLogstashService(client *resty.Client, logger *logrus.Entry) LogstashService

+ type MgetParams struct

+ Common *CommonParams

+ ForceSyntheticSource *bool

+ Preference string

+ Realtime *bool

+ Refresh *bool

+ Routing string

+ Source string

+ SourceExcludes []string

+ SourceIncludes []string

+ StoredFields []string

+ func (p *MgetParams) ToMap() map[string]string

+ type MgetRequest struct

+ Body any

+ Index string

+ Params *MgetParams

+ func (r *MgetRequest) Validate() error

+ type MgetResponse struct

+ Docs []*GetResult

+ type MigrationDeprecationsResponse struct

+ ClusterSettings []map[string]any

+ IndexSettings map[string][]map[string]any

+ MLSettings []map[string]any

+ NodeSettings []map[string]any

+ type MigrationFeatureUpgradeStatusResponse struct

+ Features []struct{ ... }

+ type MigrationService interface

+ Deprecations func(ctx context.Context, index string) (*MigrationDeprecationsResponse, error)

+ GetFeatureUpgradeStatus func(ctx context.Context) (*MigrationFeatureUpgradeStatusResponse, error)

+ PostFeatureUpgrade func(ctx context.Context) (json.RawMessage, error)

+ func NewMigrationService(client *resty.Client, logger *logrus.Entry) MigrationService

+ type MlCloseJobParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ Force *bool

+ Timeout string

+ func (p *MlCloseJobParams) ToMap() map[string]string

+ type MlCloseJobResponse struct

+ Closed bool

+ type MlDatafeedConfig struct

+ ChunkingConfig map[string]any

+ DatafeedId string

+ Frequency *int

+ Indices []string

+ JobId string

+ Query map[string]any

+ type MlDeleteDatafeedParams struct

+ Common *CommonParams

+ Force *bool

+ func (p *MlDeleteDatafeedParams) ToMap() map[string]string

+ type MlDeleteJobParams struct

+ Common *CommonParams

+ Force *bool

+ WaitForCompletion *bool

+ func (p *MlDeleteJobParams) ToMap() map[string]string

+ type MlDeleteJobResponse struct

+ Acknowledged bool

+ type MlFilter struct

+ Description string

+ FilterId string

+ Items []string

+ type MlFlushJobParams struct

+ AdvanceTime string

+ CalcInterim *bool

+ Common *CommonParams

+ End string

+ SkipTime string

+ Start string

+ func (p *MlFlushJobParams) ToMap() map[string]string

+ type MlFlushJobResponse struct

+ Flushed bool

+ Last string

+ type MlGetDatafeedsParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ ExcludeGenerated *bool

+ func (p *MlGetDatafeedsParams) ToMap() map[string]string

+ type MlGetDatafeedsResponse struct

+ Count int

+ Datafeeds []MlDatafeedConfig

+ type MlGetFiltersParams struct

+ Common *CommonParams

+ From *int

+ Size *int

+ func (p *MlGetFiltersParams) ToMap() map[string]string

+ type MlGetFiltersResponse struct

+ Count int

+ Filters []MlFilter

+ type MlGetJobsParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ ExcludeGenerated *bool

+ func (p *MlGetJobsParams) ToMap() map[string]string

+ type MlGetJobsResponse struct

+ Count int

+ Jobs []MlJobConfig

+ type MlGetTrainedModelsParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ DecompressDefinition *bool

+ ExcludeGenerated *bool

+ From *int

+ Include string

+ Size *int

+ Tags []string

+ func (p *MlGetTrainedModelsParams) ToMap() map[string]string

+ type MlGetTrainedModelsResponse struct

+ Count int

+ TrainedModels []MlTrainedModelConfig

+ type MlInferTrainedModelParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *MlInferTrainedModelParams) ToMap() map[string]string

+ type MlJobConfig struct

+ AllowLazyOpen *bool

+ AnalysisConfig map[string]any

+ AnalysisLimits map[string]any

+ CustomSettings map[string]any

+ DataDescription map[string]any

+ Description string

+ JobId string

+ MaxModelMemory string

+ ModelSnapshotRetentionDays *int

+ ResultsRetentionDays *int

+ type MlOpenJobParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *MlOpenJobParams) ToMap() map[string]string

+ type MlOpenJobResponse struct

+ Opened bool

+ type MlResetJobParams struct

+ Common *CommonParams

+ WaitForCompletion *bool

+ func (p *MlResetJobParams) ToMap() map[string]string

+ type MlService interface

+ CloseJob func(ctx context.Context, jobId string, params *MlCloseJobParams) (*MlCloseJobResponse, error)

+ DeleteDatafeed func(ctx context.Context, datafeedId string, params *MlDeleteDatafeedParams) (*types.AcknowledgedResponse, error)

+ DeleteJob func(ctx context.Context, jobId string, params *MlDeleteJobParams) (*MlDeleteJobResponse, error)

+ FlushJob func(ctx context.Context, jobId string, body any, params *MlFlushJobParams) (*MlFlushJobResponse, error)

+ GetDatafeeds func(ctx context.Context, datafeedIds []string, params *MlGetDatafeedsParams) (*MlGetDatafeedsResponse, error)

+ GetFilters func(ctx context.Context, filterId string, params *MlGetFiltersParams) (*MlGetFiltersResponse, error)

+ GetJobs func(ctx context.Context, jobIds []string, params *MlGetJobsParams) (*MlGetJobsResponse, error)

+ GetTrainedModels func(ctx context.Context, modelIds []string, params *MlGetTrainedModelsParams) (*MlGetTrainedModelsResponse, error)

+ InferTrainedModel func(ctx context.Context, modelId string, body any, ...) (json.RawMessage, error)

+ OpenJob func(ctx context.Context, jobId string, params *MlOpenJobParams) (*MlOpenJobResponse, error)

+ PutDatafeed func(ctx context.Context, datafeedId string, body any) (*MlDatafeedConfig, error)

+ PutJob func(ctx context.Context, jobId string, body any) (*MlJobConfig, error)

+ ResetJob func(ctx context.Context, jobId string, params *MlResetJobParams) (*types.AcknowledgedResponse, error)

+ StartDatafeed func(ctx context.Context, datafeedId string, body any, ...) (*MlStartDatafeedResponse, error)

+ StopDatafeed func(ctx context.Context, datafeedId string, params *MlStopDatafeedParams) (*MlStopDatafeedResponse, error)

+ func NewMlService(client *resty.Client, logger *logrus.Entry) MlService

+ type MlStartDatafeedParams struct

+ Common *CommonParams

+ End string

+ Start string

+ Timeout string

+ func (p *MlStartDatafeedParams) ToMap() map[string]string

+ type MlStartDatafeedResponse struct

+ Started bool

+ type MlStopDatafeedParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ Force *bool

+ Timeout string

+ func (p *MlStopDatafeedParams) ToMap() map[string]string

+ type MlStopDatafeedResponse struct

+ Stopped bool

+ type MlTrainedModelConfig struct

+ Definition map[string]any

+ Input map[string]any

+ ModelId string

+ Type string

+ type ModifyDataStreamAction struct

+ DataStream string

+ Index string

+ Type string

+ type ModifyDataStreamParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *ModifyDataStreamParams) ToMap() map[string]string

+ type ModifyDataStreamRequest struct

+ Actions []*ModifyDataStreamAction

+ Params *ModifyDataStreamParams

+ func (r *ModifyDataStreamRequest) Validate() error

+ type MtermvectorsParams = TermVectorsParams

+ type MtermvectorsRequest struct

+ Body any

+ Index string

+ Params *MtermvectorsParams

+ type MultiSearchParams struct

+ CcsMinimizeRoundtrips *bool

+ Common *CommonParams

+ MaxConcurrentSearches *int

+ MaxConcurrentShardRequests *int

+ PreFilterShardSize *int

+ RestTotalHitsAsInt *bool

+ SearchType SearchType

+ TypedKeys *bool

+ func (p *MultiSearchParams) ToMap() map[string]string

+ type MultiSearchRequest struct

+ Body string

+ Indices []string

+ Params *MultiSearchParams

+ func (r *MultiSearchRequest) Validate() error

+ type MultiSearchTemplateParams struct

+ CcsMinimizeRoundtrips *bool

+ Common *CommonParams

+ MaxConcurrentSearches *int

+ RestTotalHitsAsInt *bool

+ SearchType SearchType

+ TypedKeys *bool

+ func (p *MultiSearchTemplateParams) ToMap() map[string]string

+ type MultiSearchTemplateRequest struct

+ Body string

+ Indices []string

+ Params *MultiSearchTemplateParams

+ func (r *MultiSearchTemplateRequest) Validate() error

+ type MultiTermvectorResponse struct

+ Docs []*TermvectorsResponse

+ type NodeInfo struct

+ Aggregations map[string]any

+ Attributes map[string]string

+ BuildDate string

+ BuildHash string

+ BuildType string

+ HTTP map[string]any

+ Host string

+ IP string

+ Ingest map[string]any

+ JVM map[string]any

+ Modules []PluginInfo

+ Name string

+ OS map[string]any

+ Plugins []PluginInfo

+ Process map[string]any

+ Roles []string

+ Settings map[string]any

+ ThreadPool map[string]any

+ Transport map[string]any

+ TransportAddress string

+ Version string

+ type NodeStats struct

+ AdaptiveSelection map[string]any

+ Attributes map[string]string

+ Breakers map[string]any

+ Discovery map[string]any

+ FS map[string]any

+ HTTP map[string]any

+ Host string

+ IP string

+ IndexingPressure map[string]any

+ Indices map[string]any

+ Ingest map[string]any

+ JVM map[string]any

+ Name string

+ OS map[string]any

+ Process map[string]any

+ Roles []string

+ Script map[string]any

+ ThreadPool map[string]any

+ Timestamp int64

+ Transport map[string]any

+ TransportAddress string

+ type NodesHotThreadsParams struct

+ Common *CommonParams

+ IgnoreIdleThreads *bool

+ Interval string

+ Snapshots *int

+ Sort string

+ Threads *int

+ Timeout string

+ Type string

+ func (p *NodesHotThreadsParams) ToMap() map[string]string

+ type NodesInfoParams struct

+ Common *CommonParams

+ FlatSettings *bool

+ Timeout string

+ func (p *NodesInfoParams) ToMap() map[string]string

+ type NodesInfoRequest struct

+ Metrics []string

+ NodeIds []string

+ Params *NodesInfoParams

+ type NodesInfoResponse struct

+ ClusterName string

+ Nodes map[string]NodeInfo

+ type NodesReloadSecureSettingsParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *NodesReloadSecureSettingsParams) ToMap() map[string]string

+ type NodesReloadSecureSettingsResponse struct

+ ClusterName string

+ Failures []*types.FailedNodeException

+ Nodes map[string]any

+ type NodesService interface

+ HotThreads func(ctx context.Context, nodeIds []string, params *NodesHotThreadsParams) (string, error)

+ Info func(ctx context.Context, req *NodesInfoRequest) (*NodesInfoResponse, error)

+ ReloadSecureSettings func(ctx context.Context, nodeIds []string, body any, ...) (*NodesReloadSecureSettingsResponse, error)

+ Stats func(ctx context.Context, req *NodesStatsRequest) (*NodesStatsResponse, error)

+ Usage func(ctx context.Context, req *NodesUsageRequest) (*NodesUsageResponse, error)

+ func NewNodesService(client *resty.Client, logger *logrus.Entry) NodesService

+ type NodesStatsParams struct

+ Common *CommonParams

+ CompletionFields []string

+ FielddataFields []string

+ Fields []string

+ Groups []string

+ IncludeSegmentFileSizes *bool

+ Level Level

+ Timeout string

+ Types []string

+ func (p *NodesStatsParams) ToMap() map[string]string

+ type NodesStatsRequest struct

+ IndexMetrics []string

+ Metrics []string

+ NodeIds []string

+ Params *NodesStatsParams

+ type NodesStatsResponse struct

+ ClusterName string

+ Nodes map[string]NodeStats

+ type NodesUsageParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *NodesUsageParams) ToMap() map[string]string

+ type NodesUsageRequest struct

+ Metrics []string

+ NodeIds []string

+ Params *NodesUsageParams

+ type NodesUsageResponse struct

+ ClusterName string

+ Nodes map[string]struct{ ... }

+ type OpType string

+ const OpTypeCreate

+ const OpTypeIndex

+ type OpenPITParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ KeepAlive string

+ Preference string

+ Routing string

+ func (p *OpenPITParams) ToMap() map[string]string

+ type OpenPITRequest struct

+ Indices []string

+ Params *OpenPITParams

+ func (r *OpenPITRequest) Validate() error

+ type OpenPITResponse struct

+ Id string

+ type PluginInfo struct

+ Classname string

+ Description string

+ ElasticsearchVersion string

+ ExtendedPlugins []string

+ HasNativeController bool

+ JavaVersion string

+ Name string

+ Version string

+ type PutAliasRequest struct

+ Alias string

+ Body any

+ Index string

+ Params *AliasParams

+ func (r *PutAliasRequest) Validate() error

+ type PutComponentTemplateParams struct

+ Cause string

+ Common *CommonParams

+ Create *bool

+ Timeout string

+ func (p *PutComponentTemplateParams) ToMap() map[string]string

+ type PutComponentTemplateRequest struct

+ Body any

+ Name string

+ Params *PutComponentTemplateParams

+ func (r *PutComponentTemplateRequest) Validate() error

+ type PutIndexTemplateParams struct

+ Cause string

+ Common *CommonParams

+ Create *bool

+ func (p *PutIndexTemplateParams) ToMap() map[string]string

+ type PutIndexTemplateRequest struct

+ Body any

+ Name string

+ Params *PutIndexTemplateParams

+ func (r *PutIndexTemplateRequest) Validate() error

+ type PutMappingParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Timeout string

+ WriteIndexOnly *bool

+ func (p *PutMappingParams) ToMap() map[string]string

+ type PutMappingRequest struct

+ Body any

+ Indices []string

+ Params *PutMappingParams

+ func (r *PutMappingRequest) Validate() error

+ type PutTemplateParams struct

+ Common *CommonParams

+ Create *bool

+ FlatSettings *bool

+ Order *int

+ Timeout string

+ func (p *PutTemplateParams) ToMap() map[string]string

+ type PutTemplateRequest struct

+ Body any

+ Name string

+ Params *PutTemplateParams

+ func (r *PutTemplateRequest) Validate() error

+ type QueryRulesListParams struct

+ Common *CommonParams

+ From *int

+ Size *int

+ func (p *QueryRulesListParams) ToMap() map[string]string

+ type QueryRulesService interface

+ DeleteRuleset func(ctx context.Context, rulesetId string) (*types.AcknowledgedResponse, error)

+ GetRuleset func(ctx context.Context, rulesetId string) (json.RawMessage, error)

+ ListRulesets func(ctx context.Context, params *QueryRulesListParams) (json.RawMessage, error)

+ PutRuleset func(ctx context.Context, rulesetId string, body any) (*types.AcknowledgedResponse, error)

+ Test func(ctx context.Context, rulesetId string, body any, params *QueryRulesTestParams) (json.RawMessage, error)

+ func NewQueryRulesService(client *resty.Client, logger *logrus.Entry) QueryRulesService

+ type QueryRulesTestParams struct

+ Common *CommonParams

+ QueryParams []string

+ QueryText string

+ func (p *QueryRulesTestParams) ToMap() map[string]string

+ type RankEvalParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ SearchType SearchType

+ func (p *RankEvalParams) ToMap() map[string]string

+ type RankEvalRequest struct

+ Body any

+ Indices []string

+ Params *RankEvalParams

+ func (r *RankEvalRequest) Validate() error

+ type RecoveryNode struct

+ Host string

+ Name string

+ TransportAddress string

+ type Refresh string

+ const RefreshFalse

+ const RefreshTrue

+ const RefreshWaitFor

+ type RefreshResult struct

+ Shards *types.ShardsInfo

+ type ReindexParams struct

+ Common *CommonParams

+ MaxDocs *int

+ Refresh *bool

+ RequestsPerSecond *float64

+ RequireAlias *bool

+ Scroll string

+ Slices string

+ Timeout string

+ WaitForActiveShards string

+ WaitForCompletion *bool

+ func (p *ReindexParams) ToMap() map[string]string

+ type ReindexRequest struct

+ Body any

+ Params *ReindexParams

+ type ReloadDetails struct

+ Index string

+ Node string

+ ReloadedAnalyzers []string

+ type RenderSearchTemplateRequest struct

+ Body any

+ Id string

+ type ResolveAliasInfo struct

+ Indices []string

+ Name string

+ type ResolveClusterInfo struct

+ ClusterCredentials string

+ Connected bool

+ Mode string

+ Seeds []string

+ SkipUnavailable bool

+ type ResolveDataStreamInfo struct

+ Aliases []string

+ BackingIndices []string

+ Name string

+ type ResolveIndexInfo struct

+ Aliases []string

+ Attributes []string

+ Name string

+ type RethrottleParams struct

+ Common *CommonParams

+ RequestsPerSecond *float64

+ func (p *RethrottleParams) ToMap() map[string]string

+ type RethrottleRequest struct

+ Params *RethrottleParams

+ RequestsPerSecond float64

+ TaskId string

+ func (r *RethrottleRequest) Validate() error

+ type RolloverParams struct

+ Common *CommonParams

+ DryRun *bool

+ Timeout string

+ WaitForActiveShards string

+ func (p *RolloverParams) ToMap() map[string]string

+ type RolloverRequest struct

+ Alias string

+ Body any

+ NewIndex string

+ Params *RolloverParams

+ func (r *RolloverRequest) Validate() error

+ type Script struct

+ Lang string

+ Options map[string]any

+ Source string

+ type ScriptContextInfo struct

+ Context string

+ Methods []ScriptContextMethod

+ type ScriptContextMethod struct

+ Name string

+ Params []string

+ type ScriptContextResponse struct

+ Contexts []ScriptContextInfo

+ type ScriptDeleteParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *ScriptDeleteParams) ToMap() map[string]string

+ type ScriptGetParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *ScriptGetParams) ToMap() map[string]string

+ type ScriptGetResponse struct

+ Found bool

+ Id string

+ Script *Script

+ type ScriptLanguageContext struct

+ Contexts []string

+ Language string

+ type ScriptLanguagesResponse struct

+ LanguageContexts []ScriptLanguageContext

+ TypesAllowed []string

+ type ScriptPutParams struct

+ Common *CommonParams

+ Context string

+ Timeout string

+ func (p *ScriptPutParams) ToMap() map[string]string

+ type ScriptPutRequest struct

+ Body any

+ Id string

+ Params *ScriptPutParams

+ func (r *ScriptPutRequest) Validate() error

+ type ScriptService interface

+ Delete func(ctx context.Context, id string, params *ScriptDeleteParams) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, id string, params *ScriptGetParams) (*ScriptGetResponse, error)

+ GetContext func(ctx context.Context) (*ScriptContextResponse, error)

+ GetLanguages func(ctx context.Context) (*ScriptLanguagesResponse, error)

+ Put func(ctx context.Context, req *ScriptPutRequest) (*types.AcknowledgedResponse, error)

+ func NewScriptService(client *resty.Client, logger *logrus.Entry) ScriptService

+ type ScrollParams struct

+ Common *CommonParams

+ RestTotalHitsAsInt *bool

+ Scroll string

+ ScrollId string

+ func (p *ScrollParams) ToMap() map[string]string

+ type ScrollRequest struct

+ Params *ScrollParams

+ Scroll string

+ ScrollId string

+ type SearchApplicationListParams struct

+ Common *CommonParams

+ From *int

+ Size *int

+ func (p *SearchApplicationListParams) ToMap() map[string]string

+ type SearchApplicationPutParams struct

+ Common *CommonParams

+ Create *bool

+ func (p *SearchApplicationPutParams) ToMap() map[string]string

+ type SearchApplicationService interface

+ Delete func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ DeleteBehavioralAnalytics func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, name string) (json.RawMessage, error)

+ GetBehavioralAnalytics func(ctx context.Context, name string) (json.RawMessage, error)

+ List func(ctx context.Context, params *SearchApplicationListParams) (json.RawMessage, error)

+ Put func(ctx context.Context, name string, body any, params *SearchApplicationPutParams) (*types.AcknowledgedResponse, error)

+ PutBehavioralAnalytics func(ctx context.Context, name string, body any) (*types.AcknowledgedResponse, error)

+ Search func(ctx context.Context, name string, body any) (*querydsl.SearchResult, error)

+ func NewSearchApplicationService(client *resty.Client, logger *logrus.Entry) SearchApplicationService

+ type SearchMVTParams struct

+ Common *CommonParams

+ ExactBounds *bool

+ Extent *int

+ GridAgg string

+ GridPrecision *int

+ GridType string

+ Size *int

+ TrackTotalHits string

+ WithLabels *bool

+ func (p *SearchMVTParams) ToMap() map[string]string

+ type SearchMVTRequest struct

+ Body any

+ Field string

+ Index string

+ Params *SearchMVTParams

+ X *int

+ Y *int

+ Zoom *int

+ func (r *SearchMVTRequest) Validate() error

+ type SearchParams struct

+ AllowNoIndices *bool

+ AllowPartialSearchResults *bool

+ AnalyzeWildcard *bool

+ Analyzer string

+ BatchedReduceSize *int

+ CcsMinimizeRoundtrips *bool

+ Common *CommonParams

+ DefaultOperator DefaultOperator

+ Df string

+ DocvalueFields []string

+ ExpandWildcards ExpandWildcards

+ Explain *bool

+ From *int

+ IgnoreThrottled *bool

+ IgnoreUnavailable *bool

+ Lenient *bool

+ MaxConcurrentShardRequests *int

+ MinCompatibleShardNode string

+ PreFilterShardSize *int

+ Preference string

+ Q string

+ RequestCache *bool

+ RestTotalHitsAsInt *bool

+ Routing string

+ Scroll string

+ SearchType SearchType

+ SeqNoPrimaryTerm *bool

+ Size *int

+ Sort []string

+ Source string

+ SourceExcludes []string

+ SourceIncludes []string

+ Stats []string

+ StoredFields []string

+ SuggestField string

+ SuggestMode SuggestMode

+ SuggestSize *int

+ SuggestText string

+ TerminateAfter *int

+ Timeout string

+ TrackScores *bool

+ TrackTotalHits string

+ TypedKeys *bool

+ Version *bool

+ func (p *SearchParams) ToMap() map[string]string

+ type SearchRequest struct

+ Body any

+ Indices []string

+ Params *SearchParams

+ RequestId string

+ func NewSearchRequest(r *querydsl.SearchRequest) (*SearchRequest, error)

+ type SearchService interface

+ ClearScroll func(ctx context.Context, scrollIds []string) (*querydsl.ClearScrollResponse, error)

+ ClosePointInTime func(ctx context.Context, pitIds []string) (*ClosePITResponse, error)

+ Count func(ctx context.Context, req *CountRequest) (int64, error)

+ FieldCaps func(ctx context.Context, req *FieldCapsRequest) (*querydsl.FieldCapsResponse, error)

+ MultiSearch func(ctx context.Context, req *MultiSearchRequest) (*querydsl.MultiSearchResult, error)

+ MultiSearchTemplate func(ctx context.Context, req *MultiSearchTemplateRequest) (*querydsl.MultiSearchResult, error)

+ OpenPointInTime func(ctx context.Context, req *OpenPITRequest) (*OpenPITResponse, error)

+ RankEval func(ctx context.Context, req *RankEvalRequest) (*querydsl.RankEvalResponse, error)

+ RenderSearchTemplate func(ctx context.Context, req *RenderSearchTemplateRequest) (*querydsl.RenderSearchTemplateResponse, error)

+ ScriptsPainlessExec func(ctx context.Context, body any) (json.RawMessage, error)

+ Scroll func(ctx context.Context, req *ScrollRequest) (*querydsl.SearchResult, error)

+ Search func(ctx context.Context, req *SearchRequest) (*querydsl.SearchResult, error)

+ SearchMVT func(ctx context.Context, req *SearchMVTRequest) (json.RawMessage, error)

+ SearchShards func(ctx context.Context, req *SearchShardsRequest) (*querydsl.SearchShardsResponse, error)

+ SearchTemplate func(ctx context.Context, req *SearchTemplateRequest) (*querydsl.SearchResult, error)

+ Validate func(ctx context.Context, req *ValidateQueryRequest) (*querydsl.ValidateResponse, error)

+ func NewSearchService(client *resty.Client, logger *logrus.Entry) SearchService

+ type SearchShardsParams struct

+ AllowNoIndices *bool

+ Common *CommonParams

+ ExpandWildcards ExpandWildcards

+ IgnoreUnavailable *bool

+ Local *bool

+ Preference string

+ Routing string

+ func (p *SearchShardsParams) ToMap() map[string]string

+ type SearchShardsRequest struct

+ Indices []string

+ Params *SearchShardsParams

+ type SearchTemplateParams struct

+ AllowNoIndices *bool

+ CcsMinimizeRoundtrips *bool

+ Common *CommonParams

+ Explain *bool

+ IgnoreThrottled *bool

+ IgnoreUnavailable *bool

+ Preference string

+ Profile *bool

+ RestTotalHitsAsInt *bool

+ Routing string

+ Scroll string

+ SearchType SearchType

+ TypedKeys *bool

+ func (p *SearchTemplateParams) ToMap() map[string]string

+ type SearchTemplateRequest struct

+ Body any

+ Indices []string

+ Params *SearchTemplateParams

+ func (r *SearchTemplateRequest) Validate() error

+ type SearchType string

+ const SearchTypeDfsQueryThenFetch

+ const SearchTypeQueryThenFetch

+ type SearchableSnapshotsMountParams struct

+ Common *CommonParams

+ WaitForActiveShards string

+ WaitForCompletion *bool

+ func (p *SearchableSnapshotsMountParams) ToMap() map[string]string

+ type SearchableSnapshotsService interface

+ CacheStats func(ctx context.Context, nodeIds []string) (json.RawMessage, error)

+ ClearCache func(ctx context.Context, indices []string) (*types.AcknowledgedResponse, error)

+ Mount func(ctx context.Context, repository, snapshot string, body any, ...) (json.RawMessage, error)

+ RepositoryStats func(ctx context.Context, repository string) (json.RawMessage, error)

+ Stats func(ctx context.Context, indices []string, params *SearchableSnapshotsStatsParams) (json.RawMessage, error)

+ func NewSearchableSnapshotsService(client *resty.Client, logger *logrus.Entry) SearchableSnapshotsService

+ type SearchableSnapshotsStatsParams struct

+ Common *CommonParams

+ Level Level

+ func (p *SearchableSnapshotsStatsParams) ToMap() map[string]string

+ type SecurityAPIKey struct

+ Creation int64

+ Descriptors []map[string]any

+ Expiration int64

+ ID string

+ Invalidated bool

+ Name string

+ Realm string

+ Type string

+ Username string

+ type SecurityAuthenticateResponse struct

+ AuthenticationRealm struct{ ... }

+ AuthenticationType string

+ Email string

+ FullName string

+ LookupRealm struct{ ... }

+ Metadata map[string]any

+ Roles []string

+ Username string

+ type SecurityClearRealmCacheParams struct

+ Common *CommonParams

+ Usernames []string

+ func (p *SecurityClearRealmCacheParams) ToMap() map[string]string

+ type SecurityCreateAPIKeyResponse struct

+ APIKey string

+ Encoded string

+ Expiration int64

+ ID string

+ Name string

+ type SecurityCreateResponse struct

+ Created bool

+ type SecurityGetAPIKeyParams struct

+ ActiveOnly *bool

+ Common *CommonParams

+ ID string

+ Name string

+ Owner *bool

+ RealmName string

+ Username string

+ WithLimitedPrivileges *bool

+ WithProfileUid *bool

+ func (p *SecurityGetAPIKeyParams) ToMap() map[string]string

+ type SecurityGetAPIKeyResponse struct

+ APIKeys []SecurityAPIKey

+ type SecurityGetTokenResponse struct

+ AccessToken string

+ ExpiresIn int

+ RefreshToken string

+ Scope string

+ Type string

+ type SecurityHasPrivilegesResponse struct

+ HasPrivilege map[string]any

+ Username string

+ type SecurityInvalidateAPIKeyResponse struct

+ Errors []map[string]any

+ InvalidatedAPIKeys []string

+ PreviouslyInvalidatedAPIKeys []string

+ type SecurityInvalidateTokenResponse struct

+ CreatedTokens []string

+ ErrorsCount int

+ InvalidatedTokens int

+ PreviouslyInvalidatedTokens int

+ type SecurityPutPrivilegesResponse struct

+ Created map[string]map[string]bool

+ type SecurityRole struct

+ Applications []SecurityRoleApplication

+ Cluster []string

+ Indices []SecurityRoleIndex

+ Metadata map[string]any

+ RunAs []string

+ TransientMetadata map[string]any

+ type SecurityRoleApplication struct

+ Application string

+ Privileges []string

+ Resources []string

+ type SecurityRoleIndex struct

+ AllowRestrictedIndices *bool

+ FieldSecurity map[string]any

+ Names []string

+ Privileges []string

+ Query string

+ type SecurityRoleMapping struct

+ Enabled bool

+ Metadata map[string]any

+ RoleTemplates []map[string]any

+ Roles []string

+ Rules map[string]any

+ type SecurityRoleMappingCreateResponse struct

+ Created bool

+ type SecurityService interface

+ Authenticate func(ctx context.Context) (*SecurityAuthenticateResponse, error)

+ ChangePassword func(ctx context.Context, username string, body any) (*types.AcknowledgedResponse, error)

+ ClearRealmCache func(ctx context.Context, realms []string, params *SecurityClearRealmCacheParams) (*types.AcknowledgedResponse, error)

+ ClearRoleCache func(ctx context.Context, names []string) (*types.AcknowledgedResponse, error)

+ CreateAPIKey func(ctx context.Context, body any) (*SecurityCreateAPIKeyResponse, error)

+ DeletePrivileges func(ctx context.Context, application, name string) (*types.AcknowledgedResponse, error)

+ DeleteRole func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ DeleteRoleMapping func(ctx context.Context, name string) (*types.AcknowledgedResponse, error)

+ DeleteUser func(ctx context.Context, username string) (*types.AcknowledgedResponse, error)

+ DisableUser func(ctx context.Context, username string) (*types.AcknowledgedResponse, error)

+ EnableUser func(ctx context.Context, username string) (*types.AcknowledgedResponse, error)

+ GetAPIKey func(ctx context.Context, params *SecurityGetAPIKeyParams) (*SecurityGetAPIKeyResponse, error)

+ GetPrivileges func(ctx context.Context, application, name string) (map[string]any, error)

+ GetRole func(ctx context.Context, names []string) (map[string]*SecurityRole, error)

+ GetRoleMapping func(ctx context.Context, names []string) (map[string]*SecurityRoleMapping, error)

+ GetToken func(ctx context.Context, body any) (*SecurityGetTokenResponse, error)

+ GetUser func(ctx context.Context, usernames []string) (map[string]*SecurityUser, error)

+ GetUserPrivileges func(ctx context.Context) (map[string]any, error)

+ HasPrivileges func(ctx context.Context, body any) (*SecurityHasPrivilegesResponse, error)

+ InvalidateAPIKey func(ctx context.Context, body any) (*SecurityInvalidateAPIKeyResponse, error)

+ InvalidateToken func(ctx context.Context, body any) (*SecurityInvalidateTokenResponse, error)

+ PutPrivileges func(ctx context.Context, body any) (*SecurityPutPrivilegesResponse, error)

+ PutRole func(ctx context.Context, name string, body any) (*SecurityCreateResponse, error)

+ PutRoleMapping func(ctx context.Context, name string, body any) (*SecurityRoleMappingCreateResponse, error)

+ PutUser func(ctx context.Context, username string, body any) (*SecurityCreateResponse, error)

+ UpdateAPIKey func(ctx context.Context, id string, body any) (*SecurityUpdateAPIKeyResponse, error)

+ func NewSecurityService(client *resty.Client, logger *logrus.Entry) SecurityService

+ type SecurityUpdateAPIKeyResponse struct

+ Updated bool

+ type SecurityUser struct

+ Email string

+ Enabled bool

+ FullName string

+ Metadata map[string]any

+ Roles []string

+ Username string

+ type Segment struct

+ Attributes map[string]string

+ Committed bool

+ Compound bool

+ DeletedDocs int

+ Generation int

+ NumDocs int

+ Search bool

+ SizeInBytes int64

+ Version string

+ type ShardRecovery struct

+ Index map[string]any

+ Primary bool

+ Source RecoveryNode

+ Stage string

+ StartTimeInMillis int64

+ StopTimeInMillis int64

+ Target RecoveryNode

+ TotalTimeInMillis int64

+ Type string

+ type ShardStore struct

+ Allocation string

+ ID string

+ Path string

+ StoreException ...

+ type ShrinkParams struct

+ Common *CommonParams

+ Timeout string

+ WaitForActiveShards string

+ func (p *ShrinkParams) ToMap() map[string]string

+ type ShrinkRequest struct

+ Body any

+ Params *ShrinkParams

+ Source string

+ Target string

+ func (r *ShrinkRequest) Validate() error

+ type ShutdownGetNodeResponse struct

+ Nodes []struct{ ... }

+ type ShutdownService interface

+ DeleteNode func(ctx context.Context, nodeId string) (*types.AcknowledgedResponse, error)

+ GetNode func(ctx context.Context, nodeId string) (*ShutdownGetNodeResponse, error)

+ PutNode func(ctx context.Context, nodeId string, body any) (*types.AcknowledgedResponse, error)

+ func NewShutdownService(client *resty.Client, logger *logrus.Entry) ShutdownService

+ type SimulateIndexTemplateParams struct

+ Cause string

+ Common *CommonParams

+ Create *bool

+ func (p *SimulateIndexTemplateParams) ToMap() map[string]string

+ type SimulateIndexTemplateRequest struct

+ Body any

+ Name string

+ Params *SimulateIndexTemplateParams

+ func (r *SimulateIndexTemplateRequest) Validate() error

+ type SimulateTemplateParams = SimulateIndexTemplateParams

+ type SimulateTemplateRequest struct

+ Body any

+ Name string

+ Params *SimulateTemplateParams

+ type SlmExecuteResponse struct

+ SnapshotName string

+ type SlmPolicy struct

+ Config map[string]any

+ ModifiedDate string

+ ModifiedDateMillis int64

+ Name string

+ NextExecutionMillis int64

+ Policy map[string]any

+ Retention map[string]any

+ SnapshotName string

+ Uuid string

+ Version int

+ type SlmService interface

+ DeleteLifecycle func(ctx context.Context, policyId string) (*types.AcknowledgedResponse, error)

+ ExecuteLifecycle func(ctx context.Context, policyId string) (*SlmExecuteResponse, error)

+ ExecuteRetention func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ GetLifecycle func(ctx context.Context, policyIds []string) (map[string]*SlmPolicy, error)

+ GetStats func(ctx context.Context) (*SlmStatsResponse, error)

+ GetStatus func(ctx context.Context) (*SlmStatusResponse, error)

+ PutLifecycle func(ctx context.Context, policyId string, body any) (*types.AcknowledgedResponse, error)

+ Start func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ Stop func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func NewSlmService(client *resty.Client, logger *logrus.Entry) SlmService

+ type SlmStatsResponse struct

+ PolicyStats []map[string]any

+ RetentionDeletionTime string

+ RetentionDeletionTimeMillis int64

+ RetentionFailed int64

+ RetentionRuns int64

+ RetentionTimedOut int64

+ TotalSnapshotDeletionFailures int64

+ TotalSnapshotDeletions int64

+ TotalSnapshotsFailed int64

+ TotalSnapshotsTaken int64

+ type SlmStatusResponse struct

+ OperationMode string

+ type SnapshotCleanupRepositoryParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *SnapshotCleanupRepositoryParams) ToMap() map[string]string

+ type SnapshotCleanupRepositoryResponse struct

+ DeletedBlobs int64

+ DeletedBytes int64

+ type SnapshotCloneRequest struct

+ Body any

+ Repository string

+ Snapshot string

+ TargetSnapshot string

+ func (r *SnapshotCloneRequest) Validate() error

+ type SnapshotCreateParams struct

+ Common *CommonParams

+ WaitForCompletion *bool

+ func (p *SnapshotCreateParams) ToMap() map[string]string

+ type SnapshotCreateRepositoryParams struct

+ Common *CommonParams

+ Timeout string

+ Verify *bool

+ func (p *SnapshotCreateRepositoryParams) ToMap() map[string]string

+ type SnapshotCreateRequest struct

+ Body any

+ Params *SnapshotCreateParams

+ Repository string

+ Snapshot string

+ func (r *SnapshotCreateRequest) Validate() error

+ type SnapshotCreateResponse struct

+ Snapshot SnapshotInfo

+ type SnapshotDeleteRepositoryParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *SnapshotDeleteRepositoryParams) ToMap() map[string]string

+ type SnapshotDeleteRequest struct

+ Repository string

+ Snapshot string

+ func (r *SnapshotDeleteRequest) Validate() error

+ type SnapshotGetParams struct

+ Common *CommonParams

+ IgnoreUnavailable *bool

+ IncludeRepository *bool

+ IndexDetails *bool

+ func (p *SnapshotGetParams) ToMap() map[string]string

+ type SnapshotGetRepositoryParams struct

+ Common *CommonParams

+ Local *bool

+ func (p *SnapshotGetRepositoryParams) ToMap() map[string]string

+ type SnapshotGetRequest struct

+ Params *SnapshotGetParams

+ Repository string

+ Snapshots []string

+ func (r *SnapshotGetRequest) Validate() error

+ type SnapshotGetResponse struct

+ Snapshots []SnapshotInfo

+ Total int

+ type SnapshotIndexStatus struct

+ Shards *types.ShardsInfo

+ Stats SnapshotStats

+ type SnapshotInfo struct

+ DataStreams []string

+ DurationInMillis int64

+ EndTime string

+ EndTimeInMillis int64

+ Failures []map[string]any

+ IncludeGlobalState *bool

+ Indices []string

+ Repository string

+ Shards *types.ShardsInfo

+ Snapshot string

+ StartTime string

+ StartTimeInMillis int64

+ State string

+ UUID string

+ Version string

+ VersionId string

+ type SnapshotRepository struct

+ Settings map[string]string

+ Type string

+ UUID string

+ type SnapshotRepositoryAnalyzeParams struct

+ BlobCount *int

+ Common *CommonParams

+ Concurrency *int

+ Detailed *bool

+ MaxBlobSize string

+ MaxTotalDataSize string

+ Seed *int

+ Timeout string

+ func (p *SnapshotRepositoryAnalyzeParams) ToMap() map[string]string

+ type SnapshotRepositoryAnalyzeResponse struct

+ BlobCount int

+ Concurrency int

+ CoordinatingNode string

+ Details []map[string]any

+ ReadNodeCount int

+ Summary map[string]any

+ type SnapshotRepositoryVerifyIntegrityParams struct

+ Common *CommonParams

+ IndexSnapshotVerification *bool

+ SnapshotVerification *bool

+ Timeout string

+ func (p *SnapshotRepositoryVerifyIntegrityParams) ToMap() map[string]string

+ type SnapshotRepositoryVerifyIntegrityResponse struct

+ Repositories []struct{ ... }

+ type SnapshotRestoreParams struct

+ Common *CommonParams

+ WaitForCompletion *bool

+ func (p *SnapshotRestoreParams) ToMap() map[string]string

+ type SnapshotRestoreRequest struct

+ Body any

+ Params *SnapshotRestoreParams

+ Repository string

+ Snapshot string

+ func (r *SnapshotRestoreRequest) Validate() error

+ type SnapshotRestoreResponse struct

+ Accepted bool

+ Snapshot struct{ ... }

+ type SnapshotService interface

+ CleanupRepository func(ctx context.Context, name string, params *SnapshotCleanupRepositoryParams) (*SnapshotCleanupRepositoryResponse, error)

+ Clone func(ctx context.Context, req *SnapshotCloneRequest) (*types.AcknowledgedResponse, error)

+ Create func(ctx context.Context, req *SnapshotCreateRequest) (*SnapshotCreateResponse, error)

+ CreateRepository func(ctx context.Context, name string, body any, ...) (*types.AcknowledgedResponse, error)

+ Delete func(ctx context.Context, req *SnapshotDeleteRequest) (*types.AcknowledgedResponse, error)

+ DeleteRepository func(ctx context.Context, names []string, params *SnapshotDeleteRepositoryParams) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, req *SnapshotGetRequest) (*SnapshotGetResponse, error)

+ GetRepository func(ctx context.Context, names []string, params *SnapshotGetRepositoryParams) (map[string]*SnapshotRepository, error)

+ RepositoryAnalyze func(ctx context.Context, name string, params *SnapshotRepositoryAnalyzeParams) (*SnapshotRepositoryAnalyzeResponse, error)

+ RepositoryVerifyIntegrity func(ctx context.Context, name string, ...) (*SnapshotRepositoryVerifyIntegrityResponse, error)

+ Restore func(ctx context.Context, req *SnapshotRestoreRequest) (*SnapshotRestoreResponse, error)

+ Status func(ctx context.Context, req *SnapshotStatusRequest) (*SnapshotStatusResponse, error)

+ VerifyRepository func(ctx context.Context, name string, params *SnapshotVerifyRepositoryParams) (*SnapshotVerifyRepositoryResponse, error)

+ func NewSnapshotService(client *resty.Client, logger *logrus.Entry) SnapshotService

+ type SnapshotStats struct

+ Incremental SnapshotStatsCount

+ StartTimeInMillis int64

+ TimeInMillis int64

+ Total SnapshotStatsCount

+ type SnapshotStatsCount struct

+ FileCount int

+ SizeInBytes int64

+ type SnapshotStatus struct

+ IncludeGlobalState *bool

+ Indices map[string]SnapshotIndexStatus

+ Repository string

+ Shards *types.ShardsInfo

+ Snapshot string

+ State string

+ UUID string

+ type SnapshotStatusParams struct

+ Common *CommonParams

+ IgnoreUnavailable *bool

+ func (p *SnapshotStatusParams) ToMap() map[string]string

+ type SnapshotStatusRequest struct

+ Params *SnapshotStatusParams

+ Repository string

+ Snapshots []string

+ type SnapshotStatusResponse struct

+ Snapshots []SnapshotStatus

+ type SnapshotVerifyRepositoryParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *SnapshotVerifyRepositoryParams) ToMap() map[string]string

+ type SnapshotVerifyRepositoryResponse struct

+ Nodes map[string]struct{ ... }

+ type SortOrder string

+ const SortOrderAsc

+ const SortOrderDesc

+ type SplitParams = ShrinkParams

+ type SplitRequest struct

+ Body any

+ Params *SplitParams

+ Source string

+ Target string

+ func (r *SplitRequest) Validate() error

+ type SqlAsyncStatusResponse struct

+ CompletionStatus int

+ ExpirationInMillis int64

+ ID string

+ IsPartial bool

+ IsRunning bool

+ StartInMillis int64

+ type SqlClearCursorResponse struct

+ Succeeded bool

+ type SqlGetAsyncParams struct

+ Common *CommonParams

+ Delimiter string

+ Format string

+ KeepAlive string

+ WaitForCompletionTimeout string

+ func (p *SqlGetAsyncParams) ToMap() map[string]string

+ type SqlQueryParams struct

+ Common *CommonParams

+ Format string

+ func (p *SqlQueryParams) ToMap() map[string]string

+ type SqlQueryResponse struct

+ Columns []struct{ ... }

+ Cursor string

+ IsRunning bool

+ Rows [][]any

+ type SqlService interface

+ ClearCursor func(ctx context.Context, body any) (*SqlClearCursorResponse, error)

+ DeleteAsync func(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ GetAsync func(ctx context.Context, id string, params *SqlGetAsyncParams) (*SqlQueryResponse, error)

+ GetAsyncStatus func(ctx context.Context, id string) (*SqlAsyncStatusResponse, error)

+ Query func(ctx context.Context, body any, params *SqlQueryParams) (*SqlQueryResponse, error)

+ Translate func(ctx context.Context, body any) (*SqlTranslateResponse, error)

+ func NewSqlService(client *resty.Client, logger *logrus.Entry) SqlService

+ type SqlTranslateResponse struct

+ Query map[string]any

+ Size int

+ Sort []map[string]any

+ type SslCertificate struct

+ Alias string

+ HasPrivateKey bool

+ IssuerDN string

+ NotAfter string

+ NotBefore string

+ Path string

+ SerialNumber string

+ SubjectDN string

+ Version string

+ type SslCertificatesResponse []SslCertificate

+ type SslService interface

+ Certificates func(ctx context.Context) (SslCertificatesResponse, error)

+ func NewSslService(client *resty.Client, logger *logrus.Entry) SslService

+ type StreamsService interface

+ LogsDisable func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ LogsEnable func(ctx context.Context, body any) (*types.AcknowledgedResponse, error)

+ Status func(ctx context.Context) (json.RawMessage, error)

+ func NewStreamsService(client *resty.Client, logger *logrus.Entry) StreamsService

+ type SuggestMode string

+ const SuggestModeAlways

+ const SuggestModeMissing

+ const SuggestModePopular

+ type SynonymRule struct

+ ID string

+ Synonyms string

+ Type string

+ type SynonymRulesResponse struct

+ Count int

+ Rules []SynonymRule

+ type SynonymSetItem struct

+ Count int

+ SynonymSet string

+ type SynonymsGetParams struct

+ Common *CommonParams

+ From *int

+ Size *int

+ func (p *SynonymsGetParams) ToMap() map[string]string

+ type SynonymsListParams struct

+ Common *CommonParams

+ From *int

+ Size *int

+ func (p *SynonymsListParams) ToMap() map[string]string

+ type SynonymsService interface

+ DeleteSynonym func(ctx context.Context, id string) (*types.AcknowledgedResponse, error)

+ DeleteSynonymRule func(ctx context.Context, id, ruleId string) (*types.AcknowledgedResponse, error)

+ GetSynonym func(ctx context.Context, id string, params *SynonymsGetParams) (*SynonymRulesResponse, error)

+ GetSynonymRule func(ctx context.Context, id, ruleId string) (*SynonymRule, error)

+ GetSynonymsSets func(ctx context.Context, params *SynonymsListParams) (*SynonymsSetsResponse, error)

+ PutSynonym func(ctx context.Context, id string, body any) (*types.AcknowledgedResponse, error)

+ PutSynonymRule func(ctx context.Context, id, ruleId string, body any) (*types.AcknowledgedResponse, error)

+ func NewSynonymsService(client *resty.Client, logger *logrus.Entry) SynonymsService

+ type SynonymsSetsResponse struct

+ Count int

+ Results []SynonymSetItem

+ type TaskGetResponse struct

+ Completed bool

+ Error *types.ElasticsearchErrorDetails

+ Response map[string]any

+ Task TaskInfo

+ type TaskInfo struct

+ Action string

+ Cancellable bool

+ Cancelled bool

+ Description string

+ Headers map[string]string

+ Id int64

+ Node string

+ ParentTaskId string

+ RunningTimeInNanos int64

+ StartTimeInMillis int64

+ Status map[string]any

+ Type string

+ type TaskNode struct

+ Host string

+ IP string

+ Name string

+ NodeID string

+ Tasks map[string]TaskInfo

+ TransportAddress string

+ type TasksCancelParams struct

+ Actions []string

+ Common *CommonParams

+ Nodes []string

+ ParentTaskId string

+ WaitForCompletion *bool

+ func (p *TasksCancelParams) ToMap() map[string]string

+ type TasksGetParams struct

+ Common *CommonParams

+ Timeout string

+ WaitForCompletion *bool

+ func (p *TasksGetParams) ToMap() map[string]string

+ type TasksListParams struct

+ Actions []string

+ Common *CommonParams

+ Detailed *bool

+ GroupBy GroupBy

+ Nodes []string

+ ParentTaskId string

+ Timeout string

+ WaitForCompletion *bool

+ func (p *TasksListParams) ToMap() map[string]string

+ type TasksListResponse struct

+ Nodes map[string]TaskNode

+ type TasksService interface

+ Cancel func(ctx context.Context, taskId string, params *TasksCancelParams) (*TasksListResponse, error)

+ Get func(ctx context.Context, taskId string, params *TasksGetParams) (*TaskGetResponse, error)

+ List func(ctx context.Context, params *TasksListParams) (*TasksListResponse, error)

+ func NewTasksService(client *resty.Client, logger *logrus.Entry) TasksService

+ type TemplateBody struct

+ Aliases map[string]any

+ Mappings map[string]any

+ Settings map[string]any

+ type TermVectorsFieldInfo struct

+ FieldStatistics FieldStatistics

+ Terms map[string]TermsInfo

+ type TermVectorsParams struct

+ Common *CommonParams

+ FieldStatistics *bool

+ Fields []string

+ Offsets *bool

+ Payloads *bool

+ Positions *bool

+ Preference string

+ Realtime *bool

+ Routing string

+ TermStatistics *bool

+ Version *int64

+ VersionType VersionType

+ func (p *TermVectorsParams) ToMap() map[string]string

+ type TermVectorsRequest struct

+ Body any

+ Id string

+ Index string

+ Params *TermVectorsParams

+ func (r *TermVectorsRequest) Validate() error

+ type TermsEnumParams struct

+ CaseInsensitive *bool

+ Common *CommonParams

+ func (p *TermsEnumParams) ToMap() map[string]string

+ type TermsEnumRequest struct

+ Body any

+ Index string

+ Params *TermsEnumParams

+ func (r *TermsEnumRequest) Validate() error

+ type TermsEnumResponse struct

+ Complete bool

+ Shards *types.ShardsInfo

+ Terms []string

+ type TermsInfo struct

+ DocFreq int64

+ Score float64

+ TermFreq int64

+ Tokens []TokenInfo

+ Ttf int64

+ type TermvectorsResponse struct

+ Found bool

+ Id string

+ Index string

+ TermVectors map[string]TermVectorsFieldInfo

+ Took int64

+ Version int

+ type TextStructureFindParams struct

+ Charset string

+ ColumnNames []string

+ Common *CommonParams

+ Delimiter string

+ Explain *bool

+ Format string

+ GrokPattern string

+ HasHeaderRow *bool

+ LineMergeSizeLimit *int

+ LinesToSample *int

+ Quote string

+ ShouldTrimFields *bool

+ TimestampField string

+ TimestampFormat string

+ func (p *TextStructureFindParams) ToMap() map[string]string

+ type TextStructureResponse struct

+ Charset string

+ ColumnNames []string

+ Delimiter string

+ Explanation []string

+ Format string

+ GrokPattern string

+ HasByteOrderMarker bool

+ HasHeaderRow bool

+ IngestPipeline map[string]any

+ LinesMerged int

+ Mappings map[string]any

+ NDJSON bool

+ NeedClientTimezone bool

+ NumLinesAnalyzed int

+ NumMessagesAnalyzed int

+ OriginalQuote string

+ Quote string

+ SampleSize int

+ SampleStart string

+ ShouldTrimFields bool

+ TimestampField string

+ TimestampFormat string

+ type TextStructureService interface

+ FindFieldStructure func(ctx context.Context, index, field string, params *TextStructureFindParams) (json.RawMessage, error)

+ FindMessageStructure func(ctx context.Context, index string, params *TextStructureFindParams) (json.RawMessage, error)

+ FindStructure func(ctx context.Context, body any, params *TextStructureFindParams) (*TextStructureResponse, error)

+ TestGrokPattern func(ctx context.Context, body any, params *TextStructureFindParams) (json.RawMessage, error)

+ func NewTextStructureService(client *resty.Client, logger *logrus.Entry) TextStructureService

+ type TimeType string

+ type TokenInfo struct

+ EndOffset int64

+ Payload string

+ Position int64

+ StartOffset int64

+ type TransformConfig struct

+ CreateTime int64

+ Description string

+ Dest map[string]any

+ Frequency string

+ ID string

+ Latest map[string]any

+ Meta map[string]any

+ Pivot map[string]any

+ Settings map[string]any

+ Source map[string]any

+ Sync map[string]any

+ Version *int

+ type TransformDeleteParams struct

+ Common *CommonParams

+ Force *bool

+ Timeout string

+ func (p *TransformDeleteParams) ToMap() map[string]string

+ type TransformGetParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ ExcludeGenerated *bool

+ From *int

+ Size *int

+ func (p *TransformGetParams) ToMap() map[string]string

+ type TransformGetResponse struct

+ Count int

+ Transforms []TransformConfig

+ type TransformGetStatsParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ From *int

+ Size *int

+ Timeout string

+ func (p *TransformGetStatsParams) ToMap() map[string]string

+ type TransformNodeStatsResponse struct

+ Nodes map[string]struct{ ... }

+ type TransformPreviewParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *TransformPreviewParams) ToMap() map[string]string

+ type TransformPreviewResponse struct

+ Preview []map[string]any

+ type TransformPutParams struct

+ Common *CommonParams

+ DeferValidation *bool

+ Timeout string

+ func (p *TransformPutParams) ToMap() map[string]string

+ type TransformPutResponse struct

+ Acknowledged bool

+ Created bool

+ type TransformResetParams struct

+ Common *CommonParams

+ Force *bool

+ Timeout string

+ func (p *TransformResetParams) ToMap() map[string]string

+ type TransformService interface

+ Delete func(ctx context.Context, transformId string, params *TransformDeleteParams) (*types.AcknowledgedResponse, error)

+ Get func(ctx context.Context, transformIds []string, params *TransformGetParams) (*TransformGetResponse, error)

+ GetNodeStats func(ctx context.Context) (*TransformNodeStatsResponse, error)

+ GetStats func(ctx context.Context, transformIds []string, params *TransformGetStatsParams) (*TransformStatsResponse, error)

+ Preview func(ctx context.Context, transformId string, body any, ...) (*TransformPreviewResponse, error)

+ Put func(ctx context.Context, transformId string, body any, params *TransformPutParams) (*TransformPutResponse, error)

+ Reset func(ctx context.Context, transformId string, params *TransformResetParams) (*types.AcknowledgedResponse, error)

+ ScheduleNow func(ctx context.Context, transformId string) (*types.AcknowledgedResponse, error)

+ Start func(ctx context.Context, transformId string, params *TransformStartParams) (*types.AcknowledgedResponse, error)

+ Stop func(ctx context.Context, transformId string, params *TransformStopParams) (*types.AcknowledgedResponse, error)

+ Upgrade func(ctx context.Context, params *TransformUpgradeParams) (*TransformUpgradeResponse, error)

+ func NewTransformService(client *resty.Client, logger *logrus.Entry) TransformService

+ type TransformStartParams struct

+ Common *CommonParams

+ Timeout string

+ func (p *TransformStartParams) ToMap() map[string]string

+ type TransformStats struct

+ CheckpointInfo map[string]any

+ Health map[string]any

+ ID string

+ Reason string

+ State string

+ Stats map[string]any

+ type TransformStatsResponse struct

+ Count int

+ Transforms []TransformStats

+ type TransformStopParams struct

+ AllowNoMatch *bool

+ Common *CommonParams

+ Force *bool

+ Timeout string

+ WaitForCheckpoint *bool

+ WaitForCompletion *bool

+ func (p *TransformStopParams) ToMap() map[string]string

+ type TransformUpgradeParams struct

+ Common *CommonParams

+ DryRun *bool

+ Timeout string

+ func (p *TransformUpgradeParams) ToMap() map[string]string

+ type TransformUpgradeResponse struct

+ DryRun bool

+ NeedsUpdate bool

+ NoAction []string

+ Updated []string

+ type UpdateByQueryParams struct

+ AnalyzeWildcard *bool

+ Analyzer string

+ Common *CommonParams

+ Conflicts Conflicts

+ DefaultOperator DefaultOperator

+ Df string

+ ExpandWildcards ExpandWildcards

+ From *int

+ IgnoreUnavailable *bool

+ Lenient *bool

+ MaxDocs *int

+ Pipeline string

+ Preference string

+ Q string

+ Refresh *bool

+ RequestCache *bool

+ RequestsPerSecond *float64

+ Routing string

+ Scroll string

+ ScrollSize *int

+ SearchTimeout string

+ SearchType SearchType

+ SliceId string

+ SliceMax *int

+ Slices string

+ Sort []string

+ Stats []string

+ TerminateAfter *int

+ Timeout string

+ Version *bool

+ VersionType VersionType

+ WaitForActiveShards string

+ WaitForCompletion *bool

+ func (p *UpdateByQueryParams) ToMap() map[string]string

+ type UpdateByQueryRequest struct

+ Body any

+ Indices []string

+ Params *UpdateByQueryParams

+ func (r *UpdateByQueryRequest) Validate() error

+ type UpdateParams struct

+ Common *CommonParams

+ IfPrimaryTerm *int64

+ IfSeqNo *int64

+ Lang string

+ Refresh Refresh

+ RequireAlias *bool

+ RetryOnConflict *int

+ Routing string

+ Source string

+ SourceExcludes []string

+ SourceIncludes []string

+ Timeout string

+ WaitForActiveShards string

+ func (p *UpdateParams) ToMap() map[string]string

+ type UpdateRequest struct

+ Body any

+ Id string

+ Index string

+ Params *UpdateParams

+ func (r *UpdateRequest) Validate() error

+ type UpdateResponse struct

+ ForcedRefresh bool

+ GetResult *GetResult

+ Id string

+ Index string

+ PrimaryTerm int64

+ Result string

+ SeqNo int64

+ Shards *types.ShardsInfo

+ Status int

+ Version int64

+ type ValidateQueryParams struct

+ AllShards *bool

+ AllowNoIndices *bool

+ AnalyzeWildcard *bool

+ Analyzer string

+ Common *CommonParams

+ DefaultOperator DefaultOperator

+ Df string

+ ExpandWildcards ExpandWildcards

+ Explain *bool

+ IgnoreUnavailable *bool

+ Lenient *bool

+ Q string

+ Rewrite *bool

+ func (p *ValidateQueryParams) ToMap() map[string]string

+ type ValidateQueryRequest struct

+ Body any

+ Indices []string

+ Params *ValidateQueryParams

+ type VersionType string

+ const VersionTypeExternal

+ const VersionTypeExternalGte

+ const VersionTypeInternal

+ type WaitForStatus string

+ const WaitForStatusGreen

+ const WaitForStatusRed

+ const WaitForStatusYellow

+ type WatcherAckWatchResponse struct

+ Status map[string]any

+ type WatcherActivateWatchResponse struct

+ Status map[string]any

+ type WatcherDeleteWatchResponse struct

+ Found bool

+ ID string

+ Version int64

+ type WatcherExecuteWatchParams struct

+ Common *CommonParams

+ Debug *bool

+ func (p *WatcherExecuteWatchParams) ToMap() map[string]string

+ type WatcherExecuteWatchResponse struct

+ ID string

+ WatchRecord map[string]any

+ type WatcherGetWatchResponse struct

+ Found bool

+ ID string

+ Status map[string]any

+ Watch map[string]any

+ type WatcherPutWatchParams struct

+ Active *bool

+ Common *CommonParams

+ IfPrimaryTerm *int64

+ IfSeqNo *int64

+ func (p *WatcherPutWatchParams) ToMap() map[string]string

+ type WatcherPutWatchResponse struct

+ Created bool

+ ID string

+ Version int64

+ type WatcherQueryWatchesResponse struct

+ Count int

+ Watches []struct{ ... }

+ type WatcherService interface

+ AckWatch func(ctx context.Context, id, actionId string) (*WatcherAckWatchResponse, error)

+ ActivateWatch func(ctx context.Context, id string) (*WatcherActivateWatchResponse, error)

+ DeactivateWatch func(ctx context.Context, id string) (*WatcherActivateWatchResponse, error)

+ DeleteWatch func(ctx context.Context, id string) (*WatcherDeleteWatchResponse, error)

+ ExecuteWatch func(ctx context.Context, id string, body any, params *WatcherExecuteWatchParams) (*WatcherExecuteWatchResponse, error)

+ GetWatch func(ctx context.Context, id string) (*WatcherGetWatchResponse, error)

+ PutWatch func(ctx context.Context, id string, body any, params *WatcherPutWatchParams) (*WatcherPutWatchResponse, error)

+ QueryWatches func(ctx context.Context, body any) (*WatcherQueryWatchesResponse, error)

+ Start func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ Stats func(ctx context.Context, metrics []string, params *WatcherStatsParams) (*WatcherStatsResponse, error)

+ Stop func(ctx context.Context) (*types.AcknowledgedResponse, error)

+ func NewWatcherService(client *resty.Client, logger *logrus.Entry) WatcherService

+ type WatcherStatsParams struct

+ Common *CommonParams

+ EmitStacktraces *bool

+ func (p *WatcherStatsParams) ToMap() map[string]string

+ type WatcherStatsResponse struct

+ CurrentWatches []map[string]any

+ Queues map[string]any

+ Stats map[string]any

+ WatcherState string

+ type XpackFeature struct

+ Available bool

+ Description string

+ Enabled bool

+ NativeRealms []string

+ type XpackInfoParams struct

+ Categories []string

+ Common *CommonParams

+ func (p *XpackInfoParams) ToMap() map[string]string

+ type XpackInfoResponse struct

+ Build map[string]any

+ Features map[string]XpackFeature

+ License map[string]any

+ Tagline string

+ type XpackService interface

+ Info func(ctx context.Context, params *XpackInfoParams) (*XpackInfoResponse, error)

+ Usage func(ctx context.Context) (XpackUsageResponse, error)

+ func NewXpackService(client *resty.Client, logger *logrus.Entry) XpackService

+ type XpackUsage struct

+ Available bool

+ Data map[string]any

+ Enabled bool

+ func (u *XpackUsage) UnmarshalJSON(b []byte) error

+ type XpackUsageResponse map[string]XpackUsage