fix: wrong streaming mockery package name (#39261)

issue: #39095 pr: #39260 Signed-off-by: chyezh <[email protected]>
milvus-io · Jan 15, 2025 · 74246d8 · 74246d8
1 parent 4c91e05
commit 74246d8
Show file tree

Hide file tree

Showing 17 changed files with 8 additions and 8 deletions.
diff --git a/internal/streamingcoord/client/assignment/assignment_test.go b/internal/streamingcoord/client/assignment/assignment_test.go
@@ -12,7 +12,7 @@ import (
 
 	"github.com/milvus-io/milvus/internal/mocks/util/streamingutil/service/mock_lazygrpc"
 	"github.com/milvus-io/milvus/internal/util/streamingutil/status"
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/types"
 	"github.com/milvus-io/milvus/pkg/util/typeutil"

diff --git a/internal/streamingcoord/server/service/discover/discover_server_test.go b/internal/streamingcoord/server/service/discover/discover_server_test.go
@@ -9,7 +9,7 @@ import (
 
 	"github.com/milvus-io/milvus/internal/mocks/streamingcoord/server/mock_balancer"
 	"github.com/milvus-io/milvus/internal/streamingcoord/server/resource"
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/types"
 	"github.com/milvus-io/milvus/pkg/util/typeutil"

diff --git a/internal/streamingnode/client/handler/consumer/consumer_test.go b/internal/streamingnode/client/handler/consumer/consumer_test.go
@@ -10,7 +10,7 @@ import (
 	"github.com/stretchr/testify/mock"
 
 	"github.com/milvus-io/milvus-proto/go-api/v2/msgpb"
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/proto/messagespb"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/message"

diff --git a/internal/streamingnode/client/handler/handler_client_test.go b/internal/streamingnode/client/handler/handler_client_test.go
@@ -16,7 +16,7 @@ import (
 	"github.com/milvus-io/milvus/internal/streamingnode/client/handler/consumer"
 	"github.com/milvus-io/milvus/internal/streamingnode/client/handler/producer"
 	"github.com/milvus-io/milvus/internal/util/streamingutil/status"
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/mocks/streaming/util/mock_types"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/message"

diff --git a/internal/streamingnode/client/handler/producer/producer_test.go b/internal/streamingnode/client/handler/producer/producer_test.go
@@ -9,7 +9,7 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/proto/messagespb"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/message"

diff --git a/internal/streamingnode/client/manager/manager_test.go b/internal/streamingnode/client/manager/manager_test.go
@@ -17,7 +17,7 @@ import (
 	"github.com/milvus-io/milvus/internal/util/streamingutil/service/attributes"
 	"github.com/milvus-io/milvus/internal/util/streamingutil/service/contextutil"
 	"github.com/milvus-io/milvus/internal/util/streamingutil/service/discoverer"
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/types"
 	"github.com/milvus-io/milvus/pkg/util/etcd"

diff --git a/internal/streamingnode/server/service/handler/consumer/consume_server_test.go b/internal/streamingnode/server/service/handler/consumer/consume_server_test.go
@@ -17,7 +17,7 @@ import (
 	"github.com/milvus-io/milvus/internal/util/streamingutil/service/contextutil"
 	"github.com/milvus-io/milvus/internal/util/streamingutil/status"
 	"github.com/milvus-io/milvus/pkg/log"
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/mocks/streaming/util/mock_message"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/message"

diff --git a/internal/streamingnode/server/service/handler/producer/produce_server_test.go b/internal/streamingnode/server/service/handler/producer/produce_server_test.go
@@ -20,7 +20,7 @@ import (
 	"github.com/milvus-io/milvus/internal/streamingnode/server/walmanager"
 	"github.com/milvus-io/milvus/internal/util/streamingutil/service/contextutil"
 	"github.com/milvus-io/milvus/pkg/log"
-	"github.com/milvus-io/milvus/pkg/mocks/streaming/proto/mock_streamingpb"
+	"github.com/milvus-io/milvus/pkg/mocks/proto/mock_streamingpb"
 	"github.com/milvus-io/milvus/pkg/proto/messagespb"
 	"github.com/milvus-io/milvus/pkg/proto/streamingpb"
 	"github.com/milvus-io/milvus/pkg/streaming/util/message"

diff --git a/..._StreamingCoordAssignmentServiceClient.go → ..._StreamingCoordAssignmentServiceClient.go b/..._StreamingCoordAssignmentServiceClient.go → ..._StreamingCoordAssignmentServiceClient.go
diff --git a/...gnmentService_AssignmentDiscoverClient.go → ...gnmentService_AssignmentDiscoverClient.go b/...gnmentService_AssignmentDiscoverClient.go → ...gnmentService_AssignmentDiscoverClient.go
diff --git a/...gnmentService_AssignmentDiscoverServer.go → ...gnmentService_AssignmentDiscoverServer.go b/...gnmentService_AssignmentDiscoverServer.go → ...gnmentService_AssignmentDiscoverServer.go
diff --git a/...mock_StreamingNodeHandlerServiceClient.go → ...mock_StreamingNodeHandlerServiceClient.go b/...mock_StreamingNodeHandlerServiceClient.go → ...mock_StreamingNodeHandlerServiceClient.go
diff --git a/...eamingNodeHandlerService_ConsumeClient.go → ...eamingNodeHandlerService_ConsumeClient.go b/...eamingNodeHandlerService_ConsumeClient.go → ...eamingNodeHandlerService_ConsumeClient.go
diff --git a/...eamingNodeHandlerService_ConsumeServer.go → ...eamingNodeHandlerService_ConsumeServer.go b/...eamingNodeHandlerService_ConsumeServer.go → ...eamingNodeHandlerService_ConsumeServer.go
diff --git a/...eamingNodeHandlerService_ProduceClient.go → ...eamingNodeHandlerService_ProduceClient.go b/...eamingNodeHandlerService_ProduceClient.go → ...eamingNodeHandlerService_ProduceClient.go
diff --git a/...eamingNodeHandlerService_ProduceServer.go → ...eamingNodeHandlerService_ProduceServer.go b/...eamingNodeHandlerService_ProduceServer.go → ...eamingNodeHandlerService_ProduceServer.go
diff --git a/...mock_StreamingNodeManagerServiceClient.go → ...mock_StreamingNodeManagerServiceClient.go b/...mock_StreamingNodeManagerServiceClient.go → ...mock_StreamingNodeManagerServiceClient.go