Versions in this module Expand all Collapse all v0 v0.1.0 Feb 28, 2019 Changes in this version + type MockBigChain struct + func NewMockBigChain(ctrl *gomock.Controller) *MockBigChain + func (_m *MockBigChain) EXPECT() *_MockBigChainRecorder + func (_m *MockBigChain) Fetch(ctx context.Context, accID AccID, limit int) ([]Txn, *Settings, error) + type MockChain struct + func NewMockChain(ctrl *gomock.Controller) *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 struct + func NewMockMetaDBServiceInterface(ctrl *gomock.Controller) *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 struct + func NewMockPlutoDBServiceInterface(ctrl *gomock.Controller) *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 struct + func NewMockPreloader(ctrl *gomock.Controller) *MockPreloader + func (_m *MockPreloader) EXPECT() *_MockPreloaderRecorder + func (_m *MockPreloader) Preload(_param0 context.Context, _param1 AccID) error + func (_m *MockPreloader) Reset(_param0 context.Context, _param1 AccID) + type MockProcessorServiceInterface struct + func NewMockProcessorServiceInterface(ctrl *gomock.Controller) *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 struct + func NewMockPusher(ctrl *gomock.Controller) *MockPusher + func (_m *MockPusher) EXPECT() *_MockPusherRecorder + func (_m *MockPusher) Push(ctx context.Context, txns []Txn) error + type MockPusherServiceInterface struct + func NewMockPusherServiceInterface(ctrl *gomock.Controller) *MockPusherServiceInterface + func (_m *MockPusherServiceInterface) EXPECT() *_MockPusherServiceInterfaceRecorder + func (_m *MockPusherServiceInterface) Push(_param0 context.Context, _param1 *pusherpb.PushRequest) (*pusherpb.PushResponse, error) + type MockRouter struct + func NewMockRouter(ctrl *gomock.Controller) *MockRouter + func (_m *MockRouter) EXPECT() *_MockRouterRecorder + func (_m *MockRouter) GetHostByKey(key string) string + func (_m *MockRouter) IsSelf(node string) bool + func (_m *MockRouter) Nodes() []string + func (_m *MockRouter) SetNodes(nodes []string) + type MockSettingsChain struct + func NewMockSettingsChain(ctrl *gomock.Controller) *MockSettingsChain + func (_m *MockSettingsChain) EXPECT() *_MockSettingsChainRecorder + func (_m *MockSettingsChain) GetLastHash(accID AccID) Hash + func (_m *MockSettingsChain) GetLastSettings(accID AccID) *Settings + func (_m *MockSettingsChain) Put(s *Settings) + func (_m *MockSettingsChain) Reset(_param0 AccID) + type MockSettingsProcessor struct + func NewMockSettingsProcessor(ctrl *gomock.Controller) *MockSettingsProcessor + func (_m *MockSettingsProcessor) EXPECT() *_MockSettingsProcessorRecorder + func (_m *MockSettingsProcessor) GetLastSettings(ctx context.Context, acc AccID) (*Settings, error) + func (_m *MockSettingsProcessor) ProcessSettings(ctx context.Context, s *Settings) (SettingsResult, error) + type MockSettingsPusher struct + func NewMockSettingsPusher(ctrl *gomock.Controller) *MockSettingsPusher + func (_m *MockSettingsPusher) EXPECT() *_MockSettingsPusherRecorder + func (_m *MockSettingsPusher) PushSettings(ctx context.Context, sett *Settings) error + type MockTransferProcessor struct + func NewMockTransferProcessor(ctrl *gomock.Controller) *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)