server

package

Go to main page

Versions in this module

v0

v0.13.0

Nov 29, 2024

Changes in this version

type Agent

+ func (a *Agent) RotateLogIfSizeExceeded(rotationSize int64)

v0.12.2

Sep 10, 2024

v0.12.1

Jun 20, 2024

Changes in this version

+ func UserNotExists(err error) bool

v0.12.0

Jun 18, 2024

Changes in this version

type Agent

+ func (a *Agent) IsMySQL84(ctx context.Context) (bool, error)

type MySQLReplicaStatus

+ ExecSourceLogPos int

+ GetSourcepublickey string

+ ReadSourceLogPos int

+ RelaySourceLogFile string

+ ReplicaIORunning string

+ ReplicaIOState string

+ ReplicaSQLRunning string

+ ReplicaSQLRunningState string

+ SecondsBehindSource sql.NullInt64

+ SourceBind string

+ SourceHost string

+ SourceInfoFile string

+ SourceLogFile string

+ SourcePort int

+ SourceRetryCount int

+ SourceSSLAllowed string

+ SourceSSLCAFile string

+ SourceSSLCAPath string

+ SourceSSLCert string

+ SourceSSLCipher string

+ SourceSSLCrl string

+ SourceSSLCrlpath string

+ SourceSSLKey string

+ SourceSSLVerifyServerCert string

+ SourceServerID int

+ SourceTLSVersion string

+ SourceUUID string

+ SourceUser string

+ Sourcepublickeypath string

v0.11.0

Jun 10, 2024

v0.10.0

Aug 7, 2023

v0.9.0

Mar 8, 2023

v0.8.0

Nov 2, 2022

v0.7.1

Nov 15, 2021

v0.7.0

Nov 15, 2021

v0.6.9

Jul 29, 2021

v0.6.8

Jun 24, 2021

v0.6.7

Jun 22, 2021

v0.6.6

Jun 4, 2021

v0.6.5

May 18, 2021

Changes in this version

type Agent

+ func (a *Agent) GetTransactionTimestamps(ctx context.Context) (queued, applied time.Time, err error)

v0.6.4

May 14, 2021

v0.6.3

May 10, 2021

v0.6.2

May 6, 2021

v0.6.1

Apr 26, 2021

v0.6.0

Apr 2, 2021

Changes in this version

+ var Plugins = []Plugin

+ var Users = []UserSetting

+ func GetMySQLConnLocalSocket(user, password, socket string) (*sqlx.DB, error)

+ func Init(ctx context.Context, db *sqlx.DB, socket string) error

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

+ func IsAccessDenied(err error) bool

+ func IsRestartFailed(err error) bool

+ func NewAgentService(agent *Agent) proto.AgentServer

type Agent

+ func (a *Agent) CloseDB() error

+ func (a *Agent) GetMySQLCloneStateStatus(ctx context.Context) (*MySQLCloneStateStatus, error)

+ func (a *Agent) GetMySQLGlobalVariable(ctx context.Context) (*MySQLGlobalVariablesStatus, error)

+ func (a *Agent) GetMySQLLastAppliedTransactionTimestamps(ctx context.Context) (*MySQLLastAppliedTransactionTimestamps, error)

+ func (a *Agent) GetMySQLPrimaryStatus(ctx context.Context) (*MySQLPrimaryStatus, error)

+ func (a *Agent) GetMySQLReplicaStatus(ctx context.Context) (*MySQLReplicaStatus, error)

+ func (a *Agent) MySQLDHealth(w http.ResponseWriter, r *http.Request)

+ func (a *Agent) MySQLDReady(w http.ResponseWriter, r *http.Request)

+ type MySQLAccessorConfig struct

+ ConnMaxIdleTime time.Duration

+ ConnectionTimeout time.Duration

+ Host string

+ Password string

+ Port int

+ ReadTimeout time.Duration

+ type MySQLCloneStateStatus struct

+ State sql.NullString

+ type MySQLGlobalVariablesStatus struct

+ CloneValidDonorList sql.NullString

+ ReadOnly bool

+ RplSemiSyncMasterWaitForSlaveCount int

+ SuperReadOnly bool

+ type MySQLLastAppliedTransactionTimestamps struct

+ EndApplyTimestamp time.Time

+ OriginalCommitTimestamp time.Time

+ type MySQLPrimaryStatus struct

+ BinlogDoDB string

+ BinlogIgnoreDB string

+ ExecutedGtidSet string

+ File string

+ Position string

+ type MySQLReplicaStatus struct

+ AutoPosition string

+ ChannelName string

+ ConnectRetry int

+ ExecMasterLogPos int

+ ExecutedGtidSet string

+ Getmasterpublickey string

+ LastErrno int

+ LastError string

+ LastIOErrno int

+ LastIOError string

+ LastIOErrorTimestamp 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

+ type Plugin struct

+ type UserSetting struct

v0.5.0

Mar 15, 2021

v0.4.0

Mar 2, 2021

Changes in this version

+ func NewBackupBinlogService(agent *Agent) agentrpc.BackupBinlogServiceServer

v0.3.0

Feb 26, 2021

Changes in this version

+ func NewCloneService(agent *Agent) proto.CloneServiceServer

+ func NewHealthService(agent *Agent) proto.HealthServiceServer

v0.2.1

Feb 22, 2021

v0.2.0

Feb 18, 2021

Changes in this version

type Agent

+ func (a *Agent) FlushAndBackupBinaryLogs(w http.ResponseWriter, r *http.Request)

+ func (a *Agent) FlushBinaryLogs(w http.ResponseWriter, r *http.Request)

+ type BackupBinaryLogsParams struct

+ AccessKeyID string

+ BackupID string

+ BucketHost string

+ BucketName string

+ BucketPort int

+ BucketRegion string

+ SecretAccessKey string

v0.1.0

Feb 1, 2021

Changes in this version

+ type Agent struct

+ func New(podName, token, miscUserPassword, donorUserPassword, ... string, ...) *Agent

+ func (a *Agent) Clone(w http.ResponseWriter, r *http.Request)

+ func (a *Agent) Health(w http.ResponseWriter, r *http.Request)

+ func (a *Agent) RotateLog(w http.ResponseWriter, r *http.Request)

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