constant

package
v0.8.3 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: AGPL-3.0 Imports: 1 Imported by: 12

Documentation

Index

Constants

View Source 
const (
	// config keys used in viper, DON'T refactor the value without careful inspections
	CfgKeyServerInfo                    = "_KUBE_SERVER_INFO"
	CfgKeyCtrlrMgrNS                    = "CM_NAMESPACE"
	CfgKeyCtrlrMgrAffinity              = "CM_AFFINITY"
	CfgKeyCtrlrMgrNodeSelector          = "CM_NODE_SELECTOR"
	CfgKeyCtrlrMgrTolerations           = "CM_TOLERATIONS"
	CfgKeyCtrlrReconcileRetryDurationMS = "CM_RECON_RETRY_DURATION_MS"       // accept time
	CfgRecoverVolumeExpansionFailure    = "RECOVER_VOLUME_EXPANSION_FAILURE" // refer to feature gates RecoverVolumeExpansionFailure of k8s.
	CfgKeyProvider                      = "KUBE_PROVIDER"
	CfgHostPortConfigMapName            = "HOST_PORT_CM_NAME"
	CfgHostPortIncludeRanges            = "HOST_PORT_INCLUDE_RANGES"
	CfgHostPortExcludeRanges            = "HOST_PORT_EXCLUDE_RANGES"

	// addon config keys
	CfgKeyAddonJobTTL        = "ADDON_JOB_TTL"
	CfgAddonJobImgPullPolicy = "ADDON_JOB_IMAGE_PULL_POLICY"

	// data plane config key
	CfgKeyDataPlaneTolerations = "DATA_PLANE_TOLERATIONS"
	CfgKeyDataPlaneAffinity    = "DATA_PLANE_AFFINITY"

	// storage config keys
	CfgKeyDefaultStorageClass = "DEFAULT_STORAGE_CLASS"

	// customized encryption key for encrypting the password of connection credential.
	CfgKeyDPEncryptionKey = "DP_ENCRYPTION_KEY"

	CfgKBReconcileWorkers = "KUBEBLOCKS_RECONCILE_WORKERS"
	CfgClientQPS          = "CLIENT_QPS"
	CfgClientBurst        = "CLIENT_BURST"
)
View Source 
const (
	// TODO: deprecated, will be removed later.
	KBConnCredentialPlaceHolder = "$(CONN_CREDENTIAL_SECRET_NAME)"
	KBComponentEnvCMPlaceHolder = "$(COMP_ENV_CM_NAME)"
	KBToolsImagePlaceHolder     = "$(KUBEBLOCKS_TOOLS_IMAGE)"
)
View Source 
const (
	KBPrefix      = "KB"
	KBLowerPrefix = "kb"
)
View Source 
const (
	KBServiceAccountName     = "KUBEBLOCKS_SERVICEACCOUNT_NAME"
	KBToolsImage             = "KUBEBLOCKS_TOOLS_IMAGE"
	KBImagePullPolicy        = "KUBEBLOCKS_IMAGE_PULL_POLICY"
	KBDataScriptClientsImage = "KUBEBLOCKS_DATASCRIPT_CLIENTS_IMAGE"
)
View Source 
const (
	APIGroup = "kubeblocks.io"

	AppName = "kubeblocks"

	// AppInstanceLabelKey refer cluster.Name
	AppInstanceLabelKey = "app.kubernetes.io/instance"
	// AppNameLabelKey refer clusterDefinition.Name before KubeBlocks Version 0.8.0 or refer ComponentDefinition.Name after KubeBlocks Version 0.8.0 (TODO：Pending)
	AppNameLabelKey = "app.kubernetes.io/name"
	// AppComponentLabelKey refer clusterDefinition.Spec.ComponentDefs[*].Name before KubeBlocks Version 0.8.0 or refer ComponentDefinition.Name after KubeBlocks Version 0.8.0
	AppComponentLabelKey = "app.kubernetes.io/component"
	// AppVersionLabelKey refer clusterVersion.Name before KubeBlocks Version 0.8.0 or refer ComponentDefinition.Name after KubeBlocks Version 0.8.0
	AppVersionLabelKey   = "app.kubernetes.io/version"
	AppManagedByLabelKey = "app.kubernetes.io/managed-by"
	RegionLabelKey       = "topology.kubernetes.io/region"
	ZoneLabelKey         = "topology.kubernetes.io/zone"

	// kubeblocks.io labels
	BackupProtectionLabelKey                 = "kubeblocks.io/backup-protection" // BackupProtectionLabelKey Backup delete protection policy label
	AddonProviderLabelKey                    = "kubeblocks.io/provider"          // AddonProviderLabelKey marks the addon provider
	RoleLabelKey                             = "kubeblocks.io/role"              // RoleLabelKey consensusSet and replicationSet role label key
	ReadyWithoutPrimaryKey                   = "kubeblocks.io/ready-without-primary"
	VolumeTypeLabelKey                       = "kubeblocks.io/volume-type"
	ClusterAccountLabelKey                   = "account.kubeblocks.io/name"
	KBAppClusterUIDLabelKey                  = "apps.kubeblocks.io/cluster-uid"
	KBAppComponentLabelKey                   = "apps.kubeblocks.io/component-name"
	KBAppShardingNameLabelKey                = "apps.kubeblocks.io/sharding-name"
	KBAppComponentDefRefLabelKey             = "apps.kubeblocks.io/component-def-ref" // refer clusterDefinition.Spec.ComponentDefs[*].Name before KubeBlocks Version 0.8.0 or refer ComponentDefinition.Name after KubeBlocks Version 0.8.0
	KBAppClusterDefTypeLabelKey              = "apps.kubeblocks.io/cluster-type"      // refer clusterDefinition.Spec.Type (deprecated)
	AppConfigTypeLabelKey                    = "apps.kubeblocks.io/config-type"
	KBManagedByKey                           = "apps.kubeblocks.io/managed-by" // KBManagedByKey marks resources that auto created
	PVCNameLabelKey                          = "apps.kubeblocks.io/pvc-name"
	VolumeClaimTemplateNameLabelKey          = "apps.kubeblocks.io/vct-name"
	VolumeClaimTemplateNameLabelKeyForLegacy = "vct.kubeblocks.io/name" // Deprecated: only compatible with version 0.5, will be removed in 0.7
	WorkloadTypeLabelKey                     = "apps.kubeblocks.io/workload-type"
	ClassProviderLabelKey                    = "class.kubeblocks.io/provider"
	ClusterDefLabelKey                       = "clusterdefinition.kubeblocks.io/name"
	ClusterVerLabelKey                       = "clusterversion.kubeblocks.io/name"
	ComponentDefinitionLabelKey              = "componentdefinition.kubeblocks.io/name"
	CMConfigurationSpecProviderLabelKey      = "config.kubeblocks.io/config-spec"    // CMConfigurationSpecProviderLabelKey is ComponentConfigSpec name
	CMConfigurationCMKeysLabelKey            = "config.kubeblocks.io/configmap-keys" // CMConfigurationCMKeysLabelKey Specify configmap keys
	CMConfigurationTemplateNameLabelKey      = "config.kubeblocks.io/config-template-name"
	CMTemplateNameLabelKey                   = "config.kubeblocks.io/template-name"
	CMConfigurationTypeLabelKey              = "config.kubeblocks.io/config-type"
	CMInsConfigurationHashLabelKey           = "config.kubeblocks.io/config-hash"
	CMInsCurrentConfigurationHashLabelKey    = "config.kubeblocks.io/update-config-hash"
	CMConfigurationConstraintsNameLabelKey   = "config.kubeblocks.io/config-constraints-name"
	CMConfigurationTemplateVersion           = "config.kubeblocks.io/config-template-version"
	ConsensusSetAccessModeLabelKey           = "cs.apps.kubeblocks.io/access-mode"
	AddonNameLabelKey                        = "extensions.kubeblocks.io/addon-name"
	OpsRequestTypeLabelKey                   = "ops.kubeblocks.io/ops-type"
	OpsRequestNameLabelKey                   = "ops.kubeblocks.io/ops-name"
	OpsRequestNamespaceLabelKey              = "ops.kubeblocks.io/ops-namespace"
	ServiceDescriptorNameLabelKey            = "servicedescriptor.kubeblocks.io/name"
	RestoreForHScaleLabelKey                 = "apps.kubeblocks.io/restore-for-hscale"
	ResourceConstraintProviderLabelKey       = "resourceconstraint.kubeblocks.io/provider"

	// StatefulSetPodNameLabelKey is used to mark the pod name of the StatefulSet
	StatefulSetPodNameLabelKey = "statefulset.kubernetes.io/pod-name"

	// kubeblocks.io annotations
	ClusterSnapshotAnnotationKey                = "kubeblocks.io/cluster-snapshot"           // ClusterSnapshotAnnotationKey saves the snapshot of cluster.
	DefaultClusterVersionAnnotationKey          = "kubeblocks.io/is-default-cluster-version" // DefaultClusterVersionAnnotationKey specifies the default cluster version.
	OpsRequestAnnotationKey                     = "kubeblocks.io/ops-request"                // OpsRequestAnnotationKey OpsRequest annotation key in Cluster
	ReconcileAnnotationKey                      = "kubeblocks.io/reconcile"                  // ReconcileAnnotationKey Notify k8s object to reconcile
	RestartAnnotationKey                        = "kubeblocks.io/restart"                    // RestartAnnotationKey the annotation which notices the StatefulSet/DeploySet to restart
	RestoreFromBackupAnnotationKey              = "kubeblocks.io/restore-from-backup"        // RestoreFromBackupAnnotationKey specifies the component to recover from the backup.
	SnapShotForStartAnnotationKey               = "kubeblocks.io/snapshot-for-start"
	ComponentReplicasAnnotationKey              = "apps.kubeblocks.io/component-replicas" // ComponentReplicasAnnotationKey specifies the number of pods in replicas
	BackupPolicyTemplateAnnotationKey           = "apps.kubeblocks.io/backup-policy-template"
	LastAppliedClusterAnnotationKey             = "apps.kubeblocks.io/last-applied-cluster"
	PVLastClaimPolicyAnnotationKey              = "apps.kubeblocks.io/pv-last-claim-policy"
	HaltRecoveryAllowInconsistentCVAnnotKey     = "clusters.apps.kubeblocks.io/allow-inconsistent-cv"
	HaltRecoveryAllowInconsistentResAnnotKey    = "clusters.apps.kubeblocks.io/allow-inconsistent-resource"
	PrimaryAnnotationKey                        = "rs.apps.kubeblocks.io/primary"
	DisableUpgradeInsConfigurationAnnotationKey = "config.kubeblocks.io/disable-reconfigure"
	LastAppliedConfigAnnotationKey              = "config.kubeblocks.io/last-applied-configuration"
	LastAppliedOpsCRAnnotationKey               = "config.kubeblocks.io/last-applied-ops-name"
	UpgradePolicyAnnotationKey                  = "config.kubeblocks.io/reconfigure-policy"
	KBParameterUpdateSourceAnnotationKey        = "config.kubeblocks.io/reconfigure-source"
	UpgradeRestartAnnotationKey                 = "config.kubeblocks.io/restart"
	ConfigAppliedVersionAnnotationKey           = "config.kubeblocks.io/config-applied-version"
	KubeBlocksGenerationKey                     = "kubeblocks.io/generation"
	ExtraEnvAnnotationKey                       = "kubeblocks.io/extra-env"
	LastRoleSnapshotVersionAnnotationKey        = "apps.kubeblocks.io/last-role-snapshot-version"
	HostPortAnnotationKey                       = "kubeblocks.io/host-port"
	HostPortIncludeAnnotationKey                = "network.kubeblocks.io/host-ports-include"
	HostPortExcludeAnnotationKey                = "network.kubeblocks.io/host-ports-exclude"

	// EnabledNodePortSvcAnnotationKey defines the feature gate of NodePort Service defined in ComponentDefinition.Spec.Services.
	// Components defined in the annotation value, their all services of type NodePort defined in ComponentDefinition will be created; otherwise, they will be ignored.
	// Multiple components are separated by ','. for example: "kubeblocks.io/enabled-node-port-svc: comp1,comp2"
	EnabledNodePortSvcAnnotationKey = "kubeblocks.io/enabled-node-port-svc"
	// EnabledPodOrdinalSvcAnnotationKey defines the feature gate of PodOrdinal Service defined in ComponentDefinition.Spec.Services.
	// Components defined in the annotation value, their all Services defined in the ComponentDefinition with the GeneratePodOrdinalService attribute set to true will be created; otherwise, they will be ignored.
	// This can generate a corresponding Service for each Pod, which can be used in certain specific scenarios: for example, creating a dedicated access service for each read-only Pod.
	// Multiple components are separated by ','. for example: "kubeblocks.io/enabled-pod-ordinal-svc: comp1,comp2"
	EnabledPodOrdinalSvcAnnotationKey = "kubeblocks.io/enabled-pod-ordinal-svc"
	// DisabledClusterIPSvcAnnotationKey defines whether the feature gate of ClusterIp Service defined in ComponentDefinition.Spec.Services will be effected.
	// Components defined in the annotation value, their all services of type ClusterIp defined in ComponentDefinition will be ignored; otherwise, they will be created.
	// Multiple components are separated by ','. for example: "kubeblocks.io/disabled-cluster-ip-svc: comp1,comp2"
	DisabledClusterIPSvcAnnotationKey = "kubeblocks.io/disabled-cluster-ip-svc"
	// ShardSvcAnnotationKey defines the feature gate of creating service for each shard.
	// Sharding name defined in the annotation value, a set of Service defined in Cluster.Spec.Services with the ShardingSelector will be automatically generated for each shard when Cluster.Spec.ShardingSpecs[x].shards is not nil.
	// Multiple sharding names are separated by ','. for example: "kubeblocks.io/enabled-shard-svc: proxy-shard,db-shard"
	ShardSvcAnnotationKey = "kubeblocks.io/enabled-shard-svc"

	// kubeblocks.io well-known finalizers
	DBClusterFinalizerName             = "cluster.kubeblocks.io/finalizer"
	DBComponentFinalizerName           = "component.kubeblocks.io/finalizer"
	DBComponentDefinitionFinalizerName = "componentdefinition.kubeblocks.io/finalizer"
	ConfigurationTemplateFinalizerName = "config.kubeblocks.io/finalizer"
	ServiceDescriptorFinalizerName     = "servicedescriptor.kubeblocks.io/finalizer"
	OpsRequestFinalizerName            = "opsrequest.kubeblocks.io/finalizer"

	// ConfigurationTplLabelPrefixKey clusterVersion or clusterdefinition using tpl
	ConfigurationTplLabelPrefixKey         = "config.kubeblocks.io/tpl"
	ConfigurationConstraintsLabelPrefixKey = "config.kubeblocks.io/constraints"

	// CMInsLastReconfigurePhaseKey defines the current phase
	CMInsLastReconfigurePhaseKey = "config.kubeblocks.io/last-applied-reconfigure-phase"

	// ConfigurationRevision defines the current revision
	// TODO support multi version
	ConfigurationRevision          = "config.kubeblocks.io/configuration-revision"
	LastConfigurationRevisionPhase = "config.kubeblocks.io/revision-reconcile-phase"

	// Deprecated: only compatible with version 0.6, will be removed in 0.8
	// CMInsEnableRerenderTemplateKey is used to enable rerender template
	CMInsEnableRerenderTemplateKey = "config.kubeblocks.io/enable-rerender"

	// IgnoreResourceConstraint is used to specify whether to ignore the resource constraint
	IgnoreResourceConstraint = "resource.kubeblocks.io/ignore-constraint"

	RBACRoleName        = "kubeblocks-cluster-pod-role"
	RBACClusterRoleName = "kubeblocks-volume-protection-pod-role"

	// FeatureReconciliationInCompactModeAnnotationKey indicates that the controller should run in compact mode,
	// means to try the best to cutoff useless objects.
	FeatureReconciliationInCompactModeAnnotationKey = "kubeblocks.io/compact-mode"
)
View Source 
const (
	// ReasonNotFoundCR referenced custom resource not found
	ReasonNotFoundCR = "NotFound"
	// ReasonRefCRUnavailable  referenced custom resource is unavailable
	ReasonRefCRUnavailable = "Unavailable"
	// ReasonDeletedCR deleted custom resource
	ReasonDeletedCR = "DeletedCR"
	// ReasonDeletingCR deleting custom resource
	ReasonDeletingCR = "DeletingCR"
	// ReasonCreatedCR created custom resource
	ReasonCreatedCR = "CreatedCR"
	// ReasonRunTaskFailed run task failed
	ReasonRunTaskFailed = "RunTaskFailed"
	// ReasonDeleteFailed delete failed
	ReasonDeleteFailed = "DeleteFailed"
)
View Source 
const (
	DeploymentKind            = "Deployment"
	StatefulSetKind           = "StatefulSet"
	RSMKind                   = "ReplicatedStateMachine"
	PodKind                   = "Pod"
	PersistentVolumeClaimKind = "PersistentVolumeClaim"
	CronJobKind               = "CronJob"
	JobKind                   = "Job"
	ReplicaSetKind            = "ReplicaSet"
	VolumeSnapshotKind        = "VolumeSnapshot"
	ServiceKind               = "Service"
	ConfigMapKind             = "ConfigMap"
	DaemonSetKind             = "DaemonSet"
)
View Source 
const (
	// BackupRetain always retained, unless manually deleted by the user
	BackupRetain = "Retain"

	// BackupRetainUntilExpired retains backup till it expires
	BackupRetainUntilExpired = "RetainUntilExpired"

	// BackupDelete (default) deletes backup immediately when cluster's terminationPolicy is WipeOut
	BackupDelete = "Delete"
)
View Source 
const (
	// Container port name
	LorryHTTPPortName                  = "lorry-http-port"
	LorryGRPCPortName                  = "lorry-grpc-port"
	LorryContainerName                 = "lorry"
	LorryInitContainerName             = "init-lorry"
	ProbeInitContainerName             = "kb-initprobe"
	RoleProbeContainerName             = "kb-checkrole"
	StatusProbeContainerName           = "kb-checkstatus"
	RunningProbeContainerName          = "kb-checkrunning"
	VolumeProtectionProbeContainerName = "kb-volume-protection"
	LorryRoleProbePath                 = "/v1.0/checkrole"
	LorryVolumeProtectPath             = "/v1.0/volumeprotection"

	// the filedpath name used in event.InvolvedObject.FieldPath
	ProbeCheckStatusPath  = "spec.containers{" + StatusProbeContainerName + "}"
	ProbeCheckRunningPath = "spec.containers{" + RunningProbeContainerName + "}"
)
View Source 
const (
	ConfigSidecarName        = "config-manager"
	ConfigManagerGPRCPortEnv = "CONFIG_MANAGER_GRPC_PORT"
	ConfigManagerLogLevel    = "CONFIG_MANAGER_LOG_LEVEL"

	PodMinReadySecondsEnv = "POD_MIN_READY_SECONDS"
	ConfigTemplateType    = "tpl"
	ConfigInstanceType    = "instance"

	ReconfigureManagerSource  = "manager"
	ReconfigureUserSource     = "ops"
	ReconfigureTemplateSource = "external-template"

	ConfigManagerPortName = "config-manager"
)
View Source 
const (
	Primary   = "primary"
	Secondary = "secondary"

	Leader   = "leader"
	Follower = "follower"
	Learner  = "learner"
)
View Source 
const (
	AccountNameForSecret   = "username"
	AccountPasswdForSecret = "password"
)

