tasks

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: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTaskContext

func NewTaskContext(logger logr.Logger, c client.Client) task.Task[ReconcileContext]

func NewTaskFeatureGates

func NewTaskFeatureGates(logger logr.Logger, c client.Client) task.Task[ReconcileContext]

func NewTaskFinalizer

func NewTaskFinalizer(logger logr.Logger, c client.Client) task.Task[ReconcileContext]

func NewTaskStatus

func NewTaskStatus(logger logr.Logger, c client.Client, pdcm pdm.PDClientManager) task.Task[ReconcileContext]

Types

type Metadata

type Metadata struct {
	ResourceVersion string `json:"resourceVersion"`
}

type Patch

type Patch struct {
	Metadata Metadata `json:"metadata"`
	Spec     Spec     `json:"spec"`
}

type ReconcileContext

type ReconcileContext struct {
	context.Context

	Key types.NamespacedName

	Cluster          *v1alpha1.Cluster
	PDGroup          *v1alpha1.PDGroup
	TiKVGroups       []*v1alpha1.TiKVGroup
	TiFlashGroups    []*v1alpha1.TiFlashGroup
	TiDBGroups       []*v1alpha1.TiDBGroup
	TiCDCGroups      []*v1alpha1.TiCDCGroup
	TSOGroups        []*v1alpha1.TSOGroup
	SchedulingGroups []*v1alpha1.SchedulingGroup
	SchedulerGroups  []*v1alpha1.SchedulerGroup
	TiProxyGroups    []*v1alpha1.TiProxyGroup
}

func (*ReconcileContext) Self

func (ctx *ReconcileContext) Self() *ReconcileContext

type Spec

type Spec struct {
	Features []metav1alpha1.Feature `json:"features"`
}

type TaskContext

type TaskContext struct {
	Logger logr.Logger
	Client client.Client
}

func (*TaskContext) Name

func (*TaskContext) Name() string

func (*TaskContext) Sync

TODO: refactor to use task v3

type TaskFeatureGates

type TaskFeatureGates struct {
	Logger logr.Logger
	Client client.Client
}

func (*TaskFeatureGates) Name

func (*TaskFeatureGates) Name() string

func (*TaskFeatureGates) Sync

type TaskFinalizer

type TaskFinalizer struct {
	Logger logr.Logger
	Client client.Client
}

func (*TaskFinalizer) Name

func (*TaskFinalizer) Name() string

func (*TaskFinalizer) Sync

type TaskStatus

type TaskStatus struct {
	Logger          logr.Logger
	Client          client.Client
	PDClientManager pdm.PDClientManager
}

func (*TaskStatus) Name

func (*TaskStatus) Name() string

func (*TaskStatus) Sync

Jump to

Keyboard shortcuts

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