db

Jul 3, 2026

Changes in this version

+ type AdminManager struct

+ func NewAdminManager(pod *corev1.Pod, cliCmd clientcmd.Client, user apiv1.SystemUser, ...) *AdminManager

+ func (m *AdminManager) SetReadOnly(ctx context.Context, readonly bool) error

+ func (m *AdminManager) SetSuperReadOnly(ctx context.Context, readonly bool) error

type ReplicationDBManager

+ func (m *ReplicationDBManager) CheckIfClusterMetadataDBExists(ctx context.Context) (bool, error)

+ func (m *ReplicationDBManager) GetClusterSetReplicationRunning(ctx context.Context) (bool, error)

type UserManager

+ func (m *UserManager) CreateClusterSetUser(ctx context.Context, pass string) error

Apr 17, 2026

Changes in this version

type ReplicationStatus

+ const ReplicationStatusStopped

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