db

package

v0.9.0 Latest Latest Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation ¶

This section is empty.

View Source

var ErrRestartAfterClone = errors.New("Error 3707: Restart server failed (mysqld is not managed by supervisor process).")

This section is empty.

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

func NewDatabase(ctx context.Context, user apiv1alpha1.SystemUser, pass, host string, port int32) (*DB, error)

func (d *DB) CheckIfInPrimaryPartition(ctx context.Context) (bool, error)

func (d *DB) Clone(ctx context.Context, donor, user, pass string, port int32) error

func (d *DB) CloneInProgress(ctx context.Context) (bool, error)

func (d *DB) Close() error

func (d *DB) DisableSuperReadonly(ctx context.Context) error

func (d *DB) DumbQuery(ctx context.Context) error

func (d *DB) EnableSuperReadonly(ctx context.Context) error

func (d *DB) GetMemberState(ctx context.Context, host string) (db.MemberState, error)

func (d *DB) IsReadonly(ctx context.Context) (bool, error)

func (d *DB) IsReplica(ctx context.Context) (bool, error)

func (d *DB) ReplicationStatus(ctx context.Context) (db.ReplicationStatus, string, error)

func (d *DB) ReportHost(ctx context.Context) (string, error)

func (d *DB) ResetReplication(ctx context.Context) error

func (d *DB) StartReplication(ctx context.Context, host, replicaPass string, port int32) error

func (d *DB) StopReplication(ctx context.Context) error

type ReplicationStatus int8