mysql

package

Go to main page

Versions in this module

v1

v1.0.36

Apr 3, 2017

v1.0.35

Mar 12, 2017

Changes in this version

+ const MaxTableNameLength

type ReplicationLagResult

+ func NewNoReplicationLagResult() *ReplicationLagResult

+ func (this *ReplicationLagResult) HasLag() bool

v1.0.34

Jan 9, 2017

v1.0.32

Dec 14, 2016

v1.0.30

Dec 6, 2016

v1.0.28

Nov 1, 2016

Changes in this version

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

v1.0.21

Oct 12, 2016

Changes in this version

type ConnectionConfig

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

v1.0.20

Sep 13, 2016

v1.0.18-experimental

Sep 7, 2016

v1.0.17

Sep 5, 2016

v1.0.14

Aug 26, 2016

v1.0.13

Aug 24, 2016

v1.0.11

Aug 22, 2016

v1.0.10

Aug 18, 2016

v1.0.9

Aug 15, 2016

v1.0.8

Aug 1, 2016

v1.0.7

Jul 31, 2016

v1.0.6

Jul 27, 2016

Changes in this version

+ type ReplicationLagResult struct

+ Err error

+ Key InstanceKey

+ Lag time.Duration

v1.0.2

Jul 19, 2016

v1.0.1

Jul 8, 2016

v0

v0.9.9

Jul 4, 2016

v0.9.8

Jun 28, 2016

v0.9.7

Jun 21, 2016

v0.9.6

Jun 20, 2016

Changes in this version

type ConnectionConfig

+ ImpliedKey *InstanceKey

type InstanceKey

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

v0.9.2

Jun 15, 2016

v0.8.8

Jun 9, 2016

v0.8.7

Jun 7, 2016

v0.8.5

Jun 7, 2016

v0.8.4

Jun 7, 2016

v0.8.3

Jun 6, 2016

v0.8.2

Jun 1, 2016

v0.7.16

May 20, 2016

Changes in this version

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

v0.7.2

May 17, 2016

v0.7.1

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL