Skip to content

Commit e62b106

Browse files
engedaamengedaam
committed
Allow the plugins to be public
1 parent 1a3db16 commit e62b106

File tree

8 files changed

+73
-71
lines changed

8 files changed

+73
-71
lines changed

‎go.mod‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ require (
1818
github.com/kubernetes-csi/csi-test/v5 v5.4.0
1919
github.com/prometheus/client_golang v1.23.2
2020
github.com/prometheus/common v0.67.5
21-
github.com/samber/lo v1.52.0
2221
github.com/spf13/pflag v1.0.10
2322
github.com/stretchr/testify v1.11.1
2423
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.64.0

‎go.sum‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -210,8 +210,6 @@ github.com/prometheus/procfs v0.19.2/go.mod h1:M0aotyiemPhBCM0z5w87kL22CxfcH05Zp
210210
github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
211211
github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc=
212212
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
213-
github.com/samber/lo v1.52.0 h1:Rvi+3BFHES3A8meP33VPAxiBZX/Aws5RxrschYGjomw=
214-
github.com/samber/lo v1.52.0/go.mod h1:4+MXEGsJzbKGaUEQFKBq2xtfuznW9oz/WrgyzMzRoM0=
215213
github.com/sirupsen/logrus v1.4.1/go.mod h1:ni0Sbl8bgC9z8RoU9G6nDWqqs/fq4eDPysMBDgk/93Q=
216214
github.com/spf13/cobra v1.10.2 h1:DMTTonx5m65Ic0GOoRY2c16WCbHxOOw6xxezuLaBpcU=
217215
github.com/spf13/cobra v1.10.2/go.mod h1:7C1pvHqHw5A4vrJfjNwvOdzYu0Gml16OCs2GRiTUUS4=

‎pkg/driver/controller.go‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@ import (
3535
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/driver/internal"
3636
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/util"
3737
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/util/template"
38-
"github.com/samber/lo"
3938
"google.golang.org/grpc/codes"
4039
"google.golang.org/grpc/status"
4140
"google.golang.org/protobuf/types/known/timestamppb"
@@ -1210,7 +1209,7 @@ func newCreateVolumeResponse(disk *cloud.Disk, ctx map[string]string) *csi.Creat
12101209
}
12111210

12121211
segments := map[string]string{WellKnownZoneTopologyKey: disk.AvailabilityZone}
1213-
lo.Assign(segments, util.GetNodeSegments())
1212+
maps.Copy(segments, util.GetNodeSegments())
12141213

12151214
arn, err := arn.Parse(disk.OutpostArn)
12161215

‎pkg/driver/controller_test.go‎

Lines changed: 20 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020
"context"
2121
"errors"
2222
"fmt"
23+
"maps"
2324
"math/rand"
2425
"reflect"
2526
"strings"
@@ -36,7 +37,6 @@ import (
3637
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/driver/internal"
3738
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/testutil"
3839
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/util"
39-
"github.com/samber/lo"
4040
"github.com/stretchr/testify/assert"
4141
"github.com/stretchr/testify/require"
4242
"google.golang.org/grpc/codes"
@@ -172,19 +172,21 @@ func TestCreateVolume(t *testing.T) {
172172
},
173173
},
174174
}
175+
expectedSegments := map[string]string{
176+
WellKnownZoneTopologyKey: expZone,
177+
AwsAccountIDKey: outpostArn.AccountID,
178+
AwsOutpostIDKey: outpostArn.Resource,
179+
AwsRegionKey: outpostArn.Region,
180+
AwsPartitionKey: outpostArn.Partition,
181+
}
182+
maps.Copy(expectedSegments, util.GetNodeSegments())
175183
expVol := &csi.Volume{
176184
CapacityBytes: stdVolSize,
177185
VolumeId: "vol-test",
178186
VolumeContext: map[string]string{},
179187
AccessibleTopology: []*csi.Topology{
180188
{
181-
Segments: lo.Assign(map[string]string{
182-
WellKnownZoneTopologyKey: expZone,
183-
AwsAccountIDKey: outpostArn.AccountID,
184-
AwsOutpostIDKey: outpostArn.Resource,
185-
AwsRegionKey: outpostArn.Region,
186-
AwsPartitionKey: outpostArn.Partition,
187-
}, util.GetNodeSegments()),
189+
Segments: expectedSegments,
188190
},
189191
},
190192
}
@@ -658,15 +660,17 @@ func TestCreateVolume(t *testing.T) {
658660
},
659661
},
660662
}
663+
expectedSegments := map[string]string{
664+
WellKnownZoneTopologyKey: expZone,
665+
}
666+
maps.Copy(expectedSegments, util.GetNodeSegments())
661667
expVol := &csi.Volume{
662668
CapacityBytes: stdVolSize,
663669
VolumeId: "vol-test",
664670
VolumeContext: map[string]string{},
665671
AccessibleTopology: []*csi.Topology{
666672
{
667-
Segments: lo.Assign(map[string]string{
668-
WellKnownZoneTopologyKey: expZone,
669-
}, util.GetNodeSegments()),
673+
Segments: expectedSegments,
670674
},
671675
},
672676
}
@@ -2169,15 +2173,17 @@ func TestCreateVolume(t *testing.T) {
21692173
},
21702174
},
21712175
}
2176+
expectedSegments := map[string]string{
2177+
WellKnownZoneTopologyKey: expZone,
2178+
}
2179+
maps.Copy(expectedSegments, util.GetNodeSegments())
21722180
expVol := &csi.Volume{
21732181
CapacityBytes: stdVolSize,
21742182
VolumeId: "vol-test",
21752183
VolumeContext: map[string]string{},
21762184
AccessibleTopology: []*csi.Topology{
21772185
{
2178-
Segments: lo.Assign(map[string]string{
2179-
WellKnownZoneTopologyKey: expZone,
2180-
}, util.GetNodeSegments()),
2186+
Segments: expectedSegments,
21812187
},
21822188
},
21832189
}

