use int64 type for offset since uint64 is not supported

centrifugal · Aug 30, 2020 · a5479da · a5479da
1 parent 3d6f0f1
commit a5479da
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/events.go b/events.go
@@ -72,7 +72,7 @@ type ErrorHandler interface {
 // ServerPublishEvent has info about received channel Publication.
 type ServerPublishEvent struct {
 	Channel string
-	Offset  uint64
+	Offset  int64
 	Data    []byte
 	Info    *ClientInfo
 }
@@ -198,7 +198,7 @@ func (p *eventProxy) OnMessage(_ *gocentrifuge.Client, e gocentrifuge.MessageEve
 func (p *eventProxy) OnServerPublish(_ *gocentrifuge.Client, e gocentrifuge.ServerPublishEvent) {
 	event := &ServerPublishEvent{
 		Channel: e.Channel,
-		Offset:  e.Offset,
+		Offset:  int64(e.Offset),
 		Data:    e.Data,
 	}
 	if e.Info != nil {
@@ -350,7 +350,7 @@ type JoinEvent struct {
 
 // PublishEvent has info about received channel Publication.
 type PublishEvent struct {
-	Offset uint64
+	Offset int64
 	Data   []byte
 	Info   *ClientInfo
 }
@@ -400,7 +400,7 @@ type subEventProxy struct {
 
 func (p *subEventProxy) OnPublish(_ *gocentrifuge.Subscription, e gocentrifuge.PublishEvent) {
 	event := &PublishEvent{
-		Offset: e.Offset,
+		Offset: int64(e.Offset),
 		Data:   e.Data,
 	}
 	if e.Info != nil {

diff --git a/subscription.go b/subscription.go
@@ -6,7 +6,7 @@ import (
 
 // Publication ...
 type Publication struct {
-	Offset uint64
+	Offset int64
 	Data   []byte
 	Info   *ClientInfo
 }
@@ -79,7 +79,7 @@ func (d *HistoryData) ItemAt(i int) *Publication {
 		}
 	}
 	return &Publication{
-		Offset: pub.Offset,
+		Offset: int64(pub.Offset),
 		Data:   pub.Data,
 		Info:   info,
 	}