Documentation
¶
Index ¶
- func NewStepBinder(name string, f StepFunc) control.BindFunc
- func NewStepIfBinder(conditionName string, condFunc ConditionFunc, binders ...control.BindFunc) control.BindFunc
- type ConditionFunc
- type Context
- func (rc *Context) Close() error
- func (rc *Context) Config() config.Config
- func (rc *Context) ContainsControllerHint(hint string) bool
- func (rc *Context) Debug() bool
- func (rc *Context) GetConfigMap(name string) (*corev1.ConfigMap, error)
- func (rc *Context) GetHpfsClient() (hpfs.HpfsServiceClient, error)
- func (rc *Context) GetNodes() ([]corev1.Node, error)
- func (rc *Context) GetXStore() (*polardbxv1.XStore, error)
- func (rc *Context) GetXStoreAccountPassword(user string) (string, error)
- func (rc *Context) GetXStoreClusterAddr(serviceType convention.ServiceType, port string) (string, error)
- func (rc *Context) GetXStoreConfigMap(cmType convention.ConfigMapType) (*corev1.ConfigMap, error)
- func (rc *Context) GetXStoreHeadlessServiceForPod(pod string) (*corev1.Service, error)
- func (rc *Context) GetXStoreHeadlessServices() (map[string]corev1.Service, error)
- func (rc *Context) GetXStoreJob(jobName string) (*batchv1.Job, error)
- func (rc *Context) GetXStorePod(name string) (*corev1.Pod, error)
- func (rc *Context) GetXStorePods() ([]corev1.Pod, error)
- func (rc *Context) GetXStoreSecret() (*corev1.Secret, error)
- func (rc *Context) GetXStoreService(serviceType convention.ServiceType) (*corev1.Service, error)
- func (rc *Context) IsXStoreChanged() bool
- func (rc *Context) IsXStoreStatusChanged() bool
- func (rc *Context) MarkXStoreChanged()
- func (rc *Context) MustGetXStore() *polardbxv1.XStore
- func (rc *Context) SetControllerRef(obj client.Object) error
- func (rc *Context) SetControllerRefAndCreate(obj client.Object) error
- func (rc *Context) SetXStoreKey(key types.NamespacedName)
- func (rc *Context) TryGetXStoreLeaderPod() (*corev1.Pod, error)
- func (rc *Context) UpdateXStore() error
- func (rc *Context) UpdateXStoreCondition(cond *polardbxv1xstore.Condition)
- func (rc *Context) UpdateXStoreStatus() error
- type Reconciler
- type StepFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewStepIfBinder ¶
Types ¶
type Context ¶
type Context struct {
*control.BaseReconcileContext
// contains filtered or unexported fields
}
func NewContext ¶
func NewContext(base *control.BaseReconcileContext, configLoader func() config.Config) *Context
func (*Context) ContainsControllerHint ¶
func (*Context) GetConfigMap ¶
func (*Context) GetHpfsClient ¶
func (rc *Context) GetHpfsClient() (hpfs.HpfsServiceClient, error)
func (*Context) GetXStoreAccountPassword ¶
func (*Context) GetXStoreClusterAddr ¶
func (rc *Context) GetXStoreClusterAddr(serviceType convention.ServiceType, port string) (string, error)
func (*Context) GetXStoreConfigMap ¶
func (rc *Context) GetXStoreConfigMap(cmType convention.ConfigMapType) (*corev1.ConfigMap, error)
func (*Context) GetXStoreHeadlessServiceForPod ¶
func (*Context) GetXStoreHeadlessServices ¶
func (*Context) GetXStoreJob ¶
func (*Context) GetXStoreService ¶
func (rc *Context) GetXStoreService(serviceType convention.ServiceType) (*corev1.Service, error)
func (*Context) IsXStoreChanged ¶
func (*Context) IsXStoreStatusChanged ¶
func (*Context) MarkXStoreChanged ¶
func (rc *Context) MarkXStoreChanged()
func (*Context) MustGetXStore ¶
func (rc *Context) MustGetXStore() *polardbxv1.XStore
func (*Context) SetControllerRefAndCreate ¶
func (*Context) SetXStoreKey ¶
func (rc *Context) SetXStoreKey(key types.NamespacedName)
func (*Context) TryGetXStoreLeaderPod ¶
func (*Context) UpdateXStore ¶
func (*Context) UpdateXStoreCondition ¶
func (rc *Context) UpdateXStoreCondition(cond *polardbxv1xstore.Condition)
func (*Context) UpdateXStoreStatus ¶
type Reconciler ¶
Source Files
Click to show internal directories.
Click to hide internal directories.