tenant

package
v0.0.0-...-fee78ac Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DBA_OB_TENANTS               = "oceanbase.DBA_OB_TENANTS"
	DBA_OB_UNITS                 = "oceanbase.DBA_OB_UNITS"
	DBA_OB_RESOURCE_POOLS        = "oceanbase.DBA_OB_RESOURCE_POOLS"
	DBA_OB_TENANT_JOBS           = "oceanbase.DBA_OB_TENANT_JOBS"
	DBA_OB_UNIT_CONFIGS          = "oceanbase.DBA_OB_UNIT_CONFIGS"
	DBA_OB_CLUSTER_EVENT_HISTORY = "oceanbase.DBA_OB_CLUSTER_EVENT_HISTORY"
	DBA_RECYCLEBIN               = "oceanbase.DBA_RECYCLEBIN"

	CDB_OB_SYS_VARIABLES        = "oceanbase.CDB_OB_SYS_VARIABLES"
	CDB_OB_ARCHIVELOG           = "oceanbase.CDB_OB_ARCHIVELOG"
	CDB_OB_BACKUP_DELETE_POLICY = "oceanbase.CDB_OB_BACKUP_DELETE_POLICY"
	CDB_OB_BACKUP_JOBS          = "oceanbase.CDB_OB_BACKUP_JOBS"
	CDB_OB_ARCHIVE_DEST         = "oceanbase.CDB_OB_ARCHIVE_DEST"
	CDB_OB_BACKUP_PARAMETER     = "oceanbase.CDB_OB_BACKUP_PARAMETER"
	CDB_OB_BACKUP_TASKS         = "oceanbase.CDB_OB_BACKUP_TASKS"
	CDB_OB_BACKUP_TASK_HISTORY  = "oceanbase.CDB_OB_BACKUP_TASK_HISTORY"
	CDB_OB_RESTORE_PROGRESS     = "oceanbase.CDB_OB_RESTORE_PROGRESS"
	CDB_OB_RESTORE_HISTORY      = "oceanbase.CDB_OB_RESTORE_HISTORY"

	GV_OB_PARAMETERS = "oceanbase.GV$OB_PARAMETERS"
	GV_OB_SERVERS    = "oceanbase.GV$OB_SERVERS"

	MYSQL_TIME_ZONE = "mysql.time_zone"
)
View Source 
const (
	// tenant sql
	SQL_CREATE_TENANT_BASIC = "CREATE TENANT `%s` resource_pool_list=(%s)"
	SQL_DROP_TENANT         = "DROP TENANT IF EXISTS `%s` PURGE"
	SQL_RECYCLE_TENANT      = "set session recyclebin=1; DROP TENANT `%s`"
	SQL_RENAME_TENANT       = "ALTER TENANT `%s` RENAME GLOBAL_NAME TO `%s`"
	SQL_FLASHBACK_TENANT    = "FLASHBACK TENANT `%s` TO BEFORE DROP RENAME TO `%s`"
	SQL_PURGE_TENANT        = "PURGE TENANT `%s`"

	SQL_ALTER_RESOURCE_LIST        = "ALTER TENANT `%s` RESOURCE_POOL_LIST=(%s)"
	SQL_ALTER_TENANT_LOCALITY      = "ALTER TENANT `%s` LOCALITY = \"%s\""
	SQL_ALTER_TENANT_UNIT_NUM      = "ALTER RESOURCE TENANT `%s` UNIT_NUM = %d"
	SQL_ALTER_TENANT_PRIMARY_ZONE  = "ALTER TENANT `%s` PRIMARY_ZONE = `%s`"
	SQL_ALTER_TENANT_ROOT_PASSWORD = "ALTER USER root@'%%' IDENTIFIED BY \"%s\""

	SQL_LOCK_TENANT   = "ALTER TENANT `%s` LOCK"
	SQL_UNLOCK_TENANT = "ALTER TENANT `%s` UNLOCK"

	SQL_SET_TENANT_PARAMETER_BASIC = "ALTER SYSTEM SET "
	SQL_SET_TENANT_VARIABLE_BASIC  = "ALTER TENANT `%s` SET VARIABLES "

	// resource pool sql
	SQL_CREATE_RESOURCE_POOL = "CREATE RESOURCE POOL `%s` UNIT = `%s`, UNIT_NUM = %d, ZONE_LIST = ('%s')"

	SQL_DROP_RESOURCE_POOL_IF_EXISTS = "DROP RESOURCE POOL IF EXISTS `%s`"
	SQL_DROP_RESOURCE_POOL           = "DROP RESOURCE POOL `%s`"

	SQL_ALTER_RESOURCE_POOL_SPLIT       = "ALTER RESOURCE POOL `%s` SPLIT INTO (%s) ON (%s)"
	SQL_ALTER_RESOURCE_POOL_UNIT_CONFIG = "ALTER RESOURCE POOL `%s` UNIT = `%s`"

	// parameters and variables
	SQL_ALTER_TENANT_WHITELIST = "ALTER TENANT `%s` SET VARIABLES ob_tcp_invited_nodes = `%s`"
)

