Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
What's new
10
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
p2p
go-p2p-pubsub
Commits
0827f5e9
Commit
0827f5e9
authored
Oct 04, 2018
by
Kevin Atkinson
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
gx publish 0.9.31
parent
1abb0209
Changes
10
Hide whitespace changes
Inline
Side-by-side
Showing
10 changed files
with
28 additions
and
28 deletions
+28
-28
.gx/lastpubver
.gx/lastpubver
+1
-1
comm.go
comm.go
+3
-3
floodsub.go
floodsub.go
+3
-3
floodsub_test.go
floodsub_test.go
+5
-5
gossipsub.go
gossipsub.go
+3
-3
gossipsub_test.go
gossipsub_test.go
+1
-1
notify.go
notify.go
+2
-2
package.json
package.json
+3
-3
pb/rpc.pb.go
pb/rpc.pb.go
+1
-1
pubsub.go
pubsub.go
+6
-6
No files found.
.gx/lastpubver
View file @
0827f5e9
0.9.3
0
: Qm
ch44z24hut8iN2snohMNLiX63E3QfZLMQKoe14iZ3FhQ
0.9.3
1
: Qm
UK4h113Hh7bR2gPpsMcbUEbbzc7hspocmPi91Bmi69nH
comm.go
View file @
0827f5e9
...
...
@@ -7,9 +7,9 @@ import (
pb
"github.com/libp2p/go-floodsub/pb"
inet
"gx/ipfs/QmQdLcvoy3JuSqhV6iwQ9T6Cv7hWLAdzob4jUZRPqFL67Z/go-libp2p-net
"
ggio
"gx/ipfs/QmdxUuburamoF6zF9qjeQC4WYcWGbWuRmdLacMEsW8ioD8
/gogo
-
protobuf/
i
o"
proto
"gx/ipfs/QmdxUuburamoF6zF9qjeQC4WYcWGbWuRmdLacMEsW8ioD8/gogo-protobuf/proto
"
ggio
"github.com/gogo/protobuf/io
"
proto
"github.com
/gogo
/
protobuf/
prot
o"
inet
"github.com/libp2p/go-libp2p-net
"
)
// get the initial RPC containing all of our subscriptions to send to new peers
...
...
floodsub.go
View file @
0827f5e9
...
...
@@ -5,9 +5,9 @@ import (
pb
"github.com/libp2p/go-floodsub/pb"
host
"g
x/ipfs/QmX9pw5dSUZ2FozbppcSDJiS7eEh1RFwJNwrbmyLoUMS9x
/go-libp2p-host"
p
rotocol
"gx/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN
/go-libp2p-p
rotocol
"
p
eer
"gx/ipfs/QmbNepETomvmXfz1X5pHNFD2QuPqnqi47dTd94QJWSorQ3
/go-libp2p-p
eer
"
host
"g
ithub.com/libp2p
/go-libp2p-host"
p
eer
"github.com/libp2p
/go-libp2p-p
eer
"
p
rotocol
"github.com/libp2p
/go-libp2p-p
rotocol
"
)
const
(
...
...
floodsub_test.go
View file @
0827f5e9
...
...
@@ -10,12 +10,12 @@ import (
"testing"
"time"
host
"g
x/ipfs/QmX9pw5dSUZ2FozbppcSDJiS7eEh1RFwJNwrbmyLoUMS9x
/go-libp2p-host"
peer
"g
x/ipfs/QmbNepETomvmXfz1X5pHNFD2QuPqnqi47dTd94QJWSorQ3
/go-libp2p-peer"
swarmt
"g
x/ipfs/QmcyQj1V6Ht8uSrRqj865UXGUo5Sc8GxNA4U8bLQxCSmfX
/go-libp2p-swarm/testing"
host
"g
ithub.com/libp2p
/go-libp2p-host"
peer
"g
ithub.com/libp2p
/go-libp2p-peer"
swarmt
"g
ithub.com/libp2p
/go-libp2p-swarm/testing"
//bhost "github.com/libp2p/go-libp2p/p2p/host/basic"
bhost
"g
x/ipfs/QmSG4P432Eomm1s8rkgUuBk9Nzp8YjY35RUcJTGT2Huwki
/go-libp2p-blankhost"
"g
x/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN
/go-libp2p-protocol"
bhost
"g
ithub.com/libp2p
/go-libp2p-blankhost"
"g
ithub.com/libp2p
/go-libp2p-protocol"
)
func
checkMessageRouting
(
t
*
testing
.
T
,
topic
string
,
pubs
[]
*
PubSub
,
subs
[]
*
Subscription
)
{
...
...
gossipsub.go
View file @
0827f5e9
...
...
@@ -7,9 +7,9 @@ import (
pb
"github.com/libp2p/go-floodsub/pb"
host
"g
x/ipfs/QmX9pw5dSUZ2FozbppcSDJiS7eEh1RFwJNwrbmyLoUMS9x
/go-libp2p-host"
p
rotocol
"gx/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN
/go-libp2p-p
rotocol
"
p
eer
"gx/ipfs/QmbNepETomvmXfz1X5pHNFD2QuPqnqi47dTd94QJWSorQ3
/go-libp2p-p
eer
"
host
"g
ithub.com/libp2p
/go-libp2p-host"
p
eer
"github.com/libp2p
/go-libp2p-p
eer
"
p
rotocol
"github.com/libp2p
/go-libp2p-p
rotocol
"
)
const
(
...
...
gossipsub_test.go
View file @
0827f5e9
...
...
@@ -8,7 +8,7 @@ import (
"testing"
"time"
host
"g
x/ipfs/QmX9pw5dSUZ2FozbppcSDJiS7eEh1RFwJNwrbmyLoUMS9x
/go-libp2p-host"
host
"g
ithub.com/libp2p
/go-libp2p-host"
)
func
getGossipsubs
(
ctx
context
.
Context
,
hs
[]
host
.
Host
,
opts
...
Option
)
[]
*
PubSub
{
...
...
notify.go
View file @
0827f5e9
package
floodsub
import
(
inet
"g
x/ipfs/QmQdLcvoy3JuSqhV6iwQ9T6Cv7hWLAdzob4jUZRPqFL67Z
/go-libp2p-net"
ma
"g
x/ipfs/QmYmsdtJ3HsodkePE3eU3TsCaP2YvPZJ4LoXnNkDE5Tpt7
/go-multiaddr"
inet
"g
ithub.com/libp2p
/go-libp2p-net"
ma
"g
ithub.com/multiformats
/go-multiaddr"
)
var
_
inet
.
Notifiee
=
(
*
PubSubNotif
)(
nil
)
...
...
package.json
View file @
0827f5e9
...
...
@@ -56,9 +56,9 @@
},
{
"author"
:
"whyrusleeping"
,
"hash"
:
"Qmc
yQj1V6Ht8uSrRqj865UXGUo5Sc8GxNA4U8bLQxCSmfX
"
,
"hash"
:
"Qmc
ALnLPFXgLLaZkXzGv99yt8xPfiWqFTumiXpWBJbU9cY
"
,
"name"
:
"go-libp2p-swarm"
,
"version"
:
"3.0.1
4
"
"version"
:
"3.0.1
5
"
},
{
"author"
:
"whyrusleeping"
,
...
...
@@ -72,6 +72,6 @@
"license"
:
""
,
"name"
:
"go-libp2p-floodsub"
,
"releaseCmd"
:
"git commit -a -m
\"
gx publish $VERSION
\"
"
,
"version"
:
"0.9.3
0
"
"version"
:
"0.9.3
1
"
}
pb/rpc.pb.go
View file @
0827f5e9
...
...
@@ -3,7 +3,7 @@
package floodsub_pb
import proto "g
x/ipfs/QmdxUuburamoF6zF9qjeQC4WYcWGbWuRmdLacMEsW8ioD8
/gogo
-
protobuf/proto"
import proto "g
ithub.com
/gogo
/
protobuf/proto"
import fmt "fmt"
import math "math"
...
...
pubsub.go
View file @
0827f5e9
...
...
@@ -10,12 +10,12 @@ import (
pb
"github.com/libp2p/go-floodsub/pb"
inet
"gx/ipfs/QmQdLcvoy3JuSqhV6iwQ9T6Cv7hWLAdzob4jUZRPqFL67Z/go-libp2p-net
"
host
"g
x/ipfs/QmX9pw5dSUZ2FozbppcSDJiS7eEh1RFwJNwrbmyLoUMS9x
/go-libp2p-host"
timecache
"gx/ipfs/QmYftoT56eEfUBTD3erR6heXuPSUhGRezSmhSU8LeczP8b/timecache
"
logging
"gx/ipfs/QmZChCsSt8DctjceaL56Eibc29CVQq4dGKRXC5JRZ6Ppae/go-log
"
protocol
"g
x/ipfs/QmZNkThpqfVXs9GNbexPrfBbXSLNYeKrE7jwFM2oqHbyqN
/go-libp2p-protocol"
peer
"gx/ipfs/QmbNepETomvmXfz1X5pHNFD2QuPqnqi47dTd94QJWSorQ3/go-libp2p-peer
"
logging
"github.com/ipfs/go-log
"
host
"g
ithub.com/libp2p
/go-libp2p-host"
inet
"github.com/libp2p/go-libp2p-net
"
peer
"github.com/libp2p/go-libp2p-peer
"
protocol
"g
ithub.com/libp2p
/go-libp2p-protocol"
timecache
"github.com/whyrusleeping/timecache
"
)
const
(
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment