Documentation ¶
Index ¶
- func CheckIfUserExistsOnInstaclustrAPI(username, clusterID, app string, api instaclustr.API) (bool, error)
- func GetClusterID(cl client.Client, ctx context.Context, ref *v1beta1.ClusterRef) (string, error)
- func GetDataCentreID(cl client.Client, ctx context.Context, ref *v1beta1.ClusterRef) (string, error)
- type AWSEncryptionKeyReconciler
- type AWSEndpointServicePrincipalReconciler
- type AWSSecurityGroupFirewallRuleReconciler
- type AWSVPCPeeringReconciler
- type AzureVNetPeeringReconciler
- type CassandraUserReconciler
- type ClusterBackupReconciler
- type ClusterIDProvider
- type ClusterNetworkFirewallRuleReconciler
- func (r *ClusterNetworkFirewallRuleReconciler) HandleCreateFirewallRule(ctx context.Context, firewallRule *v1beta1.ClusterNetworkFirewallRule, ...) (ctrl.Result, error)
- func (r *ClusterNetworkFirewallRuleReconciler) HandleDeleteFirewallRule(ctx context.Context, firewallRule *v1beta1.ClusterNetworkFirewallRule, ...) (ctrl.Result, error)
- func (r *ClusterNetworkFirewallRuleReconciler) HandleUpdateFirewallRule(ctx context.Context, firewallRule *v1beta1.ClusterNetworkFirewallRule, ...) (ctrl.Result, error)
- func (r *ClusterNetworkFirewallRuleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *ClusterNetworkFirewallRuleReconciler) SetupWithManager(mgr ctrl.Manager) error
- type ExclusionWindowReconciler
- type GCPVPCPeeringReconciler
- type MaintenanceEventsReconciler
- type NodeReloadReconciler
- type OpenSearchEgressRulesReconciler
- type OpenSearchUserReconciler
- type PostgreSQLUserReconciler
- func (r *PostgreSQLUserReconciler) ExecPostgreSQLQuery(ctx context.Context, query string, defaultCreds *models.Credentials, ...) error
- func (r *PostgreSQLUserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *PostgreSQLUserReconciler) SetupWithManager(mgr ctrl.Manager) error
- type RedisUserReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckIfUserExistsOnInstaclustrAPI ¶ added in v0.1.3
func CheckIfUserExistsOnInstaclustrAPI(username, clusterID, app string, api instaclustr.API) (bool, error)
func GetClusterID ¶ added in v0.1.4
func GetDataCentreID ¶ added in v0.1.4
Types ¶
type AWSEncryptionKeyReconciler ¶ added in v0.0.3
type AWSEncryptionKeyReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
AWSEncryptionKeyReconciler reconciles a AWSEncryptionKey object
func (*AWSEncryptionKeyReconciler) Reconcile ¶ added in v0.0.3
func (r *AWSEncryptionKeyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the AWSEncryptionKey object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile
func (*AWSEncryptionKeyReconciler) SetupWithManager ¶ added in v0.0.3
func (r *AWSEncryptionKeyReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type AWSEndpointServicePrincipalReconciler ¶ added in v0.1.2
type AWSEndpointServicePrincipalReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
AWSEndpointServicePrincipalReconciler reconciles a AWSEndpointServicePrincipal object
func (*AWSEndpointServicePrincipalReconciler) Reconcile ¶ added in v0.1.2
func (r *AWSEndpointServicePrincipalReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile
func (*AWSEndpointServicePrincipalReconciler) SetupWithManager ¶ added in v0.1.2
func (r *AWSEndpointServicePrincipalReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type AWSSecurityGroupFirewallRuleReconciler ¶
type AWSSecurityGroupFirewallRuleReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
AWSSecurityGroupFirewallRuleReconciler reconciles a AWSSecurityGroupFirewallRule object
func (*AWSSecurityGroupFirewallRuleReconciler) Reconcile ¶
func (r *AWSSecurityGroupFirewallRuleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile
func (*AWSSecurityGroupFirewallRuleReconciler) SetupWithManager ¶
func (r *AWSSecurityGroupFirewallRuleReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type AWSVPCPeeringReconciler ¶
type AWSVPCPeeringReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
AWSVPCPeeringReconciler reconciles a AWSVPCPeering object
func (*AWSVPCPeeringReconciler) Reconcile ¶
func (r *AWSVPCPeeringReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile
func (*AWSVPCPeeringReconciler) SetupWithManager ¶
func (r *AWSVPCPeeringReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type AzureVNetPeeringReconciler ¶
type AzureVNetPeeringReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
AzureVNetPeeringReconciler reconciles a AzureVNetPeering object
func (*AzureVNetPeeringReconciler) Reconcile ¶
func (r *AzureVNetPeeringReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.2/pkg/reconcile
func (*AzureVNetPeeringReconciler) SetupWithManager ¶
func (r *AzureVNetPeeringReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type CassandraUserReconciler ¶ added in v0.0.6
type CassandraUserReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API EventRecorder record.EventRecorder }
CassandraUserReconciler reconciles a CassandraUser object
func (*CassandraUserReconciler) Reconcile ¶ added in v0.0.6
func (r *CassandraUserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile
func (*CassandraUserReconciler) SetupWithManager ¶ added in v0.0.6
func (r *CassandraUserReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ClusterBackupReconciler ¶
type ClusterBackupReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API EventRecorder record.EventRecorder }
ClusterBackupReconciler reconciles a ClusterBackup object
func (*ClusterBackupReconciler) Reconcile ¶
func (r *ClusterBackupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.2/pkg/reconcile
func (*ClusterBackupReconciler) SetupWithManager ¶
func (r *ClusterBackupReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ClusterIDProvider ¶ added in v0.1.4
type ClusterNetworkFirewallRuleReconciler ¶
type ClusterNetworkFirewallRuleReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
ClusterNetworkFirewallRuleReconciler reconciles a ClusterNetworkFirewallRule object
func (*ClusterNetworkFirewallRuleReconciler) HandleCreateFirewallRule ¶
func (r *ClusterNetworkFirewallRuleReconciler) HandleCreateFirewallRule( ctx context.Context, firewallRule *v1beta1.ClusterNetworkFirewallRule, l *logr.Logger, ) (ctrl.Result, error)
func (*ClusterNetworkFirewallRuleReconciler) HandleDeleteFirewallRule ¶
func (r *ClusterNetworkFirewallRuleReconciler) HandleDeleteFirewallRule( ctx context.Context, firewallRule *v1beta1.ClusterNetworkFirewallRule, l *logr.Logger, ) (ctrl.Result, error)
func (*ClusterNetworkFirewallRuleReconciler) HandleUpdateFirewallRule ¶
func (r *ClusterNetworkFirewallRuleReconciler) HandleUpdateFirewallRule( ctx context.Context, firewallRule *v1beta1.ClusterNetworkFirewallRule, l *logr.Logger, ) (ctrl.Result, error)
func (*ClusterNetworkFirewallRuleReconciler) Reconcile ¶
func (r *ClusterNetworkFirewallRuleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile
func (*ClusterNetworkFirewallRuleReconciler) SetupWithManager ¶
func (r *ClusterNetworkFirewallRuleReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ExclusionWindowReconciler ¶ added in v0.1.2
type ExclusionWindowReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API EventRecorder record.EventRecorder }
ExclusionWindowReconciler reconciles a ExclusionWindow object
func (*ExclusionWindowReconciler) Reconcile ¶ added in v0.1.2
func (r *ExclusionWindowReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ExclusionWindow object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.1/pkg/reconcile
func (*ExclusionWindowReconciler) SetupWithManager ¶ added in v0.1.2
func (r *ExclusionWindowReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type GCPVPCPeeringReconciler ¶
type GCPVPCPeeringReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
GCPVPCPeeringReconciler reconciles a GCPVPCPeering object
func (*GCPVPCPeeringReconciler) Reconcile ¶
func (r *GCPVPCPeeringReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.2/pkg/reconcile
func (*GCPVPCPeeringReconciler) SetupWithManager ¶
func (r *GCPVPCPeeringReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type MaintenanceEventsReconciler ¶
type MaintenanceEventsReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API Scheduler scheduler.Interface EventRecorder record.EventRecorder }
MaintenanceEventsReconciler reconciles a MaintenanceEvents object
func (*MaintenanceEventsReconciler) Reconcile ¶
func (r *MaintenanceEventsReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the MaintenanceEvents object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.1/pkg/reconcile
func (*MaintenanceEventsReconciler) SetupWithManager ¶
func (r *MaintenanceEventsReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type NodeReloadReconciler ¶
type NodeReloadReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API EventRecorder record.EventRecorder }
NodeReloadReconciler reconciles a NodeReload object
func (*NodeReloadReconciler) Reconcile ¶
func (r *NodeReloadReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.1/pkg/reconcile
func (*NodeReloadReconciler) SetupWithManager ¶
func (r *NodeReloadReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type OpenSearchEgressRulesReconciler ¶ added in v0.1.3
type OpenSearchEgressRulesReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API EventRecorder record.EventRecorder }
OpenSearchEgressRulesReconciler reconciles a OpenSearchEgressRules object
func (*OpenSearchEgressRulesReconciler) Reconcile ¶ added in v0.1.3
func (r *OpenSearchEgressRulesReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the OpenSearchEgressRules object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile
func (*OpenSearchEgressRulesReconciler) SetupWithManager ¶ added in v0.1.3
func (r *OpenSearchEgressRulesReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type OpenSearchUserReconciler ¶ added in v0.0.6
type OpenSearchUserReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API EventRecorder record.EventRecorder }
OpenSearchUserReconciler reconciles a OpenSearchUser object
func (*OpenSearchUserReconciler) Reconcile ¶ added in v0.0.6
func (r *OpenSearchUserReconciler) Reconcile( ctx context.Context, req ctrl.Request, ) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile
func (*OpenSearchUserReconciler) SetupWithManager ¶ added in v0.0.6
func (r *OpenSearchUserReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type PostgreSQLUserReconciler ¶ added in v0.1.2
type PostgreSQLUserReconciler struct { client.Client Scheme *runtime.Scheme EventRecorder record.EventRecorder }
PostgreSQLUserReconciler reconciles a PostgreSQLUser object
func (*PostgreSQLUserReconciler) ExecPostgreSQLQuery ¶ added in v0.1.3
func (r *PostgreSQLUserReconciler) ExecPostgreSQLQuery( ctx context.Context, query string, defaultCreds *models.Credentials, clusterName string, defaultUserSecretNamespacedName clusterresourcesv1beta1.NamespacedName, ) error
func (*PostgreSQLUserReconciler) Reconcile ¶ added in v0.1.2
func (r *PostgreSQLUserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile
func (*PostgreSQLUserReconciler) SetupWithManager ¶ added in v0.1.2
func (r *PostgreSQLUserReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type RedisUserReconciler ¶ added in v0.0.2
type RedisUserReconciler struct { client.Client Scheme *runtime.Scheme API instaclustr.API EventRecorder record.EventRecorder }
RedisUserReconciler reconciles a RedisUser object
func (*RedisUserReconciler) Reconcile ¶ added in v0.0.2
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.12.2/pkg/reconcile
func (*RedisUserReconciler) SetupWithManager ¶ added in v0.0.2
func (r *RedisUserReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files ¶
- awsencryptionkey_controller.go
- awsendpointserviceprincipal_controller.go
- awssecuritygroupfirewallrule_controller.go
- awsvpcpeering_controller.go
- azurevnetpeering_controller.go
- cassandrauser_controller.go
- clusterbackup_controller.go
- clusternetworkfirewallrule_controller.go
- exclusionwindow_controller.go
- gcpvpcpeering_controller.go
- helpers.go
- maintenanceevents_controller.go
- nodereload_controller.go
- opensearchegressrules_controller.go
- opensearchuser_controller.go
- postgresqluser_controller.go
- redisuser_controller.go