Documentation
¶
Index ¶
- Variables
- func AddCommit(mgr manager.Manager) error
- func AddCreateSubscription(mgr manager.Manager) error
- func AddEditConfig(mgr manager.Manager) error
- func AddEstablishSubscription(mgr manager.Manager) error
- func AddGet(mgr manager.Manager) error
- func AddGetConfig(mgr manager.Manager) error
- func AddLock(mgr manager.Manager) error
- func AddMountPoint(mgr manager.Manager) error
- func AddRPC(mgr manager.Manager) error
- func AddUnlock(mgr manager.Manager) error
- func CheckMountPointExists(r util.ReconcilerBase, namespacedName types.NamespacedName) bool
- func SendToKafka(message string, kafkaSync netconfv1.KafkaSink) error
- func ValidateXML(data string, dataStruct interface{}) error
- type CommitReconciler
- type CreateSubscriptionReconciler
- type EditConfigReconciler
- type EstablishSubscriptionReconciler
- type GetConfigReconciler
- type GetReconciler
- type LockReconciler
- type MountPointReconciler
- type RPCReconciler
- type UnlockReconciler
Constants ¶
This section is empty.
Variables ¶
var Sessions = make(map[string]*netconf.Session)
Sessions hold the active SSH session to NETCONF servers. The key is the NamespacedName of the MountPoint object referred in the CR
Functions ¶
func AddCreateSubscription ¶
AddCreateSubscription creates a new MountPoint Controller and adds it to the Manager.
func AddEditConfig ¶
AddEditConfig Add creates a new MountPoint Controller and adds it to the Manager.
func AddEstablishSubscription ¶
AddEstablishSubscription Add creates a new MountPoint Controller and adds it to the Manager.
func AddGetConfig ¶
AddGetConfig Add creates a new MountPoint Controller and adds it to the Manager.
func AddMountPoint ¶
AddMountPoint Add creates a new MountPoint Controller and adds it to the Manager.
func CheckMountPointExists ¶
func CheckMountPointExists(r util.ReconcilerBase, namespacedName types.NamespacedName) bool
CheckMountPointExists validates a MountPoint, defined by its namespacedName, exists
func SendToKafka ¶
SendToKafka establish a connection and sends a message to Kafka
func ValidateXML ¶
ValidateXML checks a provided string can be properly unmarshall in the specified struct
Types ¶
type CommitReconciler ¶
type CommitReconciler struct {
util.ReconcilerBase
}
CommitReconciler reconciles a Commit object
type CreateSubscriptionReconciler ¶
type CreateSubscriptionReconciler struct {
util.ReconcilerBase
// contains filtered or unexported fields
}
CreateSubscriptionReconciler reconciles a CreateSubscription object
type EditConfigReconciler ¶
type EditConfigReconciler struct {
util.ReconcilerBase
}
EditConfigReconciler reconciles a EditConfig object
type EstablishSubscriptionReconciler ¶
type EstablishSubscriptionReconciler struct {
util.ReconcilerBase
// contains filtered or unexported fields
}
EstablishSubscriptionReconciler reconciles a EstablishSubscription object
func (*EstablishSubscriptionReconciler) Reconcile ¶
func (r *EstablishSubscriptionReconciler) 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.
type GetConfigReconciler ¶
type GetConfigReconciler struct {
util.ReconcilerBase
}
GetConfigReconciler reconciles a GetConfig object
type GetReconciler ¶
type GetReconciler struct {
util.ReconcilerBase
}
GetReconciler reconciles a Get object
type LockReconciler ¶
type LockReconciler struct {
util.ReconcilerBase
}
LockReconciler reconciles a Lock object
type MountPointReconciler ¶
type MountPointReconciler struct {
util.ReconcilerBase
}
MountPointReconciler reconciles a MountPoint object
type RPCReconciler ¶
type RPCReconciler struct {
util.ReconcilerBase
}
RPCReconciler reconciles a RPC object
type UnlockReconciler ¶
type UnlockReconciler struct {
util.ReconcilerBase
}
UnlockReconciler reconciles a Unlock object
Source Files