Versions in this module Expand all Collapse all v1 v1.2.3 Aug 25, 2022 v1.0.2 Aug 25, 2022 v1.0.1 Aug 25, 2022 Changes in this version + const ConfigKeyEnableBackgroundStatisticCollection + const ConfigKeyEnableBinlogRowsQueryLogEvents + const ConfigKeyEnableComplexDmlCrossDB + const ConfigKeyEnableLocalMode + const ConfigKeyEnableTableRecycleBin + const ConfigKeyForbidDeleteWholeTable + const ConfigKeyInformationSchemaAggregateStats + const ConfigKeyLogicalConnIdleTimeout + const ConfigKeyMaxAllowedPacketSize + const ConfigKeyMemoryLimitPerQuery + const ConfigKeyMergeUnionSize + const ConfigKeyParallelism + const ConfigKeyPhysicalConnBlockingTimeout + const ConfigKeyPhysicalConnIdleTimeout + const ConfigKeyPhysicalConnMaxPoolSize + const ConfigKeyPhysicalConnMinPoolSize + const ConfigKeyPhysicalConnSocketTimeout + const ConfigKeySlowSqlRtThreshold + const ConfigKeyTimeZone + const ConfigKeyTransactionLogsPurgeStartTime + const MetaDBName + func ConvertIntOrStringMapToStringMap(config map[string]intstr.IntOrString) map[string]string + func GenerateDynamicConfigMap(config map[string]string) map[string]string + type CdcNodeInfo struct + ContainerId string + DaemonPort int32 + Host string + type ClusterKind int32 + const MasterCluster + const ReadOnlyCluster + func (k ClusterKind) String() string + type ComputeNodeInfo struct + CpuCore int32 + Extra string + Host string + HtapPort int32 + MemSize int64 + MgrPort int32 + MppPort int32 + Port int32 + Status PCNodeStatus + type GrantOption struct + Databases []string + Host string + Privileges []string + Type GrantPrivilegeType + User string + type GrantPrivilegeType string + const GrantAllPrivilege + const GrantCustomPrivilege + const GrantDdlPrivilege + const GrantReadOnlyPrivilege + const GrantReadWritePrivilege + const GrantSuperPrivilege + type K8sObject struct + Name string + Uid types.UID + type K8sTopology struct + DN map[string]K8sObject + GMS K8sObject + type Manager interface + Close func() error + CreateDBAccount func(user, passwd string, grantOptions ...*GrantOption) error + DeleteCdcNodes func(cdcNodes ...CdcNodeInfo) error + DeleteComputeNodes func(computeNodes ...ComputeNodeInfo) error + DeleteDBAccount func(user string) error + DisableComputeNodes func(computeNodes ...ComputeNodeInfo) error + DisableStorageNodes func(storageNodes ...StorageNodeInfo) error + EnableComputeNodes func(computeNodes ...ComputeNodeInfo) error + EnableStorageNodes func(storageNodes ...StorageNodeInfo) error + GetK8sTopology func() (*K8sTopology, error) + InitializeMetaDB func() error + IsGmsSchemaRestored func() (bool, error) + IsMetaDBInitialized func() (bool, error) + ListCdcNodes func() ([]CdcNodeInfo, error) + ListComputeNodes func() ([]ComputeNodeInfo, error) + ListDynamicParams func() (map[string]string, error) + ListStorageNodes func(kind StorageKind) ([]StorageNodeInfo, error) + Lock func() error + RestoreSchemas func(fromPxcCluster string) error + SyncAccountPasswd func(user, passwd string) error + SyncComputeNodes func(computeNodes ...ComputeNodeInfo) error + SyncDynamicParams func(params map[string]string) error + SyncK8sTopology func(topology *K8sTopology) error + SyncSecurityIPs func([]string) error + Unlock func() error + func NewGmsManager(ctx context.Context, clusterId string, metadb *MetaDB, ...) Manager + type MetaDB struct + Host string + Host4Conn string + Id string + Passwd string + Port int + Type StorageType + User string + XPort int + type PCNodeStatus int32 + const PCNodeDisabled + const PCNodeEnabled + type PSNodeStatus int32 + const PSNodeDisabled + const PSNodeDisabling + const PSNodeEnabled + type StorageKind int32 + const StorageKindMaster + const StorageKindMetaDB + const StorageKindSlave + type StorageNodeInfo struct + CpuCore int32 + Extra string + Host string + Id string + Kind StorageKind + MaxConn int32 + MemSize int64 + Passwd string + Port int32 + Status PSNodeStatus + Type StorageType + User string + XProtocolPort int32 + type StorageType int32 + const StorageTypeGalaxyCluster + const StorageTypeGalaxySingle + const StorageTypeMySQL + const StorageTypePolarDB + const StorageTypeXCluster57 + const StorageTypeXCluster80 + func GetStorageType(engine string, version string) (StorageType, error)
Go to main page