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
7c7f24a9
Commit
7c7f24a9
authored
Nov 28, 2016
by
Jeromy
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
bubble up go-datastore deps
License: MIT Signed-off-by:
Jeromy
<
why@ipfs.io
>
parent
353586cf
Changes
12
Hide whitespace changes
Inline
Side-by-side
Showing
12 changed files
with
43 additions
and
43 deletions
+43
-43
mock/centralized_client.go
mock/centralized_client.go
+4
-4
mock/centralized_server.go
mock/centralized_server.go
+4
-4
mock/centralized_test.go
mock/centralized_test.go
+2
-2
mock/dht.go
mock/dht.go
+4
-4
mock/interface.go
mock/interface.go
+4
-4
none/none_client.go
none/none_client.go
+4
-4
offline/offline.go
offline/offline.go
+4
-4
supernode/client.go
supernode/client.go
+5
-5
supernode/proxy/loopback.go
supernode/proxy/loopback.go
+2
-2
supernode/proxy/standard.go
supernode/proxy/standard.go
+5
-5
supernode/server.go
supernode/server.go
+3
-3
supernode/server_test.go
supernode/server_test.go
+2
-2
No files found.
mock/centralized_client.go
View file @
7c7f24a9
...
...
@@ -8,15 +8,15 @@ import (
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
ma
"gx/ipfs/QmUAQaWbKxGCUTuoQVvvicbQNZ9APF5pDGWyAZSe93AtKH/go-multiaddr"
routing
"gx/ipfs/QmUrCwTDvJgmBbJVHu1HGEyqDaod3dR6sEkZkpxZk4u47c/go-libp2p-routing"
pstore
"gx/ipfs/QmXXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peerstore"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
u
"gx/ipfs/Qmb912gdngC1UWwTkhuW8knyRbcWeu5kqkxBpveLmW8bSr/go-ipfs-util"
ds
"gx/ipfs/Qmb
zuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore
"
cid
"gx/ipfs/Qmc
EcrBAMrwMyhSjXt4yfyPpzgSuV8HLHavnfmiKCSRqZU
/go-cid"
routing
"gx/ipfs/Qmb
kGVaN9W6RYJK4Ws5FvMKXKDqdRQ5snhtaa92qP6L8eU/go-libp2p-routing
"
cid
"gx/ipfs/Qmc
TcsTvfaeEBRFo1TkFgT8sRmgi1n1LTZpecfVP8fzpGD
/go-cid"
dhtpb
"gx/ipfs/QmdM4ohF7cr4MvAECVeD3hRA3HtZrk1ngaek4n8ojVT87h/go-libp2p-record/pb"
pstore
"gx/ipfs/QmeXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
mock/centralized_server.go
View file @
7c7f24a9
...
...
@@ -8,10 +8,10 @@ import (
"github.com/ipfs/go-ipfs/thirdparty/testutil"
pstore
"gx/ipfs/Qm
XXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peer
store"
ds
"gx/ipfs/Qm
bzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU
/go-datastore"
dssync
"gx/ipfs/Qm
bzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore/sync
"
cid
"gx/ipfs/Qm
cEcrBAMrwMyhSjXt4yfyPpzgSuV8HLHavnfmiKCSRqZU/go-cid
"
ds
"gx/ipfs/Qm
RWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-data
store"
ds
sync
"gx/ipfs/Qm
RWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364
/go-datastore
/sync
"
cid
"gx/ipfs/Qm
cTcsTvfaeEBRFo1TkFgT8sRmgi1n1LTZpecfVP8fzpGD/go-cid
"
pstore
"gx/ipfs/Qm
eXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore
"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
mock/centralized_test.go
View file @
7c7f24a9
...
...
@@ -8,9 +8,9 @@ import (
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
pstore
"gx/ipfs/QmXXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peerstore"
u
"gx/ipfs/Qmb912gdngC1UWwTkhuW8knyRbcWeu5kqkxBpveLmW8bSr/go-ipfs-util"
cid
"gx/ipfs/QmcEcrBAMrwMyhSjXt4yfyPpzgSuV8HLHavnfmiKCSRqZU/go-cid"
cid
"gx/ipfs/QmcTcsTvfaeEBRFo1TkFgT8sRmgi1n1LTZpecfVP8fzpGD/go-cid"
pstore
"gx/ipfs/QmeXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore"
)
func
TestKeyNotFound
(
t
*
testing
.
T
)
{
...
...
mock/dht.go
View file @
7c7f24a9
...
...
@@ -3,10 +3,10 @@ package mockrouting
import
(
context
"context"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
mockne
t
"gx/ipfs/Qm
ZyBJGpRnbQ7oUstoGNZbhXC4HJuFUCgpp8pmsVTUwdS3/go-libp2p/p2p/net/mock
"
d
ht
"gx/ipfs/Qm
aMRCpeKL34rdT7t3bEndrENbVdD6gcCZr3YdkDUk6jue/go-libp2p-kad-dht
"
d
s
"gx/ipfs/Qm
bzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU
/go-datastore"
sync
"gx/ipfs/Qmbz
uUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore/sync
"
dh
t
"gx/ipfs/Qm
NQPjpcXrwwwgDErKzKUm2xxhXCB3cuFgTHsrcCJ5uGbu/go-libp2p-kad-dht
"
d
s
"gx/ipfs/Qm
RWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore
"
s
ync
"gx/ipfs/Qm
RWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364
/go-datastore
/sync
"
mocknet
"gx/ipfs/Qmbz
CT1CwxVZ2ednptC9RavuJe7Bv8DDi2Ne89qUrA37XM/go-libp2p/p2p/net/mock
"
)
type
mocknetserver
struct
{
...
...
mock/interface.go
View file @
7c7f24a9
...
...
@@ -10,10 +10,10 @@ import (
delay
"github.com/ipfs/go-ipfs/thirdparty/delay"
"github.com/ipfs/go-ipfs/thirdparty/testutil"
routing
"gx/ipfs/Qm
UrCwTDvJgmBbJVHu1HGEyqDaod3dR6sEkZkpxZk4u47c/go-libp2p-routing
"
pstore
"gx/ipfs/Qm
XXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo
/go-libp2p-
peerstore
"
d
s
"gx/ipfs/Qm
bzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore
"
cid
"gx/ipfs/Qm
cEcrBAMrwMyhSjXt4yfyPpzgSuV8HLHavnfmiKCSRqZU/go-cid
"
ds
"gx/ipfs/Qm
RWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore
"
routing
"gx/ipfs/Qm
bkGVaN9W6RYJK4Ws5FvMKXKDqdRQ5snhtaa92qP6L8eU
/go-libp2p-
routing
"
ci
d
"gx/ipfs/Qm
cTcsTvfaeEBRFo1TkFgT8sRmgi1n1LTZpecfVP8fzpGD/go-cid
"
pstore
"gx/ipfs/Qm
eXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore
"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
none/none_client.go
View file @
7c7f24a9
...
...
@@ -6,11 +6,11 @@ import (
repo
"github.com/ipfs/go-ipfs/repo"
p2phost
"gx/ipfs/QmPTGbC34bPKaUm9wTxBo7zSCac7pDuG42ZmnXC718CKZZ/go-libp2p-host"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
routing
"gx/ipfs/QmUrCwTDvJgmBbJVHu1HGEyqDaod3dR6sEkZkpxZk4u47c/go-libp2p-routing"
pstore
"gx/ipfs/QmXXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peerstore"
p2phost
"gx/ipfs/Qmb6UFbVu1grhv5o5KnouvtZ6cqdrjXj6zLejAHWunxgCt/go-libp2p-host"
cid
"gx/ipfs/QmcEcrBAMrwMyhSjXt4yfyPpzgSuV8HLHavnfmiKCSRqZU/go-cid"
routing
"gx/ipfs/QmbkGVaN9W6RYJK4Ws5FvMKXKDqdRQ5snhtaa92qP6L8eU/go-libp2p-routing"
cid
"gx/ipfs/QmcTcsTvfaeEBRFo1TkFgT8sRmgi1n1LTZpecfVP8fzpGD/go-cid"
pstore
"gx/ipfs/QmeXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
offline/offline.go
View file @
7c7f24a9
...
...
@@ -7,14 +7,14 @@ import (
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
ds
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
routing
"gx/ipfs/QmUrCwTDvJgmBbJVHu1HGEyqDaod3dR6sEkZkpxZk4u47c/go-libp2p-routing"
pstore
"gx/ipfs/QmXXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peerstore"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
ds
"gx/ipfs/Qmb
zuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore
"
cid
"gx/ipfs/Qmc
EcrBAMrwMyhSjXt4yfyPpzgSuV8HLHavnfmiKCSRqZU
/go-cid"
routing
"gx/ipfs/Qmb
kGVaN9W6RYJK4Ws5FvMKXKDqdRQ5snhtaa92qP6L8eU/go-libp2p-routing
"
cid
"gx/ipfs/Qmc
TcsTvfaeEBRFo1TkFgT8sRmgi1n1LTZpecfVP8fzpGD
/go-cid"
record
"gx/ipfs/QmdM4ohF7cr4MvAECVeD3hRA3HtZrk1ngaek4n8ojVT87h/go-libp2p-record"
pb
"gx/ipfs/QmdM4ohF7cr4MvAECVeD3hRA3HtZrk1ngaek4n8ojVT87h/go-libp2p-record/pb"
pstore
"gx/ipfs/QmeXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore"
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
ci
"gx/ipfs/QmfWDLQjGjVe4fr5CoztYW2DYYjRysMJrFe1RCsXLPTf46/go-libp2p-crypto"
)
...
...
supernode/client.go
View file @
7c7f24a9
...
...
@@ -8,15 +8,15 @@ import (
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
dhtpb
"gx/ipfs/QmNQPjpcXrwwwgDErKzKUm2xxhXCB3cuFgTHsrcCJ5uGbu/go-libp2p-kad-dht/pb"
"gx/ipfs/QmPTGbC34bPKaUm9wTxBo7zSCac7pDuG42ZmnXC718CKZZ/go-libp2p-host"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
loggables
"gx/ipfs/QmTMy4hVSY28DdwJ9kBz6y7q6MuioFzPcpM3Ma3aPjo1i3/go-libp2p-loggables"
routing
"gx/ipfs/QmUrCwTDvJgmBbJVHu1HGEyqDaod3dR6sEkZkpxZk4u47c/go-libp2p-routing"
pstore
"gx/ipfs/QmXXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peerstore"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
dhtpb
"gx/ipfs/QmaMRCpeKL34rdT7t3bEndrENbVdD6gcCZr3YdkDUk6jue/go-libp2p-kad-dht/pb"
"gx/ipfs/Qmb6UFbVu1grhv5o5KnouvtZ6cqdrjXj6zLejAHWunxgCt/go-libp2p-host"
cid
"gx/ipfs/QmcEcrBAMrwMyhSjXt4yfyPpzgSuV8HLHavnfmiKCSRqZU/go-cid"
routing
"gx/ipfs/QmbkGVaN9W6RYJK4Ws5FvMKXKDqdRQ5snhtaa92qP6L8eU/go-libp2p-routing"
cid
"gx/ipfs/QmcTcsTvfaeEBRFo1TkFgT8sRmgi1n1LTZpecfVP8fzpGD/go-cid"
pb
"gx/ipfs/QmdM4ohF7cr4MvAECVeD3hRA3HtZrk1ngaek4n8ojVT87h/go-libp2p-record/pb"
pstore
"gx/ipfs/QmeXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
supernode/proxy/loopback.go
View file @
7c7f24a9
...
...
@@ -2,9 +2,9 @@ package proxy
import
(
context
"context"
inet
"gx/ipfs/QmU3pGGVT1riXp5dBJbNrGpxssVScfvk9236drRHZZbKJ1/go-libp2p-net"
dhtpb
"gx/ipfs/QmNQPjpcXrwwwgDErKzKUm2xxhXCB3cuFgTHsrcCJ5uGbu/go-libp2p-kad-dht/pb"
inet
"gx/ipfs/QmQx1dHDDYENugYgqA22BaBrRfuv1coSsuPiM7rYh1wwGH/go-libp2p-net"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
dhtpb
"gx/ipfs/QmaMRCpeKL34rdT7t3bEndrENbVdD6gcCZr3YdkDUk6jue/go-libp2p-kad-dht/pb"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
supernode/proxy/standard.go
View file @
7c7f24a9
...
...
@@ -4,14 +4,14 @@ import (
"context"
"errors"
dhtpb
"gx/ipfs/QmNQPjpcXrwwwgDErKzKUm2xxhXCB3cuFgTHsrcCJ5uGbu/go-libp2p-kad-dht/pb"
host
"gx/ipfs/QmPTGbC34bPKaUm9wTxBo7zSCac7pDuG42ZmnXC718CKZZ/go-libp2p-host"
inet
"gx/ipfs/QmQx1dHDDYENugYgqA22BaBrRfuv1coSsuPiM7rYh1wwGH/go-libp2p-net"
kbucket
"gx/ipfs/QmRVHVr38ChANF2PUMNKQs7Q4uVWCLVabrfcTG9taNbcVy/go-libp2p-kbucket"
logging
"gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
loggables
"gx/ipfs/QmTMy4hVSY28DdwJ9kBz6y7q6MuioFzPcpM3Ma3aPjo1i3/go-libp2p-loggables"
inet
"gx/ipfs/QmU3pGGVT1riXp5dBJbNrGpxssVScfvk9236drRHZZbKJ1/go-libp2p-net"
kbucket
"gx/ipfs/QmUKePKcUEXwdvJENZJ6z8mJjPaxLsDZ3V9CZjPPtyawPm/go-libp2p-kbucket"
pstore
"gx/ipfs/QmXXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peerstore"
ggio
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/io"
dhtpb
"gx/ipfs/QmaMRCpeKL34rdT7t3bEndrENbVdD6gcCZr3YdkDUk6jue/go-libp2p-kad-dht/pb"
host
"gx/ipfs/Qmb6UFbVu1grhv5o5KnouvtZ6cqdrjXj6zLejAHWunxgCt/go-libp2p-host"
pstore
"gx/ipfs/QmeXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
supernode/server.go
View file @
7c7f24a9
...
...
@@ -8,12 +8,12 @@ import (
proxy
"github.com/ipfs/go-ipfs/routing/supernode/proxy"
dshelp
"github.com/ipfs/go-ipfs/thirdparty/ds-help"
pstore
"gx/ipfs/QmXXCcQ7CLg5a81Ui9TTR35QcR4y7ZyihxwfjqaHfUVcVo/go-libp2p-peerstore"
dhtpb
"gx/ipfs/QmNQPjpcXrwwwgDErKzKUm2xxhXCB3cuFgTHsrcCJ5uGbu/go-libp2p-kad-dht/pb"
datastore
"gx/ipfs/QmRWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364/go-datastore"
proto
"gx/ipfs/QmZ4Qi3GaRbjcx28Sme5eMH7RQjGkt8wHxt2a65oLaeFEV/gogo-protobuf/proto"
dhtpb
"gx/ipfs/QmaMRCpeKL34rdT7t3bEndrENbVdD6gcCZr3YdkDUk6jue/go-libp2p-kad-dht/pb"
datastore
"gx/ipfs/QmbzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU/go-datastore"
record
"gx/ipfs/QmdM4ohF7cr4MvAECVeD3hRA3HtZrk1ngaek4n8ojVT87h/go-libp2p-record"
pb
"gx/ipfs/QmdM4ohF7cr4MvAECVeD3hRA3HtZrk1ngaek4n8ojVT87h/go-libp2p-record/pb"
pstore
"gx/ipfs/QmeXj9VAjmYQZxpmVz7VzccbJrpmr8qkCDSjfVNsPTWTYU/go-libp2p-peerstore"
peer
"gx/ipfs/QmfMmLGoKzCHDN7cGgk64PJr4iipzidDRME8HABSJqvmhC/go-libp2p-peer"
)
...
...
supernode/server_test.go
View file @
7c7f24a9
...
...
@@ -3,8 +3,8 @@ package supernode
import
(
"testing"
dhtpb
"gx/ipfs/Qm
aMRCpeKL34rdT7t3bEndrENbVdD6gcCZr3YdkDUk6jue
/go-libp2p-kad-dht/pb"
datastore
"gx/ipfs/Qm
bzuUusHqaLLoNTDEVLcSF6vZDHZDLPC7p4bztRvvkXxU
/go-datastore"
dhtpb
"gx/ipfs/Qm
NQPjpcXrwwwgDErKzKUm2xxhXCB3cuFgTHsrcCJ5uGbu
/go-libp2p-kad-dht/pb"
datastore
"gx/ipfs/Qm
RWDav6mzWseLWeYfVd5fvUKiVe9xNH29YfMF438fG364
/go-datastore"
)
func
TestPutProviderDoesntResultInDuplicates
(
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