@@ -15,7 +15,7 @@ The move of the Kubernetes Volume Snapshot feature to beta also means:
|
|||||||
* A revamp of volume snapshot APIs.
|
* A revamp of volume snapshot APIs.
|
||||||
* The CSI external-snapshotter sidecar is split into two controllers, a snapshot controller and a CSI external-snapshotter sidecar.
|
* The CSI external-snapshotter sidecar is split into two controllers, a snapshot controller and a CSI external-snapshotter sidecar.
|
||||||
|
|
||||||
The snapshot controller is deployed by the Kubernetes distributions and is responsible for watching the VolumeSnapshot CRD objects and manges the creation and deletion lifecycle of snapshots.
|
The snapshot controller is deployed by the Kubernetes distributions and is responsible for watching the VolumeSnapshot CRD objects and manages the creation and deletion lifecycle of snapshots.
|
||||||
|
|
||||||
The CSI external-snapshotter sidecar watches Kubernetes VolumeSnapshotContent CRD objects and triggers CreateSnapshot/DeleteSnapshot against a CSI endpoint.
|
The CSI external-snapshotter sidecar watches Kubernetes VolumeSnapshotContent CRD objects and triggers CreateSnapshot/DeleteSnapshot against a CSI endpoint.
|
||||||
|
|
||||||
|
@@ -108,7 +108,7 @@ func main() {
|
|||||||
factory := informers.NewSharedInformerFactory(snapClient, *resyncPeriod)
|
factory := informers.NewSharedInformerFactory(snapClient, *resyncPeriod)
|
||||||
coreFactory := coreinformers.NewSharedInformerFactory(kubeClient, *resyncPeriod)
|
coreFactory := coreinformers.NewSharedInformerFactory(kubeClient, *resyncPeriod)
|
||||||
|
|
||||||
// Add Snapshot types to the defualt Kubernetes so events can be logged for them
|
// Add Snapshot types to the default Kubernetes so events can be logged for them
|
||||||
snapshotscheme.AddToScheme(scheme.Scheme)
|
snapshotscheme.AddToScheme(scheme.Scheme)
|
||||||
|
|
||||||
// Connect to CSI.
|
// Connect to CSI.
|
||||||
|
@@ -87,7 +87,7 @@ func main() {
|
|||||||
factory := informers.NewSharedInformerFactory(snapClient, *resyncPeriod)
|
factory := informers.NewSharedInformerFactory(snapClient, *resyncPeriod)
|
||||||
coreFactory := coreinformers.NewSharedInformerFactory(kubeClient, *resyncPeriod)
|
coreFactory := coreinformers.NewSharedInformerFactory(kubeClient, *resyncPeriod)
|
||||||
|
|
||||||
// Add Snapshot types to the defualt Kubernetes so events can be logged for them
|
// Add Snapshot types to the default Kubernetes so events can be logged for them
|
||||||
snapshotscheme.AddToScheme(scheme.Scheme)
|
snapshotscheme.AddToScheme(scheme.Scheme)
|
||||||
|
|
||||||
klog.V(2).Infof("Start NewCSISnapshotController with kubeconfig [%s] resyncPeriod [%+v]", *kubeconfig, *resyncPeriod)
|
klog.V(2).Infof("Start NewCSISnapshotController with kubeconfig [%s] resyncPeriod [%+v]", *kubeconfig, *resyncPeriod)
|
||||||
|
@@ -33,7 +33,7 @@ import (
|
|||||||
func TestUpdateSnapshotClass(t *testing.T) {
|
func TestUpdateSnapshotClass(t *testing.T) {
|
||||||
tests := []controllerTest{
|
tests := []controllerTest{
|
||||||
{
|
{
|
||||||
// defualt snapshot class name should be set
|
// default snapshot class name should be set
|
||||||
name: "1-1 - default snapshot class name should be set",
|
name: "1-1 - default snapshot class name should be set",
|
||||||
initialContents: nocontents,
|
initialContents: nocontents,
|
||||||
initialSnapshots: newSnapshotArray("snap1-1", "snapuid1-1", "claim1-1", "", "", "", &True, nil, nil, nil, false, true, nil),
|
initialSnapshots: newSnapshotArray("snap1-1", "snapuid1-1", "claim1-1", "", "", "", &True, nil, nil, nil, false, true, nil),
|
||||||
|
Reference in New Issue
Block a user