Skip to content

Commit 5c3ba2e

Browse files
authored
added method spies to improve grpc server mocking (#6)
1 parent bea6f8a commit 5c3ba2e

7 files changed

Lines changed: 224 additions & 58 deletions

File tree

internal/testutil/fake_backup.go

Lines changed: 45 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -22,92 +22,115 @@ type FakeBackupService struct {
2222
CreateBackupScheduleFunc func(context.Context, *backupv1.CreateBackupScheduleRequest) (*backupv1.CreateBackupScheduleResponse, error)
2323
UpdateBackupScheduleFunc func(context.Context, *backupv1.UpdateBackupScheduleRequest) (*backupv1.UpdateBackupScheduleResponse, error)
2424
DeleteBackupScheduleFunc func(context.Context, *backupv1.DeleteBackupScheduleRequest) (*backupv1.DeleteBackupScheduleResponse, error)
25+
26+
ListBackupsCalls MethodSpy[*backupv1.ListBackupsRequest, *backupv1.ListBackupsResponse]
27+
GetBackupCalls MethodSpy[*backupv1.GetBackupRequest, *backupv1.GetBackupResponse]
28+
CreateBackupCalls MethodSpy[*backupv1.CreateBackupRequest, *backupv1.CreateBackupResponse]
29+
DeleteBackupCalls MethodSpy[*backupv1.DeleteBackupRequest, *backupv1.DeleteBackupResponse]
30+
ListBackupRestoresCalls MethodSpy[*backupv1.ListBackupRestoresRequest, *backupv1.ListBackupRestoresResponse]
31+
RestoreBackupCalls MethodSpy[*backupv1.RestoreBackupRequest, *backupv1.RestoreBackupResponse]
32+
ListBackupSchedulesCalls MethodSpy[*backupv1.ListBackupSchedulesRequest, *backupv1.ListBackupSchedulesResponse]
33+
GetBackupScheduleCalls MethodSpy[*backupv1.GetBackupScheduleRequest, *backupv1.GetBackupScheduleResponse]
34+
CreateBackupScheduleCalls MethodSpy[*backupv1.CreateBackupScheduleRequest, *backupv1.CreateBackupScheduleResponse]
35+
UpdateBackupScheduleCalls MethodSpy[*backupv1.UpdateBackupScheduleRequest, *backupv1.UpdateBackupScheduleResponse]
36+
DeleteBackupScheduleCalls MethodSpy[*backupv1.DeleteBackupScheduleRequest, *backupv1.DeleteBackupScheduleResponse]
2537
}
2638

27-
// ListBackups delegates to ListBackupsFunc if set.
39+
// ListBackups delegates to ListBackupsFunc if set, otherwise dispatches via ListBackupsCalls.
2840
func (f *FakeBackupService) ListBackups(ctx context.Context, req *backupv1.ListBackupsRequest) (*backupv1.ListBackupsResponse, error) {
41+
f.ListBackupsCalls.record(req)
2942
if f.ListBackupsFunc != nil {
3043
return f.ListBackupsFunc(ctx, req)
3144
}
32-
return f.UnimplementedBackupServiceServer.ListBackups(ctx, req)
45+
return f.ListBackupsCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.ListBackups)
3346
}
3447

35-
// GetBackup delegates to GetBackupFunc if set.
48+
// GetBackup delegates to GetBackupFunc if set, otherwise dispatches via GetBackupCalls.
3649
func (f *FakeBackupService) GetBackup(ctx context.Context, req *backupv1.GetBackupRequest) (*backupv1.GetBackupResponse, error) {
50+
f.GetBackupCalls.record(req)
3751
if f.GetBackupFunc != nil {
3852
return f.GetBackupFunc(ctx, req)
3953
}
40-
return f.UnimplementedBackupServiceServer.GetBackup(ctx, req)
54+
return f.GetBackupCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.GetBackup)
4155
}
4256

43-
// CreateBackup delegates to CreateBackupFunc if set.
57+
// CreateBackup delegates to CreateBackupFunc if set, otherwise dispatches via CreateBackupCalls.
4458
func (f *FakeBackupService) CreateBackup(ctx context.Context, req *backupv1.CreateBackupRequest) (*backupv1.CreateBackupResponse, error) {
59+
f.CreateBackupCalls.record(req)
4560
if f.CreateBackupFunc != nil {
4661
return f.CreateBackupFunc(ctx, req)
4762
}
48-
return f.UnimplementedBackupServiceServer.CreateBackup(ctx, req)
63+
return f.CreateBackupCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.CreateBackup)
4964
}
5065

