tasks

package

v2.0.0 Latest Latest Go to latest Published: Dec 5, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pingcap/tidb-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CondClusterIsNotReadyForBR(rtx *ReconcileContext) t.Condition
func CondClusterNotFound(rtx *ReconcileContext) t.Condition
func CondTiBRIsDeleting(rtx *ReconcileContext) t.Condition
func CondTiBRNotFound(rtx *ReconcileContext) t.Condition
func ConfigMapName(tibr *v1alpha1br.TiBR) string
func GetImage(tibr *v1alpha1br.TiBR) string
func HeadlessSvcName(tibr *v1alpha1br.TiBR) string
func SecretName(tibr *v1alpha1br.TiBR) string
func StatefulSetName(tibr *v1alpha1br.TiBR) string
func TaskContextRefreshCluster(rtx *ReconcileContext) t.Task
func TaskContextRefreshConfigMap(rtx *ReconcileContext) t.Task
func TaskContextRefreshHeadlessSvc(rtx *ReconcileContext) t.Task
func TaskContextRefreshStatefulSet(rtx *ReconcileContext) t.Task
func TaskContextRefreshTiBR(rtx *ReconcileContext) t.Task
func TaskEnsureSubResources(rtx *ReconcileContext) t.Task
func TaskEnsureSubResourcesCleanup(rtx *ReconcileContext) t.Task
func TaskUpdateStatusIfNeeded(rtx *ReconcileContext) t.Task
func TiBRSubResourceLabels(tibr *v1alpha1br.TiBR) map[string]string
type ReconcileContext
- func NewReconcileContext(ctx context.Context, namespacedName types.NamespacedName, cli client.Client) *ReconcileContext
- func (c *ReconcileContext) Client() client.Client
- func (c *ReconcileContext) Cluster() *v1alpha1.Cluster
- func (c *ReconcileContext) ConfigMap() *corev1.ConfigMap
- func (c *ReconcileContext) HeadlessSvc() *corev1.Service
- func (c *ReconcileContext) NamespacedName() types.NamespacedName
- func (c *ReconcileContext) RefreshCluster() error
- func (c *ReconcileContext) RefreshConfigMap() error
- func (c *ReconcileContext) RefreshHeadlessSvc() error
- func (c *ReconcileContext) RefreshStatefulSet() error
- func (c *ReconcileContext) RefreshTiBR() error
- func (c *ReconcileContext) StatefulSet() *appsv1.StatefulSet
- func (c *ReconcileContext) TLSEnabled() bool
- func (c *ReconcileContext) TiBR() *v1alpha1br.TiBR

Constants ¶

View Source

const (
	ComponentName      = "tibr"
	ConfigFileName     = "tibr-config.yaml"
	StatefulSetReplica = int32(1)
	APIServerPort      = 19500
	SecretAccessMode   = int32(420)
	ConfigVolumeName   = "config-volume"
	TLSVolumeName      = "tibr-tls"
	TLSMountPath       = "/var/lib/tibr-tls"
	ConfigMountPath    = "/etc/config"
)

Variables ¶

View Source

var (
	TLSCmdArgs = []string{
		"--cacert",
		TLSMountPath + "/ca.crt",
		"--cert",
		TLSMountPath + "/tls.crt",
		"--key",
		TLSMountPath + "/tls.key",
	}
)

Functions ¶

func CondClusterIsNotReadyForBR ¶

func CondClusterIsNotReadyForBR(rtx *ReconcileContext) t.Condition

func CondClusterNotFound ¶

func CondClusterNotFound(rtx *ReconcileContext) t.Condition

func CondTiBRIsDeleting ¶

func CondTiBRIsDeleting(rtx *ReconcileContext) t.Condition

func CondTiBRNotFound ¶

func CondTiBRNotFound(rtx *ReconcileContext) t.Condition

func ConfigMapName ¶

func ConfigMapName(tibr *v1alpha1br.TiBR) string

func GetImage ¶

func GetImage(tibr *v1alpha1br.TiBR) string

func HeadlessSvcName ¶

func HeadlessSvcName(tibr *v1alpha1br.TiBR) string

func SecretName ¶

func SecretName(tibr *v1alpha1br.TiBR) string

func StatefulSetName ¶

func StatefulSetName(tibr *v1alpha1br.TiBR) string

func TaskContextRefreshCluster ¶

func TaskContextRefreshCluster(rtx *ReconcileContext) t.Task

func TaskContextRefreshConfigMap ¶

func TaskContextRefreshConfigMap(rtx *ReconcileContext) t.Task

func TaskContextRefreshHeadlessSvc ¶

func TaskContextRefreshHeadlessSvc(rtx *ReconcileContext) t.Task

func TaskContextRefreshStatefulSet ¶

func TaskContextRefreshStatefulSet(rtx *ReconcileContext) t.Task

func TaskContextRefreshTiBR ¶

func TaskContextRefreshTiBR(rtx *ReconcileContext) t.Task

func TaskEnsureSubResources ¶

func TaskEnsureSubResources(rtx *ReconcileContext) t.Task

func TaskEnsureSubResourcesCleanup ¶

func TaskEnsureSubResourcesCleanup(rtx *ReconcileContext) t.Task

func TaskUpdateStatusIfNeeded ¶

func TaskUpdateStatusIfNeeded(rtx *ReconcileContext) t.Task

func TiBRSubResourceLabels ¶

func TiBRSubResourceLabels(tibr *v1alpha1br.TiBR) map[string]string

Types ¶

type ReconcileContext ¶

type ReconcileContext struct {
	// contains filtered or unexported fields
}

func NewReconcileContext ¶

func NewReconcileContext(ctx context.Context,
	namespacedName types.NamespacedName,
	cli client.Client,
) *ReconcileContext

func (*ReconcileContext) Client ¶

func (c *ReconcileContext) Client() client.Client

func (*ReconcileContext) Cluster ¶

func (c *ReconcileContext) Cluster() *v1alpha1.Cluster

func (*ReconcileContext) ConfigMap ¶

func (c *ReconcileContext) ConfigMap() *corev1.ConfigMap

func (*ReconcileContext) HeadlessSvc ¶

func (c *ReconcileContext) HeadlessSvc() *corev1.Service

func (*ReconcileContext) NamespacedName ¶

func (c *ReconcileContext) NamespacedName() types.NamespacedName

func (*ReconcileContext) RefreshCluster ¶

func (c *ReconcileContext) RefreshCluster() error

func (*ReconcileContext) RefreshConfigMap ¶

func (c *ReconcileContext) RefreshConfigMap() error

func (*ReconcileContext) RefreshHeadlessSvc ¶

func (c *ReconcileContext) RefreshHeadlessSvc() error

func (*ReconcileContext) RefreshStatefulSet ¶

func (c *ReconcileContext) RefreshStatefulSet() error

func (*ReconcileContext) RefreshTiBR ¶

func (c *ReconcileContext) RefreshTiBR() error

func (*ReconcileContext) StatefulSet ¶

func (c *ReconcileContext) StatefulSet() *appsv1.StatefulSet

func (*ReconcileContext) TLSEnabled ¶

func (c *ReconcileContext) TLSEnabled() bool

func (*ReconcileContext) TiBR ¶

func (c *ReconcileContext) TiBR() *v1alpha1br.TiBR

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL