Skip to content

Commit eefd1a5

Browse files
yevgeny-shnaidmank8s-ci-robot
authored andcommitted
Changing the names of the APIs of mic package to align with mbsc package
1) changing ApplyMIC to CreateOrPatch 2) chaning NewModuleImagesConfigAPI to New
1 parent 946be3a commit eefd1a5

File tree

6 files changed

+21
-21
lines changed

6 files changed

+21
-21
lines changed

cmd/manager/main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ func main() {
123123
buildHelperAPI := build.NewHelper()
124124
nodeAPI := node.NewNode(client)
125125
kernelAPI := module.NewKernelMapper(buildHelperAPI, sign.NewSignerHelper())
126-
micAPI := mic.NewModuleImagesConfigAPI(client, scheme)
126+
micAPI := mic.New(client, scheme)
127127

128128
dpc := controllers.NewDevicePluginReconciler(
129129
client,

internal/controllers/module_reconciler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -356,7 +356,7 @@ func (mrh *moduleReconcilerHelper) handleMIC(ctx context.Context, mod *kmmv1beta
356356
images = append(images, mis)
357357
}
358358

359-
if err := mrh.micAPI.ApplyMIC(ctx, mod.Name, mod.Namespace, images, mod.Spec.ImageRepoSecret, mod); err != nil {
359+
if err := mrh.micAPI.CreateOrPatch(ctx, mod.Name, mod.Namespace, images, mod.Spec.ImageRepoSecret, mod); err != nil {
360360
errs = append(errs, fmt.Errorf("failed to apply %s/%s MIC: %v", mod.Namespace, mod.Name, err))
361361
}
362362

internal/controllers/module_reconciler_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -441,7 +441,7 @@ var _ = Describe("handleMIC", func() {
441441
It("should return an error if we failed to get moduleLoaderData for kernel", func() {
442442

443443
mockKernelMapper.EXPECT().GetModuleLoaderDataForKernel(mod, gomock.Any()).Return(nil, errors.New("some error"))
444-
mockMICAPI.EXPECT().ApplyMIC(ctx, mod.Name, mod.Namespace, gomock.Any(), mod.Spec.ImageRepoSecret, mod).Return(nil)
444+
mockMICAPI.EXPECT().CreateOrPatch(ctx, mod.Name, mod.Namespace, gomock.Any(), mod.Spec.ImageRepoSecret, mod).Return(nil)
445445

446446
err := mrh.handleMIC(ctx, mod, targetedNodes)
447447
Expect(err).To(HaveOccurred())
@@ -453,7 +453,7 @@ var _ = Describe("handleMIC", func() {
453453
img := "example.registry.com/org/image:tag"
454454
mld := &api.ModuleLoaderData{ContainerImage: img}
455455
mockKernelMapper.EXPECT().GetModuleLoaderDataForKernel(mod, gomock.Any()).Return(mld, nil)
456-
mockMICAPI.EXPECT().ApplyMIC(ctx, mod.Name, mod.Namespace, gomock.Any(), mod.Spec.ImageRepoSecret,
456+
mockMICAPI.EXPECT().CreateOrPatch(ctx, mod.Name, mod.Namespace, gomock.Any(), mod.Spec.ImageRepoSecret,
457457
mod).Return(errors.New("some error"))
458458

459459
err := mrh.handleMIC(ctx, mod, targetedNodes)
@@ -466,7 +466,7 @@ var _ = Describe("handleMIC", func() {
466466
img := "example.registry.com/org/image:tag"
467467
mld := &api.ModuleLoaderData{ContainerImage: img}
468468
mockKernelMapper.EXPECT().GetModuleLoaderDataForKernel(mod, gomock.Any()).Return(mld, nil)
469-
mockMICAPI.EXPECT().ApplyMIC(ctx, mod.Name, mod.Namespace, gomock.Any(), mod.Spec.ImageRepoSecret, mod).Return(nil)
469+
mockMICAPI.EXPECT().CreateOrPatch(ctx, mod.Name, mod.Namespace, gomock.Any(), mod.Spec.ImageRepoSecret, mod).Return(nil)
470470

471471
err := mrh.handleMIC(ctx, mod, targetedNodes)
472472
Expect(err).NotTo(HaveOccurred())

internal/mic/mic.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ import (
1616
//go:generate mockgen -source=mic.go -package=mic -destination=mock_mic.go
1717

1818
type MIC interface {
19-
ApplyMIC(ctx context.Context, name, ns string, images []kmmv1beta1.ModuleImageSpec,
19+
CreateOrPatch(ctx context.Context, name, ns string, images []kmmv1beta1.ModuleImageSpec,
2020
imageRepoSecret *v1.LocalObjectReference, owner metav1.Object) error
2121
GetModuleImageSpec(micObj *kmmv1beta1.ModuleImagesConfig, image string) *kmmv1beta1.ModuleImageSpec
2222
SetImageStatus(micObj *kmmv1beta1.ModuleImagesConfig, image string, status kmmv1beta1.ImageState)
@@ -28,14 +28,14 @@ type micImpl struct {
2828
scheme *runtime.Scheme
2929
}
3030

31-
func NewModuleImagesConfigAPI(client client.Client, scheme *runtime.Scheme) MIC {
31+
func New(client client.Client, scheme *runtime.Scheme) MIC {
3232
return &micImpl{
3333
client: client,
3434
scheme: scheme,
3535
}
3636
}
3737

38-
func (mici *micImpl) ApplyMIC(ctx context.Context, name, ns string, images []kmmv1beta1.ModuleImageSpec,
38+
func (mici *micImpl) CreateOrPatch(ctx context.Context, name, ns string, images []kmmv1beta1.ModuleImageSpec,
3939
imageRepoSecret *v1.LocalObjectReference, owner metav1.Object) error {
4040

4141
logger := log.FromContext(ctx)

internal/mic/mic_test.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -36,15 +36,15 @@ var _ = Describe("ApplyMIC", func() {
3636
ctx = context.Background()
3737
ctrl = gomock.NewController(GinkgoT())
3838
mockClient = client.NewMockClient(ctrl)
39-
micAPI = NewModuleImagesConfigAPI(mockClient, scheme)
39+
micAPI = New(mockClient, scheme)
4040
utilruntime.Must(v1beta1.AddToScheme(scheme))
4141
})
4242

4343
It("should fail if we failed to create or patch", func() {
4444

4545
mockClient.EXPECT().Get(ctx, gomock.Any(), gomock.Any()).Return(nil)
4646

47-
err := micAPI.ApplyMIC(ctx, micName, micNamespace, []v1beta1.ModuleImageSpec{}, nil, nil)
47+
err := micAPI.CreateOrPatch(ctx, micName, micNamespace, []v1beta1.ModuleImageSpec{}, nil, nil)
4848

4949
Expect(err).To(HaveOccurred())
5050
Expect(err.Error()).To(ContainSubstring("failed to create or patch"))
@@ -80,7 +80,7 @@ var _ = Describe("ApplyMIC", func() {
8080
},
8181
}
8282

83-
err := micAPI.ApplyMIC(ctx, micName, micNamespace, images, imageRepoSecret, owner)
83+
err := micAPI.CreateOrPatch(ctx, micName, micNamespace, images, imageRepoSecret, owner)
8484

8585
Expect(err).NotTo(HaveOccurred())
8686
})
@@ -126,7 +126,7 @@ var _ = Describe("ApplyMIC", func() {
126126
},
127127
}
128128

129-
err := micAPI.ApplyMIC(ctx, micName, micNamespace, images, nil, owner)
129+
err := micAPI.CreateOrPatch(ctx, micName, micNamespace, images, nil, owner)
130130

131131
Expect(err).NotTo(HaveOccurred())
132132
})
@@ -138,7 +138,7 @@ var _ = Describe("GetModuleImageSpec", func() {
138138
)
139139

140140
BeforeEach(func() {
141-
micAPI = NewModuleImagesConfigAPI(nil, nil)
141+
micAPI = New(nil, nil)
142142
})
143143

144144
testMic := kmmv1beta1.ModuleImagesConfig{
@@ -173,7 +173,7 @@ var _ = Describe("SetImageStatus", func() {
173173
)
174174

175175
BeforeEach(func() {
176-
micAPI = NewModuleImagesConfigAPI(nil, nil)
176+
micAPI = New(nil, nil)
177177
})
178178

179179
testMic := kmmv1beta1.ModuleImagesConfig{
@@ -211,7 +211,7 @@ var _ = Describe("GetImageState", func() {
211211
)
212212

213213
BeforeEach(func() {
214-
micAPI = NewModuleImagesConfigAPI(nil, nil)
214+
micAPI = New(nil, nil)
215215
})
216216

217217
testMic := kmmv1beta1.ModuleImagesConfig{

internal/mic/mock_mic.go

Lines changed: 6 additions & 6 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)