51-
// DeleteBackup delegates to DeleteBackupFunc if set.
66+
// DeleteBackup delegates to DeleteBackupFunc if set, otherwise dispatches via DeleteBackupCalls.
5267
func (f *FakeBackupService) DeleteBackup(ctx context.Context, req *backupv1.DeleteBackupRequest) (*backupv1.DeleteBackupResponse, error) {
68+
f.DeleteBackupCalls.record(req)
5369
if f.DeleteBackupFunc != nil {
5470
return f.DeleteBackupFunc(ctx, req)
5571
}
56-
return f.UnimplementedBackupServiceServer.DeleteBackup(ctx, req)
72+
return f.DeleteBackupCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.DeleteBackup)
5773
}
5874

59-
// ListBackupRestores delegates to ListBackupRestoresFunc if set.
75+
// ListBackupRestores delegates to ListBackupRestoresFunc if set, otherwise dispatches via ListBackupRestoresCalls.
6076
func (f *FakeBackupService) ListBackupRestores(ctx context.Context, req *backupv1.ListBackupRestoresRequest) (*backupv1.ListBackupRestoresResponse, error) {
77+
f.ListBackupRestoresCalls.record(req)
6178
if f.ListBackupRestoresFunc != nil {
6279
return f.ListBackupRestoresFunc(ctx, req)
6380
}
64-
return f.UnimplementedBackupServiceServer.ListBackupRestores(ctx, req)
81+
return f.ListBackupRestoresCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.ListBackupRestores)
6582
}
6683

67-
// RestoreBackup delegates to RestoreBackupFunc if set.
84+
// RestoreBackup delegates to RestoreBackupFunc if set, otherwise dispatches via RestoreBackupCalls.
6885
func (f *FakeBackupService) RestoreBackup(ctx context.Context, req *backupv1.RestoreBackupRequest) (*backupv1.RestoreBackupResponse, error) {
86+
f.RestoreBackupCalls.record(req)
6987
if f.RestoreBackupFunc != nil {
7088
return f.RestoreBackupFunc(ctx, req)
7189
}
72-
return f.UnimplementedBackupServiceServer.RestoreBackup(ctx, req)
90+
return f.RestoreBackupCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.RestoreBackup)
7391
}
7492

75-
// ListBackupSchedules delegates to ListBackupSchedulesFunc if set.
93+
// ListBackupSchedules delegates to ListBackupSchedulesFunc if set, otherwise dispatches via ListBackupSchedulesCalls.
7694
func (f *FakeBackupService) ListBackupSchedules(ctx context.Context, req *backupv1.ListBackupSchedulesRequest) (*backupv1.ListBackupSchedulesResponse, error) {
95+
f.ListBackupSchedulesCalls.record(req)
7796
if f.ListBackupSchedulesFunc != nil {
7897
return f.ListBackupSchedulesFunc(ctx, req)
7998
}
80-
return f.UnimplementedBackupServiceServer.ListBackupSchedules(ctx, req)
99+
return f.ListBackupSchedulesCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.ListBackupSchedules)
81100
}
82101

83-
// GetBackupSchedule delegates to GetBackupScheduleFunc if set.
102+
// GetBackupSchedule delegates to GetBackupScheduleFunc if set, otherwise dispatches via GetBackupScheduleCalls.
84103
func (f *FakeBackupService) GetBackupSchedule(ctx context.Context, req *backupv1.GetBackupScheduleRequest) (*backupv1.GetBackupScheduleResponse, error) {
104+
f.GetBackupScheduleCalls.record(req)
85105
if f.GetBackupScheduleFunc != nil {
86106
return f.GetBackupScheduleFunc(ctx, req)
87107
}
88-
return f.UnimplementedBackupServiceServer.GetBackupSchedule(ctx, req)
108+
return f.GetBackupScheduleCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.GetBackupSchedule)
89109
}
90110

