eshandler

type ElasticsearchHandler interface {
	Client() (client elasticsearch.Client)

	// License scope
	LicenseUpdate(license string) (err error)
	LicenseDelete() (err error)
	LicenseGet() (license *esapi.LicenseInfo, err error)
	LicenseDiff(actual, expected *esapi.LicenseInfo) (diff bool)
	LicenseEnableBasic() (err error)

	// ILM scope
	ILMUpdate(name string, policy *esapi.IlmPolicy) (err error)
	ILMDelete(name string) (err error)
	ILMGet(name string) (policy *esapi.IlmPolicy, err error)
	ILMDiff(actualObject, expectedObject, originalObject *esapi.IlmPolicy) (patchResult *patch.PatchResult, err error)

	// SLM scope
	SLMUpdate(name string, policy *SnapshotLifecyclePolicySpec) (err error)
	SLMDelete(name string) (err error)
	SLMGet(name string) (policy *SnapshotLifecyclePolicySpec, err error)
	SLMDiff(actualObject, expectedObject, originalObject *SnapshotLifecyclePolicySpec) (patchResult *patch.PatchResult, err error)

	// Snapshot repository scope
	SnapshotRepositoryUpdate(name string, repository *esapi.SnapshotRepository) (err error)
	SnapshotRepositoryDelete(name string) (err error)
	SnapshotRepositoryGet(name string) (repository *esapi.SnapshotRepository, err error)
	SnapshotRepositoryDiff(actualObject, expectedObject, originalObject *esapi.SnapshotRepository) (patchResult *patch.PatchResult, err error)

	// Role scope
	RoleUpdate(name string, role *XPackSecurityRole) (err error)
	RoleDelete(name string) (err error)
	RoleGet(name string) (role *XPackSecurityRole, err error)
	RoleDiff(actualObject, expectedObject, originalObject *XPackSecurityRole) (patchResult *patch.PatchResult, err error)

	// Role mapping scope
	RoleMappingUpdate(name string, roleMapping *esapi.SecurityRoleMapping) (err error)
	RoleMappingDelete(name string) (err error)
	RoleMappingGet(name string) (roleMapping *esapi.SecurityRoleMapping, err error)
	RoleMappingDiff(actualObject, expectedObject, originalObject *esapi.SecurityRoleMapping) (patchResult *patch.PatchResult, err error)

	// User scope
	UserCreate(name string, user *SecurityPutUserRequest) (err error)
	UserUpdate(name string, user *SecurityPutUserRequest, isProtected ...bool) (err error)
	UserDelete(name string) (err error)
	UserGet(name string) (user *esapi.SecurityUser, err error)
	UserDiff(actualObject, expectedObject, originalObject *SecurityPutUserRequest) (patchResult *patch.PatchResult, err error)

	// Component template scope
	ComponentTemplateUpdate(name string, component *localpatch.ComponentTemplate) (err error)
	ComponentTemplateDelete(name string) (err error)
	ComponentTemplateGet(name string) (component *localpatch.ComponentTemplate, err error)
	ComponentTemplateDiff(actualObject, expectedObject, originalObject *localpatch.ComponentTemplate) (patchResult *patch.PatchResult, err error)

	// Index template scope
	IndexTemplateUpdate(name string, template *localpatch.IndexTemplate) (err error)
	IndexTemplateDelete(name string) (err error)
	IndexTemplateGet(name string) (template *localpatch.IndexTemplate, err error)
	IndexTemplateDiff(actualObject, expectedObject, originalObject *localpatch.IndexTemplate) (patchResult *patch.PatchResult, err error)

	// Watch scope
	WatchUpdate(name string, watch *XPackWatch) (err error)
	WatchDelete(name string) (err error)
	WatchGet(name string) (watch *XPackWatch, err error)
	WatchDiff(actualObject, expectedObject, originalObject *XPackWatch) (patchResult *patch.PatchResult, err error)

	// Ingest pipline scope
	IngestPipelineUpdate(name string, pipeline *esapi.IngestPipeline) (err error)
	IngestPipelineDelete(name string) (err error)
	IngestPipelineGet(name string) (pipeline *esapi.IngestPipeline, err error)
	IngestPipelineDiff(actualObject, expectedObject, originalObject *esapi.IngestPipeline) (patchResult *patch.PatchResult, err error)

	// Transform scope
	TransformUpdate(name string, transform *Transform) (err error)
	TransformDelete(name string) (err error)
	TransformGet(name string) (transform *Transform, err error)
	TransformDiff(actualObject, expectedObject, originalObject *Transform) (patchResult *patch.PatchResult, err error)

	// Cluster scope
	ClusterHealth() (health *esapi.ClusterHealthResponse, err error)
	EnableRoutingRebalance() (err error)
	DisableRoutingRebalance() (err error)
	EnableRoutingAllocation() (err error)
	DisableRoutingAllocation() (err error)

	SetLogger(log *logrus.Entry)
}

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

