This repository has been archived by the owner on Jan 21, 2022. It is now read-only.
/
noop_controller_client.go
64 lines (50 loc) · 2.78 KB
/
noop_controller_client.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
package csibroker
import (
"golang.org/x/net/context"
csi "github.com/container-storage-interface/spec/lib/go/csi"
"google.golang.org/grpc"
)
type NoopControllerClient struct{}
func (c *NoopControllerClient) CreateVolume(ctx context.Context, in *csi.CreateVolumeRequest, opts ...grpc.CallOption) (*csi.CreateVolumeResponse, error) {
var capacityBytes int64
if in.CapacityRange != nil {
capacityBytes = in.CapacityRange.RequiredBytes
}
return &csi.CreateVolumeResponse{
Volume: &csi.Volume{
CapacityBytes: capacityBytes,
VolumeId: in.Name,
VolumeContext: in.Parameters,
},
}, nil
}
func (c *NoopControllerClient) DeleteVolume(ctx context.Context, in *csi.DeleteVolumeRequest, opts ...grpc.CallOption) (*csi.DeleteVolumeResponse, error) {
return new(csi.DeleteVolumeResponse), nil
}
func (c *NoopControllerClient) ControllerPublishVolume(ctx context.Context, in *csi.ControllerPublishVolumeRequest, opts ...grpc.CallOption) (*csi.ControllerPublishVolumeResponse, error) {
return new(csi.ControllerPublishVolumeResponse), nil
}
func (c *NoopControllerClient) ControllerUnpublishVolume(ctx context.Context, in *csi.ControllerUnpublishVolumeRequest, opts ...grpc.CallOption) (*csi.ControllerUnpublishVolumeResponse, error) {
return new(csi.ControllerUnpublishVolumeResponse), nil
}
func (c *NoopControllerClient) ValidateVolumeCapabilities(ctx context.Context, in *csi.ValidateVolumeCapabilitiesRequest, opts ...grpc.CallOption) (*csi.ValidateVolumeCapabilitiesResponse, error) {
return new(csi.ValidateVolumeCapabilitiesResponse), nil
}
func (c *NoopControllerClient) ListVolumes(ctx context.Context, in *csi.ListVolumesRequest, opts ...grpc.CallOption) (*csi.ListVolumesResponse, error) {
return new(csi.ListVolumesResponse), nil
}
func (c *NoopControllerClient) GetCapacity(ctx context.Context, in *csi.GetCapacityRequest, opts ...grpc.CallOption) (*csi.GetCapacityResponse, error) {
return new(csi.GetCapacityResponse), nil
}
func (c *NoopControllerClient) ControllerGetCapabilities(ctx context.Context, in *csi.ControllerGetCapabilitiesRequest, opts ...grpc.CallOption) (*csi.ControllerGetCapabilitiesResponse, error) {
return new(csi.ControllerGetCapabilitiesResponse), nil
}
func (c *NoopControllerClient) CreateSnapshot(ctx context.Context, in *csi.CreateSnapshotRequest, opts ...grpc.CallOption) (*csi.CreateSnapshotResponse, error) {
return new(csi.CreateSnapshotResponse), nil
}
func (c *NoopControllerClient) DeleteSnapshot(ctx context.Context, in *csi.DeleteSnapshotRequest, opts ...grpc.CallOption) (*csi.DeleteSnapshotResponse, error) {
return new(csi.DeleteSnapshotResponse), nil
}
func (c *NoopControllerClient) ListSnapshots(ctx context.Context, in *csi.ListSnapshotsRequest, opts ...grpc.CallOption) (*csi.ListSnapshotsResponse, error) {
return new(csi.ListSnapshotsResponse), nil
}