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
dms3
go-dms3-routing
Commits
25bee4be
Commit
25bee4be
authored
Jan 24, 2018
by
Steven Allen
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
gx: mass update
License: MIT Signed-off-by:
Steven Allen
<
steven@stebalien.com
>
parent
1ff01d3f
Changes
7
Hide whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
37 additions
and
37 deletions
+37
-37
mock/centralized_client.go
mock/centralized_client.go
+9
-9
mock/centralized_server.go
mock/centralized_server.go
+6
-6
mock/centralized_test.go
mock/centralized_test.go
+4
-4
mock/interface.go
mock/interface.go
+4
-4
none/none_client.go
none/none_client.go
+5
-5
offline/offline.go
offline/offline.go
+7
-7
offline/offline_test.go
offline/offline_test.go
+2
-2
No files found.
mock/centralized_client.go
View file @
25bee4be
...
...
@@ -6,18 +6,18 @@ import (
"time"
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
"gx/ipfs/Qm
eDA8gNhvRTsbrjEieay5wezupJDiky8xvCzDABbsGzmp
/go-testutil"
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG
/go-testutil"
routing
"gx/ipfs/QmPCGUjMRuBcPybZFpjhzpifwPP9wPRoiy5geTQKU4vqWA/go-libp2p-routing"
u
"gx/ipfs/QmPsAfmDBnZN3kZGSuNwvCNDZiHneERSKmRcFyG3UkvcT3/go-ipfs-util"
u
"gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
ds
"gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore"
routing
"gx/ipfs/QmRijoA6zGS98ELTDbGsLWPZbVotYsGbjp3RbXcKCYBeon/go-libp2p-routing"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
ma
"gx/ipfs/QmW8s4zTsUoX1Q6CeYxVKPyqSKbF7H1YDUyTostBtZ8DaG/go-multiaddr"
dhtpb
"gx/ipfs/QmWGtsyPYEoiqTtWLpeUA2jpW4YSZgarKDD2zivYAFz7sR/go-libp2p-record/pb"
peer
"gx/ipfs/QmWNY7dV54ZDYmTA1ykVdwNCqC11mpU4zSUp6XDpLTH9eG/go-libp2p-peer"
pstore
"gx/ipfs/QmYijbtjCxFEjSXaudaQAUz3LN5VKLssm8WCUsRoqzXmQR/go-libp2p-peerstore"
ma
"gx/ipfs/QmWWQ2Txc2c6tqjsBpzg5Ar652cHPGNsQQp2SejkNmkUMb/go-multiaddr"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
ds
"gx/ipfs/QmdHG8MAuARdGHxx4rPQASLcvhz24fzjSQq7AJRAQEorq5/go-datastore"
cid
"gx/ipfs/QmeSrf6pzut73u6zLQkRFQ3ygt3k6XFT2kjdYP8Tnkwwyg/go-cid"
peer
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
dhtpb
"gx/ipfs/QmbsY8Pr6s3uZsKg7rzBtGDKeCtdoAhNaMTCXBUbvb1eCV/go-libp2p-record/pb"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
pstore
"gx/ipfs/QmeZVQzUrXqaszo24DAoHfGzcmCptN9JyngLkGAiEfk2x7/go-libp2p-peerstore"
)
var
log = logging.Logger(
"mockrouter"
)
...
...
mock/centralized_server.go
View file @
25bee4be
...
...
@@ -6,13 +6,13 @@ import (
"sync"
"time"
"gx/ipfs/Qm
eDA8gNhvRTsbrjEieay5wezupJDiky8xvCzDABbsGzmp
/go-testutil"
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG
/go-testutil"
peer
"gx/ipfs/Qm
WNY7dV54ZDYmTA1ykVdwNCqC11mpU4zSUp6XDpLTH9eG/go-libp2p-peer
"
pstore
"gx/ipfs/Qm
YijbtjCxFEjSXaudaQAUz3LN5VKLssm8WCUsRoqzXmQR/go-libp2p-peerstore
"
ds
"gx/ipfs/Qm
dHG8MAuARdGHxx4rPQASLcvhz24fzjSQq7AJRAQEorq5/go-datastore
"
dssync
"gx/ipfs/Qm
dHG8MAuARdGHxx4rPQASLcvhz24fzjSQq7AJRAQEorq5/go-datastore/sync
"
cid
"gx/ipfs/Qme
Srf6pzut73u6zLQkRFQ3ygt3k6XFT2kjdYP8Tnkwwyg/go-cid
"
ds
"gx/ipfs/Qm
PpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore
"
dssync
"gx/ipfs/Qm
PpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore/sync
"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer
"
cid
"gx/ipfs/Qm
cZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid
"
pstore
"gx/ipfs/Qme
ZVQzUrXqaszo24DAoHfGzcmCptN9JyngLkGAiEfk2x7/go-libp2p-peerstore
"
)
// server is the mockrouting.Client's private interface to the routing server
...
...
mock/centralized_test.go
View file @
25bee4be
...
...
@@ -6,11 +6,11 @@ import (
"time"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"gx/ipfs/Qm
eDA8gNhvRTsbrjEieay5wezupJDiky8xvCzDABbsGzmp
/go-testutil"
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG
/go-testutil"
u
"gx/ipfs/Qm
PsAfmDBnZN3kZGSuNwvCNDZiHneERSKmRcFyG3UkvcT3
/go-ipfs-util"
pstore
"gx/ipfs/Qm
YijbtjCxFEjSXaudaQAUz3LN5VKLssm8WCUsRoqzXmQR/go-libp2p-peerstore
"
cid
"gx/ipfs/Qme
Srf6pzut73u6zLQkRFQ3ygt3k6XFT2kjdYP8Tnkwwyg/go-cid
"
u
"gx/ipfs/Qm
NiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx
/go-ipfs-util"
cid
"gx/ipfs/Qm
cZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid
"
pstore
"gx/ipfs/Qme
ZVQzUrXqaszo24DAoHfGzcmCptN9JyngLkGAiEfk2x7/go-libp2p-peerstore
"
)
func
TestKeyNotFound(t *testing.T) {
...
...
mock/interface.go
View file @
25bee4be
...
...
@@ -8,11 +8,11 @@ import (
"context"
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"gx/ipfs/Qm
eDA8gNhvRTsbrjEieay5wezupJDiky8xvCzDABbsGzmp
/go-testutil"
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG
/go-testutil"
routing
"gx/ipfs/QmP
CGUjMRuBcPybZFpjhzpifwPP9wPRoiy5geTQKU4vqWA/go-libp2p-routing
"
peer
"gx/ipfs/Qm
WNY7dV54ZDYmTA1ykVdwNCqC11mpU4zSUp6XDpLTH9eG
/go-libp2p-
peer
"
ds
"gx/ipfs/Qm
dHG8MAuARdGHxx4rPQASLcvhz24fzjSQq7AJRAQEorq5/go-datastore
"
ds
"gx/ipfs/QmP
pegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore
"
routing
"gx/ipfs/Qm
RijoA6zGS98ELTDbGsLWPZbVotYsGbjp3RbXcKCYBeon
/go-libp2p-
routing
"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer
"
)
// Server provides mockrouting Clients
...
...
none/none_client.go
View file @
25bee4be
...
...
@@ -6,11 +6,11 @@ import (
repo
"github.com/ipfs/go-ipfs/repo"
p2phost
"gx/ipfs/Qm
P46LGWhzVZTMmt5akNNLfoV8qL4h5wTwmzQxLyDafggd
/go-libp2p-
host
"
routing
"gx/ipfs/Qm
PCGUjMRuBcPybZFpjhzpifwPP9wPRoiy5geTQKU4vqWA
/go-libp2p-
routing
"
peer
"gx/ipfs/Qm
WNY7dV54ZDYmTA1ykVdwNCqC11mpU4zSUp6XDpLTH9eG/go-libp2p-peer
"
pstore
"gx/ipfs/Qm
YijbtjCxFEjSXaudaQAUz3LN5VKLssm8WCUsRoqzXmQR
/go-libp2p-peerstore"
cid
"gx/ipfs/Qm
eSrf6pzut73u6zLQkRFQ3ygt3k6XFT2kjdYP8Tnkwwyg/go-cid
"
routing
"gx/ipfs/Qm
RijoA6zGS98ELTDbGsLWPZbVotYsGbjp3RbXcKCYBeon
/go-libp2p-
routing
"
peer
"gx/ipfs/Qm
a7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU
/go-libp2p-
peer
"
cid
"gx/ipfs/Qm
cZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid
"
pstore
"gx/ipfs/Qm
eZVQzUrXqaszo24DAoHfGzcmCptN9JyngLkGAiEfk2x7
/go-libp2p-peerstore"
p2phost
"gx/ipfs/Qm
fCtHMCd9xFvehvHeVxtKVXJTMVTuHhyPRVHEXetn87vL/go-libp2p-host
"
)
type
nilclient
struct
{
...
...
offline/offline.go
View file @
25bee4be
...
...
@@ -7,15 +7,15 @@ import (
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
routing
"gx/ipfs/QmPCGUjMRuBcPybZFpjhzpifwPP9wPRoiy5geTQKU4vqWA/go-libp2p-routing"
record
"gx/ipfs/QmWGtsyPYEoiqTtWLpeUA2jpW4YSZgarKDD2zivYAFz7sR/go-libp2p-record"
pb
"gx/ipfs/QmWGtsyPYEoiqTtWLpeUA2jpW4YSZgarKDD2zivYAFz7sR/go-libp2p-record/pb"
"gx/ipfs/QmWNY7dV54ZDYmTA1ykVdwNCqC11mpU4zSUp6XDpLTH9eG/go-libp2p-peer"
pstore
"gx/ipfs/QmYijbtjCxFEjSXaudaQAUz3LN5VKLssm8WCUsRoqzXmQR/go-libp2p-peerstore"
ds
"gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore"
routing
"gx/ipfs/QmRijoA6zGS98ELTDbGsLWPZbVotYsGbjp3RbXcKCYBeon/go-libp2p-routing"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
"gx/ipfs/Qma7H6RW8wRrfZpNSXwxYGcd1E149s42FpWNpDNieSVrnU/go-libp2p-peer"
ci
"gx/ipfs/QmaPbCnUMBohSGo3KnxEa2bHqyJVVeEEcwtqJAYxerieBo/go-libp2p-crypto"
ds
"gx/ipfs/QmdHG8MAuARdGHxx4rPQASLcvhz24fzjSQq7AJRAQEorq5/go-datastore"
cid
"gx/ipfs/QmeSrf6pzut73u6zLQkRFQ3ygt3k6XFT2kjdYP8Tnkwwyg/go-cid"
record
"gx/ipfs/QmbsY8Pr6s3uZsKg7rzBtGDKeCtdoAhNaMTCXBUbvb1eCV/go-libp2p-record"
pb
"gx/ipfs/QmbsY8Pr6s3uZsKg7rzBtGDKeCtdoAhNaMTCXBUbvb1eCV/go-libp2p-record/pb"
cid
"gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
pstore
"gx/ipfs/QmeZVQzUrXqaszo24DAoHfGzcmCptN9JyngLkGAiEfk2x7/go-libp2p-peerstore"
)
var
ErrOffline = errors.New(
"routing system in offline mode"
)
...
...
offline/offline_test.go
View file @
25bee4be
...
...
@@ -5,8 +5,8 @@ import (
"context"
"testing"
ds
"gx/ipfs/Qm
dHG8MAuARdGHxx4rPQASLcvhz24fzjSQq7AJRAQEorq5
/go-datastore"
"gx/ipfs/Qm
eDA8gNhvRTsbrjEieay5wezupJDiky8xvCzDABbsGzmp
/go-testutil"
ds
"gx/ipfs/Qm
PpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg
/go-datastore"
"gx/ipfs/Qm
fB65MYJqaKzBiMvW47fquCRhmEeXW6AhrJSGM7TeY5eG
/go-testutil"
)
func
TestOfflineRouterStorage(t *testing.T) {
...
...
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