Variables

This section is empty.

Functions

func ParseLocalityToReplicaInfoMap 

func ParseLocalityToReplicaInfoMap(locality string) (map[string]string, error)

func ParsePrimaryZone 

func ParsePrimaryZone(primaryZone string) (res []string)

ParsePrimaryZone will parse the primary zone string to a slice of different priority zones. every priority zone will be a string with zones separated by comma and sorted.

Types

type TenantService 

type TenantService struct{}

func (*TenantService) ActiveTenant 

func (s *TenantService) ActiveTenant(tenantName string) (err error)

func (*TenantService) AlterResourcePoolList 

func (t *TenantService) AlterResourcePoolList(tenantId int, poolList []string) error

func (*TenantService) AlterResourcePoolUnitConfig 

func (t *TenantService) AlterResourcePoolUnitConfig(poolName string, unitConfigName string) error

AlterResourcePoolUnitConfigByZoneName alter resource pool unit config by zone name, only support the pool contains only one zone

func (*TenantService) AlterTenantLocality 

func (t *TenantService) AlterTenantLocality(tenantId int, locality string) error

func (*TenantService) AlterTenantPrimaryZone 

func (t *TenantService) AlterTenantPrimaryZone(tenantName string, primaryZone string) error

func (*TenantService) AlterTenantUnitNum 

func (t *TenantService) AlterTenantUnitNum(tenantName string, unitNum int) error

func (*TenantService) CancelRestore 

func (s *TenantService) CancelRestore(tenantName string) (err error)

func (*TenantService) CheckTenantHasPoolOnZone 

func (t *TenantService) CheckTenantHasPoolOnZone(tenantId int, zoneName string) (bool, error)

func (*TenantService) CheckVariables 

func (t *TenantService) CheckVariables(vars map[string]interface{}) error

func (*TenantService) CloseArchiveLog 

func (s *TenantService) CloseArchiveLog(tenantName string) (err error)

func (*TenantService) CreateResourcePool 

func (t *TenantService) CreateResourcePool(name string, unitConfigName string, unitNum int, zonelist []string) error

func (*TenantService) CreateTenant 

func (t *TenantService) CreateTenant(basic string, input []interface{}) error

func (*TenantService) DeleteResourcePool 

func (s *TenantService) DeleteResourcePool(name string) (err error)

func (*TenantService) DeleteTenant 

func (s *TenantService) DeleteTenant(name string) (err error)

func (*TenantService) DropDeletePolicy 

func (s *TenantService) DropDeletePolicy(tenantName, policyName string) error

func (*TenantService) DropResourcePool 

func (t *TenantService) DropResourcePool(name string, ifExist bool) error

func (*TenantService) DropTenant 

func (t *TenantService) DropTenant(tenantName string) error

