Documentation
¶
Index ¶
- func NewTaskContext(logger logr.Logger, c client.Client) task.Task[ReconcileContext]
- func NewTaskFeatureGates(logger logr.Logger, c client.Client) task.Task[ReconcileContext]
- func NewTaskFinalizer(logger logr.Logger, c client.Client) task.Task[ReconcileContext]
- func NewTaskStatus(logger logr.Logger, c client.Client, pdcm pdm.PDClientManager) task.Task[ReconcileContext]
- type Metadata
- type Patch
- type ReconcileContext
- type Spec
- type TaskContext
- type TaskFeatureGates
- type TaskFinalizer
- type TaskStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTaskContext ¶
func NewTaskFeatureGates ¶
func NewTaskFinalizer ¶
func NewTaskStatus ¶
func NewTaskStatus(logger logr.Logger, c client.Client, pdcm pdm.PDClientManager) task.Task[ReconcileContext]
Types ¶
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 ¶
func (*TaskContext) Name ¶
func (*TaskContext) Name() string
func (*TaskContext) Sync ¶
func (t *TaskContext) Sync(ctx task.Context[ReconcileContext]) task.Result
TODO: refactor to use task v3
type TaskFeatureGates ¶
func (*TaskFeatureGates) Name ¶
func (*TaskFeatureGates) Name() string
func (*TaskFeatureGates) Sync ¶
func (t *TaskFeatureGates) Sync(ctx task.Context[ReconcileContext]) task.Result
type TaskFinalizer ¶
func (*TaskFinalizer) Name ¶
func (*TaskFinalizer) Name() string
func (*TaskFinalizer) Sync ¶
func (t *TaskFinalizer) Sync(ctx task.Context[ReconcileContext]) task.Result
type TaskStatus ¶
type TaskStatus struct {
Logger logr.Logger
Client client.Client
PDClientManager pdm.PDClientManager
}
func (*TaskStatus) Name ¶
func (*TaskStatus) Name() string
func (*TaskStatus) Sync ¶
func (t *TaskStatus) Sync(ctx task.Context[ReconcileContext]) task.Result
Click to show internal directories.
Click to hide internal directories.