elasticsearch

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)

Variables

var UpdatableSettings = [...]string{
	"number_of_replicas",
	"refresh_interval",
}

Functions

func CreateIndex

func CreateIndex(esClient *elasticsearch.Client, index v1alpha1.Index) (ctrl.Result, error)

func DeleteApikey

func DeleteApikey(esClient *elasticsearch.Client, roleName string) (ctrl.Result, error)

func DeleteIndex

func DeleteIndex(esClient *elasticsearch.Client, indexName string) (ctrl.Result, error)

func DeleteIndexIfEmpty

func DeleteIndexIfEmpty(esClient *elasticsearch.Client, indexName string) (ctrl.Result, error)

func DeleteIndexLifecyclePolicy

func DeleteIndexLifecyclePolicy(esClient *elasticsearch.Client, indexLifecyclePolicyName string) (ctrl.Result, error)

func DeleteIndexTemplate

func DeleteIndexTemplate(esClient *elasticsearch.Client, indexTemplateName string) (ctrl.Result, error)

func DeleteIngestPipeline

func DeleteIngestPipeline(esClient *elasticsearch.Client, ingestPipelineId string) (ctrl.Result, error)

func DeleteRole

func DeleteRole(esClient *elasticsearch.Client, roleName string) (ctrl.Result, error)

func DeleteSnapshotLifecyclePolicy

func DeleteSnapshotLifecyclePolicy(esClient *elasticsearch.Client, snapshotLifecyclePolicyName string) (ctrl.Result, error)

func DeleteSnapshotRepository

func DeleteSnapshotRepository(esClient *elasticsearch.Client, repositoryName string) (ctrl.Result, error)

func DeleteUser

func DeleteUser(esClient *elasticsearch.Client, userName string) (ctrl.Result, error)

func DependenciesFulfilled

func DependenciesFulfilled(esClient *elasticsearch.Client, dependencies v1alpha1.Dependencies) error

func GetClientErrorOrResponseError

func GetClientErrorOrResponseError(err error, response *esapi.Response) error

func GetElasticsearchClient

func GetElasticsearchClient(cli client.Client, ctx context.Context, esSpec configv2.ElasticsearchSpec, req ctrl.Request) (*elasticsearch.Client, error)

func GetTargetElasticsearchInstance

func GetTargetElasticsearchInstance(cli client.Client, ctx context.Context, namespace string, targetName string, esInstance *eseckv1alpha1.ElasticsearchInstance) error

func IndexTemplateExists

func IndexTemplateExists(esClient *elasticsearch.Client, indexTemplateName string) (bool, error)

func UpdateIndex

func UpdateIndex(esClient *elasticsearch.Client, index v1alpha1.Index, eventRecorder record.EventRecorder) (ctrl.Result, error)

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 UpsertUser(esClient *elasticsearch.Client, cli client.Client, ctx context.Context, user v1alpha1.ElasticsearchUser) (ctrl.Result, error)

func VerifyIndexEmpty

func VerifyIndexEmpty(esClient *elasticsearch.Client, indexName string) (bool, error)

func VerifyIndexExists

func VerifyIndexExists(esClient *elasticsearch.Client, indexName string) (bool, error)