func (*TenantService) EnableArchiveLogDest 

func (s *TenantService) EnableArchiveLogDest(tenantName string) (err error)

func (*TenantService) FlashbackTenant 

func (t *TenantService) FlashbackTenant(name string, newName string) error

func (*TenantService) GetAllResourcePool 

func (t *TenantService) GetAllResourcePool() (pools []model.DbaObResourcePool, err error)

func (*TenantService) GetAllUserTenants 

func (s *TenantService) GetAllUserTenants() (res []oceanbase.DbaObTenant, err error)

func (*TenantService) GetArchiveDestByID 

func (s *TenantService) GetArchiveDestByID(tenantID int) (value string, err error)

func (*TenantService) GetArchiveLogByID 

func (s *TenantService) GetArchiveLogByID(tenantID int) (res *oceanbase.CdbOBArchivelog, err error)

func (*TenantService) GetArchiveLogStatus 

func (s *TenantService) GetArchiveLogStatus(tenantID int) (status string, err error)

func (*TenantService) GetDataBackupDestByID 

func (s *TenantService) GetDataBackupDestByID(tenantID int) (value string, err error)

func (*TenantService) GetDeletePolicy 

func (s *TenantService) GetDeletePolicy(tenantID int) (*oceanbase.CdbObBackupDeletePolicy, error)

func (*TenantService) GetInProgressTenantJobBo 

func (t *TenantService) GetInProgressTenantJobBo(jobType string, tenantId int) (*bo.DbaObTenantJobBo, error)

func (*TenantService) GetLastBackupTask 

func (s *TenantService) GetLastBackupTask(tenantID int) (task *oceanbase.CdbObBackupTask, err error)

func (*TenantService) GetLastRestoreTask 

func (s *TenantService) GetLastRestoreTask(tenantName string) (*bo.CdbObRestoreHistory, error)

func (*TenantService) GetObServerCapacityByZone 

func (t *TenantService) GetObServerCapacityByZone(zone string) (servers []oceanbase.ObServerCapacity, err error)

func (*TenantService) GetRecycledTenant 

func (t *TenantService) GetRecycledTenant() (overview []oceanbase.DbaRecyclebin, err error)

func (*TenantService) GetRecycledTenantObjectName 

func (t *TenantService) GetRecycledTenantObjectName(objectOrOriginalName string) (objectName string, err error)

func (*TenantService) GetRecycledTenantOriginalName 

func (t *TenantService) GetRecycledTenantOriginalName(objectOrOriginalName string) (originalName string, err error)

func (*TenantService) GetResourcePoolByName 

func (t *TenantService) GetResourcePoolByName(name string) (pool *model.DbaObResourcePool, err error)

func (*TenantService) GetResourcePoolsByName 

func (s *TenantService) GetResourcePoolsByName(poolName string) (res *oceanbase.DbaObResourcePool, err error)

func (*TenantService) GetResourcePoolsByTenantID 

func (s *TenantService) GetResourcePoolsByTenantID(tenantID int) (res []oceanbase.DbaObResourcePool, err error)

func (*TenantService) GetResourcePoolsNameByTenantID 

func (s *TenantService) GetResourcePoolsNameByTenantID(tenantID int) (res []string, err error)

func (*TenantService) GetRunningBackupTask 

func (s *TenantService) GetRunningBackupTask(tenantID int) (task *oceanbase.CdbObBackupTask, err error)

func (*TenantService) GetRunningRestoreTask 

func (s *TenantService) GetRunningRestoreTask(tenantName string) (*bo.CdbObRestoreProgress, error)

func (*TenantService) GetTargetTenantJob 

func (t *TenantService) GetTargetTenantJob(jobType string, tenantId int, sqlText string) (id int, err error)

func (*TenantService) GetTenantActiveAgent 

func (t *TenantService) GetTenantActiveAgent(tenantName string) (agent *meta.AgentInfo, err error)

func (*TenantService) GetTenantActiveServer 

