Documentation
¶
Index ¶
- type Reconciler
- func (r *Reconciler) DeleteClusterMetadata(id, index 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) MaybeDeleteRole(rolename string) error
- func (r *Reconciler) MaybeDeleteUser(username string) error
- func (r *Reconciler) MaybeRemoveRolesMapping(roleName string, userName string) error
- func (r *Reconciler) MaybeUpdateRolesMapping(roleName string, userName string) 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
- type ReconcilerOptions
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) DeleteClusterMetadata ¶ added in v0.10.0
func (r *Reconciler) DeleteClusterMetadata(id, index string) error
func (*Reconciler) ImportKibanaObjects ¶
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
func (*Reconciler) UpsertClusterMetadata ¶ added in v0.10.0
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
}
Click to show internal directories.
Click to hide internal directories.