91-
// CreateBackupSchedule delegates to CreateBackupScheduleFunc if set.
111+
// CreateBackupSchedule delegates to CreateBackupScheduleFunc if set, otherwise dispatches via CreateBackupScheduleCalls.
92112
func (f *FakeBackupService) CreateBackupSchedule(ctx context.Context, req *backupv1.CreateBackupScheduleRequest) (*backupv1.CreateBackupScheduleResponse, error) {
113+
f.CreateBackupScheduleCalls.record(req)
93114
if f.CreateBackupScheduleFunc != nil {
94115
return f.CreateBackupScheduleFunc(ctx, req)
95116
}
96-
return f.UnimplementedBackupServiceServer.CreateBackupSchedule(ctx, req)
117+
return f.CreateBackupScheduleCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.CreateBackupSchedule)
97118
}
98119

99-
// UpdateBackupSchedule delegates to UpdateBackupScheduleFunc if set.
120+
// UpdateBackupSchedule delegates to UpdateBackupScheduleFunc if set, otherwise dispatches via UpdateBackupScheduleCalls.
100121
func (f *FakeBackupService) UpdateBackupSchedule(ctx context.Context, req *backupv1.UpdateBackupScheduleRequest) (*backupv1.UpdateBackupScheduleResponse, error) {
122+
f.UpdateBackupScheduleCalls.record(req)
101123
if f.UpdateBackupScheduleFunc != nil {
102124
return f.UpdateBackupScheduleFunc(ctx, req)
103125
}
104-
return f.UnimplementedBackupServiceServer.UpdateBackupSchedule(ctx, req)
126+
return f.UpdateBackupScheduleCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.UpdateBackupSchedule)
105127
}
106128

107-
// DeleteBackupSchedule delegates to DeleteBackupScheduleFunc if set.
129+
// DeleteBackupSchedule delegates to DeleteBackupScheduleFunc if set, otherwise dispatches via DeleteBackupScheduleCalls.
108130
func (f *FakeBackupService) DeleteBackupSchedule(ctx context.Context, req *backupv1.DeleteBackupScheduleRequest) (*backupv1.DeleteBackupScheduleResponse, error) {
131+
f.DeleteBackupScheduleCalls.record(req)
109132
if f.DeleteBackupScheduleFunc != nil {
110133
return f.DeleteBackupScheduleFunc(ctx, req)
111134
}
112-
return f.UnimplementedBackupServiceServer.DeleteBackupSchedule(ctx, req)
135+
return f.DeleteBackupScheduleCalls.dispatch(ctx, req, f.UnimplementedBackupServiceServer.DeleteBackupSchedule)
113136
}

internal/testutil/fake_booking.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,12 +12,15 @@ type FakeBookingService struct {
1212
bookingv1.UnimplementedBookingServiceServer
1313

1414
ListPackagesFunc func(context.Context, *bookingv1.ListPackagesRequest) (*bookingv1.ListPackagesResponse, error)
15+
16+
ListPackagesCalls MethodSpy[*bookingv1.ListPackagesRequest, *bookingv1.ListPackagesResponse]
1517
}
1618

17-
// ListPackages delegates to ListPackagesFunc if set.
19+
// ListPackages delegates to ListPackagesFunc if set, otherwise dispatches via ListPackagesCalls.
1820
func (f *FakeBookingService) ListPackages(ctx context.Context, req *bookingv1.ListPackagesRequest) (*bookingv1.ListPackagesResponse, error) {
21+
f.ListPackagesCalls.record(req)
1922
if f.ListPackagesFunc != nil {
2023
return f.ListPackagesFunc(ctx, req)
2124
}
22-
return f.UnimplementedBookingServiceServer.ListPackages(ctx, req)
25+
return f.ListPackagesCalls.dispatch(ctx, req, f.UnimplementedBookingServiceServer.ListPackages)
2326
}

internal/testutil/fake_cluster.go

