Documentation
¶
Index ¶
- type Reconciler
- 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
- 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) CreateSnapshotAsync ¶ added in v0.11.2
func (r *Reconciler) CreateSnapshotAsync(name, repository string, settings types.SnapshotRequest) error
func (*Reconciler) DeleteClusterMetadata ¶ added in v0.10.0
func (r *Reconciler) DeleteClusterMetadata(id, index string) error
func (*Reconciler) GetSnapshotPolicy ¶ added in v0.11.2
func (r *Reconciler) GetSnapshotPolicy(name string) (types.SnapshotManagementResponse, error)
func (*Reconciler) GetSnapshotPolicyLastExecution ¶ added in v0.11.2
func (r *Reconciler) GetSnapshotPolicyLastExecution(name string) (*types.SnapshotPolicyExecution, error)
func (*Reconciler) GetSnapshotState ¶ added in v0.11.2
func (r *Reconciler) GetSnapshotState(name, repository string) (types.SnapshotState, 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) MaybeDeleteRepository ¶ added in v0.11.2
func (r *Reconciler) MaybeDeleteRepository(name string) error
func (*Reconciler) MaybeDeleteRole ¶
func (r *Reconciler) MaybeDeleteRole(rolename string) error
func (*Reconciler) MaybeDeleteSnapshotPolicy ¶ added in v0.11.2
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 ¶ added in v0.11.2
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 ¶ added in v0.11.2
func (r *Reconciler) MaybeUpdateSnapshotPolicy(name string, policy types.SnapshotManagementRequest) error
func (*Reconciler) NextSnapshotPolicyTrigger ¶ added in v0.11.2
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 ¶ 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
}
Source Files
Click to show internal directories.
Click to hide internal directories.