Documentation ¶
Overview ¶
Package mock_synctree is a generated GoMock package.
Index ¶
- type MockHeadNotifiable
- type MockHeadNotifiableMockRecorder
- type MockRequestFactory
- func (m *MockRequestFactory) CreateFullSyncRequest(peerId string, t objecttree.ObjectTree) *objectmessages.Request
- func (m *MockRequestFactory) CreateHeadUpdate(t objecttree.ObjectTree, ignoredPeer string, ...) (*objectmessages.HeadUpdate, error)
- func (m *MockRequestFactory) CreateNewTreeRequest(peerId, objectId string) *objectmessages.Request
- func (m *MockRequestFactory) CreateResponseProducer(t objecttree.ObjectTree, theirHeads, theirSnapshotPath []string) (response.ResponseProducer, error)
- func (m *MockRequestFactory) EXPECT() *MockRequestFactoryMockRecorder
- type MockRequestFactoryMockRecorder
- func (mr *MockRequestFactoryMockRecorder) CreateFullSyncRequest(peerId, t any) *gomock.Call
- func (mr *MockRequestFactoryMockRecorder) CreateHeadUpdate(t, ignoredPeer, added any) *gomock.Call
- func (mr *MockRequestFactoryMockRecorder) CreateNewTreeRequest(peerId, objectId any) *gomock.Call
- func (mr *MockRequestFactoryMockRecorder) CreateResponseProducer(t, theirHeads, theirSnapshotPath any) *gomock.Call
- type MockSyncClient
- func (m *MockSyncClient) Broadcast(ctx context.Context, headUpdate *objectmessages.HeadUpdate) error
- func (m *MockSyncClient) CreateFullSyncRequest(peerId string, t objecttree.ObjectTree) *objectmessages.Request
- func (m *MockSyncClient) CreateHeadUpdate(t objecttree.ObjectTree, ignoredPeer string, ...) (*objectmessages.HeadUpdate, error)
- func (m *MockSyncClient) CreateNewTreeRequest(peerId, objectId string) *objectmessages.Request
- func (m *MockSyncClient) CreateResponseProducer(t objecttree.ObjectTree, theirHeads, theirSnapshotPath []string) (response.ResponseProducer, error)
- func (m *MockSyncClient) EXPECT() *MockSyncClientMockRecorder
- func (m *MockSyncClient) QueueRequest(ctx context.Context, req syncdeps.Request) error
- func (m *MockSyncClient) SendTreeRequest(ctx context.Context, req syncdeps.Request, ...) error
- type MockSyncClientMockRecorder
- func (mr *MockSyncClientMockRecorder) Broadcast(ctx, headUpdate any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) CreateFullSyncRequest(peerId, t any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) CreateHeadUpdate(t, ignoredPeer, added any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) CreateNewTreeRequest(peerId, objectId any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) CreateResponseProducer(t, theirHeads, theirSnapshotPath any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) QueueRequest(ctx, req any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) SendTreeRequest(ctx, req, collector any) *gomock.Call
- type MockSyncTree
- func (m *MockSyncTree) AclList() list.AclList
- func (m *MockSyncTree) AddContent(ctx context.Context, content objecttree.SignableChangeContent) (objecttree.AddResult, error)
- func (m *MockSyncTree) AddContentWithValidator(ctx context.Context, content objecttree.SignableChangeContent, ...) (objecttree.AddResult, error)
- func (m *MockSyncTree) AddRawChanges(ctx context.Context, changes objecttree.RawChangesPayload) (objecttree.AddResult, error)
- func (m *MockSyncTree) AddRawChangesFromPeer(ctx context.Context, peerId string, ...) (objecttree.AddResult, error)
- func (m *MockSyncTree) AddRawChangesWithUpdater(ctx context.Context, changes objecttree.RawChangesPayload, ...) (objecttree.AddResult, error)
- func (m *MockSyncTree) ChangeInfo() *treechangeproto.TreeChangeInfo
- func (m *MockSyncTree) ChangesAfterCommonSnapshot(snapshotPath, heads []string) ([]*treechangeproto.RawTreeChangeWithId, error)
- func (m *MockSyncTree) ChangesAfterCommonSnapshotLoader(snapshotPath, heads []string) (objecttree.LoadIterator, error)
- func (m *MockSyncTree) Close() error
- func (m *MockSyncTree) Debug(parser objecttree.DescriptionParser) (objecttree.DebugInfo, error)
- func (m *MockSyncTree) Delete() error
- func (m *MockSyncTree) EXPECT() *MockSyncTreeMockRecorder
- func (m *MockSyncTree) GetChange(arg0 string) (*objecttree.Change, error)
- func (m *MockSyncTree) HandleDeprecatedRequest(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (*spacesyncproto.ObjectSyncMessage, error)
- func (m *MockSyncTree) HandleHeadUpdate(ctx context.Context, statusUpdater syncstatus.StatusUpdater, ...) (syncdeps.Request, error)
- func (m *MockSyncTree) HandleResponse(ctx context.Context, peerId, objectId string, resp syncdeps.Response) error
- func (m *MockSyncTree) HandleStreamRequest(ctx context.Context, rq syncdeps.Request, updater syncdeps.QueueSizeUpdater, ...) (syncdeps.Request, error)
- func (m *MockSyncTree) HasChanges(arg0 ...string) bool
- func (m *MockSyncTree) Header() *treechangeproto.RawTreeChangeWithId
- func (m *MockSyncTree) Heads() []string
- func (m *MockSyncTree) Id() string
- func (m *MockSyncTree) IsDerived() bool
- func (m *MockSyncTree) IterateFrom(id string, convert func(*objecttree.Change, []byte) (any, error), ...) error
- func (m *MockSyncTree) IterateRoot(convert func(*objecttree.Change, []byte) (any, error), ...) error
- func (m *MockSyncTree) Len() int
- func (m *MockSyncTree) Lock()
- func (m *MockSyncTree) PrepareChange(content objecttree.SignableChangeContent) (*treechangeproto.RawTreeChangeWithId, error)
- func (m *MockSyncTree) ResponseCollector() syncdeps.ResponseCollector
- func (m *MockSyncTree) Root() *objecttree.Change
- func (m *MockSyncTree) SetFlusher(flusher objecttree.Flusher)
- func (m *MockSyncTree) SetListener(listener updatelistener.UpdateListener)
- func (m *MockSyncTree) SnapshotPath() []string
- func (m *MockSyncTree) Storage() treestorage.TreeStorage
- func (m *MockSyncTree) SyncWithPeer(ctx context.Context, p peer.Peer) error
- func (m *MockSyncTree) TryClose(objectTTL time.Duration) (bool, error)
- func (m *MockSyncTree) TryLock() bool
- func (m *MockSyncTree) Unlock()
- func (m *MockSyncTree) UnmarshalledHeader() *objecttree.Change
- func (m *MockSyncTree) UnpackChange(raw *treechangeproto.RawTreeChangeWithId) ([]byte, error)
- type MockSyncTreeMockRecorder
- func (mr *MockSyncTreeMockRecorder) AclList() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) AddContent(ctx, content any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) AddContentWithValidator(ctx, content, validate any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) AddRawChanges(ctx, changes any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) AddRawChangesFromPeer(ctx, peerId, changesPayload any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) AddRawChangesWithUpdater(ctx, changes, updater any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) ChangeInfo() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) ChangesAfterCommonSnapshot(snapshotPath, heads any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) ChangesAfterCommonSnapshotLoader(snapshotPath, heads any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Close() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Debug(parser any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Delete() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) GetChange(arg0 any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) HandleDeprecatedRequest(ctx, req any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) HandleHeadUpdate(ctx, statusUpdater, headUpdate any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) HandleResponse(ctx, peerId, objectId, resp any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) HandleStreamRequest(ctx, rq, updater, send any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) HasChanges(arg0 ...any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Header() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Heads() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Id() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) IsDerived() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) IterateFrom(id, convert, iterate any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) IterateRoot(convert, iterate any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Len() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Lock() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) PrepareChange(content any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) ResponseCollector() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Root() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) SetFlusher(flusher any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) SetListener(listener any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) SnapshotPath() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Storage() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) SyncWithPeer(ctx, p any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) TryClose(objectTTL any) *gomock.Call
- func (mr *MockSyncTreeMockRecorder) TryLock() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) Unlock() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) UnmarshalledHeader() *gomock.Call
- func (mr *MockSyncTreeMockRecorder) UnpackChange(raw any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockHeadNotifiable ¶
type MockHeadNotifiable struct {
// contains filtered or unexported fields
}
MockHeadNotifiable is a mock of HeadNotifiable interface.
func NewMockHeadNotifiable ¶
func NewMockHeadNotifiable(ctrl *gomock.Controller) *MockHeadNotifiable
NewMockHeadNotifiable creates a new mock instance.
func (*MockHeadNotifiable) EXPECT ¶
func (m *MockHeadNotifiable) EXPECT() *MockHeadNotifiableMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockHeadNotifiable) UpdateHeads ¶
func (m *MockHeadNotifiable) UpdateHeads(id string, heads []string)
UpdateHeads mocks base method.
type MockHeadNotifiableMockRecorder ¶
type MockHeadNotifiableMockRecorder struct {
// contains filtered or unexported fields
}
MockHeadNotifiableMockRecorder is the mock recorder for MockHeadNotifiable.
func (*MockHeadNotifiableMockRecorder) UpdateHeads ¶
func (mr *MockHeadNotifiableMockRecorder) UpdateHeads(id, heads any) *gomock.Call
UpdateHeads indicates an expected call of UpdateHeads.
type MockRequestFactory ¶ added in v0.2.0
type MockRequestFactory struct {
// contains filtered or unexported fields
}
MockRequestFactory is a mock of RequestFactory interface.
func NewMockRequestFactory ¶ added in v0.2.0
func NewMockRequestFactory(ctrl *gomock.Controller) *MockRequestFactory
NewMockRequestFactory creates a new mock instance.
func (*MockRequestFactory) CreateFullSyncRequest ¶ added in v0.2.0
func (m *MockRequestFactory) CreateFullSyncRequest(peerId string, t objecttree.ObjectTree) *objectmessages.Request
CreateFullSyncRequest mocks base method.
func (*MockRequestFactory) CreateHeadUpdate ¶ added in v0.2.0
func (m *MockRequestFactory) CreateHeadUpdate(t objecttree.ObjectTree, ignoredPeer string, added []*treechangeproto.RawTreeChangeWithId) (*objectmessages.HeadUpdate, error)
CreateHeadUpdate mocks base method.
func (*MockRequestFactory) CreateNewTreeRequest ¶ added in v0.2.0
func (m *MockRequestFactory) CreateNewTreeRequest(peerId, objectId string) *objectmessages.Request
CreateNewTreeRequest mocks base method.
func (*MockRequestFactory) CreateResponseProducer ¶ added in v0.5.0
func (m *MockRequestFactory) CreateResponseProducer(t objecttree.ObjectTree, theirHeads, theirSnapshotPath []string) (response.ResponseProducer, error)
CreateResponseProducer mocks base method.
func (*MockRequestFactory) EXPECT ¶ added in v0.2.0
func (m *MockRequestFactory) EXPECT() *MockRequestFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockRequestFactoryMockRecorder ¶ added in v0.2.0
type MockRequestFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockRequestFactoryMockRecorder is the mock recorder for MockRequestFactory.
func (*MockRequestFactoryMockRecorder) CreateFullSyncRequest ¶ added in v0.2.0
func (mr *MockRequestFactoryMockRecorder) CreateFullSyncRequest(peerId, t any) *gomock.Call
CreateFullSyncRequest indicates an expected call of CreateFullSyncRequest.
func (*MockRequestFactoryMockRecorder) CreateHeadUpdate ¶ added in v0.2.0
func (mr *MockRequestFactoryMockRecorder) CreateHeadUpdate(t, ignoredPeer, added any) *gomock.Call
CreateHeadUpdate indicates an expected call of CreateHeadUpdate.
func (*MockRequestFactoryMockRecorder) CreateNewTreeRequest ¶ added in v0.2.0
func (mr *MockRequestFactoryMockRecorder) CreateNewTreeRequest(peerId, objectId any) *gomock.Call
CreateNewTreeRequest indicates an expected call of CreateNewTreeRequest.
func (*MockRequestFactoryMockRecorder) CreateResponseProducer ¶ added in v0.5.0
func (mr *MockRequestFactoryMockRecorder) CreateResponseProducer(t, theirHeads, theirSnapshotPath any) *gomock.Call
CreateResponseProducer indicates an expected call of CreateResponseProducer.
type MockSyncClient ¶ added in v0.2.0
type MockSyncClient struct {
// contains filtered or unexported fields
}
MockSyncClient is a mock of SyncClient interface.
func NewMockSyncClient ¶ added in v0.2.0
func NewMockSyncClient(ctrl *gomock.Controller) *MockSyncClient
NewMockSyncClient creates a new mock instance.
func (*MockSyncClient) Broadcast ¶ added in v0.2.0
func (m *MockSyncClient) Broadcast(ctx context.Context, headUpdate *objectmessages.HeadUpdate) error
Broadcast mocks base method.
func (*MockSyncClient) CreateFullSyncRequest ¶ added in v0.2.0
func (m *MockSyncClient) CreateFullSyncRequest(peerId string, t objecttree.ObjectTree) *objectmessages.Request
CreateFullSyncRequest mocks base method.
func (*MockSyncClient) CreateHeadUpdate ¶ added in v0.2.0
func (m *MockSyncClient) CreateHeadUpdate(t objecttree.ObjectTree, ignoredPeer string, added []*treechangeproto.RawTreeChangeWithId) (*objectmessages.HeadUpdate, error)
CreateHeadUpdate mocks base method.
func (*MockSyncClient) CreateNewTreeRequest ¶ added in v0.2.0
func (m *MockSyncClient) CreateNewTreeRequest(peerId, objectId string) *objectmessages.Request
CreateNewTreeRequest mocks base method.
func (*MockSyncClient) CreateResponseProducer ¶ added in v0.5.0
func (m *MockSyncClient) CreateResponseProducer(t objecttree.ObjectTree, theirHeads, theirSnapshotPath []string) (response.ResponseProducer, error)
CreateResponseProducer mocks base method.
func (*MockSyncClient) EXPECT ¶ added in v0.2.0
func (m *MockSyncClient) EXPECT() *MockSyncClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSyncClient) QueueRequest ¶ added in v0.2.0
QueueRequest mocks base method.
func (*MockSyncClient) SendTreeRequest ¶ added in v0.5.0
func (m *MockSyncClient) SendTreeRequest(ctx context.Context, req syncdeps.Request, collector syncdeps.ResponseCollector) error
SendTreeRequest mocks base method.
type MockSyncClientMockRecorder ¶ added in v0.2.0
type MockSyncClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSyncClientMockRecorder is the mock recorder for MockSyncClient.
func (*MockSyncClientMockRecorder) Broadcast ¶ added in v0.2.0
func (mr *MockSyncClientMockRecorder) Broadcast(ctx, headUpdate any) *gomock.Call
Broadcast indicates an expected call of Broadcast.
func (*MockSyncClientMockRecorder) CreateFullSyncRequest ¶ added in v0.2.0
func (mr *MockSyncClientMockRecorder) CreateFullSyncRequest(peerId, t any) *gomock.Call
CreateFullSyncRequest indicates an expected call of CreateFullSyncRequest.
func (*MockSyncClientMockRecorder) CreateHeadUpdate ¶ added in v0.2.0
func (mr *MockSyncClientMockRecorder) CreateHeadUpdate(t, ignoredPeer, added any) *gomock.Call
CreateHeadUpdate indicates an expected call of CreateHeadUpdate.
func (*MockSyncClientMockRecorder) CreateNewTreeRequest ¶ added in v0.2.0
func (mr *MockSyncClientMockRecorder) CreateNewTreeRequest(peerId, objectId any) *gomock.Call
CreateNewTreeRequest indicates an expected call of CreateNewTreeRequest.
func (*MockSyncClientMockRecorder) CreateResponseProducer ¶ added in v0.5.0
func (mr *MockSyncClientMockRecorder) CreateResponseProducer(t, theirHeads, theirSnapshotPath any) *gomock.Call
CreateResponseProducer indicates an expected call of CreateResponseProducer.
func (*MockSyncClientMockRecorder) QueueRequest ¶ added in v0.2.0
func (mr *MockSyncClientMockRecorder) QueueRequest(ctx, req any) *gomock.Call
QueueRequest indicates an expected call of QueueRequest.
func (*MockSyncClientMockRecorder) SendTreeRequest ¶ added in v0.5.0
func (mr *MockSyncClientMockRecorder) SendTreeRequest(ctx, req, collector any) *gomock.Call
SendTreeRequest indicates an expected call of SendTreeRequest.
type MockSyncTree ¶
type MockSyncTree struct {
// contains filtered or unexported fields
}
MockSyncTree is a mock of SyncTree interface.
func NewMockSyncTree ¶
func NewMockSyncTree(ctrl *gomock.Controller) *MockSyncTree
NewMockSyncTree creates a new mock instance.
func (*MockSyncTree) AclList ¶
func (m *MockSyncTree) AclList() list.AclList
AclList mocks base method.
func (*MockSyncTree) AddContent ¶
func (m *MockSyncTree) AddContent(ctx context.Context, content objecttree.SignableChangeContent) (objecttree.AddResult, error)
AddContent mocks base method.
func (*MockSyncTree) AddContentWithValidator ¶ added in v0.5.1
func (m *MockSyncTree) AddContentWithValidator(ctx context.Context, content objecttree.SignableChangeContent, validate func(*treechangeproto.RawTreeChangeWithId) error) (objecttree.AddResult, error)
AddContentWithValidator mocks base method.
func (*MockSyncTree) AddRawChanges ¶
func (m *MockSyncTree) AddRawChanges(ctx context.Context, changes objecttree.RawChangesPayload) (objecttree.AddResult, error)
AddRawChanges mocks base method.
func (*MockSyncTree) AddRawChangesFromPeer ¶ added in v0.4.22
func (m *MockSyncTree) AddRawChangesFromPeer(ctx context.Context, peerId string, changesPayload objecttree.RawChangesPayload) (objecttree.AddResult, error)
AddRawChangesFromPeer mocks base method.
func (*MockSyncTree) AddRawChangesWithUpdater ¶ added in v0.5.1
func (m *MockSyncTree) AddRawChangesWithUpdater(ctx context.Context, changes objecttree.RawChangesPayload, updater func(objecttree.ObjectTree, objecttree.Mode) error) (objecttree.AddResult, error)
AddRawChangesWithUpdater mocks base method.
func (*MockSyncTree) ChangeInfo ¶
func (m *MockSyncTree) ChangeInfo() *treechangeproto.TreeChangeInfo
ChangeInfo mocks base method.
func (*MockSyncTree) ChangesAfterCommonSnapshot ¶
func (m *MockSyncTree) ChangesAfterCommonSnapshot(snapshotPath, heads []string) ([]*treechangeproto.RawTreeChangeWithId, error)
ChangesAfterCommonSnapshot mocks base method.
func (*MockSyncTree) ChangesAfterCommonSnapshotLoader ¶ added in v0.5.0
func (m *MockSyncTree) ChangesAfterCommonSnapshotLoader(snapshotPath, heads []string) (objecttree.LoadIterator, error)
ChangesAfterCommonSnapshotLoader mocks base method.
func (*MockSyncTree) Debug ¶
func (m *MockSyncTree) Debug(parser objecttree.DescriptionParser) (objecttree.DebugInfo, error)
Debug mocks base method.
func (*MockSyncTree) EXPECT ¶
func (m *MockSyncTree) EXPECT() *MockSyncTreeMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSyncTree) GetChange ¶
func (m *MockSyncTree) GetChange(arg0 string) (*objecttree.Change, error)
GetChange mocks base method.
func (*MockSyncTree) HandleDeprecatedRequest ¶ added in v0.5.0
func (m *MockSyncTree) HandleDeprecatedRequest(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (*spacesyncproto.ObjectSyncMessage, error)
HandleDeprecatedRequest mocks base method.
func (*MockSyncTree) HandleHeadUpdate ¶ added in v0.5.0
func (m *MockSyncTree) HandleHeadUpdate(ctx context.Context, statusUpdater syncstatus.StatusUpdater, headUpdate drpc.Message) (syncdeps.Request, error)
HandleHeadUpdate mocks base method.
func (*MockSyncTree) HandleResponse ¶ added in v0.5.0
func (m *MockSyncTree) HandleResponse(ctx context.Context, peerId, objectId string, resp syncdeps.Response) error
HandleResponse mocks base method.
func (*MockSyncTree) HandleStreamRequest ¶ added in v0.5.0
func (m *MockSyncTree) HandleStreamRequest(ctx context.Context, rq syncdeps.Request, updater syncdeps.QueueSizeUpdater, send func(proto.Message) error) (syncdeps.Request, error)
HandleStreamRequest mocks base method.
func (*MockSyncTree) HasChanges ¶
func (m *MockSyncTree) HasChanges(arg0 ...string) bool
HasChanges mocks base method.
func (*MockSyncTree) Header ¶
func (m *MockSyncTree) Header() *treechangeproto.RawTreeChangeWithId
Header mocks base method.
func (*MockSyncTree) IsDerived ¶ added in v0.3.2
func (m *MockSyncTree) IsDerived() bool
IsDerived mocks base method.
func (*MockSyncTree) IterateFrom ¶
func (m *MockSyncTree) IterateFrom(id string, convert func(*objecttree.Change, []byte) (any, error), iterate func(*objecttree.Change) bool) error
IterateFrom mocks base method.
func (*MockSyncTree) IterateRoot ¶
func (m *MockSyncTree) IterateRoot(convert func(*objecttree.Change, []byte) (any, error), iterate func(*objecttree.Change) bool) error
IterateRoot mocks base method.
func (*MockSyncTree) PrepareChange ¶
func (m *MockSyncTree) PrepareChange(content objecttree.SignableChangeContent) (*treechangeproto.RawTreeChangeWithId, error)
PrepareChange mocks base method.
func (*MockSyncTree) ResponseCollector ¶ added in v0.5.0
func (m *MockSyncTree) ResponseCollector() syncdeps.ResponseCollector
ResponseCollector mocks base method.
func (*MockSyncTree) Root ¶
func (m *MockSyncTree) Root() *objecttree.Change
Root mocks base method.
func (*MockSyncTree) SetFlusher ¶ added in v0.5.1
func (m *MockSyncTree) SetFlusher(flusher objecttree.Flusher)
SetFlusher mocks base method.
func (*MockSyncTree) SetListener ¶
func (m *MockSyncTree) SetListener(listener updatelistener.UpdateListener)
SetListener mocks base method.
func (*MockSyncTree) SnapshotPath ¶
func (m *MockSyncTree) SnapshotPath() []string
SnapshotPath mocks base method.
func (*MockSyncTree) Storage ¶
func (m *MockSyncTree) Storage() treestorage.TreeStorage
Storage mocks base method.
func (*MockSyncTree) SyncWithPeer ¶
SyncWithPeer mocks base method.
func (*MockSyncTree) TryClose ¶
func (m *MockSyncTree) TryClose(objectTTL time.Duration) (bool, error)
TryClose mocks base method.
func (*MockSyncTree) UnmarshalledHeader ¶
func (m *MockSyncTree) UnmarshalledHeader() *objecttree.Change
UnmarshalledHeader mocks base method.
func (*MockSyncTree) UnpackChange ¶
func (m *MockSyncTree) UnpackChange(raw *treechangeproto.RawTreeChangeWithId) ([]byte, error)
UnpackChange mocks base method.
type MockSyncTreeMockRecorder ¶
type MockSyncTreeMockRecorder struct {
// contains filtered or unexported fields
}
MockSyncTreeMockRecorder is the mock recorder for MockSyncTree.
func (*MockSyncTreeMockRecorder) AclList ¶
func (mr *MockSyncTreeMockRecorder) AclList() *gomock.Call
AclList indicates an expected call of AclList.
func (*MockSyncTreeMockRecorder) AddContent ¶
func (mr *MockSyncTreeMockRecorder) AddContent(ctx, content any) *gomock.Call
AddContent indicates an expected call of AddContent.
func (*MockSyncTreeMockRecorder) AddContentWithValidator ¶ added in v0.5.1
func (mr *MockSyncTreeMockRecorder) AddContentWithValidator(ctx, content, validate any) *gomock.Call
AddContentWithValidator indicates an expected call of AddContentWithValidator.
func (*MockSyncTreeMockRecorder) AddRawChanges ¶
func (mr *MockSyncTreeMockRecorder) AddRawChanges(ctx, changes any) *gomock.Call
AddRawChanges indicates an expected call of AddRawChanges.
func (*MockSyncTreeMockRecorder) AddRawChangesFromPeer ¶ added in v0.4.22
func (mr *MockSyncTreeMockRecorder) AddRawChangesFromPeer(ctx, peerId, changesPayload any) *gomock.Call
AddRawChangesFromPeer indicates an expected call of AddRawChangesFromPeer.
func (*MockSyncTreeMockRecorder) AddRawChangesWithUpdater ¶ added in v0.5.1
func (mr *MockSyncTreeMockRecorder) AddRawChangesWithUpdater(ctx, changes, updater any) *gomock.Call
AddRawChangesWithUpdater indicates an expected call of AddRawChangesWithUpdater.
func (*MockSyncTreeMockRecorder) ChangeInfo ¶
func (mr *MockSyncTreeMockRecorder) ChangeInfo() *gomock.Call
ChangeInfo indicates an expected call of ChangeInfo.
func (*MockSyncTreeMockRecorder) ChangesAfterCommonSnapshot ¶
func (mr *MockSyncTreeMockRecorder) ChangesAfterCommonSnapshot(snapshotPath, heads any) *gomock.Call
ChangesAfterCommonSnapshot indicates an expected call of ChangesAfterCommonSnapshot.
func (*MockSyncTreeMockRecorder) ChangesAfterCommonSnapshotLoader ¶ added in v0.5.0
func (mr *MockSyncTreeMockRecorder) ChangesAfterCommonSnapshotLoader(snapshotPath, heads any) *gomock.Call
ChangesAfterCommonSnapshotLoader indicates an expected call of ChangesAfterCommonSnapshotLoader.
func (*MockSyncTreeMockRecorder) Close ¶
func (mr *MockSyncTreeMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockSyncTreeMockRecorder) Debug ¶
func (mr *MockSyncTreeMockRecorder) Debug(parser any) *gomock.Call
Debug indicates an expected call of Debug.
func (*MockSyncTreeMockRecorder) Delete ¶
func (mr *MockSyncTreeMockRecorder) Delete() *gomock.Call
Delete indicates an expected call of Delete.
func (*MockSyncTreeMockRecorder) GetChange ¶
func (mr *MockSyncTreeMockRecorder) GetChange(arg0 any) *gomock.Call
GetChange indicates an expected call of GetChange.
func (*MockSyncTreeMockRecorder) HandleDeprecatedRequest ¶ added in v0.5.0
func (mr *MockSyncTreeMockRecorder) HandleDeprecatedRequest(ctx, req any) *gomock.Call
HandleDeprecatedRequest indicates an expected call of HandleDeprecatedRequest.
func (*MockSyncTreeMockRecorder) HandleHeadUpdate ¶ added in v0.5.0
func (mr *MockSyncTreeMockRecorder) HandleHeadUpdate(ctx, statusUpdater, headUpdate any) *gomock.Call
HandleHeadUpdate indicates an expected call of HandleHeadUpdate.
func (*MockSyncTreeMockRecorder) HandleResponse ¶ added in v0.5.0
func (mr *MockSyncTreeMockRecorder) HandleResponse(ctx, peerId, objectId, resp any) *gomock.Call
HandleResponse indicates an expected call of HandleResponse.
func (*MockSyncTreeMockRecorder) HandleStreamRequest ¶ added in v0.5.0
func (mr *MockSyncTreeMockRecorder) HandleStreamRequest(ctx, rq, updater, send any) *gomock.Call
HandleStreamRequest indicates an expected call of HandleStreamRequest.
func (*MockSyncTreeMockRecorder) HasChanges ¶
func (mr *MockSyncTreeMockRecorder) HasChanges(arg0 ...any) *gomock.Call
HasChanges indicates an expected call of HasChanges.
func (*MockSyncTreeMockRecorder) Header ¶
func (mr *MockSyncTreeMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockSyncTreeMockRecorder) Heads ¶
func (mr *MockSyncTreeMockRecorder) Heads() *gomock.Call
Heads indicates an expected call of Heads.
func (*MockSyncTreeMockRecorder) Id ¶
func (mr *MockSyncTreeMockRecorder) Id() *gomock.Call
Id indicates an expected call of Id.
func (*MockSyncTreeMockRecorder) IsDerived ¶ added in v0.3.2
func (mr *MockSyncTreeMockRecorder) IsDerived() *gomock.Call
IsDerived indicates an expected call of IsDerived.
func (*MockSyncTreeMockRecorder) IterateFrom ¶
func (mr *MockSyncTreeMockRecorder) IterateFrom(id, convert, iterate any) *gomock.Call
IterateFrom indicates an expected call of IterateFrom.
func (*MockSyncTreeMockRecorder) IterateRoot ¶
func (mr *MockSyncTreeMockRecorder) IterateRoot(convert, iterate any) *gomock.Call
IterateRoot indicates an expected call of IterateRoot.
func (*MockSyncTreeMockRecorder) Len ¶
func (mr *MockSyncTreeMockRecorder) Len() *gomock.Call
Len indicates an expected call of Len.
func (*MockSyncTreeMockRecorder) Lock ¶
func (mr *MockSyncTreeMockRecorder) Lock() *gomock.Call
Lock indicates an expected call of Lock.
func (*MockSyncTreeMockRecorder) PrepareChange ¶
func (mr *MockSyncTreeMockRecorder) PrepareChange(content any) *gomock.Call
PrepareChange indicates an expected call of PrepareChange.
func (*MockSyncTreeMockRecorder) ResponseCollector ¶ added in v0.5.0
func (mr *MockSyncTreeMockRecorder) ResponseCollector() *gomock.Call
ResponseCollector indicates an expected call of ResponseCollector.
func (*MockSyncTreeMockRecorder) Root ¶
func (mr *MockSyncTreeMockRecorder) Root() *gomock.Call
Root indicates an expected call of Root.
func (*MockSyncTreeMockRecorder) SetFlusher ¶ added in v0.5.1
func (mr *MockSyncTreeMockRecorder) SetFlusher(flusher any) *gomock.Call
SetFlusher indicates an expected call of SetFlusher.
func (*MockSyncTreeMockRecorder) SetListener ¶
func (mr *MockSyncTreeMockRecorder) SetListener(listener any) *gomock.Call
SetListener indicates an expected call of SetListener.
func (*MockSyncTreeMockRecorder) SnapshotPath ¶
func (mr *MockSyncTreeMockRecorder) SnapshotPath() *gomock.Call
SnapshotPath indicates an expected call of SnapshotPath.
func (*MockSyncTreeMockRecorder) Storage ¶
func (mr *MockSyncTreeMockRecorder) Storage() *gomock.Call
Storage indicates an expected call of Storage.
func (*MockSyncTreeMockRecorder) SyncWithPeer ¶
func (mr *MockSyncTreeMockRecorder) SyncWithPeer(ctx, p any) *gomock.Call
SyncWithPeer indicates an expected call of SyncWithPeer.
func (*MockSyncTreeMockRecorder) TryClose ¶
func (mr *MockSyncTreeMockRecorder) TryClose(objectTTL any) *gomock.Call
TryClose indicates an expected call of TryClose.
func (*MockSyncTreeMockRecorder) TryLock ¶
func (mr *MockSyncTreeMockRecorder) TryLock() *gomock.Call
TryLock indicates an expected call of TryLock.
func (*MockSyncTreeMockRecorder) Unlock ¶
func (mr *MockSyncTreeMockRecorder) Unlock() *gomock.Call
Unlock indicates an expected call of Unlock.
func (*MockSyncTreeMockRecorder) UnmarshalledHeader ¶
func (mr *MockSyncTreeMockRecorder) UnmarshalledHeader() *gomock.Call
UnmarshalledHeader indicates an expected call of UnmarshalledHeader.
func (*MockSyncTreeMockRecorder) UnpackChange ¶
func (mr *MockSyncTreeMockRecorder) UnpackChange(raw any) *gomock.Call
UnpackChange indicates an expected call of UnpackChange.