forked from dell/csi-powerflex
-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.go
76 lines (60 loc) · 2.4 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
//go:generate go generate ./core
package main
import (
"context"
"flag"
"fmt"
"os"
"strings"
"github.com/dell/csi-vxflexos/k8sutils"
"github.com/dell/csi-vxflexos/provider"
"github.com/dell/csi-vxflexos/service"
"github.com/dell/gocsi"
)
// main is ignored when this package is built as a go plug-in
func main() {
arrayConfig := flag.String("array-config", "", "json file with array(s) configuration")
enableLeaderElection := flag.Bool("leader-election", false, "boolean to enable leader election")
leaderElectionNamespace := flag.String("leader-election-namespace", "", "namespace where leader election lease will be created")
kubeconfig := flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
flag.Parse()
if *arrayConfig == "" {
fmt.Fprintf(os.Stderr, "array-config argument is mandatory")
os.Exit(1)
}
service.ArrayConfig = *arrayConfig
run := func(ctx context.Context) {
gocsi.Run(ctx, service.Name, "A PowerFlex Container Storage Interface (CSI) Plugin",
usage, provider.New())
}
if !*enableLeaderElection {
run(context.Background())
} else {
driverName := strings.Replace(service.Name, ".", "-", -1)
lockName := fmt.Sprintf("driver-%s", driverName)
k8sclientset, err := k8sutils.CreateKubeClientSet(*kubeconfig)
if err != nil {
_, _ = fmt.Fprintf(os.Stderr, "failed to initialize leader election: %v", err)
os.Exit(1)
}
// Attempt to become leader and start the driver
k8sutils.LeaderElection(k8sclientset, lockName, *leaderElectionNamespace, run)
}
}
const usage = ` X_CSI_VXFLEXOS_SDCGUID
Specifies the GUID of the SDC. This is only used by the Node Service,
and removes a need for calling an external binary to retrieve the GUID.
If not set, the external binary will be invoked.
The default value is empty.
X_CSI_VXFLEXOS_THICKPROVISIONING
Specifies whether thick provisiong should be used when creating volumes.
The default value is false.
X_CSI_VXFLEXOS_ENABLESNAPSHOTCGDELETE
When a snapshot is deleted, if it is a member of a Consistency Group, enable automatic deletion
of all snapshots in the consistency group.
The default value is false.
X_CSI_VXFLEXOS_ENABLELISTVOLUMESNAPSHOTS
When listing volumes, if this option is is enabled, then volumes and snapshots will be returned.
Otherwise only volumes are returned.
The default value is false.
`