username and password are keys in created secrets for others to refer to.

View Source 
const (
	KubernetesClusterDomainEnv = "KUBERNETES_CLUSTER_DOMAIN"
	DefaultDNSDomain           = "cluster.local"
)
View Source 
const (
	ServiceDescriptorUsernameKey = "username"
	ServiceDescriptorPasswordKey = "password"
	ServiceDescriptorEndpointKey = "endpoint"
	ServiceDescriptorPortKey     = "port"
)
View Source 
const (
	BackupNameKeyForRestore          = "name"
	BackupNamespaceKeyForRestore     = "namespace"
	VolumeRestorePolicyKeyForRestore = "volumeRestorePolicy"
	RestoreTimeKeyForRestore         = "restoreTime"
	ConnectionPassword               = "connectionPassword"
)
View Source 
const (
	KBEnvClusterName                  = "KB_CLUSTER_NAME"
	KBEnvClusterUID                   = "KB_CLUSTER_UID"
	KBEnvClusterCompName              = "KB_CLUSTER_COMP_NAME"
	KBEnvClusterUIDPostfix8Deprecated = "KB_CLUSTER_UID_POSTFIX_8"
)

Cluster

View Source 
const (
	KBEnvCompName           = "KB_COMP_NAME"
	KBEnvCompReplicas       = "KB_COMP_REPLICAS"
	KBEnvCompServiceVersion = "KB_COMP_SERVICE_VERSION"
)

