data

package
v2.0.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// TODO(liubo02): extract to namer
	DefaultTiDBServiceName    = defaultTiDBGroupName + "-tidb"
	DefaultTiProxyServiceName = defaultTiProxyGroupName + "-tiproxy"
	DefaultTiProxyServicePort = 6000
)
View Source 
const (
	BootstrapSQLName = "bootstrap-sql"
)
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 NewTiProxyGroup 

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

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 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 WithCluster 

func WithCluster[
	S scope.Group[F, T],
	F client.Object,
	T runtime.Group,
](cluster 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 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 WithReplicas 

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

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 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 WithTiDBGracefulWaitConfig 

func WithTiDBGracefulWaitConfig() GroupPatch[*v1alpha1.TiDBGroup]

func WithTiDBMySQLTLS 

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

func WithTiFlashComputeMode 

func WithTiFlashComputeMode() 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 WithTiKVPodAntiAffinity 

func WithTiKVPodAntiAffinity() GroupPatch[*v1alpha1.TiKVGroup]

func WithTiProxyMySQLTLS 

func WithTiProxyMySQLTLS(ca, certKeyPair string) 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.