replication

Documentation

Index

• type Option
  • func WithRefResolver(rr *refresolver.RefResolver) Option
  • func WithSecretReconciler(sr *secret.SecretReconciler) Option
  • func WithServiceReconciler(sr *service.ServiceReconciler) Option
• type ReplicationConfig
  • func NewReplicationConfig(client client.Client, builder *builder.Builder, ...) *ReplicationConfig
  • func (r *ReplicationConfig) ConfigurePrimary(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB, ...) error
  • func (r *ReplicationConfig) ConfigureReplica(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB, ...) error
• type ReplicationReconciler
  • func NewReplicationReconciler(client client.Client, recorder record.EventRecorder, builder *builder.Builder, ...) *ReplicationReconciler
  • func (r *ReplicationReconciler) Reconcile(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB) error

Types

type Option

type Option func(*ReplicationReconciler)

func WithRefResolver

func WithRefResolver(rr *refresolver.RefResolver) Option

func WithSecretReconciler

func WithSecretReconciler(sr *secret.SecretReconciler) Option

func WithServiceReconciler

func WithServiceReconciler(sr *service.ServiceReconciler) Option

type ReplicationConfig

type ReplicationConfig struct {
	client.Client
	// contains filtered or unexported fields
}

func NewReplicationConfig

func NewReplicationConfig(client client.Client, builder *builder.Builder, secretReconciler *secret.SecretReconciler) *ReplicationConfig

func (*ReplicationConfig) ConfigurePrimary

func (r *ReplicationConfig) ConfigurePrimary(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB, client *mariadbclient.Client,
	podIndex int) error

func (*ReplicationConfig) ConfigureReplica

func (r *ReplicationConfig) ConfigureReplica(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB, client *mariadbclient.Client,
	replicaPodIndex, primaryPodIndex int, resetSlavePos bool) error

type ReplicationReconciler

type ReplicationReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewReplicationReconciler

func NewReplicationReconciler(client client.Client, recorder record.EventRecorder, builder *builder.Builder, replConfig *ReplicationConfig,
	opts ...Option) *ReplicationReconciler

func (*ReplicationReconciler) Reconcile

func (r *ReplicationReconciler) Reconcile(ctx context.Context, mariadb *mariadbv1alpha1.MariaDB) error