reconciler

Documentation

Index

• type Reconciler
  • func NewReconciler(ctx context.Context, cfg ReconcilerConfig, opts ...ReconcilerOption) (*Reconciler, error)
  • func (r *Reconciler) CreateSnapshotAsync(name, repository string, settings types.SnapshotRequest) error
  • func (r *Reconciler) DeleteClusterMetadata(id, index string) error
  • func (r *Reconciler) GetSnapshotPolicy(name string) (types.SnapshotManagementResponse, error)
  • func (r *Reconciler) GetSnapshotPolicyLastExecution(name string) (*types.SnapshotPolicyExecution, error)
  • func (r *Reconciler) GetSnapshotState(name, repository string) (types.SnapshotState, string, error)
  • func (r *Reconciler) ImportKibanaObjects(indexName string, docID string, version string, dashboardsObjects string) error
  • func (r *Reconciler) MaybeBootstrapIndex(prefix string, alias string, oldPrefixes []string) error
  • func (r *Reconciler) MaybeCreateIndex(name string, settings map[string]types.TemplateMappingsSpec) error
  • func (r *Reconciler) MaybeCreateIndexTemplate(template types.IndexTemplateSpec) error
  • func (r *Reconciler) MaybeCreateIngestPipeline(name string, pipeline types.IngestPipeline) error
  • func (r *Reconciler) MaybeCreateRole(role types.RoleSpec) error
  • func (r *Reconciler) MaybeCreateUser(user types.UserSpec) error
  • func (r *Reconciler) MaybeDeleteIndexTemplate(name string) error
  • func (r *Reconciler) MaybeDeleteIngestPipeline(name string) error
  • func (r *Reconciler) MaybeDeleteRepository(name string) error
  • func (r *Reconciler) MaybeDeleteRole(rolename string) error
  • func (r *Reconciler) MaybeDeleteSnapshotPolicy(name string) error
  • func (r *Reconciler) MaybeDeleteUser(username string) error
  • func (r *Reconciler) MaybeRemoveRolesMapping(roleName string, userName string) error
  • func (r *Reconciler) MaybeUpdateRepository(name string, settings types.RepositoryRequest) error
  • func (r *Reconciler) MaybeUpdateRolesMapping(roleName string, userName string) error
  • func (r *Reconciler) MaybeUpdateSnapshotPolicy(name string, policy types.SnapshotManagementRequest) error
  • func (r *Reconciler) NextSnapshotPolicyTrigger(name string) (time.Duration, error)
  • func (r *Reconciler) ReconcileISM(policy types.ISMPolicySpec) error
  • func (r *Reconciler) TemplateExists(name string) (bool, error)
  • func (r *Reconciler) UpdateDefaultIngestPipelineForIndex(index string, pipelineName string) error
  • func (r *Reconciler) UpsertClusterMetadata(id, name, index string) error
• type ReconcilerConfig
• type ReconcilerOption
  • func WithDashboardsPassword(password string) ReconcilerOption
  • func WithDashboardsUsername(username string) ReconcilerOption
  • func WithDashboardshClient(client *dashboards.Client) ReconcilerOption
  • func WithOpensearchClient(client *opensearch.Client) ReconcilerOption
• type ReconcilerOptions

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) CreateSnapshotAsync

func (r *Reconciler) CreateSnapshotAsync(name, repository string, settings types.SnapshotRequest) error

func (*Reconciler) DeleteClusterMetadata

func (r *Reconciler) DeleteClusterMetadata(id, index string) error

func (*Reconciler) GetSnapshotPolicy

func (r *Reconciler) GetSnapshotPolicy(name string) (types.SnapshotManagementResponse, error)

func (*Reconciler) GetSnapshotPolicyLastExecution

func (r *Reconciler) GetSnapshotPolicyLastExecution(name string) (*types.SnapshotPolicyExecution, error)

func (*Reconciler) GetSnapshotState

func (r *Reconciler) GetSnapshotState(name, repository string) (types.SnapshotState, string, 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) MaybeDeleteRepository

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

func (*Reconciler) MaybeDeleteRole

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

func (*Reconciler) MaybeDeleteSnapshotPolicy

func (r *Reconciler) MaybeDeleteSnapshotPolicy(name 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) MaybeUpdateRepository

func (r *Reconciler) MaybeUpdateRepository(name string, settings types.RepositoryRequest) error

func (*Reconciler) MaybeUpdateRolesMapping

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

func (*Reconciler) MaybeUpdateSnapshotPolicy

func (r *Reconciler) MaybeUpdateSnapshotPolicy(name string, policy types.SnapshotManagementRequest) error

func (*Reconciler) NextSnapshotPolicyTrigger

func (r *Reconciler) NextSnapshotPolicyTrigger(name string) (time.Duration, 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

func (*Reconciler) UpsertClusterMetadata

func (r *Reconciler) UpsertClusterMetadata(id, name, index 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
}