rohit/probo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Modify cursor key to use uuid

Browse Source 
Signed-off-by: gearnode <bryan@frimin.fr>
This commit is contained in:
gearnode
2025-01-22 21:39:11 +01:00
parent 25e97e25b6
commit 94847a8a28
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/probo/coredata/page/cursorkey.go
View File

@@ -20,7 +20,7 @@ var (
) )
const ( const (
byteLength = 28 byteLength = 24
) )
func ParseCursorKey(s string) (CursorKey, error) { func ParseCursorKey(s string) (CursorKey, error) {
@@ -51,8 +51,8 @@ func CursorKeyFromBytes(b []byte) (CursorKey, error) {
func NewCursorKey(id uuid.UUID, t time.Time) CursorKey { func NewCursorKey(id uuid.UUID, t time.Time) CursorKey {
var cursorKey CursorKey var cursorKey CursorKey
copy(cursorKey[:20], id[:]) copy(cursorKey[:16], id[:])
_ = binary.PutVarint(cursorKey[20:], t.UnixMicro()) _ = binary.PutVarint(cursorKey[16:], t.UnixMicro())
return cursorKey return cursorKey
} }
@@ -66,7 +66,12 @@ func (ck CursorKey) String() string {
} }
func (ck CursorKey) Timestamp() time.Time { func (ck CursorKey) Timestamp() time.Time {
return ck.ID().Timestamp() unixMicro, _ := binary.Varint(ck[16:])
seconds := unixMicro / 1e6
nanoseconds := (unixMicro % 1e6) * 1e3
return time.Unix(seconds, nanoseconds)
} }
func (ck CursorKey) ID() uuid.UUID { func (ck CursorKey) ID() uuid.UUID {