Documentation
¶
Index ¶
- Variables
- type ClusterStageRecResult
- type DorisAutoScalerReconciler
- type DorisClusterReconciler
- type DorisInitializerReconciler
- type DorisMonitorReconciler
- type MonitorStageRecResult
- type PendingError
- type ReconcileContext
- func (r *ReconcileContext) CreateOrUpdate(obj client.Object, objType client.Object) error
- func (r *ReconcileContext) CreateWhenNotExist(obj client.Object, objType client.Object) error
- func (r *ReconcileContext) DeleteWhenExist(key types.NamespacedName, objType client.Object, ...) error
- func (r *ReconcileContext) Exist(key types.NamespacedName, objType client.Object) (bool, error)
- func (r *ReconcileContext) FindRefDorisAutoScaler(dorisClusterRef client.ObjectKey) (*dapi.DorisAutoscaler, error)
- func (r *ReconcileContext) FindRefDorisInitializer(dorisClusterRef client.ObjectKey) (*dapi.DorisInitializer, error)
- func (r *ReconcileContext) Replace(obj client.Object, objType client.Object, timeout time.Duration) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( FeConfHashAnnotationKey = fmt.Sprintf("%s/fe-config", dapi.GroupVersion.Group) BeConfHashAnnotationKey = fmt.Sprintf("%s/be-config", dapi.GroupVersion.Group) CnConfHashAnnotationKey = fmt.Sprintf("%s/cn-config", dapi.GroupVersion.Group) BrokerConfHashAnnotationKey = fmt.Sprintf("%s/broker-config", dapi.GroupVersion.Group) )
View Source
var ( PrometheusConfHashAnnotationKey = fmt.Sprintf("%s/prometheus-conf", dapi.GroupVersion.Group) GrafanaConfHashAnnotationKey = fmt.Sprintf("%s/grafana-conf", dapi.GroupVersion.Group) LokiConfHashAnnotationKey = fmt.Sprintf("%s/loki-conf", dapi.GroupVersion.Group) PromtailConfHashAnnotationKey = fmt.Sprintf("%s/promtail-conf", dapi.GroupVersion.Group) )
View Source
var (
InitializerConfHashAnnotationKey = fmt.Sprintf("%s/initr-config", dapi.GroupVersion.Group)
)
Functions ¶
This section is empty.
Types ¶
type ClusterStageRecResult ¶
type ClusterStageRecResult struct {
Stage dapi.DorisClusterOprStage
Status dapi.OprStageStatus
Action dapi.OprStageAction
Err error
}
ClusterStageRecResult represents the result of a stage reconciliation for DorisCluster
func (*ClusterStageRecResult) AsDorisClusterRecStatus ¶
func (r *ClusterStageRecResult) AsDorisClusterRecStatus() dapi.DorisClusterRecStatus
type DorisAutoScalerReconciler ¶
type DorisAutoScalerReconciler struct {
ReconcileContext
CR *dapi.DorisAutoscaler
}
DorisAutoScalerReconciler reconciles a DorisCluster object
func (*DorisAutoScalerReconciler) Reconcile ¶
func (r *DorisAutoScalerReconciler) Reconcile() (dapi.AutoscalerRecStatus, error)
Reconcile hpa resources
func (*DorisAutoScalerReconciler) Sync ¶
func (r *DorisAutoScalerReconciler) Sync() (dapi.CNAutoscalerSyncStatus, error)
Sync status of hpa resources
type DorisClusterReconciler ¶
type DorisClusterReconciler struct {
ReconcileContext
CR *dapi.DorisCluster
}
DorisClusterReconciler reconciles a DorisCluster object
func (*DorisClusterReconciler) Reconcile ¶
func (r *DorisClusterReconciler) Reconcile() ClusterStageRecResult
Reconcile all sub components
func (*DorisClusterReconciler) Sync ¶
func (r *DorisClusterReconciler) Sync() (dapi.DorisClusterSyncStatus, error)
Sync all subcomponents status.
type DorisInitializerReconciler ¶
type DorisInitializerReconciler struct {
ReconcileContext
CR *dapi.DorisInitializer
}
func (*DorisInitializerReconciler) Reconcile ¶
func (r *DorisInitializerReconciler) Reconcile() (dapi.DorisInitializerRecStatus, error)
Reconcile initializer resources
func (*DorisInitializerReconciler) Sync ¶
func (r *DorisInitializerReconciler) Sync() (dapi.DorisInitializerSyncStatus, error)
Sync initializer resources status
type DorisMonitorReconciler ¶
type DorisMonitorReconciler struct {
ReconcileContext
CR *dapi.DorisMonitor
}
DorisMonitorReconciler reconciles a DorisMonitor object
func (*DorisMonitorReconciler) Reconcile ¶
func (r *DorisMonitorReconciler) Reconcile() MonitorStageRecResult
Reconcile all sub components of DorisMonitor
func (*DorisMonitorReconciler) Sync ¶
func (r *DorisMonitorReconciler) Sync() (dapi.DorisMonitorSyncStatus, error)
Sync all subcomponents status of DorisMonitor
type MonitorStageRecResult ¶
type MonitorStageRecResult struct {
Stage dapi.DorisMonitorOprStage
Status dapi.OprStageStatus
Action dapi.OprStageAction
Err error
}
func (*MonitorStageRecResult) AsDorisClusterRecStatus ¶
func (r *MonitorStageRecResult) AsDorisClusterRecStatus() dapi.DorisMonitorRecStatus
type PendingError ¶
type PendingError struct {
Reason string
}
func NewPendingError ¶
func NewPendingError(format string, a ...any) *PendingError
func (PendingError) Error ¶
func (e PendingError) Error() string
type ReconcileContext ¶
type ReconcileContext struct {
client.Client
Schema *runtime.Scheme
Ctx context.Context
Log logr.Logger
}
ReconcileContext is the context for reconciling CRD.
func NewReconcileContext ¶
func (*ReconcileContext) CreateOrUpdate ¶
CreateOrUpdate creates or updates the kubernetes object.
func (*ReconcileContext) CreateWhenNotExist ¶
CreateWhenNotExist creates the kubernetes object if it does not exist.
func (*ReconcileContext) DeleteWhenExist ¶
func (r *ReconcileContext) DeleteWhenExist(key types.NamespacedName, objType client.Object, deleteOpts ...client.DeleteOption) error
DeleteWhenExist deletes the kubernetes object if it exists.
func (*ReconcileContext) Exist ¶
func (r *ReconcileContext) Exist(key types.NamespacedName, objType client.Object) (bool, error)
Exist checks if the kubernetes object exists.
func (*ReconcileContext) FindRefDorisAutoScaler ¶
func (r *ReconcileContext) FindRefDorisAutoScaler(dorisClusterRef client.ObjectKey) (*dapi.DorisAutoscaler, error)
FindRefDorisAutoScaler finds the DorisAutoscaler CR that refer to the DorisCluster CR. A DorisCluster CR can only be bound to one additional DorisAutoScaler CR.
func (*ReconcileContext) FindRefDorisInitializer ¶
func (r *ReconcileContext) FindRefDorisInitializer(dorisClusterRef client.ObjectKey) (*dapi.DorisInitializer, error)
FindRefDorisInitializer finds the DorisInitializer CR that refer to the DorisCluster CR. A DorisCluster CR can only be bound to one additional DorisInitializer CR.
Source Files
Click to show internal directories.
Click to hide internal directories.