Component

View Source 
const (
	KBEnvPodName          = "KB_POD_NAME"
	KBEnvPodUID           = "KB_POD_UID"
	KBEnvPodIP            = "KB_POD_IP"
	KBEnvPodIPs           = "KB_POD_IPS"
	KBEnvPodFQDN          = "KB_POD_FQDN"
	KBEnvPodOrdinal       = "KB_POD_ORDINAL"
	KBEnvPodIPDeprecated  = "KB_PODIP"
	KBEnvPodIPsDeprecated = "KB_PODIPS"
)

Pod

View Source 
const (
	KBEnvHostIP           = "KB_HOST_IP"
	KBEnvNodeName         = "KB_NODENAME"
	KBEnvHostIPDeprecated = "KB_HOSTIP"
)

Host

View Source 
const (
	KBEnvTLSCertPath = "KB_TLS_CERT_PATH"
	KBEnvTLSCertFile = "KB_TLS_CERT_FILE"
	KBEnvTLSCAFile   = "KB_TLS_CA_FILE"
	KBEnvTLSKeyFile  = "KB_TLS_KEY_FILE"
)

TLS

View Source 
const (
	KBEnvWorkloadType    = "KB_WORKLOAD_TYPE"
	KBEnvBuiltinHandler  = "KB_BUILTIN_HANDLER"
	KBEnvActionCommands  = "KB_ACTION_COMMANDS"
	KBEnvCharacterType   = "KB_SERVICE_CHARACTER_TYPE"
	KBEnvServiceUser     = "KB_SERVICE_USER"
	KBEnvServicePassword = "KB_SERVICE_PASSWORD"
	KBEnvLorryHTTPPort   = "LORRY_HTTP_PORT"
	KBEnvLorryGRPCPort   = "LORRY_GRPC_PORT"
	KBEnvLorryLogLevel   = "LORRY_LOG_LEVEL"
	// KBEnvServiceRoles defines the Roles configured in the cluster definition that are visible to users.
	KBEnvServiceRoles = "KB_SERVICE_ROLES"

	// KBEnvServicePort defines the port of the DB service
	KBEnvServicePort = "KB_SERVICE_PORT"

	// KBEnvDataPath defines the data volume path of the DB service.
	KBEnvDataPath = "KB_DATA_PATH"

	// KBEnvTTL controls the lease expiration time in DCS. If the leader fails to renew its lease within the TTL duration, it will lose the leader role, allowing other replicas to take over.
	KBEnvTTL = "KB_TTL"

	// KBEnvMaxLag defines maximum replication lag permitted when performing a switchover.
	KBEnvMaxLag = "KB_MAX_LAG"

	// KBEnvEnableHA Whether to enable high availability, true by default.
	KBEnvEnableHA = "KB_ENABLE_HA"

	// KBEnvRsmRoleUpdateMechanism defines the method to send events: DirectAPIServerEventUpdate(through lorry service), ReadinessProbeEventUpdate(through kubelet service)
	KBEnvRsmRoleUpdateMechanism = "KB_RSM_ROLE_UPDATE_MECHANISM"
	KBEnvRoleProbeTimeout       = "KB_RSM_ROLE_PROBE_TIMEOUT"

	KBEnvVolumeProtectionSpec = "KB_VOLUME_PROTECTION_SPEC"
)

