anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

GO-3170: fix import order and cleanup peer manager interface

Browse source 
Signed-off-by: AnastasiaShemyakinskaya <shem98a@mail.ru>
This commit is contained in:
AnastasiaShemyakinskaya 2024-05-17 01:41:27 +02:00
parent 89e5a7899d
commit 166a85e522
No known key found for this signature in database
GPG key ID: CCD60ED83B103281
3 changed files with 1 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

14
commonspace/peermanager/mock_peermanager/mock_peermanager.go
View file

@ -70,20 +70,6 @@ func (mr *MockPeerManagerMockRecorder) GetNodePeers(arg0 any) *gomock.Call {
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetNodePeers", reflect.TypeOf((*MockPeerManager)(nil).GetNodePeers), arg0)
}
// GetNodeResponsiblePeers mocks base method.
func (m *MockPeerManager) GetNodeResponsiblePeers() []string {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "GetNodeResponsiblePeers")
ret0, _ := ret[0].([]string)
return ret0
}
// GetNodeResponsiblePeers indicates an expected call of GetNodeResponsiblePeers.
func (mr *MockPeerManagerMockRecorder) GetNodeResponsiblePeers() *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetNodeResponsiblePeers", reflect.TypeOf((*MockPeerManager)(nil).GetNodeResponsiblePeers))
}
// GetResponsiblePeers mocks base method.
func (m *MockPeerManager) GetResponsiblePeers(arg0 context.Context) ([]peer.Peer, error) {
m.ctrl.T.Helper()

2
commonspace/peermanager/peermanager.go
View file

@ -22,8 +22,6 @@ type PeerManager interface {
GetResponsiblePeers(ctx context.Context) (peers []peer.Peer, err error)
// GetNodePeers dials or gets from cache node peers
GetNodePeers(ctx context.Context) (peers []peer.Peer, err error)
// GetNodeResponsiblePeers get responsible node peers from cache
GetNodeResponsiblePeers() (peers []string)
// IsPeerOffline check if peer node has offline status
IsPeerOffline(senderId string) bool
}

2
commonspace/spaceservice.go
View file

@ -4,7 +4,6 @@ package commonspace
import (
"context"
"errors"
"github.com/anyproto/any-sync/commonspace/syncstatus"
"sync/atomic"
"time"
@ -38,6 +37,7 @@ import (
"github.com/anyproto/any-sync/commonspace/spacestate"
"github.com/anyproto/any-sync/commonspace/spacestorage"
"github.com/anyproto/any-sync/commonspace/spacesyncproto"
"github.com/anyproto/any-sync/commonspace/syncstatus"
"github.com/anyproto/any-sync/consensus/consensusproto"
"github.com/anyproto/any-sync/metric"
"github.com/anyproto/any-sync/net/pool"