func (t *TenantService) GetTenantActiveServer(tenantName string) (server *oceanbase.OBServer, err error)

func (*TenantService) GetTenantByID 

func (s *TenantService) GetTenantByID(id int) (res *oceanbase.DbaObTenant, err error)

func (*TenantService) GetTenantByName 

func (s *TenantService) GetTenantByName(name string) (res *oceanbase.DbaObTenant, err error)

func (*TenantService) GetTenantId 

func (t *TenantService) GetTenantId(name string) (int, error)

func (*TenantService) GetTenantJobStatus 

func (t *TenantService) GetTenantJobStatus(jobId int) (status string, err error)

func (*TenantService) GetTenantLevelDagIDByTenantName 

func (s *TenantService) GetTenantLevelDagIDByTenantName(name string) (id *int64, err error)

func (*TenantService) GetTenantLocality 

func (t *TenantService) GetTenantLocality(tenantId int) (locality string, err error)

func (*TenantService) GetTenantName 

func (t *TenantService) GetTenantName(id int) (string, error)

func (*TenantService) GetTenantParameter 

func (t *TenantService) GetTenantParameter(tenantId int, parameterName string) (parameter *oceanbase.GvObParameter, err error)

func (*TenantService) GetTenantParameters 

func (t *TenantService) GetTenantParameters(tenantName string, filter string) (parameters []oceanbase.GvObParameter, err error)

func (*TenantService) GetTenantPrimaryZone 

func (t *TenantService) GetTenantPrimaryZone(tenantId int) (zone string, err error)

func (*TenantService) GetTenantReplicaInfoMap 

func (t *TenantService) GetTenantReplicaInfoMap(tenantId int) (map[string]string, error)

GetTenantReplicaInfoMap return a map, key is zone, value is replica type

func (*TenantService) GetTenantResourcePool 

func (t *TenantService) GetTenantResourcePool(tenantId int) (pools []model.DbaObResourcePool, err error)

func (*TenantService) GetTenantResourcePoolNames 

func (t *TenantService) GetTenantResourcePoolNames(tenantId int) (pools []string, err error)

func (*TenantService) GetTenantRole 

func (s *TenantService) GetTenantRole(tenantName string) (role string, err error)

func (*TenantService) GetTenantStatus 

func (t *TenantService) GetTenantStatus(name string) (string, error)

func (*TenantService) GetTenantUnitNum 

func (t *TenantService) GetTenantUnitNum(tenantId int) (unitNum int, err error)

func (*TenantService) GetTenantVariable 

func (t *TenantService) GetTenantVariable(tenantName string, variableName string) (variable *oceanbase.CdbObSysVariable, err error)

func (*TenantService) GetTenantVariables 

func (t *TenantService) GetTenantVariables(tenantName string, filter string) (variables []oceanbase.CdbObSysVariable, err error)

func (*TenantService) GetTenantsOverView 

func (t *TenantService) GetTenantsOverView() (overviews []oceanbase.DbaObTenant, err error)

func (*TenantService) GetUnitConfigByName 

func (s *TenantService) GetUnitConfigByName(name string) (res *oceanbase.DbaObUnitConfig, err error)

func (*TenantService) GetUpgradeJobHistoryCount 

func (s *TenantService) GetUpgradeJobHistoryCount(tenantName string) (count int64, err error)

func (*TenantService) IsArchiveLogClosed 

func (s *TenantService) IsArchiveLogClosed(tenantName string) (bool, error)

func (*TenantService) IsBackupFinished 

func (s *TenantService) IsBackupFinished(tenantID int) (bool, error)

func (*TenantService) IsMetaTenantStatusNormal 

func (s *TenantService) IsMetaTenantStatusNormal(tenantName string) (bool, error)

func (*TenantService) IsResourcePoolExistAndFreed 

func (t *TenantService) IsResourcePoolExistAndFreed(name string, unitConfigName string, unitNum int, zoneName string) (bool, error)

