dbop

Sep 20, 2024

Changes in this version

type GlobalVariables

+ PurgedGTID string

Jun 25, 2024

Changes in this version

type ReplicaStatus

+ ExecSourceLogPos int

+ GetSourcepublickey string

+ ReadSourceLogPos int

+ RelaySourceLogFile string

+ ReplicaIORunning string

+ ReplicaIOState string

+ ReplicaSQLRunning string

+ ReplicaSQLRunningState string

+ SecondsBehindSource sql.NullInt64

+ SourceBind string

+ SourceHost string

+ SourceInfoFile string

+ SourceLogFile string

+ SourcePort int

+ SourceRetryCount int

+ SourceSSLAllowed string

+ SourceSSLCAFile string

+ SourceSSLCAPath string

+ SourceSSLCert string

+ SourceSSLCipher string

+ SourceSSLCrl string

+ SourceSSLCrlpath string

+ SourceSSLKey string

+ SourceSSLVerifyServerCert string

+ SourceServerID int

+ SourceTLSVersion string

+ SourceUUID string

+ SourceUser string

+ Sourcepublickeypath string

Nov 2, 2023

Changes in this version

+ func FindTopRunner(ctx context.Context, o Operator, status []*MySQLInstanceStatus) (int, error)

Feb 22, 2023

Changes in this version

type GlobalVariables

+ UUID string

type NopOperator

+ func (o NopOperator) SubtractGTID(ctx context.Context, set1, set2 string) (string, error)

type Operator

+ SubtractGTID func(ctx context.Context, set1, set2 string) (string, error)

Mar 7, 2022

Changes in this version

+ var ErrNop = errors.New("nop")

+ type NopOperator struct

+ func (o NopOperator) Close() error

+ func (o NopOperator) ConfigurePrimary(ctx context.Context, waitForCount int) error

+ func (o NopOperator) ConfigureReplica(ctx context.Context, source AccessInfo, semisync bool) error

+ func (o NopOperator) FindTopRunner(context.Context, []*MySQLInstanceStatus) (int, error)

+ func (o NopOperator) GetStatus(context.Context) (*MySQLInstanceStatus, error)

+ func (o NopOperator) IsSubsetGTID(ctx context.Context, set1, set2 string) (bool, error)

+ func (o NopOperator) KillConnections(context.Context) error

+ func (o NopOperator) Name() string

+ func (o NopOperator) SetReadOnly(context.Context, bool) error

+ func (o NopOperator) StopReplicaIOThread(context.Context) error

+ func (o NopOperator) WaitForGTID(ctx context.Context, gtidSet string, timeoutSeconds int) error

May 31, 2021

Changes in this version

+ func ConfigureMySQLOnDocker(pwd *password.MySQLPassword, port int) error

+ func RunMySQLOnDocker(name string, port, xport int) error

May 10, 2021

Changes in this version

type Operator

+ KillConnections func(context.Context) error

+ type Process struct

+ Host string

+ ID uint64

+ User string

Apr 30, 2021

Changes in this version

+ var ErrErrantTransactions = errors.New("detected errant transactions")

+ var ErrNoTopRunner = errors.New("unable to determine the top runner")

+ var ErrTimeout = errors.New("timeout")

+ func SetLogger(log logr.Logger)

+ type AccessInfo struct

+ Host string

+ Password string

+ Port int

+ User string

+ type CloneStatus struct

+ State sql.NullString

+ type GlobalVariables struct

+ ExecutedGTID string

+ ReadOnly bool

+ SemiSyncMasterEnabled bool

+ SemiSyncSlaveEnabled bool

+ SuperReadOnly bool

+ WaitForSlaveCount int

+ type MySQLInstanceStatus struct

+ CloneStatus *CloneStatus

+ GlobalVariables GlobalVariables

+ IsErrant bool

+ ReplicaHosts []ReplicaHost

+ ReplicaStatus *ReplicaStatus

+ type Operator interface

+ Close func() error

+ ConfigurePrimary func(ctx context.Context, waitForCount int) error

+ ConfigureReplica func(ctx context.Context, source AccessInfo, semisync bool) error

+ FindTopRunner func(context.Context, []*MySQLInstanceStatus) (int, error)

+ GetStatus func(context.Context) (*MySQLInstanceStatus, error)

+ IsSubsetGTID func(ctx context.Context, set1, set2 string) (bool, error)

+ Name func() string

+ SetReadOnly func(context.Context, bool) error

+ StopReplicaIOThread func(context.Context) error

+ WaitForGTID func(ctx context.Context, gtidSet string, timeoutSeconds int) error

+ type OperatorFactory interface

+ Cleanup func()

+ New func(context.Context, *mocov1beta1.MySQLCluster, *password.MySQLPassword, int) (Operator, error)

+ func NewFactory(r Resolver) OperatorFactory

+ func NewTestFactory() OperatorFactory

+ type ReplicaHost struct

+ Host string

+ Password string

+ Port int

+ ReplicaUUID string

+ ServerID int32

+ SourceID int32

+ User string

+ type ReplicaStatus struct

+ AutoPosition string

+ ChannelName string

+ ConnectRetry int

+ ExecMasterLogPos int

+ ExecutedGtidSet string

+ Getmasterpublickey string

+ LastErrno int

+ LastError string

+ LastIOErrorTimestamp string

+ LastIoErrno int

+ LastIoError string

+ LastSQLErrno int

+ LastSQLError string

+ LastSQLErrorTimestamp string

+ MasterBind string

+ MasterHost string

+ MasterInfoFile string

+ MasterLogFile string

+ MasterPort int

+ MasterRetryCount int

+ MasterSSLAllowed string

+ MasterSSLCAFile string

+ MasterSSLCAPath string

+ MasterSSLCert string

+ MasterSSLCipher string

+ MasterSSLCrl string

+ MasterSSLCrlpath string

+ MasterSSLKey string

+ MasterSSLVerifyServerCert string

+ MasterServerID int

+ MasterTLSVersion string

+ MasterUUID string

+ MasterUser string

+ Masterpublickeypath string

+ NetworkNamespace string

+ ReadMasterLogPos int

+ RelayLogFile string

+ RelayLogPos int

+ RelayLogSpace int

+ RelayMasterLogFile string

+ ReplicateDoDB string

+ ReplicateDoTable string

+ ReplicateIgnoreDB string

+ ReplicateIgnoreServerIds string

+ ReplicateIgnoreTable string

+ ReplicateRewriteDB string

+ ReplicateWildDoTable string

+ ReplicateWildIgnoreTable string

+ RetrievedGtidSet string

+ SQLDelay int

+ SQLRemainingDelay sql.NullInt64

+ SecondsBehindMaster sql.NullInt64

+ SkipCounter int

+ SlaveIORunning string

+ SlaveIOState string

+ SlaveSQLRunning string

+ SlaveSQLRunningState string

+ UntilCondition string

+ UntilLogFile string

+ UntilLogPos int

+ func (rs *ReplicaStatus) IsRunning() bool

+ type Resolver interface

+ Resolve func(context.Context, *mocov1beta1.MySQLCluster, int) (string, error)