Lorry

View Source 
const (
	PostgreSQLCharacterType = "postgresql"
	MySQLCharacterType      = "mysql"
	RedisCharacterType      = "redis"
	MongoDBCharacterType    = "mongodb"
	ETCDCharacterType       = "etcd"
	PolarDBXCharacterType   = "polardbx"
)
View Source 
const (
	RoleProbeAction     = "roleProbe"
	MemberJoinAction    = "memberJoin"
	MemberLeaveAction   = "memberLeave"
	ReadonlyAction      = "readonly"
	ReadWriteAction     = "readwrite"
	PostProvisionAction = "postProvision"
	PreTerminateAction  = "preTerminate"
)

action keys

View Source 
const (
	TLSPayload               = "tls"
	ComponentResourcePayload = "component-resource"
	BinaryVersionPayload     = "binary-version"
)
View Source 
const (
	ServiceKindPostgreSQL    = "postgresql"
	ServiceKindMongoDB       = "mongodb"
	ServiceKindClickHouse    = "clickhouse"
	ServiceKindZookeeper     = "zookeeper"
	ServiceKindElasticSearch = "elasticsearch"
)
View Source 
const (
	VolumeName = "tls"
	CAName     = "ca.crt"
	CertName   = "tls.crt"
	KeyName    = "tls.key"
	MountPath  = "/etc/pki/tls"
)
View Source 
const (
	EnableRBACManager = "EnableRBACManager"
)
View Source 
const (
	FeatureGateReplicatedStateMachine = "REPLICATED_STATE_MACHINE" // enable rsm
)
View Source 
const (
	KBAppMultiClusterPlacementKey = "apps.kubeblocks.io/multi-cluster-placement"
)
View Source 
const (
	KBEnvNamespace = "KB_NAMESPACE"
)

Global

View Source 
const (
	KBEnvServiceAccountName = "KB_SA_NAME"
)

ServiceAccount

View Source 
const (
	KBGeneratedVirtualCompDefPrefix = "KB_GENERATED_VIRTUAL_COMP_DEF"
)

Variables

This section is empty.

Functions

func EnvPlaceHolder added in v0.8.0 

func EnvPlaceHolder(env string) string

func GenerateAccountSecretName added in v0.8.0 

func GenerateAccountSecretName(clusterName, compName, name string) string

GenerateAccountSecretName generates the secret name of system accounts.

func GenerateClusterComponentEnvPattern added in v0.8.0 

func GenerateClusterComponentEnvPattern(clusterName, compName string) string

GenerateClusterComponentEnvPattern generates cluster and component pattern

func GenerateClusterComponentName added in v0.8.0 

func GenerateClusterComponentName(clusterName, compName string) string

GenerateClusterComponentName generates the cluster component name.

func GenerateClusterHeadlessServiceName added in v0.8.0 

func GenerateClusterHeadlessServiceName(clusterName, svcName string) string

GenerateClusterHeadlessServiceName generates the headless service name for cluster.

func GenerateClusterServiceName added in v0.8.0 

func GenerateClusterServiceName(clusterName, svcName string) string

