diff options
| author | chrislu <chris.lu@gmail.com> | 2023-01-20 01:49:21 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-01-20 01:49:21 -0800 |
| commit | 8620e287b2706e800cd9e6d76c650403f0d6ea00 (patch) | |
| tree | 6c4eb34bda8e450e94671e094f2b093114101330 /pkg | |
| parent | 318c42a3f56acb04f0aff81d782cf69155abada8 (diff) | |
| download | seaweedfs-csi-driver-8620e287b2706e800cd9e6d76c650403f0d6ea00.tar.xz seaweedfs-csi-driver-8620e287b2706e800cd9e6d76c650403f0d6ea00.zip | |
grpc connection to filer add sw-client-id header
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/driver/driver.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go index 47a55e0..67a6db0 100644 --- a/pkg/driver/driver.go +++ b/pkg/driver/driver.go @@ -43,6 +43,7 @@ type SeaweedFsDriver struct { CacheDir string UidMap string GidMap string + signature int32 } func NewSeaweedFsDriver(filer, nodeID, endpoint string) *SeaweedFsDriver { @@ -58,6 +59,7 @@ func NewSeaweedFsDriver(filer, nodeID, endpoint string) *SeaweedFsDriver { version: version, filers: pb.ServerAddresses(filer).ToAddresses(), grpcDialOption: security.LoadClientTLS(util.GetViper(), "grpc.client"), + signature: util.RandomInt32(), } n.AddVolumeCapabilityAccessModes([]csi.VolumeCapability_AccessMode_Mode{ @@ -140,7 +142,7 @@ func (d *SeaweedFsDriver) WithFilerClient(streamingMode bool, fn func(filer_pb.S var err error for x := 0; x < n; x++ { - err = pb.WithGrpcClient(streamingMode, func(grpcConnection *grpc.ClientConn) error { + err = pb.WithGrpcClient(streamingMode, d.signature, func(grpcConnection *grpc.ClientConn) error { client := filer_pb.NewSeaweedFilerClient(grpcConnection) return fn(client) }, d.filers[i].ToGrpcAddress(), false, d.grpcDialOption) |