Documentation ¶
Index ¶
- Variables
- func CreateIndex(esClient *elasticsearch.Client, index v1alpha1.Index) (ctrl.Result, error)
- func DeleteApikey(esClient *elasticsearch.Client, roleName string) (ctrl.Result, error)
- func DeleteIndex(esClient *elasticsearch.Client, indexName string) (ctrl.Result, error)
- func DeleteIndexIfEmpty(esClient *elasticsearch.Client, indexName string) (ctrl.Result, error)
- func DeleteIndexLifecyclePolicy(esClient *elasticsearch.Client, indexLifecyclePolicyName string) (ctrl.Result, error)
- func DeleteIndexTemplate(esClient *elasticsearch.Client, indexTemplateName string) (ctrl.Result, error)
- func DeleteIngestPipeline(esClient *elasticsearch.Client, ingestPipelineId string) (ctrl.Result, error)
- func DeleteRole(esClient *elasticsearch.Client, roleName string) (ctrl.Result, error)
- func DeleteSnapshotLifecyclePolicy(esClient *elasticsearch.Client, snapshotLifecyclePolicyName string) (ctrl.Result, error)
- func DeleteSnapshotRepository(esClient *elasticsearch.Client, repositoryName string) (ctrl.Result, error)
- func DeleteUser(esClient *elasticsearch.Client, userName string) (ctrl.Result, error)
- func DependenciesFulfilled(esClient *elasticsearch.Client, dependencies v1alpha1.Dependencies) error
- func GetClientErrorOrResponseError(err error, response *esapi.Response) error
- func GetElasticsearchClient(cli client.Client, ctx context.Context, esSpec configv2.ElasticsearchSpec, ...) (*elasticsearch.Client, error)
- func GetTargetElasticsearchInstance(cli client.Client, ctx context.Context, namespace string, targetName string, ...) error
- func IndexTemplateExists(esClient *elasticsearch.Client, indexTemplateName string) (bool, error)
- func UpdateIndex(esClient *elasticsearch.Client, index v1alpha1.Index, ...) (ctrl.Result, error)
- func UpsertApikey(esClient *elasticsearch.Client, role v1alpha1.ElasticsearchRole) (ctrl.Result, error)
- func UpsertIndexLifecyclePolicy(esClient *elasticsearch.Client, ...) (ctrl.Result, error)
- func UpsertIndexTemplate(esClient *elasticsearch.Client, indexTemplate v1alpha1.IndexTemplate) (ctrl.Result, error)
- func UpsertIngestPipeline(esClient *elasticsearch.Client, ingestPipeline v1alpha1.IngestPipeline) (ctrl.Result, error)
- func UpsertRole(esClient *elasticsearch.Client, role v1alpha1.ElasticsearchRole) (ctrl.Result, error)
- func UpsertSnapshotLifecyclePolicy(esClient *elasticsearch.Client, ...) (ctrl.Result, error)
- func UpsertSnapshotRepository(esClient *elasticsearch.Client, snapshotRepository v1alpha1.SnapshotRepository) (ctrl.Result, error)
- func UpsertUser(esClient *elasticsearch.Client, cli client.Client, ctx context.Context, ...) (ctrl.Result, error)
- func VerifyIndexEmpty(esClient *elasticsearch.Client, indexName string) (bool, error)
- func VerifyIndexExists(esClient *elasticsearch.Client, indexName string) (bool, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var UpdatableSettings = [...]string{
"number_of_replicas",
"refresh_interval",
}
Functions ¶
func CreateIndex ¶
func DeleteApikey ¶
func DeleteIndex ¶
func DeleteIndexIfEmpty ¶
func DeleteIndexTemplate ¶
func DeleteIngestPipeline ¶
func DeleteRole ¶
func DeleteUser ¶
func DependenciesFulfilled ¶
func DependenciesFulfilled(esClient *elasticsearch.Client, dependencies v1alpha1.Dependencies) error
func GetElasticsearchClient ¶
func GetTargetElasticsearchInstance ¶
func GetTargetElasticsearchInstance(cli client.Client, ctx context.Context, namespace string, targetName string, esInstance *eseckv1alpha1.ElasticsearchInstance) error
func IndexTemplateExists ¶
func UpdateIndex ¶
func UpsertApikey ¶
func UpsertApikey(esClient *elasticsearch.Client, role v1alpha1.ElasticsearchRole) (ctrl.Result, error)
func UpsertIndexLifecyclePolicy ¶
func UpsertIndexLifecyclePolicy(esClient *elasticsearch.Client, indexLifecyclePolicy v1alpha1.IndexLifecyclePolicy) (ctrl.Result, error)
func UpsertIndexTemplate ¶
func UpsertIndexTemplate(esClient *elasticsearch.Client, indexTemplate v1alpha1.IndexTemplate) (ctrl.Result, error)
func UpsertIngestPipeline ¶
func UpsertIngestPipeline(esClient *elasticsearch.Client, ingestPipeline v1alpha1.IngestPipeline) (ctrl.Result, error)
func UpsertRole ¶
func UpsertRole(esClient *elasticsearch.Client, role v1alpha1.ElasticsearchRole) (ctrl.Result, error)
func UpsertSnapshotLifecyclePolicy ¶
func UpsertSnapshotLifecyclePolicy(esClient *elasticsearch.Client, snapshotLifecyclePolicy v1alpha1.SnapshotLifecyclePolicy) (ctrl.Result, error)
func UpsertSnapshotRepository ¶
func UpsertSnapshotRepository(esClient *elasticsearch.Client, snapshotRepository v1alpha1.SnapshotRepository) (ctrl.Result, error)
func UpsertUser ¶
func VerifyIndexEmpty ¶
func VerifyIndexExists ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.