tasks

package

v2.2.0-alpha.3 Latest Latest Go to latest Published: Jul 8, 2026 License: Apache-2.0 Imports: 19 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 CondClusterIsNotReadyForBRGC(rtx *ReconcileContext) t.Condition
func CondClusterNotFound(rtx *ReconcileContext) t.Condition
func CondMoreThanOneTiBRGCCreated(rtx *ReconcileContext) t.Condition
func CondTiBRGCIsDeleting(rtx *ReconcileContext) t.Condition
func CondTiBRGCNotFound(rtx *ReconcileContext) t.Condition
func GetImage(tibrgc *v1alpha1br.TiBRGC) string
func SecretName(tibrgc *v1alpha1br.TiBRGC) string
func T2ConjobLabels(tibrgc *v1alpha1br.TiBRGC) map[string]string
func T2CronjobName(tibrgc *v1alpha1br.TiBRGC) string
func T3ConjobLabels(tibrgc *v1alpha1br.TiBRGC) map[string]string
func T3CronjobName(tibrgc *v1alpha1br.TiBRGC) string
func TaskContextRefreshCluster(rtx *ReconcileContext) t.Task
func TaskContextRefreshT2CronJob(rtx *ReconcileContext) t.Task
func TaskContextRefreshT3CronJob(rtx *ReconcileContext) t.Task
func TaskContextRefreshTiBRGC(rtx *ReconcileContext) t.Task
func TaskContextRefreshTiBRGCList4SameCluster(rtx *ReconcileContext) t.Task
func TaskEnsureSubResources(rtx *ReconcileContext) t.Task
func TaskEnsureSubResourcesCleanup(rtx *ReconcileContext) t.Task
func TaskSkipReconcile(rtx *ReconcileContext, reason string) t.Task
func TiBRGCSubResourceLabels(tibrgc *v1alpha1br.TiBRGC) 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) NamespacedName() types.NamespacedName
- func (c *ReconcileContext) RefreshCluster() error
- func (c *ReconcileContext) RefreshT2CronJob() error
- func (c *ReconcileContext) RefreshT3CronJob() error
- func (c *ReconcileContext) RefreshTiBRGC() error
- func (c *ReconcileContext) RefreshTiBRGCList4SameCluster() error
- func (c *ReconcileContext) T2Cronjob() *batchv1.CronJob
- func (c *ReconcileContext) T3Cronjob() *batchv1.CronJob
- func (c *ReconcileContext) TLSEnabled() bool
- func (c *ReconcileContext) TiBRGC() *v1alpha1br.TiBRGC
- func (c *ReconcileContext) TiBRGCList4SameCluster() *v1alpha1br.TiBRGCList

Constants ¶

View Source

const (
	ClusterNameField = "spec.cluster.name"

	ComponentName    = "tibrgc"
	SecretAccessMode = int32(420)
	TLSVolumeName    = "tibrgc-tls"
	TLSMountPath     = "/var/lib/tibrgc-tls"

	T2DefaultBackoffLimit = int32(16)
	T3DefaultBackoffLimit = int32(32)
)

Variables ¶

View Source

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

Functions ¶

func CondClusterIsNotReadyForBRGC ¶

func CondClusterIsNotReadyForBRGC(rtx *ReconcileContext) t.Condition

func CondClusterNotFound ¶

func CondClusterNotFound(rtx *ReconcileContext) t.Condition

func CondMoreThanOneTiBRGCCreated ¶

func CondMoreThanOneTiBRGCCreated(rtx *ReconcileContext) t.Condition

func CondTiBRGCIsDeleting ¶

func CondTiBRGCIsDeleting(rtx *ReconcileContext) t.Condition

func CondTiBRGCNotFound ¶

func CondTiBRGCNotFound(rtx *ReconcileContext) t.Condition

func GetImage ¶

func GetImage(tibrgc *v1alpha1br.TiBRGC) string

func SecretName ¶

func SecretName(tibrgc *v1alpha1br.TiBRGC) string

func T2ConjobLabels ¶

func T2ConjobLabels(tibrgc *v1alpha1br.TiBRGC) map[string]string

func T2CronjobName ¶

func T2CronjobName(tibrgc *v1alpha1br.TiBRGC) string

func T3ConjobLabels ¶

func T3ConjobLabels(tibrgc *v1alpha1br.TiBRGC) map[string]string

func T3CronjobName ¶

func T3CronjobName(tibrgc *v1alpha1br.TiBRGC) string

func TaskContextRefreshCluster ¶

func TaskContextRefreshCluster(rtx *ReconcileContext) t.Task

func TaskContextRefreshT2CronJob ¶

func TaskContextRefreshT2CronJob(rtx *ReconcileContext) t.Task

func TaskContextRefreshT3CronJob ¶

func TaskContextRefreshT3CronJob(rtx *ReconcileContext) t.Task

func TaskContextRefreshTiBRGC ¶

func TaskContextRefreshTiBRGC(rtx *ReconcileContext) t.Task

func TaskContextRefreshTiBRGCList4SameCluster ¶

func TaskContextRefreshTiBRGCList4SameCluster(rtx *ReconcileContext) t.Task

func TaskEnsureSubResources ¶

func TaskEnsureSubResources(rtx *ReconcileContext) t.Task

func TaskEnsureSubResourcesCleanup ¶

func TaskEnsureSubResourcesCleanup(rtx *ReconcileContext) t.Task

func TaskSkipReconcile ¶

func TaskSkipReconcile(rtx *ReconcileContext, reason string) t.Task

func TiBRGCSubResourceLabels ¶

func TiBRGCSubResourceLabels(tibrgc *v1alpha1br.TiBRGC) 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) NamespacedName ¶

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

func (*ReconcileContext) RefreshCluster ¶

func (c *ReconcileContext) RefreshCluster() error

func (*ReconcileContext) RefreshT2CronJob ¶

func (c *ReconcileContext) RefreshT2CronJob() error

func (*ReconcileContext) RefreshT3CronJob ¶

func (c *ReconcileContext) RefreshT3CronJob() error

func (*ReconcileContext) RefreshTiBRGC ¶

func (c *ReconcileContext) RefreshTiBRGC() error

func (*ReconcileContext) RefreshTiBRGCList4SameCluster ¶

func (c *ReconcileContext) RefreshTiBRGCList4SameCluster() error

func (*ReconcileContext) T2Cronjob ¶

func (c *ReconcileContext) T2Cronjob() *batchv1.CronJob

func (*ReconcileContext) T3Cronjob ¶

func (c *ReconcileContext) T3Cronjob() *batchv1.CronJob

func (*ReconcileContext) TLSEnabled ¶

func (c *ReconcileContext) TLSEnabled() bool

func (*ReconcileContext) TiBRGC ¶

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

func (*ReconcileContext) TiBRGCList4SameCluster ¶

func (c *ReconcileContext) TiBRGCList4SameCluster() *v1alpha1br.TiBRGCList

Source Files ¶

View all Source files

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