data

package
v2.1.0-alpha.13 Latest Latest
Warning

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

 Go to latest Published: Dec 26, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BootstrapSQLName = "bootstrap-sql"
	SEMConfigName    = "sem-config"
)
View Source 
const (
	// TODO(liubo02): extract to namer
	DefaultTiDBServiceName    = defaultTiDBGroupName + "-tidb"
	DefaultTiProxyServiceName = defaultTiProxyGroupName + "-tiproxy"
	DefaultTiProxyServicePort = 6000
)
View Source 
const (
	JWKsSecretName = "jwks-secret"
)

Variables

This section is empty.

Functions

func NewCluster 

func NewCluster(namespace string, patches ...ClusterPatch) *v1alpha1.Cluster

func NewNamespace 

func NewNamespace() *v1.Namespace

NewNamespace returns a random namespace object for testing.

func NewPDGroup 

func NewPDGroup(ns string, patches ...GroupPatch[*v1alpha1.PDGroup]) *v1alpha1.PDGroup

func NewSchedulingGroup 

func NewSchedulingGroup(ns string, patches ...GroupPatch[*v1alpha1.SchedulingGroup]) *v1alpha1.SchedulingGroup

func NewTSOGroup 

func NewTSOGroup(ns string, patches ...GroupPatch[*v1alpha1.TSOGroup]) *v1alpha1.TSOGroup

func NewTiCDCGroup 

func NewTiCDCGroup(ns string, patches ...GroupPatch[*v1alpha1.TiCDCGroup]) *v1alpha1.TiCDCGroup

func NewTiDBGroup 

func NewTiDBGroup(ns string, patches ...GroupPatch[*v1alpha1.TiDBGroup]) *v1alpha1.TiDBGroup

func NewTiFlashGroup 

func NewTiFlashGroup(ns string, patches ...GroupPatch[*v1alpha1.TiFlashGroup]) *v1alpha1.TiFlashGroup

func NewTiKVGroup 

func NewTiKVGroup(ns string, patches ...GroupPatch[*v1alpha1.TiKVGroup]) *v1alpha1.TiKVGroup

func NewTiKVWorkerGroup 

func NewTiKVWorkerGroup(ns string, patches ...GroupPatch[*v1alpha1.TiKVWorkerGroup]) *v1alpha1.TiKVWorkerGroup

func NewTiProxyGroup 

func NewTiProxyGroup(ns string, patches ...GroupPatch[*v1alpha1.TiProxyGroup]) *v1alpha1.TiProxyGroup

func SEMConfig 

func SEMConfig() string

SEMConfig returns a simple sem config for test

Types

type ClusterPatch 

type ClusterPatch func(obj *v1alpha1.Cluster)

func WithBootstrapSQL 

func WithBootstrapSQL() ClusterPatch

func WithClusterName 

func WithClusterName(name string) ClusterPatch

func WithClusterTLSAndTiProxyConfig 

func WithClusterTLSAndTiProxyConfig() ClusterPatch

func WithClusterTLSEnabled 

func WithClusterTLSEnabled() ClusterPatch

func WithCustomizedPDServiceName 

func WithCustomizedPDServiceName(name string) ClusterPatch

func WithFQDN 

func WithFQDN() ClusterPatch

func WithFeatureGates 

func WithFeatureGates(featureGates ...metav1alpha1.Feature) ClusterPatch

type FlashConfig 

type FlashConfig struct {
	DisaggregatedMode string `toml:"disaggregated_mode"`
}

type GroupPatch 

type GroupPatch[F client.Object] interface {
	Patch(obj F)
}

func WithAuthToken 

func WithAuthToken() GroupPatch[*v1alpha1.TiDBGroup]

func WithBootstrapped 

func WithBootstrapped() GroupPatch[*v1alpha1.PDGroup]

func WithCluster 

func WithCluster[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](cluster string) GroupPatch[F]

func WithClusterTLS 

func WithClusterTLS[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](ca, certKeyPair string) GroupPatch[F]

func WithClusterTLSSuffix 

func WithClusterTLSSuffix[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](ca, certKeyPair string) GroupPatch[F]

func WithEphemeralVolume 

func WithEphemeralVolume() GroupPatch[*v1alpha1.TiDBGroup]

func WithHotReloadPolicy 

func WithHotReloadPolicy() GroupPatch[*v1alpha1.TiDBGroup]

func WithHotReloadPolicyForTiProxy 

func WithHotReloadPolicyForTiProxy() GroupPatch[*v1alpha1.TiProxyGroup]