Lines changed: 41 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -21,84 +21,105 @@ type FakeClusterService struct {
2121
UnsuspendClusterFunc func(context.Context, *clusterv1.UnsuspendClusterRequest) (*clusterv1.UnsuspendClusterResponse, error)
2222
SuggestClusterNameFunc func(context.Context, *clusterv1.SuggestClusterNameRequest) (*clusterv1.SuggestClusterNameResponse, error)
2323
ListQdrantReleasesFunc func(context.Context, *clusterv1.ListQdrantReleasesRequest) (*clusterv1.ListQdrantReleasesResponse, error)
24+
25+
ListClustersCalls MethodSpy[*clusterv1.ListClustersRequest, *clusterv1.ListClustersResponse]
26+
GetClusterCalls MethodSpy[*clusterv1.GetClusterRequest, *clusterv1.GetClusterResponse]
27+
CreateClusterCalls MethodSpy[*clusterv1.CreateClusterRequest, *clusterv1.CreateClusterResponse]
28+
UpdateClusterCalls MethodSpy[*clusterv1.UpdateClusterRequest, *clusterv1.UpdateClusterResponse]
29+
DeleteClusterCalls MethodSpy[*clusterv1.DeleteClusterRequest, *clusterv1.DeleteClusterResponse]
30+
RestartClusterCalls MethodSpy[*clusterv1.RestartClusterRequest, *clusterv1.RestartClusterResponse]
31+
SuspendClusterCalls MethodSpy[*clusterv1.SuspendClusterRequest, *clusterv1.SuspendClusterResponse]
32+
UnsuspendClusterCalls MethodSpy[*clusterv1.UnsuspendClusterRequest, *clusterv1.UnsuspendClusterResponse]
33+
SuggestClusterNameCalls MethodSpy[*clusterv1.SuggestClusterNameRequest, *clusterv1.SuggestClusterNameResponse]
34+
ListQdrantReleasesCalls MethodSpy[*clusterv1.ListQdrantReleasesRequest, *clusterv1.ListQdrantReleasesResponse]
2435
}
2536

26-
// ListClusters delegates to ListClustersFunc if set.
37+
// ListClusters delegates to ListClustersFunc if set, otherwise dispatches via ListClustersCalls.
2738
func (f *FakeClusterService) ListClusters(ctx context.Context, req *clusterv1.ListClustersRequest) (*clusterv1.ListClustersResponse, error) {
39+
f.ListClustersCalls.record(req)
2840
if f.ListClustersFunc != nil {
2941
return f.ListClustersFunc(ctx, req)
3042
}
31-
return f.UnimplementedClusterServiceServer.ListClusters(ctx, req)
43+
return f.ListClustersCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.ListClusters)
3244
}
3345

34-
// GetCluster delegates to GetClusterFunc if set.
46+
// GetCluster delegates to GetClusterFunc if set, otherwise dispatches via GetClusterCalls.
3547
func (f *FakeClusterService) GetCluster(ctx context.Context, req *clusterv1.GetClusterRequest) (*clusterv1.GetClusterResponse, error) {
48+
f.GetClusterCalls.record(req)
3649
if f.GetClusterFunc != nil {
3750
return f.GetClusterFunc(ctx, req)
3851
}
39-
return f.UnimplementedClusterServiceServer.GetCluster(ctx, req)
52+
return f.GetClusterCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.GetCluster)
4053
}
4154

42-
// CreateCluster delegates to CreateClusterFunc if set.
55+
// CreateCluster delegates to CreateClusterFunc if set, otherwise dispatches via CreateClusterCalls.
4356
func (f *FakeClusterService) CreateCluster(ctx context.Context, req *clusterv1.CreateClusterRequest) (*clusterv1.CreateClusterResponse, error) {
57+
f.CreateClusterCalls.record(req)
4458
if f.CreateClusterFunc != nil {
4559
return f.CreateClusterFunc(ctx, req)
4660
}
47-
return f.UnimplementedClusterServiceServer.CreateCluster(ctx, req)
61+
return f.CreateClusterCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.CreateCluster)
4862
}
4963

50-
// UpdateCluster delegates to UpdateClusterFunc if set.
64+
// UpdateCluster delegates to UpdateClusterFunc if set, otherwise dispatches via UpdateClusterCalls.
5165
func (f *FakeClusterService) UpdateCluster(ctx context.Context, req *clusterv1.UpdateClusterRequest) (*clusterv1.UpdateClusterResponse, error) {
66+
f.UpdateClusterCalls.record(req)
5267
if f.UpdateClusterFunc != nil {
5368
return f.UpdateClusterFunc(ctx, req)
5469
}
55-
return f.UnimplementedClusterServiceServer.UpdateCluster(ctx, req)
70+
return f.UpdateClusterCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.UpdateCluster)
5671
}
5772

58-
// DeleteCluster delegates to DeleteClusterFunc if set.
73+
// DeleteCluster delegates to DeleteClusterFunc if set, otherwise dispatches via DeleteClusterCalls.
5974
func (f *FakeClusterService) DeleteCluster(ctx context.Context, req *clusterv1.DeleteClusterRequest) (*clusterv1.DeleteClusterResponse, error) {
75+
f.DeleteClusterCalls.record(req)
6076
if f.DeleteClusterFunc != nil {
6177
return f.DeleteClusterFunc(ctx, req)
6278
}
63-
return f.UnimplementedClusterServiceServer.DeleteCluster(ctx, req)
79+
return f.DeleteClusterCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.DeleteCluster)
6480
}
6581

