Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockAddr
- type MockAddrMockRecorder
- type MockAddressResolver
- type MockAddressResolverMockRecorder
- type MockDB
- type MockDBMockRecorder
- type MockDialerProvider
- type MockDialerProviderMockRecorder
- type MockFSM
- type MockFSMMockRecorder
- type MockFileSystem
- func (m *MockFileSystem) Chtimes(arg0 string, arg1, arg2 time.Time) error
- func (m *MockFileSystem) CopyDir(arg0, arg1 string) error
- func (m *MockFileSystem) CopyFile(arg0, arg1 string) error
- func (m *MockFileSystem) Create(arg0 string) (fsys.File, error)
- func (m *MockFileSystem) EXPECT() *MockFileSystemMockRecorder
- func (m *MockFileSystem) Exists(arg0 string) bool
- func (m *MockFileSystem) Lock(arg0 string) (fsys.Releaser, bool, error)
- func (m *MockFileSystem) Mkdir(arg0 string, arg1 os.FileMode) error
- func (m *MockFileSystem) MkdirAll(arg0 string, arg1 os.FileMode) error
- func (m *MockFileSystem) Open(arg0 string) (fsys.File, error)
- func (m *MockFileSystem) OpenFile(arg0 string, arg1 int, arg2 os.FileMode) (fsys.File, error)
- func (m *MockFileSystem) Remove(arg0 string) error
- func (m *MockFileSystem) RemoveAll(arg0 string) error
- func (m *MockFileSystem) Rename(arg0, arg1 string) error
- func (m *MockFileSystem) Symlink(arg0, arg1 string) error
- func (m *MockFileSystem) Walk(arg0 string, arg1 filepath.WalkFunc) error
- type MockFileSystemMockRecorder
- func (mr *MockFileSystemMockRecorder) Chtimes(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) CopyDir(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) CopyFile(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Create(arg0 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Exists(arg0 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Lock(arg0 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Mkdir(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) MkdirAll(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Open(arg0 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) OpenFile(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Remove(arg0 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) RemoveAll(arg0 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Rename(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Symlink(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockFileSystemMockRecorder) Walk(arg0, arg1 interface{}) *gomock.Call
- type MockHTTPProvider
- type MockHTTPProviderMockRecorder
- type MockLogStore
- func (m *MockLogStore) Close() error
- func (m *MockLogStore) DeleteRange(arg0, arg1 uint64) error
- func (m *MockLogStore) EXPECT() *MockLogStoreMockRecorder
- func (m *MockLogStore) FirstIndex() (uint64, error)
- func (m *MockLogStore) Get(arg0 []byte) ([]byte, error)
- func (m *MockLogStore) GetLog(arg0 uint64, arg1 *raft0.Log) error
- func (m *MockLogStore) GetUint64(arg0 []byte) (uint64, error)
- func (m *MockLogStore) LastIndex() (uint64, error)
- func (m *MockLogStore) Set(arg0, arg1 []byte) error
- func (m *MockLogStore) SetUint64(arg0 []byte, arg1 uint64) error
- func (m *MockLogStore) StoreLog(arg0 *raft0.Log) error
- func (m *MockLogStore) StoreLogs(arg0 []*raft0.Log) error
- type MockLogStoreMockRecorder
- func (mr *MockLogStoreMockRecorder) Close() *gomock.Call
- func (mr *MockLogStoreMockRecorder) DeleteRange(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockLogStoreMockRecorder) FirstIndex() *gomock.Call
- func (mr *MockLogStoreMockRecorder) Get(arg0 interface{}) *gomock.Call
- func (mr *MockLogStoreMockRecorder) GetLog(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockLogStoreMockRecorder) GetUint64(arg0 interface{}) *gomock.Call
- func (mr *MockLogStoreMockRecorder) LastIndex() *gomock.Call
- func (mr *MockLogStoreMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockLogStoreMockRecorder) SetUint64(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockLogStoreMockRecorder) StoreLog(arg0 interface{}) *gomock.Call
- func (mr *MockLogStoreMockRecorder) StoreLogs(arg0 interface{}) *gomock.Call
- type MockLogsProvider
- type MockLogsProviderMockRecorder
- type MockNetworkProvider
- type MockNetworkProviderMockRecorder
- type MockNode
- type MockNodeMockRecorder
- type MockQuery
- func (m *MockQuery) Count(arg0 database.Tx, arg1, arg2 string, arg3 ...interface{}) (int, error)
- func (m *MockQuery) DeleteObject(arg0 database.Tx, arg1 string, arg2 int64) (bool, error)
- func (m *MockQuery) EXPECT() *MockQueryMockRecorder
- func (m *MockQuery) SelectConfig(arg0 database.Tx, arg1, arg2 string, arg3 ...interface{}) (map[string]string, error)
- func (m *MockQuery) SelectObjects(arg0 database.Tx, arg1 query.Dest, arg2 string, arg3 ...interface{}) error
- func (m *MockQuery) SelectStrings(arg0 database.Tx, arg1 string, arg2 ...interface{}) ([]string, error)
- func (m *MockQuery) UpdateConfig(arg0 database.Tx, arg1 string, arg2 map[string]string) error
- func (m *MockQuery) UpsertObject(arg0 database.Tx, arg1 string, arg2 []string, arg3 []interface{}) (int64, error)
- type MockQueryCluster
- func (m *MockQueryCluster) DB() database.DB
- func (m *MockQueryCluster) EXPECT() *MockQueryClusterMockRecorder
- func (m *MockQueryCluster) EnsureSchema(arg0, arg1 string) (bool, error)
- func (m *MockQueryCluster) Open(arg0 cluster.ServerStore, arg1 ...go_dqlite.DriverOption) error
- func (m *MockQueryCluster) SchemaVersion() int
- type MockQueryClusterMockRecorder
- func (mr *MockQueryClusterMockRecorder) DB() *gomock.Call
- func (mr *MockQueryClusterMockRecorder) EnsureSchema(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueryClusterMockRecorder) Open(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockQueryClusterMockRecorder) SchemaVersion() *gomock.Call
- type MockQueryMockRecorder
- func (mr *MockQueryMockRecorder) Count(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockQueryMockRecorder) DeleteObject(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockQueryMockRecorder) SelectConfig(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockQueryMockRecorder) SelectObjects(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockQueryMockRecorder) SelectStrings(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockQueryMockRecorder) UpdateConfig(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockQueryMockRecorder) UpsertObject(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- type MockQueryNode
- type MockQueryNodeMockRecorder
- type MockRaftNodeMediator
- type MockRaftNodeMediatorMockRecorder
- type MockRaftProvider
- type MockRaftProviderMockRecorder
- type MockRegistryProvider
- type MockRegistryProviderMockRecorder
- type MockResult
- type MockResultMockRecorder
- type MockRows
- func (m *MockRows) Close() error
- func (m *MockRows) ColumnTypes() ([]database.ColumnType, error)
- func (m *MockRows) Columns() ([]string, error)
- func (m *MockRows) EXPECT() *MockRowsMockRecorder
- func (m *MockRows) Err() error
- func (m *MockRows) Next() bool
- func (m *MockRows) Scan(arg0 ...interface{}) error
- type MockRowsMockRecorder
- func (mr *MockRowsMockRecorder) Close() *gomock.Call
- func (mr *MockRowsMockRecorder) ColumnTypes() *gomock.Call
- func (mr *MockRowsMockRecorder) Columns() *gomock.Call
- func (mr *MockRowsMockRecorder) Err() *gomock.Call
- func (mr *MockRowsMockRecorder) Next() *gomock.Call
- func (mr *MockRowsMockRecorder) Scan(arg0 ...interface{}) *gomock.Call
- type MockSnapshotStore
- func (m *MockSnapshotStore) Create(arg0 raft.SnapshotVersion, arg1, arg2 uint64, arg3 raft.Configuration, ...) (raft.SnapshotSink, error)
- func (m *MockSnapshotStore) EXPECT() *MockSnapshotStoreMockRecorder
- func (m *MockSnapshotStore) List() ([]*raft.SnapshotMeta, error)
- func (m *MockSnapshotStore) Open(arg0 string) (*raft.SnapshotMeta, io.ReadCloser, error)
- type MockSnapshotStoreMockRecorder
- type MockSnapshotStoreProvider
- type MockSnapshotStoreProviderMockRecorder
- type MockTransaction
- type MockTransactionMockRecorder
- type MockTransport
- func (m *MockTransport) AppendEntries(arg0 raft.ServerID, arg1 raft.ServerAddress, arg2 *raft.AppendEntriesRequest, ...) error
- func (m *MockTransport) AppendEntriesPipeline(arg0 raft.ServerID, arg1 raft.ServerAddress) (raft.AppendPipeline, error)
- func (m *MockTransport) Consumer() <-chan raft.RPC
- func (m *MockTransport) DecodePeer(arg0 []byte) raft.ServerAddress
- func (m *MockTransport) EXPECT() *MockTransportMockRecorder
- func (m *MockTransport) EncodePeer(arg0 raft.ServerID, arg1 raft.ServerAddress) []byte
- func (m *MockTransport) InstallSnapshot(arg0 raft.ServerID, arg1 raft.ServerAddress, arg2 *raft.InstallSnapshotRequest, ...) error
- func (m *MockTransport) LocalAddr() raft.ServerAddress
- func (m *MockTransport) RequestVote(arg0 raft.ServerID, arg1 raft.ServerAddress, arg2 *raft.RequestVoteRequest, ...) error
- func (m *MockTransport) SetHeartbeatHandler(arg0 func(raft.RPC))
- type MockTransportMockRecorder
- func (mr *MockTransportMockRecorder) AppendEntries(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) AppendEntriesPipeline(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) Consumer() *gomock.Call
- func (mr *MockTransportMockRecorder) DecodePeer(arg0 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) EncodePeer(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) InstallSnapshot(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) LocalAddr() *gomock.Call
- func (mr *MockTransportMockRecorder) RequestVote(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) SetHeartbeatHandler(arg0 interface{}) *gomock.Call
- type MockTx
- type MockTxMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAddr ¶
type MockAddr struct {
// contains filtered or unexported fields
}
MockAddr is a mock of Addr interface
func NewMockAddr ¶
func NewMockAddr(ctrl *gomock.Controller) *MockAddr
NewMockAddr creates a new mock instance
func (*MockAddr) EXPECT ¶
func (m *MockAddr) EXPECT() *MockAddrMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockAddrMockRecorder ¶
type MockAddrMockRecorder struct {
// contains filtered or unexported fields
}
MockAddrMockRecorder is the mock recorder for MockAddr
func (*MockAddrMockRecorder) Network ¶
func (mr *MockAddrMockRecorder) Network() *gomock.Call
Network indicates an expected call of Network
func (*MockAddrMockRecorder) String ¶
func (mr *MockAddrMockRecorder) String() *gomock.Call
String indicates an expected call of String
type MockAddressResolver ¶
type MockAddressResolver struct {
// contains filtered or unexported fields
}
MockAddressResolver is a mock of AddressResolver interface
func NewMockAddressResolver ¶
func NewMockAddressResolver(ctrl *gomock.Controller) *MockAddressResolver
NewMockAddressResolver creates a new mock instance
func (*MockAddressResolver) EXPECT ¶
func (m *MockAddressResolver) EXPECT() *MockAddressResolverMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockAddressResolverMockRecorder ¶
type MockAddressResolverMockRecorder struct {
// contains filtered or unexported fields
}
MockAddressResolverMockRecorder is the mock recorder for MockAddressResolver
func (*MockAddressResolverMockRecorder) Resolve ¶
func (mr *MockAddressResolverMockRecorder) Resolve(arg0 interface{}) *gomock.Call
Resolve indicates an expected call of Resolve
type MockDB ¶
type MockDB struct {
// contains filtered or unexported fields
}
MockDB is a mock of DB interface
func NewMockDB ¶
func NewMockDB(ctrl *gomock.Controller) *MockDB
NewMockDB creates a new mock instance
func (*MockDB) EXPECT ¶
func (m *MockDB) EXPECT() *MockDBMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockDBMockRecorder ¶
type MockDBMockRecorder struct {
// contains filtered or unexported fields
}
MockDBMockRecorder is the mock recorder for MockDB
func (*MockDBMockRecorder) Begin ¶
func (mr *MockDBMockRecorder) Begin() *gomock.Call
Begin indicates an expected call of Begin
func (*MockDBMockRecorder) Close ¶
func (mr *MockDBMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockDBMockRecorder) Ping ¶
func (mr *MockDBMockRecorder) Ping() *gomock.Call
Ping indicates an expected call of Ping
type MockDialerProvider ¶
type MockDialerProvider struct {
// contains filtered or unexported fields
}
MockDialerProvider is a mock of DialerProvider interface
func NewMockDialerProvider ¶
func NewMockDialerProvider(ctrl *gomock.Controller) *MockDialerProvider
NewMockDialerProvider creates a new mock instance
func (*MockDialerProvider) EXPECT ¶
func (m *MockDialerProvider) EXPECT() *MockDialerProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockDialerProviderMockRecorder ¶
type MockDialerProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockDialerProviderMockRecorder is the mock recorder for MockDialerProvider
func (*MockDialerProviderMockRecorder) Dial ¶
func (mr *MockDialerProviderMockRecorder) Dial(arg0 interface{}) *gomock.Call
Dial indicates an expected call of Dial
type MockFSM ¶
type MockFSM struct {
// contains filtered or unexported fields
}
MockFSM is a mock of FSM interface
func NewMockFSM ¶
func NewMockFSM(ctrl *gomock.Controller) *MockFSM
NewMockFSM creates a new mock instance
func (*MockFSM) EXPECT ¶
func (m *MockFSM) EXPECT() *MockFSMMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockFSMMockRecorder ¶
type MockFSMMockRecorder struct {
// contains filtered or unexported fields
}
MockFSMMockRecorder is the mock recorder for MockFSM
func (*MockFSMMockRecorder) Apply ¶
func (mr *MockFSMMockRecorder) Apply(arg0 interface{}) *gomock.Call
Apply indicates an expected call of Apply
func (*MockFSMMockRecorder) Restore ¶
func (mr *MockFSMMockRecorder) Restore(arg0 interface{}) *gomock.Call
Restore indicates an expected call of Restore
func (*MockFSMMockRecorder) Snapshot ¶
func (mr *MockFSMMockRecorder) Snapshot() *gomock.Call
Snapshot indicates an expected call of Snapshot
type MockFileSystem ¶
type MockFileSystem struct {
// contains filtered or unexported fields
}
MockFileSystem is a mock of FileSystem interface
func NewMockFileSystem ¶
func NewMockFileSystem(ctrl *gomock.Controller) *MockFileSystem
NewMockFileSystem creates a new mock instance
func (*MockFileSystem) Chtimes ¶
func (m *MockFileSystem) Chtimes(arg0 string, arg1, arg2 time.Time) error
Chtimes mocks base method
func (*MockFileSystem) CopyDir ¶
func (m *MockFileSystem) CopyDir(arg0, arg1 string) error
CopyDir mocks base method
func (*MockFileSystem) CopyFile ¶
func (m *MockFileSystem) CopyFile(arg0, arg1 string) error
CopyFile mocks base method
func (*MockFileSystem) Create ¶
func (m *MockFileSystem) Create(arg0 string) (fsys.File, error)
Create mocks base method
func (*MockFileSystem) EXPECT ¶
func (m *MockFileSystem) EXPECT() *MockFileSystemMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockFileSystem) Exists ¶
func (m *MockFileSystem) Exists(arg0 string) bool
Exists mocks base method
func (*MockFileSystem) Mkdir ¶
func (m *MockFileSystem) Mkdir(arg0 string, arg1 os.FileMode) error
Mkdir mocks base method
func (*MockFileSystem) MkdirAll ¶
func (m *MockFileSystem) MkdirAll(arg0 string, arg1 os.FileMode) error
MkdirAll mocks base method
func (*MockFileSystem) Open ¶
func (m *MockFileSystem) Open(arg0 string) (fsys.File, error)
Open mocks base method
func (*MockFileSystem) Remove ¶
func (m *MockFileSystem) Remove(arg0 string) error
Remove mocks base method
func (*MockFileSystem) RemoveAll ¶
func (m *MockFileSystem) RemoveAll(arg0 string) error
RemoveAll mocks base method
func (*MockFileSystem) Rename ¶
func (m *MockFileSystem) Rename(arg0, arg1 string) error
Rename mocks base method
func (*MockFileSystem) Symlink ¶
func (m *MockFileSystem) Symlink(arg0, arg1 string) error
Symlink mocks base method
type MockFileSystemMockRecorder ¶
type MockFileSystemMockRecorder struct {
// contains filtered or unexported fields
}
MockFileSystemMockRecorder is the mock recorder for MockFileSystem
func (*MockFileSystemMockRecorder) Chtimes ¶
func (mr *MockFileSystemMockRecorder) Chtimes(arg0, arg1, arg2 interface{}) *gomock.Call
Chtimes indicates an expected call of Chtimes
func (*MockFileSystemMockRecorder) CopyDir ¶
func (mr *MockFileSystemMockRecorder) CopyDir(arg0, arg1 interface{}) *gomock.Call
CopyDir indicates an expected call of CopyDir
func (*MockFileSystemMockRecorder) CopyFile ¶
func (mr *MockFileSystemMockRecorder) CopyFile(arg0, arg1 interface{}) *gomock.Call
CopyFile indicates an expected call of CopyFile
func (*MockFileSystemMockRecorder) Create ¶
func (mr *MockFileSystemMockRecorder) Create(arg0 interface{}) *gomock.Call
Create indicates an expected call of Create
func (*MockFileSystemMockRecorder) Exists ¶
func (mr *MockFileSystemMockRecorder) Exists(arg0 interface{}) *gomock.Call
Exists indicates an expected call of Exists
func (*MockFileSystemMockRecorder) Lock ¶
func (mr *MockFileSystemMockRecorder) Lock(arg0 interface{}) *gomock.Call
Lock indicates an expected call of Lock
func (*MockFileSystemMockRecorder) Mkdir ¶
func (mr *MockFileSystemMockRecorder) Mkdir(arg0, arg1 interface{}) *gomock.Call
Mkdir indicates an expected call of Mkdir
func (*MockFileSystemMockRecorder) MkdirAll ¶
func (mr *MockFileSystemMockRecorder) MkdirAll(arg0, arg1 interface{}) *gomock.Call
MkdirAll indicates an expected call of MkdirAll
func (*MockFileSystemMockRecorder) Open ¶
func (mr *MockFileSystemMockRecorder) Open(arg0 interface{}) *gomock.Call
Open indicates an expected call of Open
func (*MockFileSystemMockRecorder) OpenFile ¶
func (mr *MockFileSystemMockRecorder) OpenFile(arg0, arg1, arg2 interface{}) *gomock.Call
OpenFile indicates an expected call of OpenFile
func (*MockFileSystemMockRecorder) Remove ¶
func (mr *MockFileSystemMockRecorder) Remove(arg0 interface{}) *gomock.Call
Remove indicates an expected call of Remove
func (*MockFileSystemMockRecorder) RemoveAll ¶
func (mr *MockFileSystemMockRecorder) RemoveAll(arg0 interface{}) *gomock.Call
RemoveAll indicates an expected call of RemoveAll
func (*MockFileSystemMockRecorder) Rename ¶
func (mr *MockFileSystemMockRecorder) Rename(arg0, arg1 interface{}) *gomock.Call
Rename indicates an expected call of Rename
func (*MockFileSystemMockRecorder) Symlink ¶
func (mr *MockFileSystemMockRecorder) Symlink(arg0, arg1 interface{}) *gomock.Call
Symlink indicates an expected call of Symlink
func (*MockFileSystemMockRecorder) Walk ¶
func (mr *MockFileSystemMockRecorder) Walk(arg0, arg1 interface{}) *gomock.Call
Walk indicates an expected call of Walk
type MockHTTPProvider ¶
type MockHTTPProvider struct {
// contains filtered or unexported fields
}
MockHTTPProvider is a mock of HTTPProvider interface
func NewMockHTTPProvider ¶
func NewMockHTTPProvider(ctrl *gomock.Controller) *MockHTTPProvider
NewMockHTTPProvider creates a new mock instance
func (*MockHTTPProvider) EXPECT ¶
func (m *MockHTTPProvider) EXPECT() *MockHTTPProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockHTTPProviderMockRecorder ¶
type MockHTTPProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockHTTPProviderMockRecorder is the mock recorder for MockHTTPProvider
func (*MockHTTPProviderMockRecorder) Handler ¶
func (mr *MockHTTPProviderMockRecorder) Handler(arg0 interface{}) *gomock.Call
Handler indicates an expected call of Handler
func (*MockHTTPProviderMockRecorder) Layer ¶
func (mr *MockHTTPProviderMockRecorder) Layer(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
Layer indicates an expected call of Layer
type MockLogStore ¶
type MockLogStore struct {
// contains filtered or unexported fields
}
MockLogStore is a mock of LogStore interface
func NewMockLogStore ¶
func NewMockLogStore(ctrl *gomock.Controller) *MockLogStore
NewMockLogStore creates a new mock instance
func (*MockLogStore) DeleteRange ¶
func (m *MockLogStore) DeleteRange(arg0, arg1 uint64) error
DeleteRange mocks base method
func (*MockLogStore) EXPECT ¶
func (m *MockLogStore) EXPECT() *MockLogStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockLogStore) FirstIndex ¶
func (m *MockLogStore) FirstIndex() (uint64, error)
FirstIndex mocks base method
func (*MockLogStore) Get ¶
func (m *MockLogStore) Get(arg0 []byte) ([]byte, error)
Get mocks base method
func (*MockLogStore) GetLog ¶
func (m *MockLogStore) GetLog(arg0 uint64, arg1 *raft0.Log) error
GetLog mocks base method
func (*MockLogStore) GetUint64 ¶
func (m *MockLogStore) GetUint64(arg0 []byte) (uint64, error)
GetUint64 mocks base method
func (*MockLogStore) LastIndex ¶
func (m *MockLogStore) LastIndex() (uint64, error)
LastIndex mocks base method
func (*MockLogStore) Set ¶
func (m *MockLogStore) Set(arg0, arg1 []byte) error
Set mocks base method
func (*MockLogStore) SetUint64 ¶
func (m *MockLogStore) SetUint64(arg0 []byte, arg1 uint64) error
SetUint64 mocks base method
type MockLogStoreMockRecorder ¶
type MockLogStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockLogStoreMockRecorder is the mock recorder for MockLogStore
func (*MockLogStoreMockRecorder) Close ¶
func (mr *MockLogStoreMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockLogStoreMockRecorder) DeleteRange ¶
func (mr *MockLogStoreMockRecorder) DeleteRange(arg0, arg1 interface{}) *gomock.Call
DeleteRange indicates an expected call of DeleteRange
func (*MockLogStoreMockRecorder) FirstIndex ¶
func (mr *MockLogStoreMockRecorder) FirstIndex() *gomock.Call
FirstIndex indicates an expected call of FirstIndex
func (*MockLogStoreMockRecorder) Get ¶
func (mr *MockLogStoreMockRecorder) Get(arg0 interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockLogStoreMockRecorder) GetLog ¶
func (mr *MockLogStoreMockRecorder) GetLog(arg0, arg1 interface{}) *gomock.Call
GetLog indicates an expected call of GetLog
func (*MockLogStoreMockRecorder) GetUint64 ¶
func (mr *MockLogStoreMockRecorder) GetUint64(arg0 interface{}) *gomock.Call
GetUint64 indicates an expected call of GetUint64
func (*MockLogStoreMockRecorder) LastIndex ¶
func (mr *MockLogStoreMockRecorder) LastIndex() *gomock.Call
LastIndex indicates an expected call of LastIndex
func (*MockLogStoreMockRecorder) Set ¶
func (mr *MockLogStoreMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
Set indicates an expected call of Set
func (*MockLogStoreMockRecorder) SetUint64 ¶
func (mr *MockLogStoreMockRecorder) SetUint64(arg0, arg1 interface{}) *gomock.Call
SetUint64 indicates an expected call of SetUint64
func (*MockLogStoreMockRecorder) StoreLog ¶
func (mr *MockLogStoreMockRecorder) StoreLog(arg0 interface{}) *gomock.Call
StoreLog indicates an expected call of StoreLog
func (*MockLogStoreMockRecorder) StoreLogs ¶
func (mr *MockLogStoreMockRecorder) StoreLogs(arg0 interface{}) *gomock.Call
StoreLogs indicates an expected call of StoreLogs
type MockLogsProvider ¶
type MockLogsProvider struct {
// contains filtered or unexported fields
}
MockLogsProvider is a mock of LogsProvider interface
func NewMockLogsProvider ¶
func NewMockLogsProvider(ctrl *gomock.Controller) *MockLogsProvider
NewMockLogsProvider creates a new mock instance
func (*MockLogsProvider) EXPECT ¶
func (m *MockLogsProvider) EXPECT() *MockLogsProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockLogsProviderMockRecorder ¶
type MockLogsProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockLogsProviderMockRecorder is the mock recorder for MockLogsProvider
func (*MockLogsProviderMockRecorder) Logs ¶
func (mr *MockLogsProviderMockRecorder) Logs(arg0, arg1 interface{}) *gomock.Call
Logs indicates an expected call of Logs
type MockNetworkProvider ¶
type MockNetworkProvider struct {
// contains filtered or unexported fields
}
MockNetworkProvider is a mock of NetworkProvider interface
func NewMockNetworkProvider ¶
func NewMockNetworkProvider(ctrl *gomock.Controller) *MockNetworkProvider
NewMockNetworkProvider creates a new mock instance
func (*MockNetworkProvider) EXPECT ¶
func (m *MockNetworkProvider) EXPECT() *MockNetworkProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNetworkProvider) Network ¶
func (m *MockNetworkProvider) Network(arg0 *raft.NetworkTransportConfig) raft.Transport
Network mocks base method
type MockNetworkProviderMockRecorder ¶
type MockNetworkProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockNetworkProviderMockRecorder is the mock recorder for MockNetworkProvider
func (*MockNetworkProviderMockRecorder) Network ¶
func (mr *MockNetworkProviderMockRecorder) Network(arg0 interface{}) *gomock.Call
Network indicates an expected call of Network
type MockNode ¶
type MockNode struct {
// contains filtered or unexported fields
}
MockNode is a mock of Node interface
func NewMockNode ¶
func NewMockNode(ctrl *gomock.Controller) *MockNode
NewMockNode creates a new mock instance
func (*MockNode) EXPECT ¶
func (m *MockNode) EXPECT() *MockNodeMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockNodeMockRecorder ¶
type MockNodeMockRecorder struct {
// contains filtered or unexported fields
}
MockNodeMockRecorder is the mock recorder for MockNode
func (*MockNodeMockRecorder) Dir ¶
func (mr *MockNodeMockRecorder) Dir() *gomock.Call
Dir indicates an expected call of Dir
func (*MockNodeMockRecorder) Transaction ¶
func (mr *MockNodeMockRecorder) Transaction(arg0 interface{}) *gomock.Call
Transaction indicates an expected call of Transaction
type MockQuery ¶
type MockQuery struct {
// contains filtered or unexported fields
}
MockQuery is a mock of Query interface
func NewMockQuery ¶
func NewMockQuery(ctrl *gomock.Controller) *MockQuery
NewMockQuery creates a new mock instance
func (*MockQuery) DeleteObject ¶
DeleteObject mocks base method
func (*MockQuery) EXPECT ¶
func (m *MockQuery) EXPECT() *MockQueryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockQuery) SelectConfig ¶
func (m *MockQuery) SelectConfig(arg0 database.Tx, arg1, arg2 string, arg3 ...interface{}) (map[string]string, error)
SelectConfig mocks base method
func (*MockQuery) SelectObjects ¶
func (m *MockQuery) SelectObjects(arg0 database.Tx, arg1 query.Dest, arg2 string, arg3 ...interface{}) error
SelectObjects mocks base method
func (*MockQuery) SelectStrings ¶
func (m *MockQuery) SelectStrings(arg0 database.Tx, arg1 string, arg2 ...interface{}) ([]string, error)
SelectStrings mocks base method
func (*MockQuery) UpdateConfig ¶
UpdateConfig mocks base method
type MockQueryCluster ¶
type MockQueryCluster struct {
// contains filtered or unexported fields
}
MockQueryCluster is a mock of QueryCluster interface
func NewMockQueryCluster ¶
func NewMockQueryCluster(ctrl *gomock.Controller) *MockQueryCluster
NewMockQueryCluster creates a new mock instance
func (*MockQueryCluster) EXPECT ¶
func (m *MockQueryCluster) EXPECT() *MockQueryClusterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockQueryCluster) EnsureSchema ¶
func (m *MockQueryCluster) EnsureSchema(arg0, arg1 string) (bool, error)
EnsureSchema mocks base method
func (*MockQueryCluster) Open ¶
func (m *MockQueryCluster) Open(arg0 cluster.ServerStore, arg1 ...go_dqlite.DriverOption) error
Open mocks base method
func (*MockQueryCluster) SchemaVersion ¶
func (m *MockQueryCluster) SchemaVersion() int
SchemaVersion mocks base method
type MockQueryClusterMockRecorder ¶
type MockQueryClusterMockRecorder struct {
// contains filtered or unexported fields
}
MockQueryClusterMockRecorder is the mock recorder for MockQueryCluster
func (*MockQueryClusterMockRecorder) DB ¶
func (mr *MockQueryClusterMockRecorder) DB() *gomock.Call
DB indicates an expected call of DB
func (*MockQueryClusterMockRecorder) EnsureSchema ¶
func (mr *MockQueryClusterMockRecorder) EnsureSchema(arg0, arg1 interface{}) *gomock.Call
EnsureSchema indicates an expected call of EnsureSchema
func (*MockQueryClusterMockRecorder) Open ¶
func (mr *MockQueryClusterMockRecorder) Open(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Open indicates an expected call of Open
func (*MockQueryClusterMockRecorder) SchemaVersion ¶
func (mr *MockQueryClusterMockRecorder) SchemaVersion() *gomock.Call
SchemaVersion indicates an expected call of SchemaVersion
type MockQueryMockRecorder ¶
type MockQueryMockRecorder struct {
// contains filtered or unexported fields
}
MockQueryMockRecorder is the mock recorder for MockQuery
func (*MockQueryMockRecorder) Count ¶
func (mr *MockQueryMockRecorder) Count(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
Count indicates an expected call of Count
func (*MockQueryMockRecorder) DeleteObject ¶
func (mr *MockQueryMockRecorder) DeleteObject(arg0, arg1, arg2 interface{}) *gomock.Call
DeleteObject indicates an expected call of DeleteObject
func (*MockQueryMockRecorder) SelectConfig ¶
func (mr *MockQueryMockRecorder) SelectConfig(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
SelectConfig indicates an expected call of SelectConfig
func (*MockQueryMockRecorder) SelectObjects ¶
func (mr *MockQueryMockRecorder) SelectObjects(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
SelectObjects indicates an expected call of SelectObjects
func (*MockQueryMockRecorder) SelectStrings ¶
func (mr *MockQueryMockRecorder) SelectStrings(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SelectStrings indicates an expected call of SelectStrings
func (*MockQueryMockRecorder) UpdateConfig ¶
func (mr *MockQueryMockRecorder) UpdateConfig(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateConfig indicates an expected call of UpdateConfig
func (*MockQueryMockRecorder) UpsertObject ¶
func (mr *MockQueryMockRecorder) UpsertObject(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
UpsertObject indicates an expected call of UpsertObject
type MockQueryNode ¶
type MockQueryNode struct {
// contains filtered or unexported fields
}
MockQueryNode is a mock of QueryNode interface
func NewMockQueryNode ¶
func NewMockQueryNode(ctrl *gomock.Controller) *MockQueryNode
NewMockQueryNode creates a new mock instance
func (*MockQueryNode) EXPECT ¶
func (m *MockQueryNode) EXPECT() *MockQueryNodeMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockQueryNode) EnsureSchema ¶
func (m *MockQueryNode) EnsureSchema(arg0 schema.Hook) (int, error)
EnsureSchema mocks base method
type MockQueryNodeMockRecorder ¶
type MockQueryNodeMockRecorder struct {
// contains filtered or unexported fields
}
MockQueryNodeMockRecorder is the mock recorder for MockQueryNode
func (*MockQueryNodeMockRecorder) DB ¶
func (mr *MockQueryNodeMockRecorder) DB() *gomock.Call
DB indicates an expected call of DB
func (*MockQueryNodeMockRecorder) EnsureSchema ¶
func (mr *MockQueryNodeMockRecorder) EnsureSchema(arg0 interface{}) *gomock.Call
EnsureSchema indicates an expected call of EnsureSchema
func (*MockQueryNodeMockRecorder) Open ¶
func (mr *MockQueryNodeMockRecorder) Open(arg0 interface{}) *gomock.Call
Open indicates an expected call of Open
type MockRaftNodeMediator ¶
type MockRaftNodeMediator struct {
// contains filtered or unexported fields
}
MockRaftNodeMediator is a mock of RaftNodeMediator interface
func NewMockRaftNodeMediator ¶
func NewMockRaftNodeMediator(ctrl *gomock.Controller) *MockRaftNodeMediator
NewMockRaftNodeMediator creates a new mock instance
func (*MockRaftNodeMediator) DetermineRaftNode ¶
func (m *MockRaftNodeMediator) DetermineRaftNode(arg0 node.Tx, arg1 config.Schema) (*db.RaftNode, error)
DetermineRaftNode mocks base method
func (*MockRaftNodeMediator) EXPECT ¶
func (m *MockRaftNodeMediator) EXPECT() *MockRaftNodeMediatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockRaftNodeMediatorMockRecorder ¶
type MockRaftNodeMediatorMockRecorder struct {
// contains filtered or unexported fields
}
MockRaftNodeMediatorMockRecorder is the mock recorder for MockRaftNodeMediator
func (*MockRaftNodeMediatorMockRecorder) DetermineRaftNode ¶
func (mr *MockRaftNodeMediatorMockRecorder) DetermineRaftNode(arg0, arg1 interface{}) *gomock.Call
DetermineRaftNode indicates an expected call of DetermineRaftNode
type MockRaftProvider ¶
type MockRaftProvider struct {
// contains filtered or unexported fields
}
MockRaftProvider is a mock of RaftProvider interface
func NewMockRaftProvider ¶
func NewMockRaftProvider(ctrl *gomock.Controller) *MockRaftProvider
NewMockRaftProvider creates a new mock instance
func (*MockRaftProvider) EXPECT ¶
func (m *MockRaftProvider) EXPECT() *MockRaftProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockRaftProviderMockRecorder ¶
type MockRaftProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockRaftProviderMockRecorder is the mock recorder for MockRaftProvider
func (*MockRaftProviderMockRecorder) Raft ¶
func (mr *MockRaftProviderMockRecorder) Raft(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
Raft indicates an expected call of Raft
type MockRegistryProvider ¶
type MockRegistryProvider struct {
// contains filtered or unexported fields
}
MockRegistryProvider is a mock of RegistryProvider interface
func NewMockRegistryProvider ¶
func NewMockRegistryProvider(ctrl *gomock.Controller) *MockRegistryProvider
NewMockRegistryProvider creates a new mock instance
func (*MockRegistryProvider) EXPECT ¶
func (m *MockRegistryProvider) EXPECT() *MockRegistryProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockRegistryProviderMockRecorder ¶
type MockRegistryProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockRegistryProviderMockRecorder is the mock recorder for MockRegistryProvider
func (*MockRegistryProviderMockRecorder) FSM ¶
func (mr *MockRegistryProviderMockRecorder) FSM(arg0 interface{}) *gomock.Call
FSM indicates an expected call of FSM
func (*MockRegistryProviderMockRecorder) Registry ¶
func (mr *MockRegistryProviderMockRecorder) Registry(arg0 interface{}) *gomock.Call
Registry indicates an expected call of Registry
type MockResult ¶
type MockResult struct {
// contains filtered or unexported fields
}
MockResult is a mock of Result interface
func NewMockResult ¶
func NewMockResult(ctrl *gomock.Controller) *MockResult
NewMockResult creates a new mock instance
func (*MockResult) EXPECT ¶
func (m *MockResult) EXPECT() *MockResultMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockResult) LastInsertId ¶
func (m *MockResult) LastInsertId() (int64, error)
LastInsertId mocks base method
func (*MockResult) RowsAffected ¶
func (m *MockResult) RowsAffected() (int64, error)
RowsAffected mocks base method
type MockResultMockRecorder ¶
type MockResultMockRecorder struct {
// contains filtered or unexported fields
}
MockResultMockRecorder is the mock recorder for MockResult
func (*MockResultMockRecorder) LastInsertId ¶
func (mr *MockResultMockRecorder) LastInsertId() *gomock.Call
LastInsertId indicates an expected call of LastInsertId
func (*MockResultMockRecorder) RowsAffected ¶
func (mr *MockResultMockRecorder) RowsAffected() *gomock.Call
RowsAffected indicates an expected call of RowsAffected
type MockRows ¶
type MockRows struct {
// contains filtered or unexported fields
}
MockRows is a mock of Rows interface
func NewMockRows ¶
func NewMockRows(ctrl *gomock.Controller) *MockRows
NewMockRows creates a new mock instance
func (*MockRows) ColumnTypes ¶
func (m *MockRows) ColumnTypes() ([]database.ColumnType, error)
ColumnTypes mocks base method
func (*MockRows) EXPECT ¶
func (m *MockRows) EXPECT() *MockRowsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockRowsMockRecorder ¶
type MockRowsMockRecorder struct {
// contains filtered or unexported fields
}
MockRowsMockRecorder is the mock recorder for MockRows
func (*MockRowsMockRecorder) Close ¶
func (mr *MockRowsMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockRowsMockRecorder) ColumnTypes ¶
func (mr *MockRowsMockRecorder) ColumnTypes() *gomock.Call
ColumnTypes indicates an expected call of ColumnTypes
func (*MockRowsMockRecorder) Columns ¶
func (mr *MockRowsMockRecorder) Columns() *gomock.Call
Columns indicates an expected call of Columns
func (*MockRowsMockRecorder) Err ¶
func (mr *MockRowsMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err
func (*MockRowsMockRecorder) Next ¶
func (mr *MockRowsMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next
func (*MockRowsMockRecorder) Scan ¶
func (mr *MockRowsMockRecorder) Scan(arg0 ...interface{}) *gomock.Call
Scan indicates an expected call of Scan
type MockSnapshotStore ¶
type MockSnapshotStore struct {
// contains filtered or unexported fields
}
MockSnapshotStore is a mock of SnapshotStore interface
func NewMockSnapshotStore ¶
func NewMockSnapshotStore(ctrl *gomock.Controller) *MockSnapshotStore
NewMockSnapshotStore creates a new mock instance
func (*MockSnapshotStore) Create ¶
func (m *MockSnapshotStore) Create(arg0 raft.SnapshotVersion, arg1, arg2 uint64, arg3 raft.Configuration, arg4 uint64, arg5 raft.Transport) (raft.SnapshotSink, error)
Create mocks base method
func (*MockSnapshotStore) EXPECT ¶
func (m *MockSnapshotStore) EXPECT() *MockSnapshotStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSnapshotStore) List ¶
func (m *MockSnapshotStore) List() ([]*raft.SnapshotMeta, error)
List mocks base method
func (*MockSnapshotStore) Open ¶
func (m *MockSnapshotStore) Open(arg0 string) (*raft.SnapshotMeta, io.ReadCloser, error)
Open mocks base method
type MockSnapshotStoreMockRecorder ¶
type MockSnapshotStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockSnapshotStoreMockRecorder is the mock recorder for MockSnapshotStore
func (*MockSnapshotStoreMockRecorder) Create ¶
func (mr *MockSnapshotStoreMockRecorder) Create(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
Create indicates an expected call of Create
func (*MockSnapshotStoreMockRecorder) List ¶
func (mr *MockSnapshotStoreMockRecorder) List() *gomock.Call
List indicates an expected call of List
func (*MockSnapshotStoreMockRecorder) Open ¶
func (mr *MockSnapshotStoreMockRecorder) Open(arg0 interface{}) *gomock.Call
Open indicates an expected call of Open
type MockSnapshotStoreProvider ¶
type MockSnapshotStoreProvider struct {
// contains filtered or unexported fields
}
MockSnapshotStoreProvider is a mock of SnapshotStoreProvider interface
func NewMockSnapshotStoreProvider ¶
func NewMockSnapshotStoreProvider(ctrl *gomock.Controller) *MockSnapshotStoreProvider
NewMockSnapshotStoreProvider creates a new mock instance
func (*MockSnapshotStoreProvider) EXPECT ¶
func (m *MockSnapshotStoreProvider) EXPECT() *MockSnapshotStoreProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSnapshotStoreProvider) Store ¶
func (m *MockSnapshotStoreProvider) Store(arg0 string) (raft.SnapshotStore, error)
Store mocks base method
type MockSnapshotStoreProviderMockRecorder ¶
type MockSnapshotStoreProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockSnapshotStoreProviderMockRecorder is the mock recorder for MockSnapshotStoreProvider
func (*MockSnapshotStoreProviderMockRecorder) Store ¶
func (mr *MockSnapshotStoreProviderMockRecorder) Store(arg0 interface{}) *gomock.Call
Store indicates an expected call of Store
type MockTransaction ¶
type MockTransaction struct {
// contains filtered or unexported fields
}
MockTransaction is a mock of Transaction interface
func NewMockTransaction ¶
func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction
NewMockTransaction creates a new mock instance
func (*MockTransaction) EXPECT ¶
func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockTransaction) Transaction ¶
Transaction mocks base method
type MockTransactionMockRecorder ¶
type MockTransactionMockRecorder struct {
// contains filtered or unexported fields
}
MockTransactionMockRecorder is the mock recorder for MockTransaction
func (*MockTransactionMockRecorder) Transaction ¶
func (mr *MockTransactionMockRecorder) Transaction(arg0, arg1 interface{}) *gomock.Call
Transaction indicates an expected call of Transaction
type MockTransport ¶
type MockTransport struct {
// contains filtered or unexported fields
}
MockTransport is a mock of Transport interface
func NewMockTransport ¶
func NewMockTransport(ctrl *gomock.Controller) *MockTransport
NewMockTransport creates a new mock instance
func (*MockTransport) AppendEntries ¶
func (m *MockTransport) AppendEntries(arg0 raft.ServerID, arg1 raft.ServerAddress, arg2 *raft.AppendEntriesRequest, arg3 *raft.AppendEntriesResponse) error
AppendEntries mocks base method
func (*MockTransport) AppendEntriesPipeline ¶
func (m *MockTransport) AppendEntriesPipeline(arg0 raft.ServerID, arg1 raft.ServerAddress) (raft.AppendPipeline, error)
AppendEntriesPipeline mocks base method
func (*MockTransport) Consumer ¶
func (m *MockTransport) Consumer() <-chan raft.RPC
Consumer mocks base method
func (*MockTransport) DecodePeer ¶
func (m *MockTransport) DecodePeer(arg0 []byte) raft.ServerAddress
DecodePeer mocks base method
func (*MockTransport) EXPECT ¶
func (m *MockTransport) EXPECT() *MockTransportMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockTransport) EncodePeer ¶
func (m *MockTransport) EncodePeer(arg0 raft.ServerID, arg1 raft.ServerAddress) []byte
EncodePeer mocks base method
func (*MockTransport) InstallSnapshot ¶
func (m *MockTransport) InstallSnapshot(arg0 raft.ServerID, arg1 raft.ServerAddress, arg2 *raft.InstallSnapshotRequest, arg3 *raft.InstallSnapshotResponse, arg4 io.Reader) error
InstallSnapshot mocks base method
func (*MockTransport) LocalAddr ¶
func (m *MockTransport) LocalAddr() raft.ServerAddress
LocalAddr mocks base method
func (*MockTransport) RequestVote ¶
func (m *MockTransport) RequestVote(arg0 raft.ServerID, arg1 raft.ServerAddress, arg2 *raft.RequestVoteRequest, arg3 *raft.RequestVoteResponse) error
RequestVote mocks base method
func (*MockTransport) SetHeartbeatHandler ¶
func (m *MockTransport) SetHeartbeatHandler(arg0 func(raft.RPC))
SetHeartbeatHandler mocks base method
type MockTransportMockRecorder ¶
type MockTransportMockRecorder struct {
// contains filtered or unexported fields
}
MockTransportMockRecorder is the mock recorder for MockTransport
func (*MockTransportMockRecorder) AppendEntries ¶
func (mr *MockTransportMockRecorder) AppendEntries(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
AppendEntries indicates an expected call of AppendEntries
func (*MockTransportMockRecorder) AppendEntriesPipeline ¶
func (mr *MockTransportMockRecorder) AppendEntriesPipeline(arg0, arg1 interface{}) *gomock.Call
AppendEntriesPipeline indicates an expected call of AppendEntriesPipeline
func (*MockTransportMockRecorder) Consumer ¶
func (mr *MockTransportMockRecorder) Consumer() *gomock.Call
Consumer indicates an expected call of Consumer
func (*MockTransportMockRecorder) DecodePeer ¶
func (mr *MockTransportMockRecorder) DecodePeer(arg0 interface{}) *gomock.Call
DecodePeer indicates an expected call of DecodePeer
func (*MockTransportMockRecorder) EncodePeer ¶
func (mr *MockTransportMockRecorder) EncodePeer(arg0, arg1 interface{}) *gomock.Call
EncodePeer indicates an expected call of EncodePeer
func (*MockTransportMockRecorder) InstallSnapshot ¶
func (mr *MockTransportMockRecorder) InstallSnapshot(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
InstallSnapshot indicates an expected call of InstallSnapshot
func (*MockTransportMockRecorder) LocalAddr ¶
func (mr *MockTransportMockRecorder) LocalAddr() *gomock.Call
LocalAddr indicates an expected call of LocalAddr
func (*MockTransportMockRecorder) RequestVote ¶
func (mr *MockTransportMockRecorder) RequestVote(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
RequestVote indicates an expected call of RequestVote
func (*MockTransportMockRecorder) SetHeartbeatHandler ¶
func (mr *MockTransportMockRecorder) SetHeartbeatHandler(arg0 interface{}) *gomock.Call
SetHeartbeatHandler indicates an expected call of SetHeartbeatHandler
type MockTx ¶
type MockTx struct {
// contains filtered or unexported fields
}
MockTx is a mock of Tx interface
func NewMockTx ¶
func NewMockTx(ctrl *gomock.Controller) *MockTx
NewMockTx creates a new mock instance
func (*MockTx) EXPECT ¶
func (m *MockTx) EXPECT() *MockTxMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockTxMockRecorder ¶
type MockTxMockRecorder struct {
// contains filtered or unexported fields
}
MockTxMockRecorder is the mock recorder for MockTx
func (*MockTxMockRecorder) Commit ¶
func (mr *MockTxMockRecorder) Commit() *gomock.Call
Commit indicates an expected call of Commit
func (*MockTxMockRecorder) Exec ¶
func (mr *MockTxMockRecorder) Exec(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Exec indicates an expected call of Exec
func (*MockTxMockRecorder) Query ¶
func (mr *MockTxMockRecorder) Query(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Query indicates an expected call of Query
func (*MockTxMockRecorder) Rollback ¶
func (mr *MockTxMockRecorder) Rollback() *gomock.Call
Rollback indicates an expected call of Rollback