diff --git a/_examples/go.sum b/_examples/go.sum index 2881d14c..73b95a25 100644 --- a/_examples/go.sum +++ b/_examples/go.sum @@ -19,8 +19,8 @@ github.com/boj/redistore v0.0.0-20180917114910-cd5dcc76aeff/go.mod h1:+RTT1BOk5P github.com/bradfitz/gomemcache v0.0.0-20190329173943-551aad21a668/go.mod h1:H0wQNHz2YrLsuXOZozoeDmnHXkNCRmMW0gwFWDfEZDA= github.com/bradleypeabody/gorilla-sessions-memcache v0.0.0-20181103040241-659414f458e1/go.mod h1:dkChI7Tbtx7H1Tj7TqGSZMOeGpMP5gLHtjroHd4agiI= github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= -github.com/centrifugal/protocol v0.3.3 h1:GCNee3RFsjQu6SyKBX0Ir7ByUrp+Gw0MU/PsIc2CM2s= -github.com/centrifugal/protocol v0.3.3/go.mod h1:2YbBCaDwQHl37ErRdMrKSj18X2yVvpkQYtSX6aVbe5A= +github.com/centrifugal/protocol v0.3.4 h1:9q22iSp4CQOdQahfopvfmWWxDbj1Lo7ERG2j56mAxkE= +github.com/centrifugal/protocol v0.3.4/go.mod h1:2YbBCaDwQHl37ErRdMrKSj18X2yVvpkQYtSX6aVbe5A= github.com/cespare/xxhash/v2 v2.1.1 h1:6MnRN8NT7+YBpUIWxHtefFZOKTAPgGjpQSxqLNn0+qY= github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw= diff --git a/client.go b/client.go index ef035196..59b04191 100644 --- a/client.go +++ b/client.go @@ -1207,6 +1207,8 @@ func (c *Client) connectCmd(cmd *protocol.ConnectRequest, rw *replyWriter) *Disc ClientID: c.ID(), Data: cmd.Data, Token: cmd.Token, + Name: cmd.Name, + Version: cmd.Version, Transport: c.transport, }) if err != nil { diff --git a/engine.go b/engine.go index fb16ec2a..7d195a66 100644 --- a/engine.go +++ b/engine.go @@ -8,6 +8,7 @@ import ( // Publication is a data sent to channel. type Publication struct { // Offset is an incremental position number inside history stream. + // Zero value means that channel does not maintain Publication stream. Offset uint64 // Data published to channel. Data []byte diff --git a/events.go b/events.go index c57f4580..2427dccd 100644 --- a/events.go +++ b/events.go @@ -12,6 +12,10 @@ type ConnectEvent struct { Token string // Data received from client as part of Connect Command. Data []byte + // Name can contain client name if provided on connect. + Name string + // Version can contain client version if provided on connect. + Version string // Transport contains information about transport used by client. Transport TransportInfo } diff --git a/go.mod b/go.mod index 289d16f2..cd93be47 100644 --- a/go.mod +++ b/go.mod @@ -5,7 +5,7 @@ go 1.12 require ( github.com/FZambia/eagle v0.0.1 github.com/FZambia/sentinel v1.1.0 - github.com/centrifugal/protocol v0.3.3 + github.com/centrifugal/protocol v0.3.4 github.com/gogo/protobuf v1.3.1 github.com/gomodule/redigo v1.8.2 github.com/google/uuid v1.1.1 diff --git a/go.sum b/go.sum index 4bfa98dc..ef8c05c5 100644 --- a/go.sum +++ b/go.sum @@ -11,8 +11,8 @@ github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24 github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8= github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM= github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw= -github.com/centrifugal/protocol v0.3.3 h1:GCNee3RFsjQu6SyKBX0Ir7ByUrp+Gw0MU/PsIc2CM2s= -github.com/centrifugal/protocol v0.3.3/go.mod h1:2YbBCaDwQHl37ErRdMrKSj18X2yVvpkQYtSX6aVbe5A= +github.com/centrifugal/protocol v0.3.4 h1:9q22iSp4CQOdQahfopvfmWWxDbj1Lo7ERG2j56mAxkE= +github.com/centrifugal/protocol v0.3.4/go.mod h1:2YbBCaDwQHl37ErRdMrKSj18X2yVvpkQYtSX6aVbe5A= github.com/cespare/xxhash/v2 v2.1.1 h1:6MnRN8NT7+YBpUIWxHtefFZOKTAPgGjpQSxqLNn0+qY= github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=