type ElasticsearchSLMConfig struct {
	ExpendWildcards    string            `json:"expand_wildcards,omitempty"`
	IgnoreUnavailable  bool              `json:"ignore_unavailable,omitempty"`
	IncludeGlobalState bool              `json:"include_global_state,omitempty"`
	Indices            []string          `json:"indices,omitempty"`
	FeatureStates      []string          `json:"feature_states,omitempty"`
	Metadata           map[string]string `json:"metadata,omitempty"`
	Partial            bool              `json:"partial,omitempty"`
}

type ElasticsearchSLMRetention struct {
	ExpireAfter string `json:"expire_after,omitempty"`
	MaxCount    int64  `json:"max_count,omitempty"`
	MinCount    int64  `json:"min_count,omitempty"`
}

type SecurityPutUserRequest struct {
	Enabled      bool           `json:"enabled,omitempty"`
	Email        string         `json:"email,omitempty"`
	FullName     string         `json:"full_name,omitempty"`
	Metadata     map[string]any `json:"metadata,omitempty"`
	Password     string         `json:"password,omitempty"`
	PasswordHash string         `json:"password_hash,omitempty"`
	Roles        []string       `json:"roles,omitempty"`
}

type SnapshotLifecyclePolicy map[string]*SnapshotLifecyclePolicyGet

type SnapshotLifecyclePolicyGet struct {
	Policy *SnapshotLifecyclePolicySpec `json:"policy"`
}

type SnapshotLifecyclePolicySpec struct {
	Schedule   string                     `json:"schedule"`
	Name       string                     `json:"name"`
	Repository string                     `json:"repository"`
	Config     ElasticsearchSLMConfig     `json:"config"`
	Retention  *ElasticsearchSLMRetention `json:"retention,omitempty"`
}

type Transform struct {
	Id          string              `json:"id,omitempty"`
	Version     string              `json:"version,omitempty"`
	CreateTime  int64               `json:"create_time,omitempty"`
	Description string              `json:"description,omitempty"`
	Destination *TransformDest      `json:"dest"`
	Frequency   string              `json:"frequency,omitempty"`
	Lastest     *TransformLatest    `json:"latest,omitempty"`
	Metadata    map[string]any      `json:"_meta,omitempty"`
	Pivot       *TransformPivot     `json:"pivot"`
	Retention   *TransformRetention `json:"retention_policy,omitempty"`
	Settings    map[string]any      `json:"settings,omitempty"`
	Source      *TransformSource    `json:"source"`
	Sync        *TransformSync      `json:"sync"`
}

type TransformDest struct {
	Index    string `json:"index"`
	Pipeline string `json:"pipeline,omitempty"`
}

type TransformGetResponse struct {
	Transforms []*Transform `json:"transforms"`
}

type TransformLatest struct {
	Sort      string   `json:"sort"`
	UniqueKey []string `json:"unique_key"`
}

type TransformPivot struct {
	GroupBy      map[string]any `json:"group_by"`
	Aggregations map[string]any `json:"aggregations"`
}

type TransformRetention struct {
	Time TransformRetentionTime `json:"time"`
}

type TransformRetentionTime struct {
	Field  string `json:"field"`
	MaxAge string `json:"max_age"`
}

type TransformSource struct {
	Index           []string `json:"index"`
	Query           any      `json:"query,omitempty"`
	RuntimeMappings any      `json:"runtime_mappings,omitempty"`
}

type TransformSync struct {
	Time TransformSyncTime `json:"time"`
}

type TransformSyncTime struct {
	Field string `json:"field"`
	Delay string `json:"delay,omitempty"`
}

type XPackSecurityApplicationPrivileges struct {
	Application string   `json:"application"`
	Privileges  []string `json:"privileges,omitempty"`
	Resources   []string `json:"resources,omitempty"`
}

type XPackSecurityIndicesPermissions struct {
	Names                  []string    `json:"names"`
	Privileges             []string    `json:"privileges"`
	FieldSecurity          interface{} `json:"field_security,omitempty"`
	Query                  string      `json:"query,omitempty"`
	AllowRestrictedIndices bool        `json:"allow_restricted_indices,omitempty"`
}

type XPackSecurityRole struct {
	RunAs             []string                             `json:"run_as,omitempty"`
	Cluster           []string                             `json:"cluster,omitempty"`
	Indices           []XPackSecurityIndicesPermissions    `json:"indices,omitempty"`
	Applications      []XPackSecurityApplicationPrivileges `json:"applications,omitempty"`
	Global            map[string]interface{}               `json:"global,omitempty"`
	Metadata          map[string]interface{}               `json:"metadata,omitempty"`
	TransientMetadata map[string]interface{}               `json:"transient_metadata,omitempty"`
}

type XPackWatch = map[string]any