enhance: rename log as streaming

Signed-off-by: chyezh <chyezh@outlook.com>

Makefile

@@ -511,8 +511,8 @@ generate-mockery-chunk-manager: getdeps
 generate-mockery-pkg:
 	$(MAKE) -C pkg generate-mockery
 
-generate-mockery-log:
-	$(INSTALL_PATH)/mockery --config $(PWD)/internal/logservice/.mockery.yaml
+generate-mockery-streaming:
+	$(INSTALL_PATH)/mockery --config $(PWD)/internal/streamingservice/.mockery.yaml
 
 generate-mockery: generate-mockery-types generate-mockery-kv generate-mockery-rootcoord generate-mockery-proxy generate-mockery-querycoord generate-mockery-querynode generate-mockery-datacoord generate-mockery-pkg generate-mockery-log
 

internal/proto/log.proto → internal/proto/streaming.proto

@@ -2,7 +2,7 @@ syntax = "proto3";
 
 package milvus.proto.log;
 
-option go_package = "github.com/milvus-io/milvus/internal/proto/logpb";
+option go_package = "github.com/milvus-io/milvus/internal/proto/streamingpb";
 
 import "milvus.proto";
 import "google/protobuf/empty.proto";
@@ -25,7 +25,7 @@ message Message {
 // PChannelInfo is the information of a pchannel info.
 message PChannelInfo {
     string name = 1; // channel name
-    int64 term = 2; // A monotonic increasing term, every time the channel is recovered or moved to another lognode, the term will increase by meta server.
+    int64 term = 2; // A monotonic increasing term, every time the channel is recovered or moved to another streamingnode, the term will increase by meta server.
     int64 serverID = 3; // The log node id address of the channel.
     repeated VChannelInfo vChannelInfos = 4; // PChannel related vchannels.
 }

internal/proto/logpb/extends.go → internal/proto/streamingpb/extends.go

@@ -1,4 +1,4 @@
-package logpb
+package streamingpb
 
 import (
 	"google.golang.org/protobuf/types/known/emptypb"

internal/lognode/server/wal/RAEDME.md → internal/streamingnode/server/wal/RAEDME.md

@@ -1,6 +1,6 @@
 # WAL
 
-`wal` package is the basic defination of wal interface of milvus lognode.
+`wal` package is the basic defination of wal interface of milvus streamingnode.
 
 ## Project arrangement
 
@@ -41,7 +41,7 @@ All things have been done.
 
 ```
 name := "your builder name"
-var yourCh *logpb.PChannelInfo
+var yourCh *streamingpb.PChannelInfo
 
 opener, err := registry.MustGetBuilder(name).Build()
 if err != nil {

internal/lognode/server/wal/adaptor/builder.go → internal/streamingnode/server/wal/adaptor/builder.go

@@ -1,8 +1,8 @@
 package adaptor
 
 import (
-	"github.com/milvus-io/milvus/internal/lognode/server/wal"
-	"github.com/milvus-io/milvus/internal/lognode/server/wal/walimpls"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal/walimpls"
 )
 
 var _ wal.OpenerBuilder = (*builderAdaptorImpl)(nil)

internal/lognode/server/wal/builder.go → internal/streamingnode/server/wal/builder.go

@@ -3,8 +3,8 @@ package wal
 import (
 	"context"
 
-	"github.com/milvus-io/milvus/internal/lognode/server/wal/walimpls"
-	"github.com/milvus-io/milvus/internal/proto/logpb"
+	"github.com/milvus-io/milvus/internal/proto/streamingpb"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal/walimpls"
 )
 
 // OpenerBuilder is the interface for build wal opener.
@@ -17,7 +17,7 @@ type OpenerBuilder interface {
 
 // OpenOption is the option for allocating wal instance.
 type OpenOption struct {
-	Channel             *logpb.PChannelInfo
+	Channel             *streamingpb.PChannelInfo
 	InterceptorBuilders []walimpls.InterceptorBuilder // Interceptor builders to build when open.
 }
 

internal/lognode/server/wal/helper/wal_helper.go → internal/streamingnode/server/wal/helper/wal_helper.go

@@ -3,8 +3,8 @@ package helper
 import (
 	"go.uber.org/zap"
 
-	"github.com/milvus-io/milvus/internal/lognode/server/wal/walimpls"
-	"github.com/milvus-io/milvus/internal/proto/logpb"
+	"github.com/milvus-io/milvus/internal/proto/streamingpb"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal/walimpls"
 	"github.com/milvus-io/milvus/pkg/log"
 )
 
@@ -19,11 +19,11 @@ func NewWALHelper(opt *walimpls.OpenOption) *WALHelper {
 // WALHelper is a helper for WAL implementation.
 type WALHelper struct {
 	logger  *log.MLogger
-	channel *logpb.PChannelInfo
+	channel *streamingpb.PChannelInfo
 }
 
 // Channel returns the channel of the WAL.
-func (w *WALHelper) Channel() *logpb.PChannelInfo {
+func (w *WALHelper) Channel() *streamingpb.PChannelInfo {
 	return w.channel
 }
 

internal/lognode/server/wal/helper/wal_helper_test.go → internal/streamingnode/server/wal/helper/wal_helper_test.go

@@ -5,17 +5,17 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	"github.com/milvus-io/milvus/internal/lognode/server/wal/walimpls"
-	"github.com/milvus-io/milvus/internal/proto/logpb"
+	"github.com/milvus-io/milvus/internal/proto/streamingpb"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal/walimpls"
 )
 
 func TestWALHelper(t *testing.T) {
 	h := NewWALHelper(&walimpls.OpenOption{
-		Channel: &logpb.PChannelInfo{
+		Channel: &streamingpb.PChannelInfo{
 			Name:          "test",
 			Term:          1,
 			ServerID:      1,
-			VChannelInfos: []*logpb.VChannelInfo{},
+			VChannelInfos: []*streamingpb.VChannelInfo{},
 		},
 	})
 	assert.NotNil(t, h.Channel())

internal/lognode/server/wal/registry/registry.go → internal/streamingnode/server/wal/registry/registry.go

@@ -1,9 +1,9 @@
 package registry
 
 import (
-	"github.com/milvus-io/milvus/internal/lognode/server/wal"
-	"github.com/milvus-io/milvus/internal/lognode/server/wal/adaptor"
-	"github.com/milvus-io/milvus/internal/lognode/server/wal/walimpls"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal/adaptor"
+	"github.com/milvus-io/milvus/internal/streamingnode/server/wal/walimpls"
 	"github.com/milvus-io/milvus/pkg/util/typeutil"
 )
 

internal/lognode/server/wal/registry/wal_test.go → internal/streamingnode/server/wal/registry/wal_test.go

@@ -7,7 +7,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	"github.com/milvus-io/milvus/internal/mocks/lognode/server/wal/mock_walimpls"
+	"github.com/milvus-io/milvus/internal/mocks/streamingnode/server/wal/mock_walimpls"
 )
 
 func TestRegister(t *testing.T) {

internal/lognode/server/wal/scanner.go → internal/streamingnode/server/wal/scanner.go

@@ -1,8 +1,8 @@
 package wal
 
 import (
-	"github.com/milvus-io/milvus/internal/util/logserviceutil/message"
-	"github.com/milvus-io/milvus/internal/util/logserviceutil/options"
+	"github.com/milvus-io/milvus/internal/util/streamingutil/message"
+	"github.com/milvus-io/milvus/internal/util/streamingutil/options"
 )
 
 // ReadOption is the option for reading records from the wal.

internal/lognode/server/wal/wal.go → internal/streamingnode/server/wal/wal.go

@@ -3,16 +3,16 @@ package wal
 import (
 	"context"
 
-	"github.com/milvus-io/milvus/internal/proto/logpb"
-	"github.com/milvus-io/milvus/internal/util/logserviceutil/message"
+	"github.com/milvus-io/milvus/internal/proto/streamingpb"
+	"github.com/milvus-io/milvus/internal/util/streamingutil/message"
 )
 
 // WAL is the WAL framework interface.
 // !!! Don't implement it directly, implement walimpls.WAL instead.
 type WAL interface {
 	// Channel returns the channel assignment info of the wal.
 	// Should be read-only.
-	Channel() *logpb.PChannelInfo
+	Channel() *streamingpb.PChannelInfo
 
 	// Append writes a record to the log.
 	Append(ctx context.Context, msg message.MutableMessage) (message.MessageID, error)