Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

binlogreplication

package

Go to main page

Versions in this module

v0

v0.19.0

Dec 19, 2024

Changes in this version

+ type BinaryLogFileMetadata struct

+ Encrypted bool

+ Name string

+ Size uint64

+ type BinaryLogStatus struct

+ DoDbs string

+ ExecutedGtids string

+ File string

+ IgnoreDbs string

+ Position uint

v0.18.1

Apr 9, 2024

Changes in this version

+ 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

+ HasBinlogReplicaController func() bool

v0.18.0

Feb 28, 2024

Changes in this version

+ type BinlogReplicaCatalog interface

+ GetBinlogReplicaController func() BinlogReplicaController

+ IsBinlogReplicaCatalog func() bool

v0.17.0

Aug 23, 2023

v0.16.0

Jun 29, 2023

v0.15.0

Apr 18, 2023

Changes in this version

+ const ReplicaIoConnecting

+ const ReplicaIoNotRunning

+ const ReplicaIoRunning

+ const ReplicaSqlNotRunning

+ const ReplicaSqlRunning

+ 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