mysql

Aug 20, 2020

Changes in this version

type ConnectionConfig

+ Timeout float64

Feb 9, 2020

Changes in this version

+ const TLS_CONFIG_KEY

Feb 14, 2019

Changes in this version

+ func GetReplicationLagFromSlaveStatus(informationSchemaDb *gosql.DB) (replicationLag time.Duration, err error)

type ConnectionConfig

+ func (this *ConnectionConfig) TLSConfig() *tls.Config

+ func (this *ConnectionConfig) UseTLS(caCertificatePath string, allowInsecure bool) error

Feb 11, 2018

Changes in this version

+ func GetDB(migrationUuid string, mysql_uri string) (*gosql.DB, bool, error)

Sep 14, 2017

Changes in this version

+ const MaxReplicationPasswordLength

Mar 12, 2017

Changes in this version

+ const MaxTableNameLength

type ReplicationLagResult

+ func NewNoReplicationLagResult() *ReplicationLagResult

+ func (this *ReplicationLagResult) HasLag() bool

Nov 1, 2016

Changes in this version

+ func GetTableColumns(db *gosql.DB, databaseName, tableName string) (*sql.ColumnList, error)

Oct 12, 2016

Changes in this version

type ConnectionConfig

+ func (this *ConnectionConfig) DuplicateCredentials(key InstanceKey) *ConnectionConfig

Jul 27, 2016

Changes in this version

+ type ReplicationLagResult struct

+ Err error

+ Key InstanceKey

+ Lag time.Duration

Jun 20, 2016

Changes in this version

type ConnectionConfig

+ ImpliedKey *InstanceKey

type InstanceKey

+ func GetInstanceKey(db *gosql.DB) (instanceKey *InstanceKey, err error)

May 20, 2016

Changes in this version

+ func GetReplicationBinlogCoordinates(db *gosql.DB) (readBinlogCoordinates *BinlogCoordinates, ...)

May 16, 2016

Changes in this version

+ const DefaultInstancePort

+ func GetMaxReplicationLag(baseConnectionConfig *ConnectionConfig, instanceKeyMap *InstanceKeyMap, ...) (replicationLag time.Duration, err error)

+ func GetReplicationLag(connectionConfig *ConnectionConfig, replicationLagQuery string) (replicationLag time.Duration, err error)

+ type BinlogCoordinates struct

+ LogFile string

+ LogPos int64

+ Type BinlogType

+ func GetReadBinlogCoordinates(db *gosql.DB) (readBinlogCoordinates *BinlogCoordinates, err error)

+ func GetSelfBinlogCoordinates(db *gosql.DB) (selfBinlogCoordinates *BinlogCoordinates, err error)

+ func ParseBinlogCoordinates(logFileLogPos string) (*BinlogCoordinates, error)

+ func (this *BinlogCoordinates) DetachedCoordinates() (isDetached bool, detachedLogFile string, detachedLogPos string)

+ func (this *BinlogCoordinates) DisplayString() string

+ func (this *BinlogCoordinates) Equals(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) FileNumber() (int, int)

+ func (this *BinlogCoordinates) FileNumberDistance(other *BinlogCoordinates) int

+ func (this *BinlogCoordinates) FileSmallerThan(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) IsEmpty() bool

+ func (this *BinlogCoordinates) NextFileCoordinates() (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) PreviousFileCoordinates() (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) PreviousFileCoordinatesBy(offset int) (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) SmallerThan(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) SmallerThanOrEquals(other *BinlogCoordinates) bool

+ func (this BinlogCoordinates) String() string

+ type BinlogType int

+ const BinaryLog

+ const RelayLog

+ type ConnectionConfig struct

+ Key InstanceKey

+ Password string

+ User string

+ func GetMasterConnectionConfigSafe(connectionConfig *ConnectionConfig, visitedKeys *InstanceKeyMap) (masterConfig *ConnectionConfig, err error)

+ func NewConnectionConfig() *ConnectionConfig

+ func (this *ConnectionConfig) Duplicate() *ConnectionConfig

+ func (this *ConnectionConfig) Equals(other *ConnectionConfig) bool

+ func (this *ConnectionConfig) GetDBUri(databaseName string) string

+ func (this *ConnectionConfig) String() string

+ type InstanceKey struct

+ Hostname string

+ Port int

+ func GetMasterKeyFromSlaveStatus(connectionConfig *ConnectionConfig) (masterKey *InstanceKey, err error)

+ func NewRawInstanceKey(hostPort string) (*InstanceKey, error)

+ func ParseRawInstanceKeyLoose(hostPort string) (*InstanceKey, error)

+ func (this *InstanceKey) DetachedKey() *InstanceKey

+ func (this *InstanceKey) DisplayString() string

+ func (this *InstanceKey) Equals(other *InstanceKey) bool

+ func (this *InstanceKey) IsDetached() bool

+ func (this *InstanceKey) IsValid() bool

+ func (this *InstanceKey) ReattachedKey() *InstanceKey

+ func (this *InstanceKey) SmallerThan(other *InstanceKey) bool

+ func (this *InstanceKey) StringCode() string

+ func (this InstanceKey) String() string

+ type InstanceKeyMap map[InstanceKey]bool

+ func NewInstanceKeyMap() *InstanceKeyMap

+ func (this *InstanceKeyMap) AddKey(key InstanceKey)

+ func (this *InstanceKeyMap) AddKeys(keys []InstanceKey)

+ func (this *InstanceKeyMap) GetInstanceKeys() []InstanceKey

+ func (this *InstanceKeyMap) HasKey(key InstanceKey) bool

+ func (this *InstanceKeyMap) Len() int

+ func (this *InstanceKeyMap) MarshalJSON() ([]byte, error)

+ func (this *InstanceKeyMap) ReadCommaDelimitedList(list string) error

+ func (this *InstanceKeyMap) ReadJson(jsonString string) error

+ func (this *InstanceKeyMap) ToCommaDelimitedList() string

+ func (this *InstanceKeyMap) ToJSON() (string, error)

+ func (this *InstanceKeyMap) ToJSONString() string