Versions in this module Expand all Collapse all v1 v1.0.1 Jul 31, 2024 Changes in this version + const ReplicaIoConnecting + const ReplicaIoNotRunning + const ReplicaIoRunning + const ReplicaSqlNotRunning + const ReplicaSqlRunning + type BinlogPrimaryCatalog interface + GetBinlogPrimaryController func() BinlogPrimaryController + HasBinlogPrimaryController func() bool + type BinlogPrimaryController interface + BinlogDumpGtid func(ctx *sql.Context, c *mysql.Conn, gtidSet mysql.GTIDSet) error + GetBinaryLogStatus func(ctx *sql.Context) error + ListBinaryLogs func(ctx *sql.Context) error + ListReplicas func(ctx *sql.Context) error + RegisterReplica func(ctx *sql.Context, c *mysql.Conn, replicaHost string, replicaPort uint16) error + type BinlogReplicaCatalog interface + GetBinlogReplicaController func() BinlogReplicaController + HasBinlogReplicaController func() bool + type BinlogReplicaController interface + GetReplicaStatus func(ctx *sql.Context) (*ReplicaStatus, error) + ResetReplica func(ctx *sql.Context, resetAll bool) error + SetReplicationFilterOptions func(ctx *sql.Context, options []ReplicationOption) error + SetReplicationSourceOptions func(ctx *sql.Context, options []ReplicationOption) error + StartReplica func(ctx *sql.Context) error + StopReplica func(ctx *sql.Context) error + type IntegerReplicationOptionValue struct + Value int + func (ov IntegerReplicationOptionValue) GetValue() interface{} + func (ov IntegerReplicationOptionValue) GetValueAsInt() int + func (ov IntegerReplicationOptionValue) String() string + type ReplicaStatus struct + AutoPosition bool + ConnectRetry uint32 + ExecutedGtidSet string + LastIoErrNumber uint + LastIoError string + LastIoErrorTimestamp *time.Time + LastSqlErrNumber uint + LastSqlError string + LastSqlErrorTimestamp *time.Time + ReplicaIoRunning string + ReplicaSqlRunning string + ReplicateDoTables []string + ReplicateIgnoreTables []string + RetrievedGtidSet string + SourceHost string + SourcePort uint + SourceRetryCount uint64 + SourceServerId string + SourceServerUuid string + SourceUser string + type ReplicationOption struct + Name string + Value ReplicationOptionValue + func NewReplicationOption(name string, value ReplicationOptionValue) *ReplicationOption + type ReplicationOptionValue interface + GetValue func() interface{} + type StringReplicationOptionValue struct + Value string + func (ov StringReplicationOptionValue) GetValue() interface{} + func (ov StringReplicationOptionValue) GetValueAsString() string + func (ov StringReplicationOptionValue) String() string + type TableNamesReplicationOptionValue struct + Value []sql.UnresolvedTable + func (ov TableNamesReplicationOptionValue) GetValue() interface{} + func (ov TableNamesReplicationOptionValue) GetValueAsTableList() []sql.UnresolvedTable + func (ov TableNamesReplicationOptionValue) String() string
Go to main page