GenerateClusterServiceName generates the service name for cluster.

func GenerateComponentHeadlessServiceName added in v0.8.0 

func GenerateComponentHeadlessServiceName(clusterName, compName, svcName string) string

GenerateComponentHeadlessServiceName generates the headless service name for component.

func GenerateComponentServiceName added in v0.8.0 

func GenerateComponentServiceName(clusterName, compName, svcName string) string

GenerateComponentServiceName generates the service name for component.

func GenerateDefaultComponentHeadlessServiceName added in v0.8.0 

func GenerateDefaultComponentHeadlessServiceName(clusterName, compName string) string

GenerateDefaultComponentHeadlessServiceName generates the default headless service name for component.

func GenerateDefaultComponentServiceName added in v0.8.0 

func GenerateDefaultComponentServiceName(clusterName, compName string) string

GenerateDefaultComponentServiceName generates the default service name for component.

func GenerateDefaultConnCredential added in v0.8.0 

func GenerateDefaultConnCredential(clusterName string) string

GenerateDefaultConnCredential generates the default connection credential name for cluster. TODO: deprecated, will be removed later.

func GenerateDefaultServiceAccountName added in v0.8.0 

func GenerateDefaultServiceAccountName(name string) string

GenerateDefaultServiceAccountName generates default service account name for a cluster.