func (*TenantService) IsTenantActiveAgent 

func (t *TenantService) IsTenantActiveAgent(tenantName string, ip string, rpcPort int) (bool, error)

func (*TenantService) IsTenantExist 

func (t *TenantService) IsTenantExist(name string) (bool, error)

func (*TenantService) IsTenantExistInRecyclebin 

func (t *TenantService) IsTenantExistInRecyclebin(name string) (bool, error)

func (*TenantService) IsTimeZoneTableEmpty 

func (t *TenantService) IsTimeZoneTableEmpty() (bool, error)

func (*TenantService) LockTenant 

func (t *TenantService) LockTenant(name string) error

func (*TenantService) ModifyTenantRootPassword 

func (t *TenantService) ModifyTenantRootPassword(tenantName string, oldPwd string, newPwd string) *errors.OcsAgentError

func (*TenantService) ModifyTenantWhitelist 

func (t *TenantService) ModifyTenantWhitelist(tenantName string, whitelist string) error

func (*TenantService) OpenArchiveLog 

func (s *TenantService) OpenArchiveLog(tenantName string) (err error)

func (*TenantService) PurgeTenant 

func (t *TenantService) PurgeTenant(name string) error

This function return immediately, but the tenant may not be purged yet. There is a column named 'CAN_PURGE' in DBA_RECYCLEBIN

func (*TenantService) RecycleTenant 

func (t *TenantService) RecycleTenant(tenantName string) error

func (*TenantService) RenameTenant 

func (t *TenantService) RenameTenant(name string, newName string) error

func (*TenantService) Restore 

func (s *TenantService) Restore(c *param.RestoreParam, locality, poolList string, scn int64) (err error)

func (*TenantService) SetArchiveLagTarget 

func (s *TenantService) SetArchiveLagTarget(tenantName string, target string) (err error)

func (*TenantService) SetDataBackupDest 

func (s *TenantService) SetDataBackupDest(tenantName, dest string) (err error)

func (*TenantService) SetDeletePolicy 

func (s *TenantService) SetDeletePolicy(tenantName string, policy param.BackupDeletePolicy) error

func (*TenantService) SetEncryption 

func (s *TenantService) SetEncryption(pwd string) (err error)

func (*TenantService) SetHaHighThreadScore 

func (s *TenantService) SetHaHighThreadScore(tenantName string, score int) error

func (*TenantService) SetHaLowThreadScore 

func (s *TenantService) SetHaLowThreadScore(tenantName string, score int) error

func (*TenantService) SetLogArchiveConcurrency 

func (s *TenantService) SetLogArchiveConcurrency(tenantName string, concurrency int) (err error)

func (*TenantService) SetLogArchiveDest 

func (s *TenantService) SetLogArchiveDest(tenantName string, dest param.LogArchiveDestConf) (err error)

func (*TenantService) SetTenantParameters 

func (t *TenantService) SetTenantParameters(tenantName string, parameters map[string]interface{}) error

func (*TenantService) SetTenantVariables 

func (t *TenantService) SetTenantVariables(tenantName string, variables map[string]interface{}) error

func (*TenantService) SplitResourcePool 

func (t *TenantService) SplitResourcePool(poolName string, poolList []string, zoneList []string) error

func (*TenantService) StartFullBackup 

func (s *TenantService) StartFullBackup(tenantName, encryption string, plusArchive bool) error

func (*TenantService) StartIncrementalBackup 

func (s *TenantService) StartIncrementalBackup(tenantName, encryption string, plusArchive bool) error

func (*TenantService) StopBackup 

func (s *TenantService) StopBackup(tenantName string) error

func (*TenantService) TryExecute 

func (t *TenantService) TryExecute(sql string) error

func (*TenantService) UnlockTenant 

func (t *TenantService) UnlockTenant(name string) error

func (*TenantService) Upgrade 

func (s *TenantService) Upgrade(tenantName string) (err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.