Documentation ¶
Index ¶
- type MockBigChain
- type MockChain
- func (_m *MockChain) CheckTxns(txns []Txn) error
- func (_m *MockChain) EXPECT() *_MockChainRecorder
- func (_m *MockChain) GetBalance(accID AccID) int64
- func (_m *MockChain) GetLastHash(accID AccID) Hash
- func (_m *MockChain) GetLastNTxns(accID AccID, n int) []Txn
- func (_m *MockChain) GetLastTxn(accID AccID) *Txn
- func (_m *MockChain) ListUnspentTxns(accID AccID) []Txn
- func (_m *MockChain) PutTo(accID AccID, txns []Txn)
- func (_m *MockChain) Reset(_param0 AccID)
- type MockMetaDBServiceInterface
- func (_m *MockMetaDBServiceInterface) Delete(_param0 context.Context, _param1 *metadbpb.DeleteRequest) (*metadbpb.DeleteResponse, error)
- func (_m *MockMetaDBServiceInterface) EXPECT() *_MockMetaDBServiceInterfaceRecorder
- func (_m *MockMetaDBServiceInterface) Get(_param0 context.Context, _param1 *metadbpb.GetRequest) (*metadbpb.GetResponse, error)
- func (_m *MockMetaDBServiceInterface) GetMulti(_param0 context.Context, _param1 *metadbpb.GetMultiRequest) (*metadbpb.GetMultiResponse, error)
- func (_m *MockMetaDBServiceInterface) Put(_param0 context.Context, _param1 *metadbpb.PutRequest) (*metadbpb.PutResponse, error)
- func (_m *MockMetaDBServiceInterface) Search(_param0 context.Context, _param1 *metadbpb.SearchRequest) (*metadbpb.SearchResponse, error)
- type MockPlutoDBServiceInterface
- func (_m *MockPlutoDBServiceInterface) EXPECT() *_MockPlutoDBServiceInterfaceRecorder
- func (_m *MockPlutoDBServiceInterface) Fetch(_param0 context.Context, _param1 *plutodbpb.FetchRequest) (*plutodbpb.FetchResponse, error)
- func (_m *MockPlutoDBServiceInterface) GetHistory(_param0 context.Context, _param1 *plutodbpb.GetHistoryRequest) (*plutodbpb.GetHistoryResponse, error)
- func (_m *MockPlutoDBServiceInterface) GetTxnMulti(_param0 context.Context, _param1 *plutodbpb.GetTxnMultiRequest) (*plutodbpb.GetTxnMultiResponse, error)
- type MockPreloader
- type MockProcessorServiceInterface
- func (_m *MockProcessorServiceInterface) EXPECT() *_MockProcessorServiceInterfaceRecorder
- func (_m *MockProcessorServiceInterface) GetBalance(_param0 context.Context, _param1 *gatepb.GetBalanceRequest) (*gatepb.GetBalanceResponse, error)
- func (_m *MockProcessorServiceInterface) GetLastSettings(_param0 context.Context, _param1 *gatepb.GetLastSettingsRequest) (*gatepb.GetLastSettingsResponse, error)
- func (_m *MockProcessorServiceInterface) GetPrevHash(_param0 context.Context, _param1 *gatepb.GetPrevHashRequest) (*gatepb.GetPrevHashResponse, error)
- func (_m *MockProcessorServiceInterface) ProcessTransfer(_param0 context.Context, _param1 *gatepb.TransferRequest) (*gatepb.TransferResponse, error)
- func (_m *MockProcessorServiceInterface) UpdateSettings(_param0 context.Context, _param1 *gatepb.SettingsRequest) (*gatepb.SettingsResponse, error)
- type MockPusher
- type MockPusherServiceInterface
- type MockRouter
- type MockSettingsChain
- type MockSettingsProcessor
- type MockSettingsPusher
- type MockTransferProcessor
- func (_m *MockTransferProcessor) EXPECT() *_MockTransferProcessorRecorder
- func (_m *MockTransferProcessor) GetBalance(ctx context.Context, acc AccID) (int64, error)
- func (_m *MockTransferProcessor) GetPrevHash(ctx context.Context, acc AccID) (Hash, error)
- func (_m *MockTransferProcessor) ProcessTransfer(ctx context.Context, t Transfer) (TransferResult, error)
- func (_m *MockTransferProcessor) SetPreloader(_param0 Preloader)
- func (_m *MockTransferProcessor) SetPusher(_param0 Pusher)
- func (_m *MockTransferProcessor) SetSettingsChain(_param0 SettingsChain)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBigChain ¶
type MockBigChain struct {
// contains filtered or unexported fields
}
Mock of BigChain interface
func NewMockBigChain ¶
func NewMockBigChain(ctrl *gomock.Controller) *MockBigChain
func (*MockBigChain) EXPECT ¶
func (_m *MockBigChain) EXPECT() *_MockBigChainRecorder
type MockChain ¶
type MockChain struct {
// contains filtered or unexported fields
}
Mock of Chain interface
func NewMockChain ¶
func NewMockChain(ctrl *gomock.Controller) *MockChain
func (*MockChain) GetBalance ¶
func (*MockChain) GetLastHash ¶
func (_m *MockChain) GetLastHash(accID AccID) Hash
func (*MockChain) GetLastNTxns ¶
func (*MockChain) GetLastTxn ¶
func (_m *MockChain) GetLastTxn(accID AccID) *Txn
func (*MockChain) ListUnspentTxns ¶
func (_m *MockChain) ListUnspentTxns(accID AccID) []Txn
type MockMetaDBServiceInterface ¶
type MockMetaDBServiceInterface struct {
// contains filtered or unexported fields
}
Mock of MetaDBServiceInterface interface
func NewMockMetaDBServiceInterface ¶
func NewMockMetaDBServiceInterface(ctrl *gomock.Controller) *MockMetaDBServiceInterface
func (*MockMetaDBServiceInterface) Delete ¶
func (_m *MockMetaDBServiceInterface) Delete(_param0 context.Context, _param1 *metadbpb.DeleteRequest) (*metadbpb.DeleteResponse, error)
func (*MockMetaDBServiceInterface) EXPECT ¶
func (_m *MockMetaDBServiceInterface) EXPECT() *_MockMetaDBServiceInterfaceRecorder
func (*MockMetaDBServiceInterface) Get ¶
func (_m *MockMetaDBServiceInterface) Get(_param0 context.Context, _param1 *metadbpb.GetRequest) (*metadbpb.GetResponse, error)
func (*MockMetaDBServiceInterface) GetMulti ¶
func (_m *MockMetaDBServiceInterface) GetMulti(_param0 context.Context, _param1 *metadbpb.GetMultiRequest) (*metadbpb.GetMultiResponse, error)
func (*MockMetaDBServiceInterface) Put ¶
func (_m *MockMetaDBServiceInterface) Put(_param0 context.Context, _param1 *metadbpb.PutRequest) (*metadbpb.PutResponse, error)
func (*MockMetaDBServiceInterface) Search ¶
func (_m *MockMetaDBServiceInterface) Search(_param0 context.Context, _param1 *metadbpb.SearchRequest) (*metadbpb.SearchResponse, error)
type MockPlutoDBServiceInterface ¶
type MockPlutoDBServiceInterface struct {
// contains filtered or unexported fields
}
Mock of PlutoDBServiceInterface interface
func NewMockPlutoDBServiceInterface ¶
func NewMockPlutoDBServiceInterface(ctrl *gomock.Controller) *MockPlutoDBServiceInterface
func (*MockPlutoDBServiceInterface) EXPECT ¶
func (_m *MockPlutoDBServiceInterface) EXPECT() *_MockPlutoDBServiceInterfaceRecorder
func (*MockPlutoDBServiceInterface) Fetch ¶
func (_m *MockPlutoDBServiceInterface) Fetch(_param0 context.Context, _param1 *plutodbpb.FetchRequest) (*plutodbpb.FetchResponse, error)
func (*MockPlutoDBServiceInterface) GetHistory ¶
func (_m *MockPlutoDBServiceInterface) GetHistory(_param0 context.Context, _param1 *plutodbpb.GetHistoryRequest) (*plutodbpb.GetHistoryResponse, error)
func (*MockPlutoDBServiceInterface) GetTxnMulti ¶
func (_m *MockPlutoDBServiceInterface) GetTxnMulti(_param0 context.Context, _param1 *plutodbpb.GetTxnMultiRequest) (*plutodbpb.GetTxnMultiResponse, error)
type MockPreloader ¶
type MockPreloader struct {
// contains filtered or unexported fields
}
Mock of Preloader interface
func NewMockPreloader ¶
func NewMockPreloader(ctrl *gomock.Controller) *MockPreloader
func (*MockPreloader) EXPECT ¶
func (_m *MockPreloader) EXPECT() *_MockPreloaderRecorder
func (*MockPreloader) Preload ¶
func (_m *MockPreloader) Preload(_param0 context.Context, _param1 AccID) error
func (*MockPreloader) Reset ¶
func (_m *MockPreloader) Reset(_param0 context.Context, _param1 AccID)
type MockProcessorServiceInterface ¶
type MockProcessorServiceInterface struct {
// contains filtered or unexported fields
}
Mock of ProcessorServiceInterface interface
func NewMockProcessorServiceInterface ¶
func NewMockProcessorServiceInterface(ctrl *gomock.Controller) *MockProcessorServiceInterface
func (*MockProcessorServiceInterface) EXPECT ¶
func (_m *MockProcessorServiceInterface) EXPECT() *_MockProcessorServiceInterfaceRecorder
func (*MockProcessorServiceInterface) GetBalance ¶
func (_m *MockProcessorServiceInterface) GetBalance(_param0 context.Context, _param1 *gatepb.GetBalanceRequest) (*gatepb.GetBalanceResponse, error)
func (*MockProcessorServiceInterface) GetLastSettings ¶
func (_m *MockProcessorServiceInterface) GetLastSettings(_param0 context.Context, _param1 *gatepb.GetLastSettingsRequest) (*gatepb.GetLastSettingsResponse, error)
func (*MockProcessorServiceInterface) GetPrevHash ¶
func (_m *MockProcessorServiceInterface) GetPrevHash(_param0 context.Context, _param1 *gatepb.GetPrevHashRequest) (*gatepb.GetPrevHashResponse, error)
func (*MockProcessorServiceInterface) ProcessTransfer ¶
func (_m *MockProcessorServiceInterface) ProcessTransfer(_param0 context.Context, _param1 *gatepb.TransferRequest) (*gatepb.TransferResponse, error)
func (*MockProcessorServiceInterface) UpdateSettings ¶
func (_m *MockProcessorServiceInterface) UpdateSettings(_param0 context.Context, _param1 *gatepb.SettingsRequest) (*gatepb.SettingsResponse, error)
type MockPusher ¶
type MockPusher struct {
// contains filtered or unexported fields
}
Mock of Pusher interface
func NewMockPusher ¶
func NewMockPusher(ctrl *gomock.Controller) *MockPusher
func (*MockPusher) EXPECT ¶
func (_m *MockPusher) EXPECT() *_MockPusherRecorder
type MockPusherServiceInterface ¶
type MockPusherServiceInterface struct {
// contains filtered or unexported fields
}
Mock of PusherServiceInterface interface
func NewMockPusherServiceInterface ¶
func NewMockPusherServiceInterface(ctrl *gomock.Controller) *MockPusherServiceInterface
func (*MockPusherServiceInterface) EXPECT ¶
func (_m *MockPusherServiceInterface) EXPECT() *_MockPusherServiceInterfaceRecorder
func (*MockPusherServiceInterface) Push ¶
func (_m *MockPusherServiceInterface) Push(_param0 context.Context, _param1 *pusherpb.PushRequest) (*pusherpb.PushResponse, error)
type MockRouter ¶
type MockRouter struct {
// contains filtered or unexported fields
}
Mock of Router interface
func NewMockRouter ¶
func NewMockRouter(ctrl *gomock.Controller) *MockRouter
func (*MockRouter) EXPECT ¶
func (_m *MockRouter) EXPECT() *_MockRouterRecorder
func (*MockRouter) GetHostByKey ¶
func (_m *MockRouter) GetHostByKey(key string) string
func (*MockRouter) IsSelf ¶
func (_m *MockRouter) IsSelf(node string) bool
func (*MockRouter) Nodes ¶
func (_m *MockRouter) Nodes() []string
func (*MockRouter) SetNodes ¶
func (_m *MockRouter) SetNodes(nodes []string)
type MockSettingsChain ¶
type MockSettingsChain struct {
// contains filtered or unexported fields
}
Mock of SettingsChain interface
func NewMockSettingsChain ¶
func NewMockSettingsChain(ctrl *gomock.Controller) *MockSettingsChain
func (*MockSettingsChain) EXPECT ¶
func (_m *MockSettingsChain) EXPECT() *_MockSettingsChainRecorder
func (*MockSettingsChain) GetLastHash ¶
func (_m *MockSettingsChain) GetLastHash(accID AccID) Hash
func (*MockSettingsChain) GetLastSettings ¶
func (_m *MockSettingsChain) GetLastSettings(accID AccID) *Settings
func (*MockSettingsChain) Put ¶
func (_m *MockSettingsChain) Put(s *Settings)
func (*MockSettingsChain) Reset ¶
func (_m *MockSettingsChain) Reset(_param0 AccID)
type MockSettingsProcessor ¶
type MockSettingsProcessor struct {
// contains filtered or unexported fields
}
Mock of SettingsProcessor interface
func NewMockSettingsProcessor ¶
func NewMockSettingsProcessor(ctrl *gomock.Controller) *MockSettingsProcessor
func (*MockSettingsProcessor) EXPECT ¶
func (_m *MockSettingsProcessor) EXPECT() *_MockSettingsProcessorRecorder
func (*MockSettingsProcessor) GetLastSettings ¶
func (_m *MockSettingsProcessor) GetLastSettings(ctx context.Context, acc AccID) (*Settings, error)
func (*MockSettingsProcessor) ProcessSettings ¶
func (_m *MockSettingsProcessor) ProcessSettings(ctx context.Context, s *Settings) (SettingsResult, error)
type MockSettingsPusher ¶
type MockSettingsPusher struct {
// contains filtered or unexported fields
}
Mock of SettingsPusher interface
func NewMockSettingsPusher ¶
func NewMockSettingsPusher(ctrl *gomock.Controller) *MockSettingsPusher
func (*MockSettingsPusher) EXPECT ¶
func (_m *MockSettingsPusher) EXPECT() *_MockSettingsPusherRecorder
func (*MockSettingsPusher) PushSettings ¶
func (_m *MockSettingsPusher) PushSettings(ctx context.Context, sett *Settings) error
type MockTransferProcessor ¶
type MockTransferProcessor struct {
// contains filtered or unexported fields
}
Mock of TransferProcessor interface
func NewMockTransferProcessor ¶
func NewMockTransferProcessor(ctrl *gomock.Controller) *MockTransferProcessor
func (*MockTransferProcessor) EXPECT ¶
func (_m *MockTransferProcessor) EXPECT() *_MockTransferProcessorRecorder
func (*MockTransferProcessor) GetBalance ¶
func (_m *MockTransferProcessor) GetBalance(ctx context.Context, acc AccID) (int64, error)
func (*MockTransferProcessor) GetPrevHash ¶
func (_m *MockTransferProcessor) GetPrevHash(ctx context.Context, acc AccID) (Hash, error)
func (*MockTransferProcessor) ProcessTransfer ¶
func (_m *MockTransferProcessor) ProcessTransfer(ctx context.Context, t Transfer) (TransferResult, error)
func (*MockTransferProcessor) SetPreloader ¶
func (_m *MockTransferProcessor) SetPreloader(_param0 Preloader)
func (*MockTransferProcessor) SetPusher ¶
func (_m *MockTransferProcessor) SetPusher(_param0 Pusher)
func (*MockTransferProcessor) SetSettingsChain ¶
func (_m *MockTransferProcessor) SetSettingsChain(_param0 SettingsChain)
Click to show internal directories.
Click to hide internal directories.