morpc: use uint64 as the ID of the message to avoid mem allocation (#3539)
* morpc: use uint64 as the ID of the message * Fix DATA RACE * Refector logservice morpc
Showing
- go.mod 1 addition, 1 deletiongo.mod
- go.sum 2 additions, 2 deletionsgo.sum
- pkg/common/morpc/backend.go 27 additions, 22 deletionspkg/common/morpc/backend.go
- pkg/common/morpc/backend_test.go 20 additions, 14 deletionspkg/common/morpc/backend_test.go
- pkg/common/morpc/codec_test.go 2 additions, 2 deletionspkg/common/morpc/codec_test.go
- pkg/common/morpc/examples/message/message.go 13 additions, 22 deletionspkg/common/morpc/examples/message/message.go
- pkg/common/morpc/examples/message/message_test.go 1 addition, 1 deletionpkg/common/morpc/examples/message/message_test.go
- pkg/common/morpc/examples/pingpong/main.go 1 addition, 1 deletionpkg/common/morpc/examples/pingpong/main.go
- pkg/common/morpc/examples/stream/main.go 1 addition, 1 deletionpkg/common/morpc/examples/stream/main.go
- pkg/common/morpc/future.go 4 additions, 5 deletionspkg/common/morpc/future.go
- pkg/common/morpc/future_test.go 7 additions, 7 deletionspkg/common/morpc/future_test.go
- pkg/common/morpc/server.go 11 additions, 8 deletionspkg/common/morpc/server.go
- pkg/common/morpc/server_test.go 3 additions, 3 deletionspkg/common/morpc/server_test.go
- pkg/common/morpc/types.go 6 additions, 4 deletionspkg/common/morpc/types.go
- pkg/logservice/service.go 13 additions, 4 deletionspkg/logservice/service.go
- pkg/pb/logservice/logservice.pb.go 178 additions, 106 deletionspkg/pb/logservice/logservice.pb.go
- pkg/pb/metadata/metadata.pb.go 3 additions, 2 deletionspkg/pb/metadata/metadata.pb.go
- pkg/pb/metric/metric.pb.go 2 additions, 1 deletionpkg/pb/metric/metric.pb.go
- pkg/pb/plan/plan.pb.go 3 additions, 2 deletionspkg/pb/plan/plan.pb.go
- pkg/pb/timestamp/timestamp.pb.go 2 additions, 1 deletionpkg/pb/timestamp/timestamp.pb.go
Please register or sign in to comment