66-
// RestartCluster delegates to RestartClusterFunc if set.
82+
// RestartCluster delegates to RestartClusterFunc if set, otherwise dispatches via RestartClusterCalls.
6783
func (f *FakeClusterService) RestartCluster(ctx context.Context, req *clusterv1.RestartClusterRequest) (*clusterv1.RestartClusterResponse, error) {
84+
f.RestartClusterCalls.record(req)
6885
if f.RestartClusterFunc != nil {
6986
return f.RestartClusterFunc(ctx, req)
7087
}
71-
return f.UnimplementedClusterServiceServer.RestartCluster(ctx, req)
88+
return f.RestartClusterCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.RestartCluster)
7289
}
7390

74-
// SuspendCluster delegates to SuspendClusterFunc if set.
91+
// SuspendCluster delegates to SuspendClusterFunc if set, otherwise dispatches via SuspendClusterCalls.
7592
func (f *FakeClusterService) SuspendCluster(ctx context.Context, req *clusterv1.SuspendClusterRequest) (*clusterv1.SuspendClusterResponse, error) {
93+
f.SuspendClusterCalls.record(req)
7694
if f.SuspendClusterFunc != nil {
7795
return f.SuspendClusterFunc(ctx, req)
7896
}
79-
return f.UnimplementedClusterServiceServer.SuspendCluster(ctx, req)
97+
return f.SuspendClusterCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.SuspendCluster)
8098
}
8199

82-
// UnsuspendCluster delegates to UnsuspendClusterFunc if set.
100+
// UnsuspendCluster delegates to UnsuspendClusterFunc if set, otherwise dispatches via UnsuspendClusterCalls.
83101
func (f *FakeClusterService) UnsuspendCluster(ctx context.Context, req *clusterv1.UnsuspendClusterRequest) (*clusterv1.UnsuspendClusterResponse, error) {
102+
f.UnsuspendClusterCalls.record(req)
84103
if f.UnsuspendClusterFunc != nil {
85104
return f.UnsuspendClusterFunc(ctx, req)
86105
}
87-
return f.UnimplementedClusterServiceServer.UnsuspendCluster(ctx, req)
106+
return f.UnsuspendClusterCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.UnsuspendCluster)
88107
}
89108

90-
// SuggestClusterName delegates to SuggestClusterNameFunc if set.
109+
// SuggestClusterName delegates to SuggestClusterNameFunc if set, otherwise dispatches via SuggestClusterNameCalls.
91110
func (f *FakeClusterService) SuggestClusterName(ctx context.Context, req *clusterv1.SuggestClusterNameRequest) (*clusterv1.SuggestClusterNameResponse, error) {
111+
f.SuggestClusterNameCalls.record(req)
92112
if f.SuggestClusterNameFunc != nil {
93113
return f.SuggestClusterNameFunc(ctx, req)
94114
}
95-
return f.UnimplementedClusterServiceServer.SuggestClusterName(ctx, req)
115+
return f.SuggestClusterNameCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.SuggestClusterName)
96116
}
97117

98-
// ListQdrantReleases delegates to ListQdrantReleasesFunc if set.
118+
// ListQdrantReleases delegates to ListQdrantReleasesFunc if set, otherwise dispatches via ListQdrantReleasesCalls.
99119
func (f *FakeClusterService) ListQdrantReleases(ctx context.Context, req *clusterv1.ListQdrantReleasesRequest) (*clusterv1.ListQdrantReleasesResponse, error) {
120+
f.ListQdrantReleasesCalls.record(req)
100121
if f.ListQdrantReleasesFunc != nil {
101122
return f.ListQdrantReleasesFunc(ctx, req)
102123
}
103-
return f.UnimplementedClusterServiceServer.ListQdrantReleases(ctx, req)
124+
return f.ListQdrantReleasesCalls.dispatch(ctx, req, f.UnimplementedClusterServiceServer.ListQdrantReleases)
104125
}

internal/testutil/fake_database_api_key.go

