Documentation
¶
Index ¶
- Constants
- type FlinkSessionJobHandler
- func (e *FlinkSessionJobHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
- func (e *FlinkSessionJobHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
- func (e *FlinkSessionJobHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
- func (e *FlinkSessionJobHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
- type FlinkSessionReconciler
- type FlinkSessionServiceHandler
- func (e *FlinkSessionServiceHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
- func (e *FlinkSessionServiceHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
- func (e *FlinkSessionServiceHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
- func (e *FlinkSessionServiceHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
Constants ¶
const ( FlinkSessionFinalizerName string = `flink.shang12360.cn/finalizer` HashAnnotations string = `flink.shang12360.cn/hash` FlinkNativeType string = `flink-native-kubernetes` FlinkRestPortName string = `rest` FlinkHAConfigType string = `high-availability` )
const (
DefaultMode int32 = 0755
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlinkSessionJobHandler ¶ added in v0.2.3
type FlinkSessionJobHandler struct {
}
func (*FlinkSessionJobHandler) Create ¶ added in v0.2.3
func (e *FlinkSessionJobHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
Create implements EventHandler.
func (*FlinkSessionJobHandler) Delete ¶ added in v0.2.3
func (e *FlinkSessionJobHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
Delete implements EventHandler.
func (*FlinkSessionJobHandler) Generic ¶ added in v0.2.3
func (e *FlinkSessionJobHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
Generic implements EventHandler.
func (*FlinkSessionJobHandler) Update ¶ added in v0.2.3
func (e *FlinkSessionJobHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
Update implements EventHandler.
type FlinkSessionReconciler ¶
type FlinkSessionReconciler struct {
client.Client
Scheme *runtime.Scheme
Recorder record.EventRecorder
}
FlinkSessionReconciler reconciles a FlinkSession object
func (*FlinkSessionReconciler) Reconcile ¶
func (r *FlinkSessionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the FlinkSession object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile
func (*FlinkSessionReconciler) SetupWithManager ¶
func (r *FlinkSessionReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type FlinkSessionServiceHandler ¶ added in v0.0.12
type FlinkSessionServiceHandler struct {
}
func (*FlinkSessionServiceHandler) Create ¶ added in v0.0.12
func (e *FlinkSessionServiceHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
Create implements EventHandler.
func (*FlinkSessionServiceHandler) Delete ¶ added in v0.0.12
func (e *FlinkSessionServiceHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
Delete implements EventHandler.
func (*FlinkSessionServiceHandler) Generic ¶ added in v0.0.12
func (e *FlinkSessionServiceHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
Generic implements EventHandler.
func (*FlinkSessionServiceHandler) Update ¶ added in v0.0.12
func (e *FlinkSessionServiceHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
Update implements EventHandler.
Source Files