‎pkg/driver/node.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020
"context"
2121
"encoding/json"
2222
"fmt"
23+
"maps"
2324
"os"
2425
"path/filepath"
2526
"runtime"
@@ -34,7 +35,6 @@ import (
3435
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/driver/internal"
3536
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/mounter"
3637
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/util"
37-
"github.com/samber/lo"
3838
"google.golang.org/grpc/codes"
3939
"google.golang.org/grpc/status"
4040
corev1 "k8s.io/api/core/v1"
@@ -616,7 +616,7 @@ func (d *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoReque
616616
WellKnownZoneTopologyKey: zone,
617617
OSTopologyKey: osType,
618618
}
619-
lo.Assign(segments, util.GetNodeSegments())
619+
maps.Copy(segments, util.GetNodeSegments())
620620

621621
outpostArn := d.metadata.GetOutpostArn()
622622

‎pkg/driver/node_test.go‎

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ package driver
2121
import (
2222
"context"
2323
"errors"
24+
"maps"
2425
"reflect"
2526
"runtime"
2627
"strings"
@@ -34,7 +35,6 @@ import (
3435
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/driver/internal"
3536
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/mounter"
3637
"github.com/kubernetes-sigs/aws-ebs-csi-driver/pkg/util"
37-
"github.com/samber/lo"
3838
"google.golang.org/grpc/codes"
3939
"google.golang.org/grpc/status"
4040
corev1 "k8s.io/api/core/v1"
@@ -2055,6 +2055,22 @@ func TestNodeGetCapabilities(t *testing.T) {
20552055
}
20562056

20572057
func TestNodeGetInfo(t *testing.T) {
2058+
expectedSegments := map[string]string{
2059+
ZoneTopologyKey: "us-west-2a",
2060+
WellKnownZoneTopologyKey: "us-west-2a",
2061+
OSTopologyKey: runtime.GOOS,
2062+
}
2063+
maps.Copy(expectedSegments, util.GetNodeSegments())
2064+
expectedSegmentsWithAWSKeys := map[string]string{
2065+
ZoneTopologyKey: "us-west-2a",
2066+
WellKnownZoneTopologyKey: "us-west-2a",
2067+
OSTopologyKey: runtime.GOOS,
2068+
AwsRegionKey: "us-west-2",
2069+
AwsPartitionKey: "aws",
2070+
AwsAccountIDKey: "123456789012",
2071+
AwsOutpostIDKey: "op-1234567890abcdef0",
2072+
}
2073+
maps.Copy(expectedSegmentsWithAWSKeys, util.GetNodeSegments())
20582074
testCases := []struct {
20592075
name string
20602076
metadataMock func(ctrl *gomock.Controller) *metadata.MockMetadataService
@@ -2073,11 +2089,7 @@ func TestNodeGetInfo(t *testing.T) {
20732089
expectedResp: &csi.NodeGetInfoResponse{
20742090
NodeId: "i-1234567890abcdef0",
20752091
AccessibleTopology: &csi.Topology{
2076-
Segments: lo.Assign(map[string]string{
2077-
ZoneTopologyKey: "us-west-2a",
2078-
WellKnownZoneTopologyKey: "us-west-2a",
2079-
OSTopologyKey: runtime.GOOS,
2080-
}, util.GetNodeSegments()),
2092+
Segments: expectedSegments,
20812093
},
20822094
},
20832095
},
@@ -2095,11 +2107,7 @@ func TestNodeGetInfo(t *testing.T) {
20952107
expectedResp: &csi.NodeGetInfoResponse{
20962108
NodeId: "i-1234567890abcdef0",
20972109
AccessibleTopology: &csi.Topology{
2098-
Segments: lo.Assign(map[string]string{
2099-
ZoneTopologyKey: "us-west-2a",
2100-
WellKnownZoneTopologyKey: "us-west-2a",
2101-
OSTopologyKey: runtime.GOOS,
2102-
}, util.GetNodeSegments()),
2110+
Segments: expectedSegments,
21032111
},
21042112
},
21052113
},
@@ -2122,15 +2130,7 @@ func TestNodeGetInfo(t *testing.T) {
21222130
expectedResp: &csi.NodeGetInfoResponse{
21232131
NodeId: "i-1234567890abcdef0",
21242132
AccessibleTopology: &csi.Topology{
2125-
Segments: lo.Assign(map[string]string{
2126-
ZoneTopologyKey: "us-west-2a",
2127-
WellKnownZoneTopologyKey: "us-west-2a",
2128-
OSTopologyKey: runtime.GOOS,
2129-
AwsRegionKey: "us-west-2",
2130-
AwsPartitionKey: "aws",
2131-
AwsAccountIDKey: "123456789012",
2132-
AwsOutpostIDKey: "op-1234567890abcdef0",
2133-
}, util.GetNodeSegments()),
2133+
Segments: expectedSegmentsWithAWSKeys,
21342134
},
21352135
},
21362136
},

‎pkg/plugin/plugin_clients.go‎

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -30,16 +30,16 @@ import (
3030
"github.com/aws/aws-sdk-go-v2/service/sagemaker"
3131
)
3232

33-
// ec2ClientBase implements stub functionality for EC2API. It can be used
33+
// Ec2ClientBase implements stub functionality for EC2API. It can be used
3434
// by plugins that only want to customize a subset of the EC2 API calls.
3535
// Use of this struct is NOT required, plugins may return any compliant
3636
// EC2API implementation from GetEC2Client.
37-
type ec2ClientBase struct {
37+
type Ec2ClientBase struct {
3838
client *ec2.Client
3939
}
4040

41-
// init sets up the EC2 client in ec2ClientBase. Must be called first.
42-
func (b *ec2ClientBase) init(cfg aws.Config, optFns ...func(*ec2.Options)) {
41+
// init sets up the EC2 client in Ec2ClientBase. Must be called first.
42+
func (b *Ec2ClientBase) init(cfg aws.Config, optFns ...func(*ec2.Options)) {
4343
b.client = ec2.NewFromConfig(cfg, optFns...)
4444
}
4545

@@ -58,58 +58,58 @@ func (b *sageMakerClientBase) init(cfg aws.Config, optFns ...func(*sagemaker.Opt
5858

5959
// EC2API stub functions.
6060

61-
func (b *ec2ClientBase) DescribeVolumes(ctx context.Context, params *ec2.DescribeVolumesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesOutput, error) {
61+
func (b *Ec2ClientBase) DescribeVolumes(ctx context.Context, params *ec2.DescribeVolumesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesOutput, error) {
6262
return b.client.DescribeVolumes(ctx, params, optFns...)
6363
}
64-
func (b *ec2ClientBase) DescribeVolumeStatus(ctx context.Context, params *ec2.DescribeVolumeStatusInput, optFns ...func(options *ec2.Options)) (*ec2.DescribeVolumeStatusOutput, error) {
64+
func (b *Ec2ClientBase) DescribeVolumeStatus(ctx context.Context, params *ec2.DescribeVolumeStatusInput, optFns ...func(options *ec2.Options)) (*ec2.DescribeVolumeStatusOutput, error) {
6565
return b.client.DescribeVolumeStatus(ctx, params, optFns...)
6666
}
67-
func (b *ec2ClientBase) CreateVolume(ctx context.Context, params *ec2.CreateVolumeInput, optFns ...func(*ec2.Options)) (*ec2.CreateVolumeOutput, error) {
67+
func (b *Ec2ClientBase) CreateVolume(ctx context.Context, params *ec2.CreateVolumeInput, optFns ...func(*ec2.Options)) (*ec2.CreateVolumeOutput, error) {
6868
return b.client.CreateVolume(ctx, params, optFns...)
6969
}
70-
func (b *ec2ClientBase) CopyVolumes(ctx context.Context, params *ec2.CopyVolumesInput, optFns ...func(*ec2.Options)) (*ec2.CopyVolumesOutput, error) {
70+
func (b *Ec2ClientBase) CopyVolumes(ctx context.Context, params *ec2.CopyVolumesInput, optFns ...func(*ec2.Options)) (*ec2.CopyVolumesOutput, error) {
7171
return b.client.CopyVolumes(ctx, params, optFns...)
7272
}
73-
func (b *ec2ClientBase) DeleteVolume(ctx context.Context, params *ec2.DeleteVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DeleteVolumeOutput, error) {
73+
func (b *Ec2ClientBase) DeleteVolume(ctx context.Context, params *ec2.DeleteVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DeleteVolumeOutput, error) {
7474
return b.client.DeleteVolume(ctx, params, optFns...)
7575
}
76-
func (b *ec2ClientBase) AttachVolume(ctx context.Context, params *ec2.AttachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.AttachVolumeOutput, error) {
76+
func (b *Ec2ClientBase) AttachVolume(ctx context.Context, params *ec2.AttachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.AttachVolumeOutput, error) {
7777
return b.client.AttachVolume(ctx, params, optFns...)
7878
}
79-
func (b *ec2ClientBase) DetachVolume(ctx context.Context, params *ec2.DetachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DetachVolumeOutput, error) {
79+
func (b *Ec2ClientBase) DetachVolume(ctx context.Context, params *ec2.DetachVolumeInput, optFns ...func(*ec2.Options)) (*ec2.DetachVolumeOutput, error) {
8080
return b.client.DetachVolume(ctx, params, optFns...)
8181
}
82-
func (b *ec2ClientBase) DescribeInstances(ctx context.Context, params *ec2.DescribeInstancesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeInstancesOutput, error) {
82+
func (b *Ec2ClientBase) DescribeInstances(ctx context.Context, params *ec2.DescribeInstancesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeInstancesOutput, error) {
8383
return b.client.DescribeInstances(ctx, params, optFns...)
8484
}
85-
func (b *ec2ClientBase) DescribeAvailabilityZones(ctx context.Context, params *ec2.DescribeAvailabilityZonesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeAvailabilityZonesOutput, error) {
85+
func (b *Ec2ClientBase) DescribeAvailabilityZones(ctx context.Context, params *ec2.DescribeAvailabilityZonesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeAvailabilityZonesOutput, error) {
8686
return b.client.DescribeAvailabilityZones(ctx, params, optFns...)
8787
}
88-
func (b *ec2ClientBase) CreateSnapshot(ctx context.Context, params *ec2.CreateSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.CreateSnapshotOutput, error) {
88+
func (b *Ec2ClientBase) CreateSnapshot(ctx context.Context, params *ec2.CreateSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.CreateSnapshotOutput, error) {
8989
return b.client.CreateSnapshot(ctx, params, optFns...)
9090
}
91-
func (b *ec2ClientBase) DeleteSnapshot(ctx context.Context, params *ec2.DeleteSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.DeleteSnapshotOutput, error) {
91+
func (b *Ec2ClientBase) DeleteSnapshot(ctx context.Context, params *ec2.DeleteSnapshotInput, optFns ...func(*ec2.Options)) (*ec2.DeleteSnapshotOutput, error) {
9292
return b.client.DeleteSnapshot(ctx, params, optFns...)
9393
}
94-
func (b *ec2ClientBase) DescribeSnapshots(ctx context.Context, params *ec2.DescribeSnapshotsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeSnapshotsOutput, error) {
94+
func (b *Ec2ClientBase) DescribeSnapshots(ctx context.Context, params *ec2.DescribeSnapshotsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeSnapshotsOutput, error) {
9595
return b.client.DescribeSnapshots(ctx, params, optFns...)
9696
}
97-
func (b *ec2ClientBase) ModifyVolume(ctx context.Context, params *ec2.ModifyVolumeInput, optFns ...func(*ec2.Options)) (*ec2.ModifyVolumeOutput, error) {
97+
func (b *Ec2ClientBase) ModifyVolume(ctx context.Context, params *ec2.ModifyVolumeInput, optFns ...func(*ec2.Options)) (*ec2.ModifyVolumeOutput, error) {
9898
return b.client.ModifyVolume(ctx, params, optFns...)
9999
}
100-
func (b *ec2ClientBase) DescribeVolumesModifications(ctx context.Context, params *ec2.DescribeVolumesModificationsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesModificationsOutput, error) {
100+
func (b *Ec2ClientBase) DescribeVolumesModifications(ctx context.Context, params *ec2.DescribeVolumesModificationsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeVolumesModificationsOutput, error) {
101101
return b.client.DescribeVolumesModifications(ctx, params, optFns...)
102102
}
103-
func (b *ec2ClientBase) DescribeTags(ctx context.Context, params *ec2.DescribeTagsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeTagsOutput, error) {
103+
func (b *Ec2ClientBase) DescribeTags(ctx context.Context, params *ec2.DescribeTagsInput, optFns ...func(*ec2.Options)) (*ec2.DescribeTagsOutput, error) {
104104
return b.client.DescribeTags(ctx, params, optFns...)
105105
}
106-
func (b *ec2ClientBase) CreateTags(ctx context.Context, params *ec2.CreateTagsInput, optFns ...func(*ec2.Options)) (*ec2.CreateTagsOutput, error) {
106+
func (b *Ec2ClientBase) CreateTags(ctx context.Context, params *ec2.CreateTagsInput, optFns ...func(*ec2.Options)) (*ec2.CreateTagsOutput, error) {
107107
return b.client.CreateTags(ctx, params, optFns...)
108108
}
109-
func (b *ec2ClientBase) DeleteTags(ctx context.Context, params *ec2.DeleteTagsInput, optFns ...func(*ec2.Options)) (*ec2.DeleteTagsOutput, error) {
109+
func (b *Ec2ClientBase) DeleteTags(ctx context.Context, params *ec2.DeleteTagsInput, optFns ...func(*ec2.Options)) (*ec2.DeleteTagsOutput, error) {
110110
return b.client.DeleteTags(ctx, params, optFns...)
111111
}
112-
func (b *ec2ClientBase) EnableFastSnapshotRestores(ctx context.Context, params *ec2.EnableFastSnapshotRestoresInput, optFns ...func(*ec2.Options)) (*ec2.EnableFastSnapshotRestoresOutput, error) {
112+
func (b *Ec2ClientBase) EnableFastSnapshotRestores(ctx context.Context, params *ec2.EnableFastSnapshotRestoresInput, optFns ...func(*ec2.Options)) (*ec2.EnableFastSnapshotRestoresOutput, error) {
113113
return b.client.EnableFastSnapshotRestores(ctx, params, optFns...)
114114
}
115115

‎pkg/plugin/plugin_common.go‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ func GetPlugin() EbsCsiPlugin {
4242
}
4343

4444
// loadPlugin loads a plugin into memory.
45-
func loadPlugin(pluginToLoad EbsCsiPlugin) {
45+
func LoadPlugin(pluginToLoad EbsCsiPlugin) {
4646
if plugin != nil {
4747
// Multiple plugins are not currently supported
4848
// Thus, exit as quickly as possible
@@ -75,27 +75,27 @@ type EbsCsiPlugin interface {
7575
GetNodeSegments() map[string]string
7676
}
7777

78-
// ebsCsiPluginBase implements stub functionality of all plugin methods except Init().
78+
// EbsCsiPluginBase implements stub functionality of all plugin methods except Init().
7979
// It is strongly recommended to embed into plugin implementations to prevent bulid failures
8080
// if/when new functions are added to the EbsCsiPlugin interface.
81-
type ebsCsiPluginBase struct{}
81+
type EbsCsiPluginBase struct{}
8282

83-
func (p *ebsCsiPluginBase) InitFlags(_ *pflag.FlagSet) {
83+
func (p *EbsCsiPluginBase) InitFlags(_ *pflag.FlagSet) {
8484
// Do nothing intentionally.
8585
}
8686

87-
func (p *ebsCsiPluginBase) GetEC2Client(_ aws.Config, _ ...func(o *ec2.Options)) util.EC2API {
87+
func (p *EbsCsiPluginBase) GetEC2Client(_ aws.Config, _ ...func(o *ec2.Options)) util.EC2API {
8888
return nil
8989
}
9090

91-
func (p *ebsCsiPluginBase) GetSageMakerClient(_ aws.Config, _ ...func(o *sagemaker.Options)) util.SageMakerAPI {
91+
func (p *EbsCsiPluginBase) GetSageMakerClient(_ aws.Config, _ ...func(o *sagemaker.Options)) util.SageMakerAPI {
9292
return nil
9393
}
9494

95-
func (p *ebsCsiPluginBase) GetDriverName() string {
95+
func (p *EbsCsiPluginBase) GetDriverName() string {
9696
return ""
9797
}
9898

99-
func (p *ebsCsiPluginBase) GetNodeSegments() map[string]string {
99+
func (p *EbsCsiPluginBase) GetNodeSegments() map[string]string {
100100
return map[string]string{}
101101
}

0 commit comments

Comments
 (0)