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

accessor

package

Go to main page

Versions in this module

v0

v0.7.0

Feb 22, 2021

v0.6.0

Feb 16, 2021

v0.5.1

Feb 4, 2021

v0.5.0

Feb 3, 2021

v0.4.0

Jan 26, 2021

v0.3.1

Nov 11, 2020

v0.3.0

Nov 5, 2020

Changes in this version

+ type IntermediatePrimaryOptions struct

+ PrimaryHost string

+ PrimaryPassword string

+ PrimaryPort int

+ PrimaryUser string

+ func GetIntermediatePrimaryOptions(ctx context.Context, cli client.Client, cluster *mocov1alpha1.MySQLCluster) (*IntermediatePrimaryOptions, error)

type MySQLClusterStatus

+ IntermediatePrimaryOptions *IntermediatePrimaryOptions

v0.2.0

Oct 8, 2020

Changes in this version

+ func CheckAllRelayLogsExecuted(ctx context.Context, db *sqlx.DB, status *MySQLReplicaStatus) (bool, error)

+ func GetLatestInstance(ctx context.Context, db *sqlx.DB, status []MySQLInstanceStatus) (*int, error)

+ type DataBaseAccessor interface

+ Get func(addr, user, password string) (*sqlx.DB, error)

+ Remove func(cluster *mocov1alpha1.MySQLCluster)

+ type Infrastructure struct

+ func NewInfrastructure(cli client.Client, acc DataBaseAccessor, password string, hosts []string, ...) Infrastructure

+ func (i Infrastructure) GetClient() client.Client

+ func (i Infrastructure) GetDB(ctx context.Context, cluster *mocov1alpha1.MySQLCluster, index int) (*sqlx.DB, error)

+ type MySQLAccessor struct

+ func NewMySQLAccessor(config *MySQLAccessorConfig) *MySQLAccessor

+ func (acc *MySQLAccessor) Get(addr, user, password string) (*sqlx.DB, error)

+ func (acc *MySQLAccessor) Remove(cluster *mocov1alpha1.MySQLCluster)

+ type MySQLAccessorConfig struct

+ ConnMaxLifeTime time.Duration

+ ConnectionTimeout time.Duration

+ ReadTimeout time.Duration

+ type MySQLCloneStateStatus struct

+ State sql.NullString

+ func GetMySQLCloneStateStatus(ctx context.Context, db *sqlx.DB) (*MySQLCloneStateStatus, error)

+ type MySQLClusterStatus struct

+ InstanceStatus []MySQLInstanceStatus

+ Latest *int

+ func GetMySQLClusterStatus(ctx context.Context, log logr.Logger, infra Infrastructure, ...) *MySQLClusterStatus

+ type MySQLGlobalVariablesStatus struct

+ CloneValidDonorList sql.NullString

+ ReadOnly bool

+ RplSemiSyncMasterWaitForSlaveCount int

+ SuperReadOnly bool

+ func GetMySQLGlobalVariablesStatus(ctx context.Context, db *sqlx.DB) (*MySQLGlobalVariablesStatus, error)

+ type MySQLInstanceStatus struct

+ AllRelayLogExecuted bool

+ Available bool

+ CloneStateStatus *MySQLCloneStateStatus

+ GlobalVariablesStatus *MySQLGlobalVariablesStatus

+ PrimaryStatus *MySQLPrimaryStatus

+ ReplicaStatus *MySQLReplicaStatus

+ Role string

+ type MySQLPrimaryStatus struct

+ BinlogDoDB string

+ BinlogIgnoreDB string

+ ExecutedGtidSet string

+ File string

+ Position string

+ func GetMySQLPrimaryStatus(ctx context.Context, db *sqlx.DB) (*MySQLPrimaryStatus, error)

+ type MySQLReplicaStatus 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 GetMySQLReplicaStatus(ctx context.Context, db *sqlx.DB) (*MySQLReplicaStatus, error)