db

package

v0.7.0 Latest Latest Go to latest Published: Mar 23, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type MemberState string

const (
	MemberStateOnline  MemberState = "ONLINE"
	MemberStateOffline MemberState = "OFFLINE"
	MemberStateError   MemberState = "ERROR"
)

type ReplicationDBManager struct {
	// contains filtered or unexported fields
}

func NewReplicationManager(pod *corev1.Pod, cliCmd clientcmd.Client, user apiv1alpha1.SystemUser, pass, host string) *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)

TODO: finish implementation

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 ReplicationStatus = iota
	ReplicationStatusError
	ReplicationStatusNotInitiated
)

type UserManager struct {
	// contains filtered or unexported fields
}

func NewUserManager(pod *corev1.Pod, cliCmd clientcmd.Client, user apiv1alpha1.SystemUser, pass, host string) *UserManager

func (m *UserManager) DiscardOldPasswords(ctx context.Context, users []mysql.User) error

DiscardOldPasswords discards old passwords of givens users

func (m *UserManager) UpdateUserPasswords(ctx context.Context, users []mysql.User) error

UpdateUserPasswords updates user passwords but retains the current password using Dual Password feature of MySQL 8