Versions in this module Expand all Collapse all v0 v0.8.0 Jul 9, 2024 v0.7.0 Mar 23, 2024 Changes in this version + type MemberState string + const MemberStateError + const MemberStateOffline + const MemberStateOnline + type ReplicationDBManager struct + func NewReplicationManager(pod *corev1.Pod, cliCmd clientcmd.Client, user apiv1alpha1.SystemUser, ...) *ReplicationDBManager + func (m *ReplicationDBManager) ChangeReplicationSource(ctx context.Context, host, replicaPass string, port int32) error + func (m *ReplicationDBManager) CheckIfDatabaseExists(ctx context.Context, name string) (bool, error) + func (m *ReplicationDBManager) GetGroupReplicationMembers(ctx context.Context) ([]innodbcluster.Member, error) + func (m *ReplicationDBManager) GetGroupReplicationPrimary(ctx context.Context) (string, error) + func (m *ReplicationDBManager) GetGroupReplicationReplicas(ctx context.Context) ([]string, error) + func (m *ReplicationDBManager) GetMemberState(ctx context.Context, host string) (MemberState, error) + func (m *ReplicationDBManager) ReplicationStatus(ctx context.Context) (ReplicationStatus, string, error) + type ReplicationStatus int8 + const ReplicationStatusActive + const ReplicationStatusError + const ReplicationStatusNotInitiated + type UserManager struct + func NewUserManager(pod *corev1.Pod, cliCmd clientcmd.Client, user apiv1alpha1.SystemUser, ...) *UserManager + func (m *UserManager) DiscardOldPasswords(ctx context.Context, users []mysql.User) error + func (m *UserManager) UpdateUserPasswords(ctx context.Context, users []mysql.User) error