v5.0.2-rc-golang

golang/client.go

@@ -28,10 +28,10 @@ import (
 	"sync"
 	"time"
 
-	innerMD "github.com/apache/rocketmq-clients/golang/metadata"
-	"github.com/apache/rocketmq-clients/golang/pkg/ticker"
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	innerMD "github.com/apache/rocketmq-clients/golang/v5/metadata"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/ticker"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"github.com/google/uuid"
 	"go.uber.org/atomic"
 	"go.uber.org/zap"

golang/client_manager.go

@@ -22,9 +22,9 @@ import (
 	"sync"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/ticker"
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/ticker"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
 )

golang/client_manager_mock.go

@@ -22,7 +22,7 @@ import (
 	reflect "reflect"
 	time "time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	gomock "github.com/golang/mock/gomock"
 )
 

golang/client_manager_test.go

@@ -25,7 +25,7 @@ import (
 	"testing"
 	"time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	gomock "github.com/golang/mock/gomock"
 	"github.com/prashantv/gostub"
 	"google.golang.org/grpc/metadata"

golang/client_mock.go

@@ -21,7 +21,7 @@ import (
 	context "context"
 	reflect "reflect"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	gomock "github.com/golang/mock/gomock"
 )
 

golang/client_options.go

@@ -20,7 +20,7 @@ package golang
 import (
 	"time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 )
 
 type clientOptions struct {

golang/client_test.go

@@ -22,7 +22,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/credentials"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
 	gomock "github.com/golang/mock/gomock"
 	"github.com/prashantv/gostub"
 )

golang/config.go

@@ -17,7 +17,7 @@
 
 package golang
 
-import "github.com/apache/rocketmq-clients/golang/credentials"
+import "github.com/apache/rocketmq-clients/golang/v5/credentials"
 
 type Config struct {
 	Endpoint      string `validate:"required"`

golang/conn.go

@@ -22,7 +22,7 @@ import (
 	"errors"
 	"fmt"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/grpc/middleware/zaplog"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/grpc/middleware/zaplog"
 	validator "github.com/go-playground/validator/v10"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials"

golang/conn_options.go

@@ -24,7 +24,7 @@ import (
 	"math"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/zaplog"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/zaplog"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 )

golang/consumer.go

@@ -20,7 +20,7 @@ package golang
 import (
 	"time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 )
 
 type Consumer interface {

golang/error.go

@@ -21,7 +21,7 @@ import (
 	"errors"
 	"fmt"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 )
 
 type ErrRpcStatus struct {

golang/example/consumer/simple_consumer/main.go

@@ -24,8 +24,8 @@ import (
 	"os"
 	"time"
 
-	rmq_client "github.com/apache/rocketmq-clients/golang"
-	"github.com/apache/rocketmq-clients/golang/credentials"
+	rmq_client "github.com/apache/rocketmq-clients/golang/v5"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
 )
 
 const (

golang/example/producer/async/main.go

@@ -25,8 +25,8 @@ import (
 	"strconv"
 	"time"
 
-	rmq_client "github.com/apache/rocketmq-clients/golang"
-	"github.com/apache/rocketmq-clients/golang/credentials"
+	rmq_client "github.com/apache/rocketmq-clients/golang/v5"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
 )
 
 const (

golang/example/producer/delay/main.go

@@ -25,8 +25,8 @@ import (
 	"strconv"
 	"time"
 
-	rmq_client "github.com/apache/rocketmq-clients/golang"
-	"github.com/apache/rocketmq-clients/golang/credentials"
+	rmq_client "github.com/apache/rocketmq-clients/golang/v5"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
 )
 
 const (

golang/example/producer/fifo/main.go

@@ -25,8 +25,8 @@ import (
 	"strconv"
 	"time"
 
-	rmq_client "github.com/apache/rocketmq-clients/golang"
-	"github.com/apache/rocketmq-clients/golang/credentials"
+	rmq_client "github.com/apache/rocketmq-clients/golang/v5"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
 )
 
 const (

golang/example/producer/normal/main.go

@@ -25,8 +25,8 @@ import (
 	"strconv"
 	"time"
 
-	rmq_client "github.com/apache/rocketmq-clients/golang"
-	"github.com/apache/rocketmq-clients/golang/credentials"
+	rmq_client "github.com/apache/rocketmq-clients/golang/v5"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
 )
 
 const (

golang/example/producer/transaction/main.go

@@ -25,8 +25,8 @@ import (
 	"strconv"
 	"time"
 
-	rmq_client "github.com/apache/rocketmq-clients/golang"
-	"github.com/apache/rocketmq-clients/golang/credentials"
+	rmq_client "github.com/apache/rocketmq-clients/golang/v5"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
 )
 
 const (

golang/go.mod

@@ -1,4 +1,4 @@
-module github.com/apache/rocketmq-clients/golang
+module github.com/apache/rocketmq-clients/golang/v5
 
 go 1.17
 

golang/loadBalancer.go

@@ -22,8 +22,8 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"github.com/dchest/siphash"
 	// "github.com/dchest/siphash"
 )

golang/log.go

@@ -23,7 +23,7 @@ import (
 	"strconv"
 	"strings"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
 	"github.com/natefinch/lumberjack"
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"

golang/message.go

@@ -25,8 +25,8 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"google.golang.org/protobuf/types/known/timestamppb"
 )
 

golang/message_id_codec.go

@@ -27,10 +27,11 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
 )
 
-/**
+/*
+*
 The codec for the message-id.
 
 Codec here provides the following two functions:
@@ -44,26 +45,26 @@ number. For V1, these two bytes are 0x0001.
 
 V1 message id example
 
-  ┌──┬────────────┬────┬────────┬────────┐
-  │01│56F7E71C361B│21BC│024CCDBE│00000000│
-  └──┴────────────┴────┴────────┴────────┘
-
+	┌──┬────────────┬────┬────────┬────────┐
+	│01│56F7E71C361B│21BC│024CCDBE│00000000│
+	└──┴────────────┴────┴────────┴────────┘
 
 V1 version message id generation rules
 
-                    process id(lower 2bytes)
-                            ▲
+	process id(lower 2bytes)
+	        ▲
+
 mac address(lower 6bytes)   │   sequence number(big endian)
-                   ▲        │          ▲ (4bytes)
-                   │        │          │
-             ┌─────┴─────┐ ┌┴┐ ┌───┐ ┌─┴─┐
-      0x01+  │     6     │ │2│ │ 4 │ │ 4 │
-             └───────────┘ └─┘ └─┬─┘ └───┘
-                                 │
-                                 ▼
-          seconds since 2021-01-01 00:00:00(UTC+0)
-                        (lower 4bytes)
 
+	             ▲        │          ▲ (4bytes)
+	             │        │          │
+	       ┌─────┴─────┐ ┌┴┐ ┌───┐ ┌─┴─┐
+	0x01+  │     6     │ │2│ │ 4 │ │ 4 │
+	       └───────────┘ └─┘ └─┬─┘ └───┘
+	                           │
+	                           ▼
+	    seconds since 2021-01-01 00:00:00(UTC+0)
+	                  (lower 4bytes)
 */
 type MessageIdCodec interface {
 	NextMessageId() MessageId

golang/metric.go

@@ -23,8 +23,8 @@ import (
 	"time"
 
 	"contrib.go.opencensus.io/exporter/ocagent"
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"go.opencensus.io/stats"
 	"go.opencensus.io/stats/view"
 	"go.opencensus.io/tag"

golang/pkg/grpc/middleware/zaplog/zaplog.go

@@ -21,7 +21,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/zaplog/ctxzap"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/zaplog/ctxzap"
 
 	"go.uber.org/zap"
 	"google.golang.org/grpc"

golang/pkg/utils/utils.go

@@ -33,8 +33,8 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/metadata"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/metadata"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"github.com/valyala/fastrand"
 	"go.opencensus.io/trace"
 	MD "google.golang.org/grpc/metadata"

golang/pkg/utils/utils_test.go

@@ -21,7 +21,7 @@ import (
 	"compress/gzip"
 	"testing"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 )
 
 func TestMod(t *testing.T) {

golang/producer.go

@@ -24,8 +24,8 @@ import (
 	"sync"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"google.golang.org/protobuf/types/known/durationpb"
 )
 

golang/producer_options.go

@@ -22,7 +22,7 @@ import (
 	"sync"
 	"time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"google.golang.org/protobuf/types/known/durationpb"
 )
 

golang/producer_test.go

@@ -23,8 +23,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/credentials"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/credentials"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	gomock "github.com/golang/mock/gomock"
 	"github.com/prashantv/gostub"
 )

golang/publishing_message.go

@@ -20,8 +20,8 @@ package golang
 import (
 	"fmt"
 
-	innerOS "github.com/apache/rocketmq-clients/golang/pkg/os"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	innerOS "github.com/apache/rocketmq-clients/golang/v5/pkg/os"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"google.golang.org/protobuf/types/known/timestamppb"
 )
 

golang/rpc_client.go

@@ -25,7 +25,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	// "google.golang.org/protobuf/types/known/durationpb"
 )
 

golang/rpc_client_mock.go

@@ -22,7 +22,7 @@ import (
 	reflect "reflect"
 	time "time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	gomock "github.com/golang/mock/gomock"
 )
 

golang/simple_consumer.go

@@ -25,8 +25,8 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/apache/rocketmq-clients/golang/pkg/utils"
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"google.golang.org/protobuf/types/known/durationpb"
 	"google.golang.org/protobuf/types/known/timestamppb"
 )

golang/simple_consumer_options.go

@@ -21,7 +21,7 @@ import (
 	"fmt"
 	"time"
 
-	v2 "github.com/apache/rocketmq-clients/golang/protocol/v2"
+	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
 	"google.golang.org/protobuf/types/known/durationpb"
 )