clusters

package

Go to main page

Versions in this module

v0

v0.1.5

Jan 24, 2024

Changes in this version

type RedisReconciler

+ RateLimiter ratelimiter.RateLimiter

v0.1.4

Jan 3, 2024

Changes in this version

+ type ClusterObject interface

+ GetAvailableUsers func() v1beta1.References

+ GetClusterID func() string

+ GetDataCentreID func(cdcName string) string

+ GetUserRefs func() v1beta1.References

+ SetAvailableUsers func(users v1beta1.References)

+ SetClusterID func(id string)

+ SetUserRefs func(refs v1beta1.References)

v0.1.3

Dec 7, 2023

Changes in this version

type CassandraReconciler

+ func (r *CassandraReconciler) NewUserResource() userObject

type KafkaReconciler

+ func (r *KafkaReconciler) NewUserResource() userObject

+ type Object interface

+ NewPatch func() client.Patch

type OpenSearchReconciler

+ func (r *OpenSearchReconciler) NewUserResource() userObject

type RedisReconciler

+ func (r *RedisReconciler) NewUserResource() userObject

v0.1.2

Sep 15, 2023

Changes in this version

type PostgreSQLReconciler

+ func (r *PostgreSQLReconciler) DefaultSecretExists(ctx context.Context, pg *v1beta1.PostgreSQL) (bool, error)

v0.1.1

Jul 24, 2023

v0.1.0

Jul 13, 2023

v0.0.6

Jul 5, 2023

v0.0.5

May 15, 2023

v0.0.4

Apr 26, 2023

v0.0.3

Apr 7, 2023

Changes in this version

type CadenceReconciler

+ EventRecorder record.EventRecorder

type OpenSearchReconciler

+ EventRecorder record.EventRecorder

type ZookeeperReconciler

+ EventRecorder record.EventRecorder

v0.0.2

Mar 10, 2023

Changes in this version

type CassandraReconciler

+ EventRecorder record.EventRecorder

type KafkaConnectReconciler

+ EventRecorder record.EventRecorder

type KafkaReconciler

+ EventRecorder record.EventRecorder

type PostgreSQLReconciler

+ EventRecorder record.EventRecorder

type RedisReconciler

+ EventRecorder record.EventRecorder

v0.0.1

Jan 27, 2023

Changes in this version

+ const StatusRUNNING

+ type CadenceReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *CadenceReconciler) HandleCreateCluster(ctx context.Context, cadenceCluster *clustersv1alpha1.Cadence, ...) reconcile.Result

+ func (r *CadenceReconciler) HandleDeleteCluster(ctx context.Context, cadenceCluster *clustersv1alpha1.Cadence, ...) reconcile.Result

+ func (r *CadenceReconciler) HandleUpdateCluster(ctx context.Context, cadenceCluster *clustersv1alpha1.Cadence, ...) reconcile.Result

+ func (r *CadenceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *CadenceReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type CassandraReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *CassandraReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *CassandraReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type KafkaConnectReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *KafkaConnectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *KafkaConnectReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type KafkaReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *KafkaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *KafkaReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type OpenSearchReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *OpenSearchReconciler) HandleCreateCluster(ctx context.Context, openSearch *clustersv1alpha1.OpenSearch, ...) reconcile.Result

+ func (r *OpenSearchReconciler) HandleDeleteCluster(ctx context.Context, openSearch *clustersv1alpha1.OpenSearch, ...) reconcile.Result

+ func (r *OpenSearchReconciler) HandleUpdateCluster(ctx context.Context, openSearch *clustersv1alpha1.OpenSearch, ...) reconcile.Result

+ func (r *OpenSearchReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *OpenSearchReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type PostgreSQLReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *PostgreSQLReconciler) HandleCreateCluster(ctx context.Context, pgCluster *clustersv1alpha1.PostgreSQL, ...) reconcile.Result

+ func (r *PostgreSQLReconciler) HandleDeleteCluster(ctx context.Context, pgCluster *clustersv1alpha1.PostgreSQL, ...) reconcile.Result

+ func (r *PostgreSQLReconciler) HandleUpdateCluster(ctx context.Context, pgCluster *clustersv1alpha1.PostgreSQL, ...) reconcile.Result

+ func (r *PostgreSQLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *PostgreSQLReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type RedisReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *RedisReconciler) HandleCreateCluster(ctx context.Context, redisCluster *clustersv1alpha1.Redis, logger logr.Logger) reconcile.Result

+ func (r *RedisReconciler) HandleDeleteCluster(ctx context.Context, redisCluster *clustersv1alpha1.Redis, logger logr.Logger) reconcile.Result

+ func (r *RedisReconciler) HandleUpdateCluster(ctx context.Context, redisCluster *clustersv1alpha1.Redis, logger logr.Logger) reconcile.Result

+ func (r *RedisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *RedisReconciler) SetupWithManager(mgr ctrl.Manager) error

+ func (r *RedisReconciler) ToInstAPIv1(redisSpec *clustersv1alpha1.RedisSpec) *modelsv1.RedisCluster

+ type ZookeeperReconciler struct

+ API instaclustr.API

+ Scheduler scheduler.Interface

+ Scheme *runtime.Scheme

+ func (r *ZookeeperReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *ZookeeperReconciler) SetupWithManager(mgr ctrl.Manager) error

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