func GeneratePodFQDN added in v0.8.0 

func GeneratePodFQDN(namespace, clusterName, compName string, ordinal int) string

GeneratePodFQDN generates the connection credential name for component.

func GeneratePodName added in v0.8.0 

func GeneratePodName(clusterName, compName string, ordinal int) string

GeneratePodName generates the connection credential name for component.

func GeneratePodSubDomain added in v0.8.0 

func GeneratePodSubDomain(clusterName, compName string) string

GeneratePodSubDomain generates the connection credential name for component.

func GenerateRSMNamePattern added in v0.8.0 

func GenerateRSMNamePattern(clusterName, compName string) string

GenerateRSMNamePattern generates rsm name pattern

func GenerateRSMServiceNamePattern added in v0.8.0 

func GenerateRSMServiceNamePattern(rsmName string) string

GenerateRSMServiceNamePattern generates rsm name pattern

func GenerateShardingNamePrefix added in v0.8.2 

func GenerateShardingNamePrefix(shardingName string) string

GenerateShardingNamePrefix generates sharding name prefix.

func GenerateShardingNameSvcPrefix added in v0.8.2 

func GenerateShardingNameSvcPrefix(shardingSvcName string) string

GenerateShardingNameSvcPrefix generates sharding service name prefix.

func GenerateVirtualComponentDefinition added in v0.8.0 

