Documentation ¶
Overview ¶
Package mock_syncacl is a generated GoMock package.
Index ¶
- type MockSyncAcl
- func (m *MockSyncAcl) AclState() *list.AclState
- func (m *MockSyncAcl) AddRawRecord(rawRec *consensusproto.RawRecordWithId) error
- func (m *MockSyncAcl) AddRawRecords(rawRecords []*consensusproto.RawRecordWithId) error
- func (m *MockSyncAcl) Close(ctx context.Context) error
- func (m *MockSyncAcl) EXPECT() *MockSyncAclMockRecorder
- func (m *MockSyncAcl) Get(id string) (*list.AclRecord, error)
- func (m *MockSyncAcl) GetIndex(idx int) (*list.AclRecord, error)
- func (m *MockSyncAcl) HandleDeprecatedRequest(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (*spacesyncproto.ObjectSyncMessage, error)
- func (m *MockSyncAcl) HandleHeadUpdate(ctx context.Context, statusUpdater syncstatus.StatusUpdater, ...) (syncdeps.Request, error)
- func (m *MockSyncAcl) HandleResponse(ctx context.Context, peerId, objectId string, resp syncdeps.Response) error
- func (m *MockSyncAcl) HandleStreamRequest(ctx context.Context, rq syncdeps.Request, updater syncdeps.QueueSizeUpdater, ...) (syncdeps.Request, error)
- func (m *MockSyncAcl) HasHead(head string) bool
- func (m *MockSyncAcl) Head() *list.AclRecord
- func (m *MockSyncAcl) Id() string
- func (m *MockSyncAcl) Init(a *app.App) error
- func (m *MockSyncAcl) IsAfter(first, second string) (bool, error)
- func (m *MockSyncAcl) Iterate(iterFunc func(*list.AclRecord) bool)
- func (m *MockSyncAcl) IterateFrom(startId string, iterFunc func(*list.AclRecord) bool)
- func (m *MockSyncAcl) KeyStorage() crypto.KeyStorage
- func (m *MockSyncAcl) Lock()
- func (m *MockSyncAcl) Name() string
- func (m *MockSyncAcl) RLock()
- func (m *MockSyncAcl) RUnlock()
- func (m *MockSyncAcl) RecordBuilder() list.AclRecordBuilder
- func (m *MockSyncAcl) Records() []*list.AclRecord
- func (m *MockSyncAcl) RecordsAfter(ctx context.Context, id string) ([]*consensusproto.RawRecordWithId, error)
- func (m *MockSyncAcl) RecordsBefore(ctx context.Context, headId string) ([]*consensusproto.RawRecordWithId, error)
- func (m *MockSyncAcl) ResponseCollector() syncdeps.ResponseCollector
- func (m *MockSyncAcl) Root() *consensusproto.RawRecordWithId
- func (m *MockSyncAcl) Run(ctx context.Context) error
- func (m *MockSyncAcl) SetAclUpdater(updater headupdater.AclUpdater)
- func (m *MockSyncAcl) SetHeadUpdater(updater headupdater.HeadUpdater)
- func (m *MockSyncAcl) SyncWithPeer(ctx context.Context, p peer.Peer) error
- func (m *MockSyncAcl) Unlock()
- func (m *MockSyncAcl) ValidateRawRecord(rawRec *consensusproto.RawRecord, afterValid func(*list.AclState) error) error
- type MockSyncAclMockRecorder
- func (mr *MockSyncAclMockRecorder) AclState() *gomock.Call
- func (mr *MockSyncAclMockRecorder) AddRawRecord(rawRec any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) AddRawRecords(rawRecords any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) Close(ctx any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) Get(id any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) GetIndex(idx any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) HandleDeprecatedRequest(ctx, req any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) HandleHeadUpdate(ctx, statusUpdater, headUpdate any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) HandleResponse(ctx, peerId, objectId, resp any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) HandleStreamRequest(ctx, rq, updater, send any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) HasHead(head any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) Head() *gomock.Call
- func (mr *MockSyncAclMockRecorder) Id() *gomock.Call
- func (mr *MockSyncAclMockRecorder) Init(a any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) IsAfter(first, second any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) Iterate(iterFunc any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) IterateFrom(startId, iterFunc any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) KeyStorage() *gomock.Call
- func (mr *MockSyncAclMockRecorder) Lock() *gomock.Call
- func (mr *MockSyncAclMockRecorder) Name() *gomock.Call
- func (mr *MockSyncAclMockRecorder) RLock() *gomock.Call
- func (mr *MockSyncAclMockRecorder) RUnlock() *gomock.Call
- func (mr *MockSyncAclMockRecorder) RecordBuilder() *gomock.Call
- func (mr *MockSyncAclMockRecorder) Records() *gomock.Call
- func (mr *MockSyncAclMockRecorder) RecordsAfter(ctx, id any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) RecordsBefore(ctx, headId any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) ResponseCollector() *gomock.Call
- func (mr *MockSyncAclMockRecorder) Root() *gomock.Call
- func (mr *MockSyncAclMockRecorder) Run(ctx any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) SetAclUpdater(updater any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) SetHeadUpdater(updater any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) SyncWithPeer(ctx, p any) *gomock.Call
- func (mr *MockSyncAclMockRecorder) Unlock() *gomock.Call
- func (mr *MockSyncAclMockRecorder) ValidateRawRecord(rawRec, afterValid any) *gomock.Call
- type MockSyncClient
- func (m *MockSyncClient) Broadcast(ctx context.Context, headUpdate *objectmessages.HeadUpdate) error
- func (m *MockSyncClient) CreateFullSyncRequest(peerId string, l list.AclList) *objectmessages.Request
- func (m *MockSyncClient) CreateFullSyncResponse(l list.AclList, theirHead string) (*response.Response, error)
- func (m *MockSyncClient) CreateHeadUpdate(l list.AclList, added []*consensusproto.RawRecordWithId) (*objectmessages.HeadUpdate, error)
- func (m *MockSyncClient) EXPECT() *MockSyncClientMockRecorder
- func (m *MockSyncClient) QueueRequest(ctx context.Context, req syncdeps.Request) error
- type MockSyncClientMockRecorder
- func (mr *MockSyncClientMockRecorder) Broadcast(ctx, headUpdate any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) CreateFullSyncRequest(peerId, l any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) CreateFullSyncResponse(l, theirHead any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) CreateHeadUpdate(l, added any) *gomock.Call
- func (mr *MockSyncClientMockRecorder) QueueRequest(ctx, req any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockSyncAcl ¶
type MockSyncAcl struct {
// contains filtered or unexported fields
}
MockSyncAcl is a mock of SyncAcl interface.
func NewMockSyncAcl ¶
func NewMockSyncAcl(ctrl *gomock.Controller) *MockSyncAcl
NewMockSyncAcl creates a new mock instance.
func (*MockSyncAcl) AclState ¶
func (m *MockSyncAcl) AclState() *list.AclState
AclState mocks base method.
func (*MockSyncAcl) AddRawRecord ¶
func (m *MockSyncAcl) AddRawRecord(rawRec *consensusproto.RawRecordWithId) error
AddRawRecord mocks base method.
func (*MockSyncAcl) AddRawRecords ¶
func (m *MockSyncAcl) AddRawRecords(rawRecords []*consensusproto.RawRecordWithId) error
AddRawRecords mocks base method.
func (*MockSyncAcl) Close ¶
func (m *MockSyncAcl) Close(ctx context.Context) error
Close mocks base method.
func (*MockSyncAcl) EXPECT ¶
func (m *MockSyncAcl) EXPECT() *MockSyncAclMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSyncAcl) Get ¶
func (m *MockSyncAcl) Get(id string) (*list.AclRecord, error)
Get mocks base method.
func (*MockSyncAcl) GetIndex ¶
func (m *MockSyncAcl) GetIndex(idx int) (*list.AclRecord, error)
GetIndex mocks base method.
func (*MockSyncAcl) HandleDeprecatedRequest ¶ added in v0.5.0
func (m *MockSyncAcl) HandleDeprecatedRequest(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (*spacesyncproto.ObjectSyncMessage, error)
HandleDeprecatedRequest mocks base method.
func (*MockSyncAcl) HandleHeadUpdate ¶ added in v0.5.0
func (m *MockSyncAcl) HandleHeadUpdate(ctx context.Context, statusUpdater syncstatus.StatusUpdater, headUpdate drpc.Message) (syncdeps.Request, error)
HandleHeadUpdate mocks base method.
func (*MockSyncAcl) HandleResponse ¶ added in v0.5.0
func (m *MockSyncAcl) HandleResponse(ctx context.Context, peerId, objectId string, resp syncdeps.Response) error
HandleResponse mocks base method.
func (*MockSyncAcl) HandleStreamRequest ¶ added in v0.5.0
func (m *MockSyncAcl) HandleStreamRequest(ctx context.Context, rq syncdeps.Request, updater syncdeps.QueueSizeUpdater, send func(proto.Message) error) (syncdeps.Request, error)
HandleStreamRequest mocks base method.
func (*MockSyncAcl) HasHead ¶
func (m *MockSyncAcl) HasHead(head string) bool
HasHead mocks base method.
func (*MockSyncAcl) IsAfter ¶
func (m *MockSyncAcl) IsAfter(first, second string) (bool, error)
IsAfter mocks base method.
func (*MockSyncAcl) Iterate ¶
func (m *MockSyncAcl) Iterate(iterFunc func(*list.AclRecord) bool)
Iterate mocks base method.
func (*MockSyncAcl) IterateFrom ¶
func (m *MockSyncAcl) IterateFrom(startId string, iterFunc func(*list.AclRecord) bool)
IterateFrom mocks base method.
func (*MockSyncAcl) KeyStorage ¶
func (m *MockSyncAcl) KeyStorage() crypto.KeyStorage
KeyStorage mocks base method.
func (*MockSyncAcl) RecordBuilder ¶
func (m *MockSyncAcl) RecordBuilder() list.AclRecordBuilder
RecordBuilder mocks base method.
func (*MockSyncAcl) Records ¶
func (m *MockSyncAcl) Records() []*list.AclRecord
Records mocks base method.
func (*MockSyncAcl) RecordsAfter ¶
func (m *MockSyncAcl) RecordsAfter(ctx context.Context, id string) ([]*consensusproto.RawRecordWithId, error)
RecordsAfter mocks base method.
func (*MockSyncAcl) RecordsBefore ¶
func (m *MockSyncAcl) RecordsBefore(ctx context.Context, headId string) ([]*consensusproto.RawRecordWithId, error)
RecordsBefore mocks base method.
func (*MockSyncAcl) ResponseCollector ¶ added in v0.5.0
func (m *MockSyncAcl) ResponseCollector() syncdeps.ResponseCollector
ResponseCollector mocks base method.
func (*MockSyncAcl) Root ¶
func (m *MockSyncAcl) Root() *consensusproto.RawRecordWithId
Root mocks base method.
func (*MockSyncAcl) Run ¶
func (m *MockSyncAcl) Run(ctx context.Context) error
Run mocks base method.
func (*MockSyncAcl) SetAclUpdater ¶ added in v0.3.0
func (m *MockSyncAcl) SetAclUpdater(updater headupdater.AclUpdater)
SetAclUpdater mocks base method.
func (*MockSyncAcl) SetHeadUpdater ¶
func (m *MockSyncAcl) SetHeadUpdater(updater headupdater.HeadUpdater)
SetHeadUpdater mocks base method.
func (*MockSyncAcl) SyncWithPeer ¶
SyncWithPeer mocks base method.
func (*MockSyncAcl) ValidateRawRecord ¶
func (m *MockSyncAcl) ValidateRawRecord(rawRec *consensusproto.RawRecord, afterValid func(*list.AclState) error) error
ValidateRawRecord mocks base method.
type MockSyncAclMockRecorder ¶
type MockSyncAclMockRecorder struct {
// contains filtered or unexported fields
}
MockSyncAclMockRecorder is the mock recorder for MockSyncAcl.
func (*MockSyncAclMockRecorder) AclState ¶
func (mr *MockSyncAclMockRecorder) AclState() *gomock.Call
AclState indicates an expected call of AclState.
func (*MockSyncAclMockRecorder) AddRawRecord ¶
func (mr *MockSyncAclMockRecorder) AddRawRecord(rawRec any) *gomock.Call
AddRawRecord indicates an expected call of AddRawRecord.
func (*MockSyncAclMockRecorder) AddRawRecords ¶
func (mr *MockSyncAclMockRecorder) AddRawRecords(rawRecords any) *gomock.Call
AddRawRecords indicates an expected call of AddRawRecords.
func (*MockSyncAclMockRecorder) Close ¶
func (mr *MockSyncAclMockRecorder) Close(ctx any) *gomock.Call
Close indicates an expected call of Close.
func (*MockSyncAclMockRecorder) Get ¶
func (mr *MockSyncAclMockRecorder) Get(id any) *gomock.Call
Get indicates an expected call of Get.
func (*MockSyncAclMockRecorder) GetIndex ¶
func (mr *MockSyncAclMockRecorder) GetIndex(idx any) *gomock.Call
GetIndex indicates an expected call of GetIndex.
func (*MockSyncAclMockRecorder) HandleDeprecatedRequest ¶ added in v0.5.0
func (mr *MockSyncAclMockRecorder) HandleDeprecatedRequest(ctx, req any) *gomock.Call
HandleDeprecatedRequest indicates an expected call of HandleDeprecatedRequest.
func (*MockSyncAclMockRecorder) HandleHeadUpdate ¶ added in v0.5.0
func (mr *MockSyncAclMockRecorder) HandleHeadUpdate(ctx, statusUpdater, headUpdate any) *gomock.Call
HandleHeadUpdate indicates an expected call of HandleHeadUpdate.
func (*MockSyncAclMockRecorder) HandleResponse ¶ added in v0.5.0
func (mr *MockSyncAclMockRecorder) HandleResponse(ctx, peerId, objectId, resp any) *gomock.Call
HandleResponse indicates an expected call of HandleResponse.
func (*MockSyncAclMockRecorder) HandleStreamRequest ¶ added in v0.5.0
func (mr *MockSyncAclMockRecorder) HandleStreamRequest(ctx, rq, updater, send any) *gomock.Call
HandleStreamRequest indicates an expected call of HandleStreamRequest.
func (*MockSyncAclMockRecorder) HasHead ¶
func (mr *MockSyncAclMockRecorder) HasHead(head any) *gomock.Call
HasHead indicates an expected call of HasHead.
func (*MockSyncAclMockRecorder) Head ¶
func (mr *MockSyncAclMockRecorder) Head() *gomock.Call
Head indicates an expected call of Head.
func (*MockSyncAclMockRecorder) Id ¶
func (mr *MockSyncAclMockRecorder) Id() *gomock.Call
Id indicates an expected call of Id.
func (*MockSyncAclMockRecorder) Init ¶
func (mr *MockSyncAclMockRecorder) Init(a any) *gomock.Call
Init indicates an expected call of Init.
func (*MockSyncAclMockRecorder) IsAfter ¶
func (mr *MockSyncAclMockRecorder) IsAfter(first, second any) *gomock.Call
IsAfter indicates an expected call of IsAfter.
func (*MockSyncAclMockRecorder) Iterate ¶
func (mr *MockSyncAclMockRecorder) Iterate(iterFunc any) *gomock.Call
Iterate indicates an expected call of Iterate.
func (*MockSyncAclMockRecorder) IterateFrom ¶
func (mr *MockSyncAclMockRecorder) IterateFrom(startId, iterFunc any) *gomock.Call
IterateFrom indicates an expected call of IterateFrom.
func (*MockSyncAclMockRecorder) KeyStorage ¶
func (mr *MockSyncAclMockRecorder) KeyStorage() *gomock.Call
KeyStorage indicates an expected call of KeyStorage.
func (*MockSyncAclMockRecorder) Lock ¶
func (mr *MockSyncAclMockRecorder) Lock() *gomock.Call
Lock indicates an expected call of Lock.
func (*MockSyncAclMockRecorder) Name ¶
func (mr *MockSyncAclMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockSyncAclMockRecorder) RLock ¶
func (mr *MockSyncAclMockRecorder) RLock() *gomock.Call
RLock indicates an expected call of RLock.
func (*MockSyncAclMockRecorder) RUnlock ¶
func (mr *MockSyncAclMockRecorder) RUnlock() *gomock.Call
RUnlock indicates an expected call of RUnlock.
func (*MockSyncAclMockRecorder) RecordBuilder ¶
func (mr *MockSyncAclMockRecorder) RecordBuilder() *gomock.Call
RecordBuilder indicates an expected call of RecordBuilder.
func (*MockSyncAclMockRecorder) Records ¶
func (mr *MockSyncAclMockRecorder) Records() *gomock.Call
Records indicates an expected call of Records.
func (*MockSyncAclMockRecorder) RecordsAfter ¶
func (mr *MockSyncAclMockRecorder) RecordsAfter(ctx, id any) *gomock.Call
RecordsAfter indicates an expected call of RecordsAfter.
func (*MockSyncAclMockRecorder) RecordsBefore ¶
func (mr *MockSyncAclMockRecorder) RecordsBefore(ctx, headId any) *gomock.Call
RecordsBefore indicates an expected call of RecordsBefore.
func (*MockSyncAclMockRecorder) ResponseCollector ¶ added in v0.5.0
func (mr *MockSyncAclMockRecorder) ResponseCollector() *gomock.Call
ResponseCollector indicates an expected call of ResponseCollector.
func (*MockSyncAclMockRecorder) Root ¶
func (mr *MockSyncAclMockRecorder) Root() *gomock.Call
Root indicates an expected call of Root.
func (*MockSyncAclMockRecorder) Run ¶
func (mr *MockSyncAclMockRecorder) Run(ctx any) *gomock.Call
Run indicates an expected call of Run.
func (*MockSyncAclMockRecorder) SetAclUpdater ¶ added in v0.3.0
func (mr *MockSyncAclMockRecorder) SetAclUpdater(updater any) *gomock.Call
SetAclUpdater indicates an expected call of SetAclUpdater.
func (*MockSyncAclMockRecorder) SetHeadUpdater ¶
func (mr *MockSyncAclMockRecorder) SetHeadUpdater(updater any) *gomock.Call
SetHeadUpdater indicates an expected call of SetHeadUpdater.
func (*MockSyncAclMockRecorder) SyncWithPeer ¶
func (mr *MockSyncAclMockRecorder) SyncWithPeer(ctx, p any) *gomock.Call
SyncWithPeer indicates an expected call of SyncWithPeer.
func (*MockSyncAclMockRecorder) Unlock ¶
func (mr *MockSyncAclMockRecorder) Unlock() *gomock.Call
Unlock indicates an expected call of Unlock.
func (*MockSyncAclMockRecorder) ValidateRawRecord ¶
func (mr *MockSyncAclMockRecorder) ValidateRawRecord(rawRec, afterValid any) *gomock.Call
ValidateRawRecord indicates an expected call of ValidateRawRecord.
type MockSyncClient ¶
type MockSyncClient struct {
// contains filtered or unexported fields
}
MockSyncClient is a mock of SyncClient interface.
func NewMockSyncClient ¶
func NewMockSyncClient(ctrl *gomock.Controller) *MockSyncClient
NewMockSyncClient creates a new mock instance.
func (*MockSyncClient) Broadcast ¶
func (m *MockSyncClient) Broadcast(ctx context.Context, headUpdate *objectmessages.HeadUpdate) error
Broadcast mocks base method.
func (*MockSyncClient) CreateFullSyncRequest ¶
func (m *MockSyncClient) CreateFullSyncRequest(peerId string, l list.AclList) *objectmessages.Request
CreateFullSyncRequest mocks base method.
func (*MockSyncClient) CreateFullSyncResponse ¶
func (m *MockSyncClient) CreateFullSyncResponse(l list.AclList, theirHead string) (*response.Response, error)
CreateFullSyncResponse mocks base method.
func (*MockSyncClient) CreateHeadUpdate ¶
func (m *MockSyncClient) CreateHeadUpdate(l list.AclList, added []*consensusproto.RawRecordWithId) (*objectmessages.HeadUpdate, error)
CreateHeadUpdate mocks base method.
func (*MockSyncClient) EXPECT ¶
func (m *MockSyncClient) EXPECT() *MockSyncClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSyncClient) QueueRequest ¶
QueueRequest mocks base method.
type MockSyncClientMockRecorder ¶
type MockSyncClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSyncClientMockRecorder is the mock recorder for MockSyncClient.
func (*MockSyncClientMockRecorder) Broadcast ¶
func (mr *MockSyncClientMockRecorder) Broadcast(ctx, headUpdate any) *gomock.Call
Broadcast indicates an expected call of Broadcast.
func (*MockSyncClientMockRecorder) CreateFullSyncRequest ¶
func (mr *MockSyncClientMockRecorder) CreateFullSyncRequest(peerId, l any) *gomock.Call
CreateFullSyncRequest indicates an expected call of CreateFullSyncRequest.
func (*MockSyncClientMockRecorder) CreateFullSyncResponse ¶
func (mr *MockSyncClientMockRecorder) CreateFullSyncResponse(l, theirHead any) *gomock.Call
CreateFullSyncResponse indicates an expected call of CreateFullSyncResponse.
func (*MockSyncClientMockRecorder) CreateHeadUpdate ¶
func (mr *MockSyncClientMockRecorder) CreateHeadUpdate(l, added any) *gomock.Call
CreateHeadUpdate indicates an expected call of CreateHeadUpdate.
func (*MockSyncClientMockRecorder) QueueRequest ¶
func (mr *MockSyncClientMockRecorder) QueueRequest(ctx, req any) *gomock.Call
QueueRequest indicates an expected call of QueueRequest.