Lines changed: 13 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,28 +14,35 @@ type FakeDatabaseApiKeyService struct {
1414
ListDatabaseApiKeysFunc func(context.Context, *clusterauthv2.ListDatabaseApiKeysRequest) (*clusterauthv2.ListDatabaseApiKeysResponse, error)
1515
CreateDatabaseApiKeyFunc func(context.Context, *clusterauthv2.CreateDatabaseApiKeyRequest) (*clusterauthv2.CreateDatabaseApiKeyResponse, error)
1616
DeleteDatabaseApiKeyFunc func(context.Context, *clusterauthv2.DeleteDatabaseApiKeyRequest) (*clusterauthv2.DeleteDatabaseApiKeyResponse, error)
17+
18+
ListDatabaseApiKeysCalls MethodSpy[*clusterauthv2.ListDatabaseApiKeysRequest, *clusterauthv2.ListDatabaseApiKeysResponse]
19+
CreateDatabaseApiKeyCalls MethodSpy[*clusterauthv2.CreateDatabaseApiKeyRequest, *clusterauthv2.CreateDatabaseApiKeyResponse]
20+
DeleteDatabaseApiKeyCalls MethodSpy[*clusterauthv2.DeleteDatabaseApiKeyRequest, *clusterauthv2.DeleteDatabaseApiKeyResponse]
1721
}
1822

19-
// ListDatabaseApiKeys delegates to ListDatabaseApiKeysFunc if set.
23+
// ListDatabaseApiKeys delegates to ListDatabaseApiKeysFunc if set, otherwise dispatches via ListDatabaseApiKeysCalls.
2024
func (f *FakeDatabaseApiKeyService) ListDatabaseApiKeys(ctx context.Context, req *clusterauthv2.ListDatabaseApiKeysRequest) (*clusterauthv2.ListDatabaseApiKeysResponse, error) {
25+
f.ListDatabaseApiKeysCalls.record(req)
2126
if f.ListDatabaseApiKeysFunc != nil {
2227
return f.ListDatabaseApiKeysFunc(ctx, req)
2328
}
24-
return f.UnimplementedDatabaseApiKeyServiceServer.ListDatabaseApiKeys(ctx, req)
29+
return f.ListDatabaseApiKeysCalls.dispatch(ctx, req, f.UnimplementedDatabaseApiKeyServiceServer.ListDatabaseApiKeys)
2530
}
2631

27-
// CreateDatabaseApiKey delegates to CreateDatabaseApiKeyFunc if set.
32+
// CreateDatabaseApiKey delegates to CreateDatabaseApiKeyFunc if set, otherwise dispatches via CreateDatabaseApiKeyCalls.
2833
func (f *FakeDatabaseApiKeyService) CreateDatabaseApiKey(ctx context.Context, req *clusterauthv2.CreateDatabaseApiKeyRequest) (*clusterauthv2.CreateDatabaseApiKeyResponse, error) {
34+
f.CreateDatabaseApiKeyCalls.record(req)
2935
if f.CreateDatabaseApiKeyFunc != nil {
3036
return f.CreateDatabaseApiKeyFunc(ctx, req)
3137
}
32-
return f.UnimplementedDatabaseApiKeyServiceServer.CreateDatabaseApiKey(ctx, req)
38+
return f.CreateDatabaseApiKeyCalls.dispatch(ctx, req, f.UnimplementedDatabaseApiKeyServiceServer.CreateDatabaseApiKey)
3339
}
3440

35-
// DeleteDatabaseApiKey delegates to DeleteDatabaseApiKeyFunc if set.
41+
// DeleteDatabaseApiKey delegates to DeleteDatabaseApiKeyFunc if set, otherwise dispatches via DeleteDatabaseApiKeyCalls.
3642
func (f *FakeDatabaseApiKeyService) DeleteDatabaseApiKey(ctx context.Context, req *clusterauthv2.DeleteDatabaseApiKeyRequest) (*clusterauthv2.DeleteDatabaseApiKeyResponse, error) {
43+
f.DeleteDatabaseApiKeyCalls.record(req)
3744
if f.DeleteDatabaseApiKeyFunc != nil {
3845
return f.DeleteDatabaseApiKeyFunc(ctx, req)
3946
}
40-
return f.UnimplementedDatabaseApiKeyServiceServer.DeleteDatabaseApiKey(ctx, req)
47+
return f.DeleteDatabaseApiKeyCalls.dispatch(ctx, req, f.UnimplementedDatabaseApiKeyServiceServer.DeleteDatabaseApiKey)
4148
}

0 commit comments

Comments
 (0)