func GenerateVirtualComponentDefinition(compDefSuffix string) string

GenerateVirtualComponentDefinition generates the virtual component definition name.

func GetAppVersionLabel added in v0.8.0 

func GetAppVersionLabel(appVersion string) map[string]string

GetAppVersionLabel returns the label for AppVersion

func GetClickHouseAlias 

func GetClickHouseAlias() []string

GetClickHouseAlias get clickhouse alias

func GetClusterCompDefLabel added in v0.8.0 

func GetClusterCompDefLabel(clusterCompDefName string) map[string]string

GetClusterCompDefLabel returns the label for ClusterComponentDefinition (refer clusterDefinition.Spec.ComponentDefs[*].Name) TODO:ClusterCompDef will be deprecated in the future

func GetClusterDefTypeLabel added in v0.8.0 

func GetClusterDefTypeLabel(clusterDefType string) map[string]string

GetClusterDefTypeLabel returns the label for ClusterDefinition type (refer clusterDefinition.Spec.Type) TODO:clusterDefType will be deprecated in the future

func GetClusterWellKnownLabels added in v0.8.0 

func GetClusterWellKnownLabels(clusterName string) map[string]string

GetClusterWellKnownLabels returns the well-known labels for a cluster

func GetComponentDefLabel added in v0.8.0 

func GetComponentDefLabel(compDefName string) map[string]string

GetComponentDefLabel returns the label for ComponentDefinition (refer ComponentDefinition.Name)

func GetComponentWellKnownLabels added in v0.8.0 

func GetComponentWellKnownLabels(clusterName, componentName string) map[string]string

GetComponentWellKnownLabels returns the well-known labels for Component API

func GetElasticSearchAlias 

func GetElasticSearchAlias() []string

GetElasticSearchAlias get elasticsearch alias

func GetKBConfigMapWellKnownLabels added in v0.8.0 

func GetKBConfigMapWellKnownLabels(cmTplName, clusterDefName, clusterName, componentName string) map[string]string

GetKBConfigMapWellKnownLabels returns the well-known labels for KB ConfigMap

func GetKBReservedLabelKeys added in v0.8.2 

func GetKBReservedLabelKeys() []string

GetKBReservedLabelKeys returns the reserved label keys for KubeBlocks

func GetKBWellKnownLabels added in v0.8.0 

func GetKBWellKnownLabels(clusterDefName, clusterName, componentName string) map[string]string

GetKBWellKnownLabels returns the well-known labels for KB resources with ClusterDefinition API

func GetKBWellKnownLabelsWithCompDef added in v0.8.0 

func GetKBWellKnownLabelsWithCompDef(compDefName, clusterName, componentName string) map[string]string

GetKBWellKnownLabelsWithCompDef returns the well-known labels for KB resources with ComponentDefinition API

func GetMongoDBAlias 

func GetMongoDBAlias() []string

GetMongoDBAlias get mongodb alias

func GetPostgreSQLAlias 

func GetPostgreSQLAlias() []string

GetPostgreSQLAlias get postgresql alias

func GetShardingNameLabel added in v0.8.2 

func GetShardingNameLabel(shardingName string) map[string]string

GetShardingNameLabel returns the shard template name label for component generated from shardSpec

func GetZookeeperAlias 

func GetZookeeperAlias() []string

GetZookeeperAlias get zookeeper alias

Types

This section is empty.

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.