opensearchhandler

package module
v2.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 16, 2024 License: MIT Imports: 14 Imported by: 0

README

es-handler

Elasticsearch handler used by Terraform, Crossplane and k8s operator

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StandardDiff 

func StandardDiff(actual, expected any, log *logrus.Entry, ignore map[string]any) (diff string, err error)

StandardDiff permit to compare objects

Types

type OpensearchHandler 

type OpensearchHandler interface {
	Client() (client *opensearch.Client)

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

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

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

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

	// Cluster scope
	ClusterHealth() (health *opensearch.ClusterHealthResponse, err error)

	SetLogger(log *logrus.Entry)
}

func NewOpensearchHandler 

func NewOpensearchHandler(cfg *config.Config, log *logrus.Entry) (OpensearchHandler, error)

type OpensearchHandlerImpl 

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

func (*OpensearchHandlerImpl) Client 

func (h *OpensearchHandlerImpl) Client() *opensearch.Client

func (*OpensearchHandlerImpl) ClusterHealth 

func (h *OpensearchHandlerImpl) ClusterHealth() (health *opensearch.ClusterHealthResponse, err error)

ClusterHealth permit to get the cluster health

func (*OpensearchHandlerImpl) ComponentTemplateDelete 

func (h *OpensearchHandlerImpl) ComponentTemplateDelete(name string) (err error)

ComponentTemplateDelete permit to delete component template

func (*OpensearchHandlerImpl) ComponentTemplateDiff 

func (h *OpensearchHandlerImpl) ComponentTemplateDiff(actualObject, expectedObject, originalObject *opensearch.IndicesGetComponentTemplate) (patchResult *patch.PatchResult, err error)

ComponentTemplateDiff permit to check if 2 component template are the same

func (*OpensearchHandlerImpl) ComponentTemplateGet 

func (h *OpensearchHandlerImpl) ComponentTemplateGet(name string) (component *opensearch.IndicesGetComponentTemplate, err error)

ComponentTemplateGet permit to get component template

func (*OpensearchHandlerImpl) ComponentTemplateUpdate 

func (h *OpensearchHandlerImpl) ComponentTemplateUpdate(name string, component *opensearch.IndicesGetComponentTemplate) (err error)

ComponentTemplateUpdate permit to update component template

func (*OpensearchHandlerImpl) IndexTemplateDelete 

func (h *OpensearchHandlerImpl) IndexTemplateDelete(name string) (err error)

IndexTemplateDelete permit to delete index template

func (*OpensearchHandlerImpl) IndexTemplateDiff 

func (h *OpensearchHandlerImpl) IndexTemplateDiff(actualObject, expectedObject, originalObject *opensearch.IndicesGetIndexTemplate) (patchResult *patch.PatchResult, err error)

IndexTemplateDiff permit to check if 2 index template is the same

func (*OpensearchHandlerImpl) IndexTemplateGet 

func (h *OpensearchHandlerImpl) IndexTemplateGet(name string) (template *opensearch.IndicesGetIndexTemplate, err error)

IndexTemplateGet permit to get index template

func (*OpensearchHandlerImpl) IndexTemplateUpdate 

func (h *OpensearchHandlerImpl) IndexTemplateUpdate(name string, template *opensearch.IndicesGetIndexTemplate) (err error)

IndexTemplateUpdate permit to create or update index template

func (*OpensearchHandlerImpl) IngestPipelineDelete 

func (h *OpensearchHandlerImpl) IngestPipelineDelete(name string) (err error)

IngestPipelineDelete permit to delete ingest pipeline

func (*OpensearchHandlerImpl) IngestPipelineDiff 

func (h *OpensearchHandlerImpl) IngestPipelineDiff(actualObject, expectedObject, originalObject *opensearch.IngestGetPipeline) (patchResult *patch.PatchResult, err error)

IngestPipelineDiff permit to check if 2 ingest pipeline are the same

func (*OpensearchHandlerImpl) IngestPipelineGet 

func (h *OpensearchHandlerImpl) IngestPipelineGet(name string) (pipeline *opensearch.IngestGetPipeline, err error)

IngestPipelineGet permit to get ingest pipeline

func (*OpensearchHandlerImpl) IngestPipelineUpdate 

func (h *OpensearchHandlerImpl) IngestPipelineUpdate(name string, pipeline *opensearch.IngestGetPipeline) (err error)

IngestPipelineUpdate permit to create or update ingest pipeline

func (*OpensearchHandlerImpl) SetLogger 

func (h *OpensearchHandlerImpl) SetLogger(log *logrus.Entry)

func (*OpensearchHandlerImpl) SnapshotRepositoryDelete 

func (h *OpensearchHandlerImpl) SnapshotRepositoryDelete(name string) (err error)

SnapshotRepositoryDelete permit to delete snapshot repository

func (*OpensearchHandlerImpl) SnapshotRepositoryDiff 

func (h *OpensearchHandlerImpl) SnapshotRepositoryDiff(actualObject, expectedObject, originalObject *opensearch.SnapshotRepositoryMetaData) (patchResult *patch.PatchResult, err error)

SnapshotRepositoryDiff permit to check if 2 repositories are the same

func (*OpensearchHandlerImpl) SnapshotRepositoryGet 

func (h *OpensearchHandlerImpl) SnapshotRepositoryGet(name string) (repository *opensearch.SnapshotRepositoryMetaData, err error)

SnapshotRepositoryGet permit to get snapshot repository

func (*OpensearchHandlerImpl) SnapshotRepositoryUpdate 

func (h *OpensearchHandlerImpl) SnapshotRepositoryUpdate(name string, repository *opensearch.SnapshotRepositoryMetaData) (err error)

SnapshotRepositoryUpdate permit to create or update snapshot repository

Source Files

View all Source files

Directories

Path Synopsis
Code generated by MockGen.
 Code generated by MockGen.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.