bug fix: use StreamId pointer to enable MarshalText

HDT3213 · Apr 16, 2023 · 386a9db · 386a9db
1 parent 82412cd
commit 386a9db
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -353,8 +353,8 @@ Tested on MacBook Pro (16-inch, 2019) 2.6 GHz 6cores Intel Core i7, using  a 1.3
 
 |usage|elapsed|speed|
 |:-:|:-:|:-:|
-|ToJson|144.11s|9.23MB/s|
+|ToJson|74.12s|17.96MB/s|
 |Memory|18.585s|71.62MB/s|
 |AOF|104.77s|12.76MB/s|
 |Top10|14.8s|89.95MB/s|
-|FlameGraph|49.38s|26.96MB/s|
+|FlameGraph|21.83s|60.98MB/s|
diff --git a/README_CN.md b/README_CN.md
@@ -346,8 +346,8 @@ func main() {
 
 |usage|elapsed|speed|
 |:-:|:-:|:-:|
-|ToJson|144.11s|9.23MB/s|
+|ToJson|74.12s|17.96MB/s|
 |Memory|18.585s|71.62MB/s|
 |AOF|104.77s|12.76MB/s|
 |Top10|14.8s|89.95MB/s|
-|FlameGraph|49.38s|26.96MB/s|
+|FlameGraph|21.83s|60.98MB/s|
diff --git a/core/stream.go b/core/stream.go
@@ -166,7 +166,7 @@ func (dec *Decoder) readStreamEntryContent(buf []byte, cursor *int, firstId *mod
 		if err != nil {
 			return nil, fmt.Errorf("read stream item id seq failed: %v", err)
 		}
-		msgId := model.StreamId{
+		msgId := &model.StreamId{
 			Ms:       ms + firstId.Ms,
 			Sequence: seq + firstId.Sequence,
 		}

diff --git a/model/stream.go b/model/stream.go
@@ -37,7 +37,7 @@ type StreamEntry struct {
 
 // StreamMessage is a message item in stream
 type StreamMessage struct {
-	Id      StreamId          `json:"id"`
+	Id      *StreamId         `json:"id"`
 	Fields  map[string]string `json:"fields"`
 	Deleted bool              `json:"deleted"`
 }