func WithImage 

func WithImage[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](image string) GroupPatch[F]

func WithKeyspace 

func WithKeyspace(keyspace string) GroupPatch[*v1alpha1.TiDBGroup]

func WithMSMode 

func WithMSMode() GroupPatch[*v1alpha1.PDGroup]

func WithName 

func WithName[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](name string) GroupPatch[F]

func WithPDFeatures 

func WithPDFeatures(fs ...metav1alpha1.Feature) GroupPatch[*v1alpha1.PDGroup]

func WithPDNextGen 

func WithPDNextGen() GroupPatch[*v1alpha1.PDGroup]

func WithReplicas 

func WithReplicas[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](replicas int32) GroupPatch[F]

func WithSEMConfig 

func WithSEMConfig() GroupPatch[*v1alpha1.TiDBGroup]

func WithSchedulingNextGen 

func WithSchedulingNextGen() GroupPatch[*v1alpha1.SchedulingGroup]

func WithSlowDataMigration 

func WithSlowDataMigration() GroupPatch[*v1alpha1.PDGroup]

func WithTLS deprecated 

func WithTLS() GroupPatch[*v1alpha1.TiDBGroup]

Deprecated: use WithTiDBMySQLTLS

func WithTLSForTiProxy deprecated 

func WithTLSForTiProxy() GroupPatch[*v1alpha1.TiProxyGroup]

Deprecated: use WithTiProxyMySQLTLS

func WithTSONextGen 

func WithTSONextGen() GroupPatch[*v1alpha1.TSOGroup]

func WithTemplateAnnotation 

func WithTemplateAnnotation[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](k, v string) GroupPatch[F]

func WithTiDBEvenlySpreadPolicy 

func WithTiDBEvenlySpreadPolicy() GroupPatch[*v1alpha1.TiDBGroup]

TODO: combine with WithTiKVEvenlySpreadPolicy

func WithTiDBMySQLTLS 

func WithTiDBMySQLTLS(ca, certKeyPair string) GroupPatch[*v1alpha1.TiDBGroup]

func WithTiDBNextGen 

func WithTiDBNextGen() GroupPatch[*v1alpha1.TiDBGroup]

func WithTiDBStandbyMode 

func WithTiDBStandbyMode() GroupPatch[*v1alpha1.TiDBGroup]

func WithTiFlashComputeMode 

func WithTiFlashComputeMode() GroupPatch[*v1alpha1.TiFlashGroup]

func WithTiFlashNextGen 

func WithTiFlashNextGen() GroupPatch[*v1alpha1.TiFlashGroup]

func WithTiFlashWriteMode 

func WithTiFlashWriteMode() GroupPatch[*v1alpha1.TiFlashGroup]

func WithTiKVAPIVersionV2 

func WithTiKVAPIVersionV2() GroupPatch[*v1alpha1.TiKVGroup]

func WithTiKVEvenlySpreadPolicy 

func WithTiKVEvenlySpreadPolicy() GroupPatch[*v1alpha1.TiKVGroup]

TODO: combine with WithTiDBEvenlySpreadPolicy

func WithTiKVEvenlySpreadPolicyOneFailureAZ 

func WithTiKVEvenlySpreadPolicyOneFailureAZ() GroupPatch[*v1alpha1.TiKVGroup]

func WithTiKVNextGen 

func WithTiKVNextGen() GroupPatch[*v1alpha1.TiKVGroup]

func WithTiKVPodAntiAffinity 

func WithTiKVPodAntiAffinity() GroupPatch[*v1alpha1.TiKVGroup]

func WithTiKVWorkerNextGen 

func WithTiKVWorkerNextGen() GroupPatch[*v1alpha1.TiKVWorkerGroup]

func WithTiKVWorkers 

func WithTiKVWorkers() GroupPatch[*v1alpha1.TiKVGroup]

func WithTiProxyMySQLTLS 

func WithTiProxyMySQLTLS(ca, certKeyPair string) GroupPatch[*v1alpha1.TiProxyGroup]

func WithTiProxyNextGen 

func WithTiProxyNextGen() GroupPatch[*v1alpha1.TiProxyGroup]

func WithVersion 

func WithVersion[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](version string) GroupPatch[F]

type GroupPatchFunc 

type GroupPatchFunc[
	F client.Object,
] func(obj F)

func (GroupPatchFunc[F]) Patch 

func (f GroupPatchFunc[F]) Patch(obj F)

type TiFlashConfig 

type TiFlashConfig struct {
	Flash FlashConfig `toml:"flash"`
}

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.