db

package

v0.12.0 Latest Latest Go to latest Published: Sep 22, 2025 License: Apache-2.0 Imports: 8 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, params DBParams) (*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 DBParams struct {
	User apiv1.SystemUser
	Pass string
	Host string
	Port int32

	ReadTimeoutSeconds uint32
}

func (p *DBParams) DSN() string

type ReplicationStatus int8