reconciler

package
v0.9.0-rc4 Latest Latest
Warning

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

Go to latest
Published: Mar 16, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Reconciler

type Reconciler struct {
	ReconcilerOptions
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(
	ctx context.Context,
	cfg ReconcilerConfig,
	opts ...ReconcilerOption,
) (*Reconciler, error)

func (*Reconciler) ImportKibanaObjects

func (r *Reconciler) ImportKibanaObjects(indexName string, docID string, version string, dashboardsObjects string) error

func (*Reconciler) MaybeBootstrapIndex

func (r *Reconciler) MaybeBootstrapIndex(prefix string, alias string, oldPrefixes []string) error

func (*Reconciler) MaybeCreateIndex

func (r *Reconciler) MaybeCreateIndex(name string, settings map[string]types.TemplateMappingsSpec) error

func (*Reconciler) MaybeCreateIndexTemplate

func (r *Reconciler) MaybeCreateIndexTemplate(template types.IndexTemplateSpec) error

func (*Reconciler) MaybeCreateIngestPipeline

func (r *Reconciler) MaybeCreateIngestPipeline(name string, pipeline types.IngestPipeline) error

func (*Reconciler) MaybeCreateRole

func (r *Reconciler) MaybeCreateRole(role types.RoleSpec) error

func (*Reconciler) MaybeCreateUser

func (r *Reconciler) MaybeCreateUser(user types.UserSpec) error

func (*Reconciler) MaybeDeleteIndexTemplate

func (r *Reconciler) MaybeDeleteIndexTemplate(name string) error

func (*Reconciler) MaybeDeleteIngestPipeline

func (r *Reconciler) MaybeDeleteIngestPipeline(name string) error

func (*Reconciler) MaybeDeleteRole

func (r *Reconciler) MaybeDeleteRole(rolename string) error

func (*Reconciler) MaybeDeleteUser

func (r *Reconciler) MaybeDeleteUser(username string) error

func (*Reconciler) MaybeRemoveRolesMapping

func (r *Reconciler) MaybeRemoveRolesMapping(roleName string, userName string) error

func (*Reconciler) MaybeUpdateRolesMapping

func (r *Reconciler) MaybeUpdateRolesMapping(roleName string, userName string) error

func (*Reconciler) ReconcileISM

func (r *Reconciler) ReconcileISM(policy types.ISMPolicySpec) error

func (*Reconciler) TemplateExists

func (r *Reconciler) TemplateExists(name string) (bool, error)

func (*Reconciler) UpdateDefaultIngestPipelineForIndex

func (r *Reconciler) UpdateDefaultIngestPipelineForIndex(index string, pipelineName string) error

type ReconcilerConfig

type ReconcilerConfig struct {
	CertReader            certs.OpensearchCertReader
	OpensearchServiceName string
	DashboardsServiceName string
}

type ReconcilerOption

type ReconcilerOption func(*ReconcilerOptions)

func WithDashboardsPassword

func WithDashboardsPassword(password string) ReconcilerOption

func WithDashboardsUsername

func WithDashboardsUsername(username string) ReconcilerOption

func WithDashboardshClient

func WithDashboardshClient(client *dashboards.Client) ReconcilerOption

func WithOpensearchClient

func WithOpensearchClient(client *opensearch.Client) ReconcilerOption

type ReconcilerOptions

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL