Documentation ¶
Index ¶
- type MockCore
- func (_m *MockCore) Close()
- func (_m *MockCore) EXPECT() *_MockCoreRecorder
- func (_m *MockCore) Reflect(_param0 api.ReflectionType, _param1 api.Command)
- func (_m *MockCore) Replicate(_param0 []crdt.Link, _param1 api.Command)
- func (_m *MockCore) RunQuery(_param0 *query.Query, _param1 api.Command)
- func (_m *MockCore) WriteMemoryImage() error
- type MockDataPeer
- func (_m *MockDataPeer) Add(_param0 io.Reader) (string, error)
- func (_m *MockDataPeer) Cat(_param0 string) (io.ReadCloser, error)
- func (_m *MockDataPeer) Connect() error
- func (_m *MockDataPeer) Disconnect() error
- func (_m *MockDataPeer) EXPECT() *_MockDataPeerRecorder
- func (_m *MockDataPeer) IsUp() bool
- func (_m *MockDataPeer) PubSubPublish(_param0 string, _param1 string) error
- func (_m *MockDataPeer) PubSubSubscribe(_param0 string) (api.PubSubSubscription, error)
- type MockNamespaceSearcher
- type MockPubSubRecord
- type MockPubSubSubscription
- type MockQueryVisitor
- func (_m *MockQueryVisitor) EXPECT() *_MockQueryVisitorRecorder
- func (_m *MockQueryVisitor) LeaveJoin(_param0 *query.QueryJoin)
- func (_m *MockQueryVisitor) LeaveSelect(_param0 *query.QuerySelect)
- func (_m *MockQueryVisitor) LeaveWhere(_param0 *query.QueryWhere)
- func (_m *MockQueryVisitor) VisitAST(_param0 *query.QueryAST)
- func (_m *MockQueryVisitor) VisitJoin(_param0 *query.QueryJoin)
- func (_m *MockQueryVisitor) VisitOpCode(_param0 query.QueryOpCode)
- func (_m *MockQueryVisitor) VisitParser(_param0 *query.QueryParser)
- func (_m *MockQueryVisitor) VisitPredicate(_param0 *query.QueryPredicate)
- func (_m *MockQueryVisitor) VisitPublicKeyHash(_param0 crypto.PublicKeyHash)
- func (_m *MockQueryVisitor) VisitRowJoin(_param0 int, _param1 *query.QueryRowJoin)
- func (_m *MockQueryVisitor) VisitSelect(_param0 *query.QuerySelect)
- func (_m *MockQueryVisitor) VisitTableKey(_param0 crdt.TableName)
- func (_m *MockQueryVisitor) VisitWhere(_param0 int, _param1 *query.QueryWhere)
- type MockRemoteNamespace
- type MockRemoteStore
- func (_m *MockRemoteStore) AddIndex(_param0 crdt.Index) (crdt.IPFSPath, error)
- func (_m *MockRemoteStore) AddNamespace(_param0 crdt.Namespace) (crdt.IPFSPath, error)
- func (_m *MockRemoteStore) CatIndex(_param0 crdt.IPFSPath) (crdt.Index, error)
- func (_m *MockRemoteStore) CatNamespace(_param0 crdt.IPFSPath) (crdt.Namespace, error)
- func (_m *MockRemoteStore) Connect() error
- func (_m *MockRemoteStore) Disconnect() error
- func (_m *MockRemoteStore) EXPECT() *_MockRemoteStoreRecorder
- func (_m *MockRemoteStore) PublishAddr(_param0 crdt.Link, _param1 []api.PubSubTopic) error
- func (_m *MockRemoteStore) SubscribeAddrStream(_param0 api.PubSubTopic) (<-chan crdt.Link, <-chan error)
- type MockService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCore ¶
type MockCore struct {
// contains filtered or unexported fields
}
Mock of Core interface
func NewMockCore ¶
func NewMockCore(ctrl *gomock.Controller) *MockCore
func (*MockCore) Reflect ¶
func (_m *MockCore) Reflect(_param0 api.ReflectionType, _param1 api.Command)
func (*MockCore) WriteMemoryImage ¶
type MockDataPeer ¶
type MockDataPeer struct {
// contains filtered or unexported fields
}
Mock of DataPeer interface
func NewMockDataPeer ¶
func NewMockDataPeer(ctrl *gomock.Controller) *MockDataPeer
func (*MockDataPeer) Cat ¶
func (_m *MockDataPeer) Cat(_param0 string) (io.ReadCloser, error)
func (*MockDataPeer) Connect ¶
func (_m *MockDataPeer) Connect() error
func (*MockDataPeer) Disconnect ¶
func (_m *MockDataPeer) Disconnect() error
func (*MockDataPeer) EXPECT ¶
func (_m *MockDataPeer) EXPECT() *_MockDataPeerRecorder
func (*MockDataPeer) IsUp ¶
func (_m *MockDataPeer) IsUp() bool
func (*MockDataPeer) PubSubPublish ¶
func (_m *MockDataPeer) PubSubPublish(_param0 string, _param1 string) error
func (*MockDataPeer) PubSubSubscribe ¶
func (_m *MockDataPeer) PubSubSubscribe(_param0 string) (api.PubSubSubscription, error)
type MockNamespaceSearcher ¶
type MockNamespaceSearcher struct {
// contains filtered or unexported fields
}
Mock of NamespaceSearcher interface
func NewMockNamespaceSearcher ¶
func NewMockNamespaceSearcher(ctrl *gomock.Controller) *MockNamespaceSearcher
func (*MockNamespaceSearcher) EXPECT ¶
func (_m *MockNamespaceSearcher) EXPECT() *_MockNamespaceSearcherRecorder
func (*MockNamespaceSearcher) ReadSearchResult ¶
func (_m *MockNamespaceSearcher) ReadSearchResult(_param0 api.SearchResult) api.TraversalUpdate
type MockPubSubRecord ¶
type MockPubSubRecord struct {
// contains filtered or unexported fields
}
Mock of PubSubRecord interface
func NewMockPubSubRecord ¶
func NewMockPubSubRecord(ctrl *gomock.Controller) *MockPubSubRecord
func (*MockPubSubRecord) Data ¶
func (_m *MockPubSubRecord) Data() []byte
func (*MockPubSubRecord) EXPECT ¶
func (_m *MockPubSubRecord) EXPECT() *_MockPubSubRecordRecorder
func (*MockPubSubRecord) From ¶
func (_m *MockPubSubRecord) From() string
func (*MockPubSubRecord) SeqNo ¶
func (_m *MockPubSubRecord) SeqNo() int64
func (*MockPubSubRecord) TopicIDs ¶
func (_m *MockPubSubRecord) TopicIDs() []string
type MockPubSubSubscription ¶
type MockPubSubSubscription struct {
// contains filtered or unexported fields
}
Mock of PubSubSubscription interface
func NewMockPubSubSubscription ¶
func NewMockPubSubSubscription(ctrl *gomock.Controller) *MockPubSubSubscription
func (*MockPubSubSubscription) EXPECT ¶
func (_m *MockPubSubSubscription) EXPECT() *_MockPubSubSubscriptionRecorder
func (*MockPubSubSubscription) Next ¶
func (_m *MockPubSubSubscription) Next() (api.PubSubRecord, error)
type MockQueryVisitor ¶
type MockQueryVisitor struct {
// contains filtered or unexported fields
}
Mock of QueryVisitor interface
func NewMockQueryVisitor ¶
func NewMockQueryVisitor(ctrl *gomock.Controller) *MockQueryVisitor
func (*MockQueryVisitor) EXPECT ¶
func (_m *MockQueryVisitor) EXPECT() *_MockQueryVisitorRecorder
func (*MockQueryVisitor) LeaveJoin ¶
func (_m *MockQueryVisitor) LeaveJoin(_param0 *query.QueryJoin)
func (*MockQueryVisitor) LeaveSelect ¶
func (_m *MockQueryVisitor) LeaveSelect(_param0 *query.QuerySelect)
func (*MockQueryVisitor) LeaveWhere ¶
func (_m *MockQueryVisitor) LeaveWhere(_param0 *query.QueryWhere)
func (*MockQueryVisitor) VisitAST ¶
func (_m *MockQueryVisitor) VisitAST(_param0 *query.QueryAST)
func (*MockQueryVisitor) VisitJoin ¶
func (_m *MockQueryVisitor) VisitJoin(_param0 *query.QueryJoin)
func (*MockQueryVisitor) VisitOpCode ¶
func (_m *MockQueryVisitor) VisitOpCode(_param0 query.QueryOpCode)
func (*MockQueryVisitor) VisitParser ¶
func (_m *MockQueryVisitor) VisitParser(_param0 *query.QueryParser)
func (*MockQueryVisitor) VisitPredicate ¶
func (_m *MockQueryVisitor) VisitPredicate(_param0 *query.QueryPredicate)
func (*MockQueryVisitor) VisitPublicKeyHash ¶
func (_m *MockQueryVisitor) VisitPublicKeyHash(_param0 crypto.PublicKeyHash)
func (*MockQueryVisitor) VisitRowJoin ¶
func (_m *MockQueryVisitor) VisitRowJoin(_param0 int, _param1 *query.QueryRowJoin)
func (*MockQueryVisitor) VisitSelect ¶
func (_m *MockQueryVisitor) VisitSelect(_param0 *query.QuerySelect)
func (*MockQueryVisitor) VisitTableKey ¶
func (_m *MockQueryVisitor) VisitTableKey(_param0 crdt.TableName)
func (*MockQueryVisitor) VisitWhere ¶
func (_m *MockQueryVisitor) VisitWhere(_param0 int, _param1 *query.QueryWhere)
type MockRemoteNamespace ¶
type MockRemoteNamespace struct {
// contains filtered or unexported fields
}
Mock of RemoteNamespace interface
func NewMockRemoteNamespace ¶
func NewMockRemoteNamespace(ctrl *gomock.Controller) *MockRemoteNamespace
func (*MockRemoteNamespace) EXPECT ¶
func (_m *MockRemoteNamespace) EXPECT() *_MockRemoteNamespaceRecorder
func (*MockRemoteNamespace) LoadTraverse ¶
func (_m *MockRemoteNamespace) LoadTraverse(_param0 api.NamespaceSearcher) error
type MockRemoteStore ¶
type MockRemoteStore struct {
// contains filtered or unexported fields
}
Mock of RemoteStore interface
func NewMockRemoteStore ¶
func NewMockRemoteStore(ctrl *gomock.Controller) *MockRemoteStore
func (*MockRemoteStore) AddNamespace ¶
func (*MockRemoteStore) CatNamespace ¶
func (*MockRemoteStore) Connect ¶
func (_m *MockRemoteStore) Connect() error
func (*MockRemoteStore) Disconnect ¶
func (_m *MockRemoteStore) Disconnect() error
func (*MockRemoteStore) EXPECT ¶
func (_m *MockRemoteStore) EXPECT() *_MockRemoteStoreRecorder
func (*MockRemoteStore) PublishAddr ¶
func (_m *MockRemoteStore) PublishAddr(_param0 crdt.Link, _param1 []api.PubSubTopic) error
func (*MockRemoteStore) SubscribeAddrStream ¶
func (_m *MockRemoteStore) SubscribeAddrStream(_param0 api.PubSubTopic) (<-chan crdt.Link, <-chan error)
type MockService ¶
type MockService struct {
// contains filtered or unexported fields
}
Mock of Service interface
func NewMockService ¶
func NewMockService(ctrl *gomock.Controller) *MockService
func (*MockService) CloseAPI ¶
func (_m *MockService) CloseAPI()
func (*MockService) EXPECT ¶
func (_m *MockService) EXPECT() *_MockServiceRecorder
Click to show internal directories.
Click to hide internal directories.