test

Documentation

Index

• type DB
  • func NewTestDB(rowMaps [][]sqlutils.RowMap) *DB
  • func (t *DB) QueryOrchestrator(query string, argsArray []any, onRow func(sqlutils.RowMap) error) error
• type InfoForRecoveryAnalysis
  • func (info *InfoForRecoveryAnalysis) ConvertToRowMap() sqlutils.RowMap
  • func (info *InfoForRecoveryAnalysis) SetValuesFromTabletInfo()

Types

type DB

type DB struct {
	// contains filtered or unexported fields
}

func NewTestDB

func NewTestDB(rowMaps [][]sqlutils.RowMap) *DB

func (*DB) QueryOrchestrator

func (t *DB) QueryOrchestrator(query string, argsArray []any, onRow func(sqlutils.RowMap) error) error

type InfoForRecoveryAnalysis

type InfoForRecoveryAnalysis struct {
	TabletInfo                                *topodatapb.Tablet
	PrimaryTabletInfo                         *topodatapb.Tablet
	PrimaryTimestamp                          *time.Time
	Keyspace                                  string
	KeyspaceType                              int
	DurabilityPolicy                          string
	IsPrimary                                 int
	IsCoPrimary                               int
	Hostname                                  string
	Port                                      int
	SourceHost                                string
	SourcePort                                int
	DataCenter                                string
	Region                                    string
	PhysicalEnvironment                       string
	LogFile                                   string
	LogPos                                    int64
	IsStaleBinlogCoordinates                  int
	SuggestedClusterAlias                     string
	ClusterName                               string
	ClusterAlias                              string
	ClusterDomain                             string
	GTIDMode                                  string
	LastCheckValid                            int
	LastCheckPartialSuccess                   int
	CountReplicas                             uint
	CountValidReplicas                        uint
	CountValidReplicatingReplicas             uint
	CountReplicasFailingToConnectToPrimary    uint
	CountDowntimedReplicas                    uint
	ReplicationDepth                          uint
	ReplicaHosts                              string
	IsFailingToConnectToPrimary               int
	ReplicationStopped                        int
	IsDowntimed                               int
	DowntimeEndTimestamp                      string
	DowntimeRemainingSeconds                  int
	IsBinlogServer                            int
	CountValidOracleGTIDReplicas              uint
	CountValidMariaDBGTIDReplicas             uint
	CountValidBinlogServerReplicas            uint
	SemiSyncPrimaryEnabled                    int
	SemiSyncPrimaryStatus                     int
	SemiSyncPrimaryWaitForReplicaCount        uint
	SemiSyncPrimaryClients                    uint
	SemiSyncReplicaEnabled                    int
	CountSemiSyncReplicasEnabled              uint
	CountLoggingReplicas                      uint
	CountStatementBasedLoggingReplicas        uint
	CountMixedBasedLoggingReplicas            uint
	CountRowBasedLoggingReplicas              uint
	CountDistinctMajorVersionsLoggingReplicas uint
	CountDelayedReplicas                      uint
	CountLaggingReplicas                      uint
	MinReplicaGTIDMode                        string
	MaxReplicaGTIDMode                        string
	MaxReplicaGTIDErrant                      string
	ReadOnly                                  uint
}

func (*InfoForRecoveryAnalysis) ConvertToRowMap

func (info *InfoForRecoveryAnalysis) ConvertToRowMap() sqlutils.RowMap

func (*InfoForRecoveryAnalysis) SetValuesFromTabletInfo

func (info *InfoForRecoveryAnalysis) SetValuesFromTabletInfo()