Documentation
¶
Overview ¶
Copyright 2023 The OpenYurt Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- Constants
- func DeleteDeviceProfilesOnControllerShutdown(ctx context.Context, cli client.Client, opts *options.YurtIoTDockOptions) error
- func DeleteDeviceServicesOnControllerShutdown(ctx context.Context, cli client.Client, opts *options.YurtIoTDockOptions) error
- func DeleteDevicesOnControllerShutdown(ctx context.Context, cli client.Client, opts *options.YurtIoTDockOptions) error
- type DeviceProfileReconciler
- type DeviceProfileSyncer
- type DeviceReconciler
- type DeviceServiceReconciler
- type DeviceServiceSyncer
- type DeviceSyncer
Constants ¶
const (
EdgeXObjectName = "yurt-iot-dock/edgex-object.name"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DeviceProfileReconciler ¶
type DeviceProfileReconciler struct {
client.Client
Scheme *runtime.Scheme
NodePool string
Namespace string
// contains filtered or unexported fields
}
DeviceProfileReconciler reconciles a DeviceProfile object
func (*DeviceProfileReconciler) Reconcile ¶
func (r *DeviceProfileReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile make changes to a deviceprofile object in EdgeX based on it in Kubernetes
func (*DeviceProfileReconciler) SetupWithManager ¶
func (r *DeviceProfileReconciler) SetupWithManager(mgr ctrl.Manager, opts *options.YurtIoTDockOptions, edgexdock *edgexobj.EdgexDock) error
SetupWithManager sets up the controller with the Manager.
type DeviceProfileSyncer ¶
type DeviceProfileSyncer struct {
// Kubernetes client
client.Client
NodePool string
Namespace string
// contains filtered or unexported fields
}
func NewDeviceProfileSyncer ¶
func NewDeviceProfileSyncer(client client.Client, opts *options.YurtIoTDockOptions, edgexdock *edgexobj.EdgexDock) (DeviceProfileSyncer, error)
NewDeviceProfileSyncer initialize a New DeviceProfileSyncer
func (*DeviceProfileSyncer) NewDeviceProfileSyncerRunnable ¶
func (dps *DeviceProfileSyncer) NewDeviceProfileSyncerRunnable() ctrlmgr.RunnableFunc
NewDeviceProfileSyncerRunnable initialize a controller-runtime manager runnable
func (*DeviceProfileSyncer) Run ¶
func (dps *DeviceProfileSyncer) Run(stop <-chan struct{})
type DeviceReconciler ¶
type DeviceReconciler struct {
client.Client
Scheme *runtime.Scheme
// which nodePool deviceController is deployed in
NodePool string
Namespace string
// contains filtered or unexported fields
}
DeviceReconciler reconciles a Device object
func (*DeviceReconciler) SetupWithManager ¶
func (r *DeviceReconciler) SetupWithManager(mgr ctrl.Manager, opts *options.YurtIoTDockOptions, edgexdock *edgexobj.EdgexDock) error
SetupWithManager sets up the controller with the Manager.
type DeviceServiceReconciler ¶
type DeviceServiceReconciler struct {
client.Client
Scheme *runtime.Scheme
NodePool string
Namespace string
// contains filtered or unexported fields
}
DeviceServiceReconciler reconciles a DeviceService object
func (*DeviceServiceReconciler) SetupWithManager ¶
func (r *DeviceServiceReconciler) SetupWithManager(mgr ctrl.Manager, opts *options.YurtIoTDockOptions, edgexdock *edgexobj.EdgexDock) error
SetupWithManager sets up the controller with the Manager.
type DeviceServiceSyncer ¶
type DeviceServiceSyncer struct {
// Kubernetes client
client.Client
NodePool string
Namespace string
// contains filtered or unexported fields
}
func NewDeviceServiceSyncer ¶
func NewDeviceServiceSyncer(client client.Client, opts *options.YurtIoTDockOptions, edgexdock *edgexobj.EdgexDock) (DeviceServiceSyncer, error)
func (*DeviceServiceSyncer) NewDeviceServiceSyncerRunnable ¶
func (ds *DeviceServiceSyncer) NewDeviceServiceSyncerRunnable() ctrlmgr.RunnableFunc
func (*DeviceServiceSyncer) Run ¶
func (ds *DeviceServiceSyncer) Run(stop <-chan struct{})
type DeviceSyncer ¶
type DeviceSyncer struct {
// kubernetes client
client.Client
// which nodePool deviceController is deployed in
NodePool string
Namespace string
// contains filtered or unexported fields
}
func NewDeviceSyncer ¶
func NewDeviceSyncer(client client.Client, opts *options.YurtIoTDockOptions, edgexdock *edgexobj.EdgexDock) (DeviceSyncer, error)
NewDeviceSyncer initialize a New DeviceSyncer
func (*DeviceSyncer) NewDeviceSyncerRunnable ¶
func (ds *DeviceSyncer) NewDeviceSyncerRunnable() ctrlmgr.RunnableFunc
NewDeviceSyncerRunnable initialize a controller-runtime manager runnable
func (*DeviceSyncer) Run ¶
func (ds *DeviceSyncer) Run(stop <-chan struct{})
Source Files
Directories