Documentation
¶
Overview ¶
Package config provides configuration for GRPC and HTTP api servers
Package grpcserver is a generated GoMock package.
Index ¶
- func NewActivationService(atxProvider atxProvider, goldenAtx types.ATXID) *activationService
- type AdminService
- func (a AdminService) CheckpointStream(req *pb.CheckpointStreamRequest, stream pb.AdminService_CheckpointStreamServer) error
- func (a AdminService) EventsStream(req *pb.EventStreamRequest, stream pb.AdminService_EventsStreamServer) error
- func (a AdminService) PeerInfoStream(_ *emptypb.Empty, stream pb.AdminService_PeerInfoStreamServer) error
- func (a AdminService) Recover(ctx context.Context, _ *pb.RecoverRequest) (*emptypb.Empty, error)
- func (s AdminService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (a AdminService) RegisterService(server *grpc.Server)
- func (a AdminService) String() string
- type Config
- type DebugService
- func (d DebugService) Accounts(ctx context.Context, in *pb.AccountsRequest) (*pb.AccountsResponse, error)
- func (d DebugService) ActiveSet(ctx context.Context, req *pb.ActiveSetRequest) (*pb.ActiveSetResponse, error)
- func (d DebugService) NetworkInfo(ctx context.Context, _ *emptypb.Empty) (*pb.NetworkInfoResponse, error)
- func (d DebugService) ProposalsStream(_ *emptypb.Empty, stream pb.DebugService_ProposalsStreamServer) error
- func (s DebugService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (d DebugService) RegisterService(server *grpc.Server)
- func (d DebugService) String() string
- type GlobalStateService
- func (s GlobalStateService) Account(ctx context.Context, in *pb.AccountRequest) (*pb.AccountResponse, error)
- func (s GlobalStateService) AccountDataQuery(ctx context.Context, in *pb.AccountDataQueryRequest) (*pb.AccountDataQueryResponse, error)
- func (s GlobalStateService) AccountDataStream(in *pb.AccountDataStreamRequest, ...) error
- func (s GlobalStateService) AppEventStream(*pb.AppEventStreamRequest, pb.GlobalStateService_AppEventStreamServer) error
- func (s GlobalStateService) GlobalStateHash(context.Context, *pb.GlobalStateHashRequest) (*pb.GlobalStateHashResponse, error)
- func (s GlobalStateService) GlobalStateStream(in *pb.GlobalStateStreamRequest, ...) error
- func (s GlobalStateService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (s GlobalStateService) RegisterService(server *grpc.Server)
- func (s GlobalStateService) SmesherDataQuery(_ context.Context, in *pb.SmesherDataQueryRequest) (*pb.SmesherDataQueryResponse, error)
- func (s GlobalStateService) SmesherRewardStream(in *pb.SmesherRewardStreamRequest, ...) error
- func (s GlobalStateService) String() string
- type JSONHTTPServer
- type MeshService
- func (s MeshService) AccountMeshDataQuery(ctx context.Context, in *pb.AccountMeshDataQueryRequest) (*pb.AccountMeshDataQueryResponse, error)
- func (s MeshService) AccountMeshDataStream(in *pb.AccountMeshDataStreamRequest, ...) error
- func (s MeshService) CurrentEpoch(context.Context, *pb.CurrentEpochRequest) (*pb.CurrentEpochResponse, error)
- func (s MeshService) CurrentLayer(context.Context, *pb.CurrentLayerRequest) (*pb.CurrentLayerResponse, error)
- func (s MeshService) EpochNumLayers(context.Context, *pb.EpochNumLayersRequest) (*pb.EpochNumLayersResponse, error)
- func (s MeshService) EpochStream(req *pb.EpochStreamRequest, stream pb.MeshService_EpochStreamServer) error
- func (s MeshService) GenesisID(context.Context, *pb.GenesisIDRequest) (*pb.GenesisIDResponse, error)
- func (s MeshService) GenesisTime(context.Context, *pb.GenesisTimeRequest) (*pb.GenesisTimeResponse, error)
- func (s MeshService) LayerDuration(context.Context, *pb.LayerDurationRequest) (*pb.LayerDurationResponse, error)
- func (s MeshService) LayerStream(_ *pb.LayerStreamRequest, stream pb.MeshService_LayerStreamServer) error
- func (s MeshService) LayersQuery(ctx context.Context, in *pb.LayersQueryRequest) (*pb.LayersQueryResponse, error)
- func (s MeshService) MalfeasanceQuery(ctx context.Context, req *pb.MalfeasanceRequest) (*pb.MalfeasanceResponse, error)
- func (s MeshService) MalfeasanceStream(req *pb.MalfeasanceStreamRequest, ...) error
- func (s MeshService) MaxTransactionsPerSecond(context.Context, *pb.MaxTransactionsPerSecondRequest) (*pb.MaxTransactionsPerSecondResponse, error)
- func (s MeshService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (s MeshService) RegisterService(server *grpc.Server)
- func (s MeshService) String() string
- type MockatxProvider
- func (m *MockatxProvider) EXPECT() *MockatxProviderMockRecorder
- func (m *MockatxProvider) GetFullAtx(id types.ATXID) (*types.VerifiedActivationTx, error)
- func (m *MockatxProvider) GetMalfeasanceProof(id types.NodeID) (*types.MalfeasanceProof, error)
- func (m *MockatxProvider) MaxHeightAtx() (types.ATXID, error)
- type MockatxProviderGetFullAtxCall
- func (c *MockatxProviderGetFullAtxCall) Do(f func(types.ATXID) (*types.VerifiedActivationTx, error)) *MockatxProviderGetFullAtxCall
- func (c *MockatxProviderGetFullAtxCall) DoAndReturn(f func(types.ATXID) (*types.VerifiedActivationTx, error)) *MockatxProviderGetFullAtxCall
- func (c *MockatxProviderGetFullAtxCall) Return(arg0 *types.VerifiedActivationTx, arg1 error) *MockatxProviderGetFullAtxCall
- type MockatxProviderGetMalfeasanceProofCall
- func (c *MockatxProviderGetMalfeasanceProofCall) Do(f func(types.NodeID) (*types.MalfeasanceProof, error)) *MockatxProviderGetMalfeasanceProofCall
- func (c *MockatxProviderGetMalfeasanceProofCall) DoAndReturn(f func(types.NodeID) (*types.MalfeasanceProof, error)) *MockatxProviderGetMalfeasanceProofCall
- func (c *MockatxProviderGetMalfeasanceProofCall) Return(arg0 *types.MalfeasanceProof, arg1 error) *MockatxProviderGetMalfeasanceProofCall
- type MockatxProviderMaxHeightAtxCall
- func (c *MockatxProviderMaxHeightAtxCall) Do(f func() (types.ATXID, error)) *MockatxProviderMaxHeightAtxCall
- func (c *MockatxProviderMaxHeightAtxCall) DoAndReturn(f func() (types.ATXID, error)) *MockatxProviderMaxHeightAtxCall
- func (c *MockatxProviderMaxHeightAtxCall) Return(arg0 types.ATXID, arg1 error) *MockatxProviderMaxHeightAtxCall
- type MockatxProviderMockRecorder
- type MockconservativeState
- func (m *MockconservativeState) EXPECT() *MockconservativeStateMockRecorder
- func (m *MockconservativeState) GetAllAccounts() ([]*types.Account, error)
- func (m *MockconservativeState) GetBalance(arg0 types.Address) (uint64, error)
- func (m *MockconservativeState) GetLayerStateRoot(arg0 types.LayerID) (types.Hash32, error)
- func (m *MockconservativeState) GetMeshTransaction(arg0 types.TransactionID) (*types.MeshTransaction, error)
- func (m *MockconservativeState) GetMeshTransactions(arg0 []types.TransactionID) ([]*types.MeshTransaction, map[types.TransactionID]struct{})
- func (m *MockconservativeState) GetNonce(arg0 types.Address) (types.Nonce, error)
- func (m *MockconservativeState) GetProjection(arg0 types.Address) (uint64, uint64)
- func (m *MockconservativeState) GetStateRoot() (types.Hash32, error)
- func (m *MockconservativeState) GetTransactionsByAddress(arg0, arg1 types.LayerID, arg2 types.Address) ([]*types.MeshTransaction, error)
- func (m *MockconservativeState) Validation(raw types.RawTx) system.ValidationRequest
- type MockconservativeStateGetAllAccountsCall
- func (c *MockconservativeStateGetAllAccountsCall) Do(f func() ([]*types.Account, error)) *MockconservativeStateGetAllAccountsCall
- func (c *MockconservativeStateGetAllAccountsCall) DoAndReturn(f func() ([]*types.Account, error)) *MockconservativeStateGetAllAccountsCall
- func (c *MockconservativeStateGetAllAccountsCall) Return(arg0 []*types.Account, arg1 error) *MockconservativeStateGetAllAccountsCall
- type MockconservativeStateGetBalanceCall
- func (c *MockconservativeStateGetBalanceCall) Do(f func(types.Address) (uint64, error)) *MockconservativeStateGetBalanceCall
- func (c *MockconservativeStateGetBalanceCall) DoAndReturn(f func(types.Address) (uint64, error)) *MockconservativeStateGetBalanceCall
- func (c *MockconservativeStateGetBalanceCall) Return(arg0 uint64, arg1 error) *MockconservativeStateGetBalanceCall
- type MockconservativeStateGetLayerStateRootCall
- func (c *MockconservativeStateGetLayerStateRootCall) Do(f func(types.LayerID) (types.Hash32, error)) *MockconservativeStateGetLayerStateRootCall
- func (c *MockconservativeStateGetLayerStateRootCall) DoAndReturn(f func(types.LayerID) (types.Hash32, error)) *MockconservativeStateGetLayerStateRootCall
- func (c *MockconservativeStateGetLayerStateRootCall) Return(arg0 types.Hash32, arg1 error) *MockconservativeStateGetLayerStateRootCall
- type MockconservativeStateGetMeshTransactionCall
- func (c *MockconservativeStateGetMeshTransactionCall) Do(f func(types.TransactionID) (*types.MeshTransaction, error)) *MockconservativeStateGetMeshTransactionCall
- func (c *MockconservativeStateGetMeshTransactionCall) DoAndReturn(f func(types.TransactionID) (*types.MeshTransaction, error)) *MockconservativeStateGetMeshTransactionCall
- func (c *MockconservativeStateGetMeshTransactionCall) Return(arg0 *types.MeshTransaction, arg1 error) *MockconservativeStateGetMeshTransactionCall
- type MockconservativeStateGetMeshTransactionsCall
- func (c *MockconservativeStateGetMeshTransactionsCall) Do(...) *MockconservativeStateGetMeshTransactionsCall
- func (c *MockconservativeStateGetMeshTransactionsCall) DoAndReturn(...) *MockconservativeStateGetMeshTransactionsCall
- func (c *MockconservativeStateGetMeshTransactionsCall) Return(arg0 []*types.MeshTransaction, arg1 map[types.TransactionID]struct{}) *MockconservativeStateGetMeshTransactionsCall
- type MockconservativeStateGetNonceCall
- func (c *MockconservativeStateGetNonceCall) Do(f func(types.Address) (types.Nonce, error)) *MockconservativeStateGetNonceCall
- func (c *MockconservativeStateGetNonceCall) DoAndReturn(f func(types.Address) (types.Nonce, error)) *MockconservativeStateGetNonceCall
- func (c *MockconservativeStateGetNonceCall) Return(arg0 types.Nonce, arg1 error) *MockconservativeStateGetNonceCall
- type MockconservativeStateGetProjectionCall
- func (c *MockconservativeStateGetProjectionCall) Do(f func(types.Address) (uint64, uint64)) *MockconservativeStateGetProjectionCall
- func (c *MockconservativeStateGetProjectionCall) DoAndReturn(f func(types.Address) (uint64, uint64)) *MockconservativeStateGetProjectionCall
- func (c *MockconservativeStateGetProjectionCall) Return(arg0, arg1 uint64) *MockconservativeStateGetProjectionCall
- type MockconservativeStateGetStateRootCall
- func (c *MockconservativeStateGetStateRootCall) Do(f func() (types.Hash32, error)) *MockconservativeStateGetStateRootCall
- func (c *MockconservativeStateGetStateRootCall) DoAndReturn(f func() (types.Hash32, error)) *MockconservativeStateGetStateRootCall
- func (c *MockconservativeStateGetStateRootCall) Return(arg0 types.Hash32, arg1 error) *MockconservativeStateGetStateRootCall
- type MockconservativeStateGetTransactionsByAddressCall
- func (c *MockconservativeStateGetTransactionsByAddressCall) Do(...) *MockconservativeStateGetTransactionsByAddressCall
- func (c *MockconservativeStateGetTransactionsByAddressCall) DoAndReturn(...) *MockconservativeStateGetTransactionsByAddressCall
- func (c *MockconservativeStateGetTransactionsByAddressCall) Return(arg0 []*types.MeshTransaction, arg1 error) *MockconservativeStateGetTransactionsByAddressCall
- type MockconservativeStateMockRecorder
- func (mr *MockconservativeStateMockRecorder) GetAllAccounts() *MockconservativeStateGetAllAccountsCall
- func (mr *MockconservativeStateMockRecorder) GetBalance(arg0 any) *MockconservativeStateGetBalanceCall
- func (mr *MockconservativeStateMockRecorder) GetLayerStateRoot(arg0 any) *MockconservativeStateGetLayerStateRootCall
- func (mr *MockconservativeStateMockRecorder) GetMeshTransaction(arg0 any) *MockconservativeStateGetMeshTransactionCall
- func (mr *MockconservativeStateMockRecorder) GetMeshTransactions(arg0 any) *MockconservativeStateGetMeshTransactionsCall
- func (mr *MockconservativeStateMockRecorder) GetNonce(arg0 any) *MockconservativeStateGetNonceCall
- func (mr *MockconservativeStateMockRecorder) GetProjection(arg0 any) *MockconservativeStateGetProjectionCall
- func (mr *MockconservativeStateMockRecorder) GetStateRoot() *MockconservativeStateGetStateRootCall
- func (mr *MockconservativeStateMockRecorder) GetTransactionsByAddress(arg0, arg1, arg2 any) *MockconservativeStateGetTransactionsByAddressCall
- func (mr *MockconservativeStateMockRecorder) Validation(raw any) *MockconservativeStateValidationCall
- type MockconservativeStateValidationCall
- func (c *MockconservativeStateValidationCall) Do(f func(types.RawTx) system.ValidationRequest) *MockconservativeStateValidationCall
- func (c *MockconservativeStateValidationCall) DoAndReturn(f func(types.RawTx) system.ValidationRequest) *MockconservativeStateValidationCall
- func (c *MockconservativeStateValidationCall) Return(arg0 system.ValidationRequest) *MockconservativeStateValidationCall
- type MockgenesisTimeAPI
- type MockgenesisTimeAPICurrentLayerCall
- func (c *MockgenesisTimeAPICurrentLayerCall) Do(f func() types.LayerID) *MockgenesisTimeAPICurrentLayerCall
- func (c *MockgenesisTimeAPICurrentLayerCall) DoAndReturn(f func() types.LayerID) *MockgenesisTimeAPICurrentLayerCall
- func (c *MockgenesisTimeAPICurrentLayerCall) Return(arg0 types.LayerID) *MockgenesisTimeAPICurrentLayerCall
- type MockgenesisTimeAPIGenesisTimeCall
- func (c *MockgenesisTimeAPIGenesisTimeCall) Do(f func() time.Time) *MockgenesisTimeAPIGenesisTimeCall
- func (c *MockgenesisTimeAPIGenesisTimeCall) DoAndReturn(f func() time.Time) *MockgenesisTimeAPIGenesisTimeCall
- func (c *MockgenesisTimeAPIGenesisTimeCall) Return(arg0 time.Time) *MockgenesisTimeAPIGenesisTimeCall
- type MockgenesisTimeAPIMockRecorder
- type MockmeshAPI
- func (m *MockmeshAPI) EXPECT() *MockmeshAPIMockRecorder
- func (m *MockmeshAPI) GetLayer(arg0 types.LayerID) (*types.Layer, error)
- func (m *MockmeshAPI) GetLayerVerified(arg0 types.LayerID) (*types.Block, error)
- func (m *MockmeshAPI) GetRewardsByCoinbase(arg0 types.Address) ([]*types.Reward, error)
- func (m *MockmeshAPI) GetRewardsBySmesherId(id types.NodeID) ([]*types.Reward, error)
- func (m *MockmeshAPI) LatestLayer() types.LayerID
- func (m *MockmeshAPI) LatestLayerInState() types.LayerID
- func (m *MockmeshAPI) MeshHash(arg0 types.LayerID) (types.Hash32, error)
- func (m *MockmeshAPI) ProcessedLayer() types.LayerID
- type MockmeshAPIGetLayerCall
- func (c *MockmeshAPIGetLayerCall) Do(f func(types.LayerID) (*types.Layer, error)) *MockmeshAPIGetLayerCall
- func (c *MockmeshAPIGetLayerCall) DoAndReturn(f func(types.LayerID) (*types.Layer, error)) *MockmeshAPIGetLayerCall
- func (c *MockmeshAPIGetLayerCall) Return(arg0 *types.Layer, arg1 error) *MockmeshAPIGetLayerCall
- type MockmeshAPIGetLayerVerifiedCall
- func (c *MockmeshAPIGetLayerVerifiedCall) Do(f func(types.LayerID) (*types.Block, error)) *MockmeshAPIGetLayerVerifiedCall
- func (c *MockmeshAPIGetLayerVerifiedCall) DoAndReturn(f func(types.LayerID) (*types.Block, error)) *MockmeshAPIGetLayerVerifiedCall
- func (c *MockmeshAPIGetLayerVerifiedCall) Return(arg0 *types.Block, arg1 error) *MockmeshAPIGetLayerVerifiedCall
- type MockmeshAPIGetRewardsByCoinbaseCall
- func (c *MockmeshAPIGetRewardsByCoinbaseCall) Do(f func(types.Address) ([]*types.Reward, error)) *MockmeshAPIGetRewardsByCoinbaseCall
- func (c *MockmeshAPIGetRewardsByCoinbaseCall) DoAndReturn(f func(types.Address) ([]*types.Reward, error)) *MockmeshAPIGetRewardsByCoinbaseCall
- func (c *MockmeshAPIGetRewardsByCoinbaseCall) Return(arg0 []*types.Reward, arg1 error) *MockmeshAPIGetRewardsByCoinbaseCall
- type MockmeshAPIGetRewardsBySmesherIdCall
- func (c *MockmeshAPIGetRewardsBySmesherIdCall) Do(f func(types.NodeID) ([]*types.Reward, error)) *MockmeshAPIGetRewardsBySmesherIdCall
- func (c *MockmeshAPIGetRewardsBySmesherIdCall) DoAndReturn(f func(types.NodeID) ([]*types.Reward, error)) *MockmeshAPIGetRewardsBySmesherIdCall
- func (c *MockmeshAPIGetRewardsBySmesherIdCall) Return(arg0 []*types.Reward, arg1 error) *MockmeshAPIGetRewardsBySmesherIdCall
- type MockmeshAPILatestLayerCall
- type MockmeshAPILatestLayerInStateCall
- func (c *MockmeshAPILatestLayerInStateCall) Do(f func() types.LayerID) *MockmeshAPILatestLayerInStateCall
- func (c *MockmeshAPILatestLayerInStateCall) DoAndReturn(f func() types.LayerID) *MockmeshAPILatestLayerInStateCall
- func (c *MockmeshAPILatestLayerInStateCall) Return(arg0 types.LayerID) *MockmeshAPILatestLayerInStateCall
- type MockmeshAPIMeshHashCall
- func (c *MockmeshAPIMeshHashCall) Do(f func(types.LayerID) (types.Hash32, error)) *MockmeshAPIMeshHashCall
- func (c *MockmeshAPIMeshHashCall) DoAndReturn(f func(types.LayerID) (types.Hash32, error)) *MockmeshAPIMeshHashCall
- func (c *MockmeshAPIMeshHashCall) Return(arg0 types.Hash32, arg1 error) *MockmeshAPIMeshHashCall
- type MockmeshAPIMockRecorder
- func (mr *MockmeshAPIMockRecorder) GetLayer(arg0 any) *MockmeshAPIGetLayerCall
- func (mr *MockmeshAPIMockRecorder) GetLayerVerified(arg0 any) *MockmeshAPIGetLayerVerifiedCall
- func (mr *MockmeshAPIMockRecorder) GetRewardsByCoinbase(arg0 any) *MockmeshAPIGetRewardsByCoinbaseCall
- func (mr *MockmeshAPIMockRecorder) GetRewardsBySmesherId(id any) *MockmeshAPIGetRewardsBySmesherIdCall
- func (mr *MockmeshAPIMockRecorder) LatestLayer() *MockmeshAPILatestLayerCall
- func (mr *MockmeshAPIMockRecorder) LatestLayerInState() *MockmeshAPILatestLayerInStateCall
- func (mr *MockmeshAPIMockRecorder) MeshHash(arg0 any) *MockmeshAPIMeshHashCall
- func (mr *MockmeshAPIMockRecorder) ProcessedLayer() *MockmeshAPIProcessedLayerCall
- type MockmeshAPIProcessedLayerCall
- func (c *MockmeshAPIProcessedLayerCall) Do(f func() types.LayerID) *MockmeshAPIProcessedLayerCall
- func (c *MockmeshAPIProcessedLayerCall) DoAndReturn(f func() types.LayerID) *MockmeshAPIProcessedLayerCall
- func (c *MockmeshAPIProcessedLayerCall) Return(arg0 types.LayerID) *MockmeshAPIProcessedLayerCall
- type MocknetworkInfo
- func (m *MocknetworkInfo) DHTServerEnabled() bool
- func (m *MocknetworkInfo) EXPECT() *MocknetworkInfoMockRecorder
- func (m *MocknetworkInfo) ID() p2p.Peer
- func (m *MocknetworkInfo) KnownAddresses() []multiaddr.Multiaddr
- func (m *MocknetworkInfo) ListenAddresses() []multiaddr.Multiaddr
- func (m *MocknetworkInfo) NATDeviceType() (network.NATDeviceType, network.NATDeviceType)
- func (m *MocknetworkInfo) Reachability() network.Reachability
- type MocknetworkInfoDHTServerEnabledCall
- func (c *MocknetworkInfoDHTServerEnabledCall) Do(f func() bool) *MocknetworkInfoDHTServerEnabledCall
- func (c *MocknetworkInfoDHTServerEnabledCall) DoAndReturn(f func() bool) *MocknetworkInfoDHTServerEnabledCall
- func (c *MocknetworkInfoDHTServerEnabledCall) Return(arg0 bool) *MocknetworkInfoDHTServerEnabledCall
- type MocknetworkInfoIDCall
- type MocknetworkInfoKnownAddressesCall
- func (c *MocknetworkInfoKnownAddressesCall) Do(f func() []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall
- func (c *MocknetworkInfoKnownAddressesCall) DoAndReturn(f func() []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall
- func (c *MocknetworkInfoKnownAddressesCall) Return(arg0 []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall
- type MocknetworkInfoListenAddressesCall
- func (c *MocknetworkInfoListenAddressesCall) Do(f func() []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall
- func (c *MocknetworkInfoListenAddressesCall) DoAndReturn(f func() []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall
- func (c *MocknetworkInfoListenAddressesCall) Return(arg0 []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall
- type MocknetworkInfoMockRecorder
- func (mr *MocknetworkInfoMockRecorder) DHTServerEnabled() *MocknetworkInfoDHTServerEnabledCall
- func (mr *MocknetworkInfoMockRecorder) ID() *MocknetworkInfoIDCall
- func (mr *MocknetworkInfoMockRecorder) KnownAddresses() *MocknetworkInfoKnownAddressesCall
- func (mr *MocknetworkInfoMockRecorder) ListenAddresses() *MocknetworkInfoListenAddressesCall
- func (mr *MocknetworkInfoMockRecorder) NATDeviceType() *MocknetworkInfoNATDeviceTypeCall
- func (mr *MocknetworkInfoMockRecorder) Reachability() *MocknetworkInfoReachabilityCall
- type MocknetworkInfoNATDeviceTypeCall
- func (c *MocknetworkInfoNATDeviceTypeCall) Do(f func() (network.NATDeviceType, network.NATDeviceType)) *MocknetworkInfoNATDeviceTypeCall
- func (c *MocknetworkInfoNATDeviceTypeCall) DoAndReturn(f func() (network.NATDeviceType, network.NATDeviceType)) *MocknetworkInfoNATDeviceTypeCall
- func (c *MocknetworkInfoNATDeviceTypeCall) Return(udpNATType, tcpNATType network.NATDeviceType) *MocknetworkInfoNATDeviceTypeCall
- type MocknetworkInfoReachabilityCall
- func (c *MocknetworkInfoReachabilityCall) Do(f func() network.Reachability) *MocknetworkInfoReachabilityCall
- func (c *MocknetworkInfoReachabilityCall) DoAndReturn(f func() network.Reachability) *MocknetworkInfoReachabilityCall
- func (c *MocknetworkInfoReachabilityCall) Return(arg0 network.Reachability) *MocknetworkInfoReachabilityCall
- type Mockoracle
- type MockoracleActiveSetCall
- func (c *MockoracleActiveSetCall) Do(f func(context.Context, types.EpochID) ([]types.ATXID, error)) *MockoracleActiveSetCall
- func (c *MockoracleActiveSetCall) DoAndReturn(f func(context.Context, types.EpochID) ([]types.ATXID, error)) *MockoracleActiveSetCall
- func (c *MockoracleActiveSetCall) Return(arg0 []types.ATXID, arg1 error) *MockoracleActiveSetCall
- type MockoracleMockRecorder
- type MockpeerCounter
- type MockpeerCounterMockRecorder
- type MockpeerCounterPeerCountCall
- type Mockpeers
- type MockpeersConnectedPeerInfoCall
- func (c *MockpeersConnectedPeerInfoCall) Do(f func(p2p.Peer) *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall
- func (c *MockpeersConnectedPeerInfoCall) DoAndReturn(f func(p2p.Peer) *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall
- func (c *MockpeersConnectedPeerInfoCall) Return(arg0 *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall
- type MockpeersGetPeersCall
- type MockpeersMockRecorder
- type MockpostSupervisor
- func (m *MockpostSupervisor) Benchmark(p activation.PostSetupProvider) (int, error)
- func (m *MockpostSupervisor) Config() activation.PostConfig
- func (m *MockpostSupervisor) EXPECT() *MockpostSupervisorMockRecorder
- func (m *MockpostSupervisor) Providers() ([]activation.PostSetupProvider, error)
- func (m *MockpostSupervisor) Start(opts activation.PostSetupOpts, id types.NodeID) error
- func (m *MockpostSupervisor) Status() *activation.PostSetupStatus
- func (m *MockpostSupervisor) Stop(deleteFiles bool) error
- type MockpostSupervisorBenchmarkCall
- func (c *MockpostSupervisorBenchmarkCall) Do(f func(activation.PostSetupProvider) (int, error)) *MockpostSupervisorBenchmarkCall
- func (c *MockpostSupervisorBenchmarkCall) DoAndReturn(f func(activation.PostSetupProvider) (int, error)) *MockpostSupervisorBenchmarkCall
- func (c *MockpostSupervisorBenchmarkCall) Return(arg0 int, arg1 error) *MockpostSupervisorBenchmarkCall
- type MockpostSupervisorConfigCall
- func (c *MockpostSupervisorConfigCall) Do(f func() activation.PostConfig) *MockpostSupervisorConfigCall
- func (c *MockpostSupervisorConfigCall) DoAndReturn(f func() activation.PostConfig) *MockpostSupervisorConfigCall
- func (c *MockpostSupervisorConfigCall) Return(arg0 activation.PostConfig) *MockpostSupervisorConfigCall
- type MockpostSupervisorMockRecorder
- func (mr *MockpostSupervisorMockRecorder) Benchmark(p any) *MockpostSupervisorBenchmarkCall
- func (mr *MockpostSupervisorMockRecorder) Config() *MockpostSupervisorConfigCall
- func (mr *MockpostSupervisorMockRecorder) Providers() *MockpostSupervisorProvidersCall
- func (mr *MockpostSupervisorMockRecorder) Start(opts, id any) *MockpostSupervisorStartCall
- func (mr *MockpostSupervisorMockRecorder) Status() *MockpostSupervisorStatusCall
- func (mr *MockpostSupervisorMockRecorder) Stop(deleteFiles any) *MockpostSupervisorStopCall
- type MockpostSupervisorProvidersCall
- func (c *MockpostSupervisorProvidersCall) Do(f func() ([]activation.PostSetupProvider, error)) *MockpostSupervisorProvidersCall
- func (c *MockpostSupervisorProvidersCall) DoAndReturn(f func() ([]activation.PostSetupProvider, error)) *MockpostSupervisorProvidersCall
- func (c *MockpostSupervisorProvidersCall) Return(arg0 []activation.PostSetupProvider, arg1 error) *MockpostSupervisorProvidersCall
- type MockpostSupervisorStartCall
- func (c *MockpostSupervisorStartCall) Do(f func(activation.PostSetupOpts, types.NodeID) error) *MockpostSupervisorStartCall
- func (c *MockpostSupervisorStartCall) DoAndReturn(f func(activation.PostSetupOpts, types.NodeID) error) *MockpostSupervisorStartCall
- func (c *MockpostSupervisorStartCall) Return(arg0 error) *MockpostSupervisorStartCall
- type MockpostSupervisorStatusCall
- func (c *MockpostSupervisorStatusCall) Do(f func() *activation.PostSetupStatus) *MockpostSupervisorStatusCall
- func (c *MockpostSupervisorStatusCall) DoAndReturn(f func() *activation.PostSetupStatus) *MockpostSupervisorStatusCall
- func (c *MockpostSupervisorStatusCall) Return(arg0 *activation.PostSetupStatus) *MockpostSupervisorStatusCall
- type MockpostSupervisorStopCall
- type Mocksyncer
- type MocksyncerIsSyncedCall
- type MocksyncerMockRecorder
- type MocktxValidator
- type MocktxValidatorMockRecorder
- type MocktxValidatorVerifyAndCacheTxCall
- func (c *MocktxValidatorVerifyAndCacheTxCall) Do(f func(context.Context, []byte) error) *MocktxValidatorVerifyAndCacheTxCall
- func (c *MocktxValidatorVerifyAndCacheTxCall) DoAndReturn(f func(context.Context, []byte) error) *MocktxValidatorVerifyAndCacheTxCall
- func (c *MocktxValidatorVerifyAndCacheTxCall) Return(arg0 error) *MocktxValidatorVerifyAndCacheTxCall
- type NodeService
- func (s NodeService) Build(context.Context, *emptypb.Empty) (*pb.BuildResponse, error)
- func (s NodeService) Echo(_ context.Context, in *pb.EchoRequest) (*pb.EchoResponse, error)
- func (s NodeService) ErrorStream(_ *pb.ErrorStreamRequest, stream pb.NodeService_ErrorStreamServer) error
- func (s NodeService) NodeInfo(context.Context, *emptypb.Empty) (*pb.NodeInfoResponse, error)
- func (s NodeService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (s NodeService) RegisterService(server *grpc.Server)
- func (s NodeService) Status(ctx context.Context, _ *pb.StatusRequest) (*pb.StatusResponse, error)
- func (s NodeService) StatusStream(_ *pb.StatusStreamRequest, stream pb.NodeService_StatusStreamServer) error
- func (s NodeService) String() string
- func (s NodeService) Version(context.Context, *emptypb.Empty) (*pb.VersionResponse, error)
- type PostService
- func (s *PostService) Client(nodeId types.NodeID) (activation.PostClient, error)
- func (s *PostService) Register(stream pb.PostService_RegisterServer) error
- func (s *PostService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (s *PostService) RegisterService(server *grpc.Server)
- func (s *PostService) String() string
- type Server
- type Service
- type ServiceAPI
- type SmesherService
- func (s SmesherService) Coinbase(context.Context, *emptypb.Empty) (*pb.CoinbaseResponse, error)
- func (s SmesherService) EstimatedRewards(context.Context, *pb.EstimatedRewardsRequest) (*pb.EstimatedRewardsResponse, error)
- func (s SmesherService) IsSmeshing(context.Context, *emptypb.Empty) (*pb.IsSmeshingResponse, error)
- func (s SmesherService) MinGas(context.Context, *emptypb.Empty) (*pb.MinGasResponse, error)
- func (s SmesherService) PostConfig(context.Context, *emptypb.Empty) (*pb.PostConfigResponse, error)
- func (s SmesherService) PostSetupProviders(ctx context.Context, in *pb.PostSetupProvidersRequest) (*pb.PostSetupProvidersResponse, error)
- func (s SmesherService) PostSetupStatus(ctx context.Context, _ *emptypb.Empty) (*pb.PostSetupStatusResponse, error)
- func (s SmesherService) PostSetupStatusStream(_ *emptypb.Empty, stream pb.SmesherService_PostSetupStatusStreamServer) error
- func (s SmesherService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (s SmesherService) RegisterService(server *grpc.Server)
- func (s SmesherService) SetCoinbase(_ context.Context, in *pb.SetCoinbaseRequest) (*pb.SetCoinbaseResponse, error)
- func (s SmesherService) SetMinGas(context.Context, *pb.SetMinGasRequest) (*pb.SetMinGasResponse, error)
- func (s SmesherService) SmesherID(context.Context, *emptypb.Empty) (*pb.SmesherIDResponse, error)
- func (s SmesherService) SmesherIDs(context.Context, *emptypb.Empty) (*pb.SmesherIDsResponse, error)
- func (s SmesherService) StartSmeshing(ctx context.Context, in *pb.StartSmeshingRequest) (*pb.StartSmeshingResponse, error)
- func (s SmesherService) StopSmeshing(ctx context.Context, in *pb.StopSmeshingRequest) (*pb.StopSmeshingResponse, error)
- func (s SmesherService) String() string
- type TransactionService
- func (s TransactionService) ParseTransaction(ctx context.Context, in *pb.ParseTransactionRequest) (*pb.ParseTransactionResponse, error)
- func (s TransactionService) RegisterHandlerService(mux *runtime.ServeMux) error
- func (s TransactionService) RegisterService(server *grpc.Server)
- func (s TransactionService) StreamResults(in *pb.TransactionResultsRequest, ...) error
- func (s TransactionService) String() string
- func (s TransactionService) SubmitTransaction(ctx context.Context, in *pb.SubmitTransactionRequest) (*pb.SubmitTransactionResponse, error)
- func (s TransactionService) TransactionsState(_ context.Context, in *pb.TransactionsStateRequest) (*pb.TransactionsStateResponse, error)
- func (s TransactionService) TransactionsStateStream(in *pb.TransactionsStateStreamRequest, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewActivationService ¶ added in v1.0.0
Types ¶
type AdminService ¶ added in v1.0.0
type AdminService struct {
// contains filtered or unexported fields
}
AdminService exposes endpoints for node administration.
func NewAdminService ¶ added in v1.0.0
func NewAdminService(db *sql.Database, dataDir string, p peers) *AdminService
NewAdminService creates a new admin grpc service.
func (AdminService) CheckpointStream ¶ added in v1.0.0
func (a AdminService) CheckpointStream( req *pb.CheckpointStreamRequest, stream pb.AdminService_CheckpointStreamServer, ) error
func (AdminService) EventsStream ¶ added in v1.0.0
func (a AdminService) EventsStream(req *pb.EventStreamRequest, stream pb.AdminService_EventsStreamServer) error
func (AdminService) PeerInfoStream ¶ added in v1.1.2
func (a AdminService) PeerInfoStream(_ *emptypb.Empty, stream pb.AdminService_PeerInfoStreamServer) error
func (AdminService) Recover ¶ added in v1.0.0
func (a AdminService) Recover(ctx context.Context, _ *pb.RecoverRequest) (*emptypb.Empty, error)
func (AdminService) RegisterHandlerService ¶ added in v1.3.0
func (s AdminService) RegisterHandlerService(mux *runtime.ServeMux) error
func (AdminService) RegisterService ¶ added in v1.0.0
func (a AdminService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (AdminService) String ¶ added in v1.3.0
func (a AdminService) String() string
String returns the name of this service.
type Config ¶ added in v1.0.0
type Config struct { PublicServices []Service PublicListener string `mapstructure:"grpc-public-listener"` PrivateServices []Service PrivateListener string `mapstructure:"grpc-private-listener"` PostServices []Service PostListener string `mapstructure:"grpc-post-listener"` TLSServices []Service `mapstructure:"grpc-tls-services"` TLSListener string `mapstructure:"grpc-tls-listener"` TLSCACert string `mapstructure:"grpc-tls-ca-cert"` TLSCert string `mapstructure:"grpc-tls-cert"` TLSKey string `mapstructure:"grpc-tls-key"` GrpcSendMsgSize int `mapstructure:"grpc-send-msg-size"` GrpcRecvMsgSize int `mapstructure:"grpc-recv-msg-size"` JSONListener string `mapstructure:"grpc-json-listener"` SmesherStreamInterval time.Duration `mapstructure:"smesherstreaminterval"` }
func DefaultConfig ¶ added in v1.0.0
func DefaultConfig() Config
DefaultConfig defines the default configuration options for api.
func DefaultTestConfig ¶ added in v1.0.0
func DefaultTestConfig() Config
DefaultTestConfig returns the default config for tests.
type DebugService ¶ added in v0.1.16
type DebugService struct {
// contains filtered or unexported fields
}
DebugService exposes global state data, output from the STF.
func NewDebugService ¶ added in v0.1.16
func NewDebugService(db *sql.Database, conState conservativeState, host networkInfo, oracle oracle) *DebugService
NewDebugService creates a new grpc service using config data.
func (DebugService) Accounts ¶ added in v0.1.16
func (d DebugService) Accounts(ctx context.Context, in *pb.AccountsRequest) (*pb.AccountsResponse, error)
Accounts returns current counter and balance for all accounts.
func (DebugService) ActiveSet ¶ added in v1.0.0
func (d DebugService) ActiveSet(ctx context.Context, req *pb.ActiveSetRequest) (*pb.ActiveSetResponse, error)
ActiveSet query provides hare active set for the specified epoch.
func (DebugService) NetworkInfo ¶ added in v1.0.0
func (d DebugService) NetworkInfo(ctx context.Context, _ *emptypb.Empty) (*pb.NetworkInfoResponse, error)
NetworkInfo query provides NetworkInfoResponse.
func (DebugService) ProposalsStream ¶ added in v1.0.0
func (d DebugService) ProposalsStream(_ *emptypb.Empty, stream pb.DebugService_ProposalsStreamServer) error
ProposalsStream streams all proposals confirmed by hare.
func (DebugService) RegisterHandlerService ¶ added in v1.3.0
func (s DebugService) RegisterHandlerService(mux *runtime.ServeMux) error
func (DebugService) RegisterService ¶ added in v0.1.16
func (d DebugService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (DebugService) String ¶ added in v1.3.0
func (d DebugService) String() string
String returns the name of this service.
type GlobalStateService ¶
type GlobalStateService struct {
// contains filtered or unexported fields
}
GlobalStateService exposes global state data, output from the STF.
func NewGlobalStateService ¶
func NewGlobalStateService(msh meshAPI, conState conservativeState) *GlobalStateService
NewGlobalStateService creates a new grpc service using config data.
func (GlobalStateService) Account ¶
func (s GlobalStateService) Account(ctx context.Context, in *pb.AccountRequest) (*pb.AccountResponse, error)
Account returns current and projected counter and balance for one account.
func (GlobalStateService) AccountDataQuery ¶
func (s GlobalStateService) AccountDataQuery( ctx context.Context, in *pb.AccountDataQueryRequest, ) (*pb.AccountDataQueryResponse, error)
AccountDataQuery returns historical account data such as rewards and receipts.
func (GlobalStateService) AccountDataStream ¶
func (s GlobalStateService) AccountDataStream( in *pb.AccountDataStreamRequest, stream pb.GlobalStateService_AccountDataStreamServer, ) error
AccountDataStream exposes a stream of account-related data.
func (GlobalStateService) AppEventStream ¶
func (s GlobalStateService) AppEventStream( *pb.AppEventStreamRequest, pb.GlobalStateService_AppEventStreamServer, ) error
AppEventStream exposes a stream of emitted app events.
func (GlobalStateService) GlobalStateHash ¶
func (s GlobalStateService) GlobalStateHash( context.Context, *pb.GlobalStateHashRequest, ) (*pb.GlobalStateHashResponse, error)
GlobalStateHash returns the latest layer and its computed global state hash.
func (GlobalStateService) GlobalStateStream ¶
func (s GlobalStateService) GlobalStateStream( in *pb.GlobalStateStreamRequest, stream pb.GlobalStateService_GlobalStateStreamServer, ) error
GlobalStateStream exposes a stream of global data data items: rewards, receipts, account info, global state hash.
func (GlobalStateService) RegisterHandlerService ¶ added in v1.3.0
func (s GlobalStateService) RegisterHandlerService(mux *runtime.ServeMux) error
func (GlobalStateService) RegisterService ¶
func (s GlobalStateService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (GlobalStateService) SmesherDataQuery ¶
func (s GlobalStateService) SmesherDataQuery( _ context.Context, in *pb.SmesherDataQueryRequest, ) (*pb.SmesherDataQueryResponse, error)
SmesherDataQuery returns historical info on smesher rewards.
func (GlobalStateService) SmesherRewardStream ¶
func (s GlobalStateService) SmesherRewardStream( in *pb.SmesherRewardStreamRequest, stream pb.GlobalStateService_SmesherRewardStreamServer, ) error
SmesherRewardStream exposes a stream of smesher rewards.
func (GlobalStateService) String ¶ added in v1.3.0
func (s GlobalStateService) String() string
String returns the name of the service.
type JSONHTTPServer ¶
type JSONHTTPServer struct { // BoundAddress contains the address that the server bound to, useful if // the server uses a dynamic port. It is set during startup and can be // safely accessed after Start has completed (I.E. the returned channel has // been waited on) BoundAddress string // contains filtered or unexported fields }
JSONHTTPServer is a JSON http server providing the Spacemesh API. It is implemented using a grpc-gateway. See https://github.com/grpc-ecosystem/grpc-gateway .
func NewJSONHTTPServer ¶
func NewJSONHTTPServer(listener string, lg *zap.Logger) *JSONHTTPServer
NewJSONHTTPServer creates a new json http server.
func (*JSONHTTPServer) Shutdown ¶ added in v1.0.0
func (s *JSONHTTPServer) Shutdown(ctx context.Context) error
Shutdown stops the server.
func (*JSONHTTPServer) StartService ¶
func (s *JSONHTTPServer) StartService( ctx context.Context, services ...ServiceAPI, ) error
StartService starts the json api server and listens for status (started, stopped).
type MeshService ¶
type MeshService struct {
// contains filtered or unexported fields
}
MeshService exposes mesh data such as accounts, blocks, and transactions.
func NewMeshService ¶
func NewMeshService( cdb *datastore.CachedDB, msh meshAPI, cstate conservativeState, genTime genesisTimeAPI, layersPerEpoch uint32, genesisID types.Hash20, layerDuration time.Duration, layerAvgSize, txsPerProposal uint32, ) *MeshService
NewMeshService creates a new service using config data.
func (MeshService) AccountMeshDataQuery ¶
func (s MeshService) AccountMeshDataQuery( ctx context.Context, in *pb.AccountMeshDataQueryRequest, ) (*pb.AccountMeshDataQueryResponse, error)
AccountMeshDataQuery returns account data.
func (MeshService) AccountMeshDataStream ¶
func (s MeshService) AccountMeshDataStream( in *pb.AccountMeshDataStreamRequest, stream pb.MeshService_AccountMeshDataStreamServer, ) error
AccountMeshDataStream exposes a stream of transactions and activations for an account.
func (MeshService) CurrentEpoch ¶
func (s MeshService) CurrentEpoch(context.Context, *pb.CurrentEpochRequest) (*pb.CurrentEpochResponse, error)
CurrentEpoch returns the current epoch number.
func (MeshService) CurrentLayer ¶
func (s MeshService) CurrentLayer(context.Context, *pb.CurrentLayerRequest) (*pb.CurrentLayerResponse, error)
CurrentLayer returns the current layer number.
func (MeshService) EpochNumLayers ¶
func (s MeshService) EpochNumLayers(context.Context, *pb.EpochNumLayersRequest) (*pb.EpochNumLayersResponse, error)
EpochNumLayers returns the number of layers per epoch (a network parameter).
func (MeshService) EpochStream ¶ added in v1.0.0
func (s MeshService) EpochStream(req *pb.EpochStreamRequest, stream pb.MeshService_EpochStreamServer) error
func (MeshService) GenesisID ¶ added in v1.0.0
func (s MeshService) GenesisID(context.Context, *pb.GenesisIDRequest) (*pb.GenesisIDResponse, error)
GenesisID returns the network ID.
func (MeshService) GenesisTime ¶
func (s MeshService) GenesisTime(context.Context, *pb.GenesisTimeRequest) (*pb.GenesisTimeResponse, error)
GenesisTime returns the network genesis time as UNIX time.
func (MeshService) LayerDuration ¶
func (s MeshService) LayerDuration(context.Context, *pb.LayerDurationRequest) (*pb.LayerDurationResponse, error)
LayerDuration returns the layer duration in seconds (a network parameter).
func (MeshService) LayerStream ¶
func (s MeshService) LayerStream(_ *pb.LayerStreamRequest, stream pb.MeshService_LayerStreamServer) error
LayerStream exposes a stream of all mesh data per layer.
func (MeshService) LayersQuery ¶
func (s MeshService) LayersQuery(ctx context.Context, in *pb.LayersQueryRequest) (*pb.LayersQueryResponse, error)
LayersQuery returns all mesh data, layer by layer.
func (MeshService) MalfeasanceQuery ¶ added in v1.1.0
func (s MeshService) MalfeasanceQuery( ctx context.Context, req *pb.MalfeasanceRequest, ) (*pb.MalfeasanceResponse, error)
func (MeshService) MalfeasanceStream ¶ added in v1.1.0
func (s MeshService) MalfeasanceStream( req *pb.MalfeasanceStreamRequest, stream pb.MeshService_MalfeasanceStreamServer, ) error
func (MeshService) MaxTransactionsPerSecond ¶
func (s MeshService) MaxTransactionsPerSecond( context.Context, *pb.MaxTransactionsPerSecondRequest, ) (*pb.MaxTransactionsPerSecondResponse, error)
MaxTransactionsPerSecond returns the max number of tx per sec (a network parameter).
func (MeshService) RegisterHandlerService ¶ added in v1.3.0
func (s MeshService) RegisterHandlerService(mux *runtime.ServeMux) error
func (MeshService) RegisterService ¶
func (s MeshService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (MeshService) String ¶ added in v1.3.0
func (s MeshService) String() string
String returns the name of this service.
type MockatxProvider ¶ added in v1.0.0
type MockatxProvider struct {
// contains filtered or unexported fields
}
MockatxProvider is a mock of atxProvider interface.
func NewMockatxProvider ¶ added in v1.0.0
func NewMockatxProvider(ctrl *gomock.Controller) *MockatxProvider
NewMockatxProvider creates a new mock instance.
func (*MockatxProvider) EXPECT ¶ added in v1.0.0
func (m *MockatxProvider) EXPECT() *MockatxProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockatxProvider) GetFullAtx ¶ added in v1.0.0
func (m *MockatxProvider) GetFullAtx(id types.ATXID) (*types.VerifiedActivationTx, error)
GetFullAtx mocks base method.
func (*MockatxProvider) GetMalfeasanceProof ¶ added in v1.1.0
func (m *MockatxProvider) GetMalfeasanceProof(id types.NodeID) (*types.MalfeasanceProof, error)
GetMalfeasanceProof mocks base method.
func (*MockatxProvider) MaxHeightAtx ¶ added in v1.0.0
func (m *MockatxProvider) MaxHeightAtx() (types.ATXID, error)
MaxHeightAtx mocks base method.
type MockatxProviderGetFullAtxCall ¶ added in v1.4.0
MockatxProviderGetFullAtxCall wrap *gomock.Call
func (*MockatxProviderGetFullAtxCall) Do ¶ added in v1.4.0
func (c *MockatxProviderGetFullAtxCall) Do(f func(types.ATXID) (*types.VerifiedActivationTx, error)) *MockatxProviderGetFullAtxCall
Do rewrite *gomock.Call.Do
func (*MockatxProviderGetFullAtxCall) DoAndReturn ¶ added in v1.4.0
func (c *MockatxProviderGetFullAtxCall) DoAndReturn(f func(types.ATXID) (*types.VerifiedActivationTx, error)) *MockatxProviderGetFullAtxCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockatxProviderGetFullAtxCall) Return ¶ added in v1.4.0
func (c *MockatxProviderGetFullAtxCall) Return(arg0 *types.VerifiedActivationTx, arg1 error) *MockatxProviderGetFullAtxCall
Return rewrite *gomock.Call.Return
type MockatxProviderGetMalfeasanceProofCall ¶ added in v1.4.0
MockatxProviderGetMalfeasanceProofCall wrap *gomock.Call
func (*MockatxProviderGetMalfeasanceProofCall) Do ¶ added in v1.4.0
func (c *MockatxProviderGetMalfeasanceProofCall) Do(f func(types.NodeID) (*types.MalfeasanceProof, error)) *MockatxProviderGetMalfeasanceProofCall
Do rewrite *gomock.Call.Do
func (*MockatxProviderGetMalfeasanceProofCall) DoAndReturn ¶ added in v1.4.0
func (c *MockatxProviderGetMalfeasanceProofCall) DoAndReturn(f func(types.NodeID) (*types.MalfeasanceProof, error)) *MockatxProviderGetMalfeasanceProofCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockatxProviderGetMalfeasanceProofCall) Return ¶ added in v1.4.0
func (c *MockatxProviderGetMalfeasanceProofCall) Return(arg0 *types.MalfeasanceProof, arg1 error) *MockatxProviderGetMalfeasanceProofCall
Return rewrite *gomock.Call.Return
type MockatxProviderMaxHeightAtxCall ¶ added in v1.4.0
MockatxProviderMaxHeightAtxCall wrap *gomock.Call
func (*MockatxProviderMaxHeightAtxCall) Do ¶ added in v1.4.0
func (c *MockatxProviderMaxHeightAtxCall) Do(f func() (types.ATXID, error)) *MockatxProviderMaxHeightAtxCall
Do rewrite *gomock.Call.Do
func (*MockatxProviderMaxHeightAtxCall) DoAndReturn ¶ added in v1.4.0
func (c *MockatxProviderMaxHeightAtxCall) DoAndReturn(f func() (types.ATXID, error)) *MockatxProviderMaxHeightAtxCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockatxProviderMaxHeightAtxCall) Return ¶ added in v1.4.0
func (c *MockatxProviderMaxHeightAtxCall) Return(arg0 types.ATXID, arg1 error) *MockatxProviderMaxHeightAtxCall
Return rewrite *gomock.Call.Return
type MockatxProviderMockRecorder ¶ added in v1.0.0
type MockatxProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockatxProviderMockRecorder is the mock recorder for MockatxProvider.
func (*MockatxProviderMockRecorder) GetFullAtx ¶ added in v1.0.0
func (mr *MockatxProviderMockRecorder) GetFullAtx(id any) *MockatxProviderGetFullAtxCall
GetFullAtx indicates an expected call of GetFullAtx.
func (*MockatxProviderMockRecorder) GetMalfeasanceProof ¶ added in v1.1.0
func (mr *MockatxProviderMockRecorder) GetMalfeasanceProof(id any) *MockatxProviderGetMalfeasanceProofCall
GetMalfeasanceProof indicates an expected call of GetMalfeasanceProof.
func (*MockatxProviderMockRecorder) MaxHeightAtx ¶ added in v1.0.0
func (mr *MockatxProviderMockRecorder) MaxHeightAtx() *MockatxProviderMaxHeightAtxCall
MaxHeightAtx indicates an expected call of MaxHeightAtx.
type MockconservativeState ¶ added in v1.0.0
type MockconservativeState struct {
// contains filtered or unexported fields
}
MockconservativeState is a mock of conservativeState interface.
func NewMockconservativeState ¶ added in v1.0.0
func NewMockconservativeState(ctrl *gomock.Controller) *MockconservativeState
NewMockconservativeState creates a new mock instance.
func (*MockconservativeState) EXPECT ¶ added in v1.0.0
func (m *MockconservativeState) EXPECT() *MockconservativeStateMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockconservativeState) GetAllAccounts ¶ added in v1.0.0
func (m *MockconservativeState) GetAllAccounts() ([]*types.Account, error)
GetAllAccounts mocks base method.
func (*MockconservativeState) GetBalance ¶ added in v1.0.0
func (m *MockconservativeState) GetBalance(arg0 types.Address) (uint64, error)
GetBalance mocks base method.
func (*MockconservativeState) GetLayerStateRoot ¶ added in v1.0.0
GetLayerStateRoot mocks base method.
func (*MockconservativeState) GetMeshTransaction ¶ added in v1.0.0
func (m *MockconservativeState) GetMeshTransaction(arg0 types.TransactionID) (*types.MeshTransaction, error)
GetMeshTransaction mocks base method.
func (*MockconservativeState) GetMeshTransactions ¶ added in v1.0.0
func (m *MockconservativeState) GetMeshTransactions(arg0 []types.TransactionID) ([]*types.MeshTransaction, map[types.TransactionID]struct{})
GetMeshTransactions mocks base method.
func (*MockconservativeState) GetProjection ¶ added in v1.0.0
func (m *MockconservativeState) GetProjection(arg0 types.Address) (uint64, uint64)
GetProjection mocks base method.
func (*MockconservativeState) GetStateRoot ¶ added in v1.0.0
func (m *MockconservativeState) GetStateRoot() (types.Hash32, error)
GetStateRoot mocks base method.
func (*MockconservativeState) GetTransactionsByAddress ¶ added in v1.0.0
func (m *MockconservativeState) GetTransactionsByAddress(arg0, arg1 types.LayerID, arg2 types.Address) ([]*types.MeshTransaction, error)
GetTransactionsByAddress mocks base method.
func (*MockconservativeState) Validation ¶ added in v1.0.0
func (m *MockconservativeState) Validation(raw types.RawTx) system.ValidationRequest
Validation mocks base method.
type MockconservativeStateGetAllAccountsCall ¶ added in v1.4.0
MockconservativeStateGetAllAccountsCall wrap *gomock.Call
func (*MockconservativeStateGetAllAccountsCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetAllAccountsCall) Do(f func() ([]*types.Account, error)) *MockconservativeStateGetAllAccountsCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetAllAccountsCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetAllAccountsCall) DoAndReturn(f func() ([]*types.Account, error)) *MockconservativeStateGetAllAccountsCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetAllAccountsCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetAllAccountsCall) Return(arg0 []*types.Account, arg1 error) *MockconservativeStateGetAllAccountsCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetBalanceCall ¶ added in v1.4.0
MockconservativeStateGetBalanceCall wrap *gomock.Call
func (*MockconservativeStateGetBalanceCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetBalanceCall) Do(f func(types.Address) (uint64, error)) *MockconservativeStateGetBalanceCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetBalanceCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetBalanceCall) DoAndReturn(f func(types.Address) (uint64, error)) *MockconservativeStateGetBalanceCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetBalanceCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetBalanceCall) Return(arg0 uint64, arg1 error) *MockconservativeStateGetBalanceCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetLayerStateRootCall ¶ added in v1.4.0
MockconservativeStateGetLayerStateRootCall wrap *gomock.Call
func (*MockconservativeStateGetLayerStateRootCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetLayerStateRootCall) Do(f func(types.LayerID) (types.Hash32, error)) *MockconservativeStateGetLayerStateRootCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetLayerStateRootCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetLayerStateRootCall) DoAndReturn(f func(types.LayerID) (types.Hash32, error)) *MockconservativeStateGetLayerStateRootCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetLayerStateRootCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetLayerStateRootCall) Return(arg0 types.Hash32, arg1 error) *MockconservativeStateGetLayerStateRootCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetMeshTransactionCall ¶ added in v1.4.0
MockconservativeStateGetMeshTransactionCall wrap *gomock.Call
func (*MockconservativeStateGetMeshTransactionCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetMeshTransactionCall) Do(f func(types.TransactionID) (*types.MeshTransaction, error)) *MockconservativeStateGetMeshTransactionCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetMeshTransactionCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetMeshTransactionCall) DoAndReturn(f func(types.TransactionID) (*types.MeshTransaction, error)) *MockconservativeStateGetMeshTransactionCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetMeshTransactionCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetMeshTransactionCall) Return(arg0 *types.MeshTransaction, arg1 error) *MockconservativeStateGetMeshTransactionCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetMeshTransactionsCall ¶ added in v1.4.0
MockconservativeStateGetMeshTransactionsCall wrap *gomock.Call
func (*MockconservativeStateGetMeshTransactionsCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetMeshTransactionsCall) Do(f func([]types.TransactionID) ([]*types.MeshTransaction, map[types.TransactionID]struct{})) *MockconservativeStateGetMeshTransactionsCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetMeshTransactionsCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetMeshTransactionsCall) DoAndReturn(f func([]types.TransactionID) ([]*types.MeshTransaction, map[types.TransactionID]struct{})) *MockconservativeStateGetMeshTransactionsCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetMeshTransactionsCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetMeshTransactionsCall) Return(arg0 []*types.MeshTransaction, arg1 map[types.TransactionID]struct{}) *MockconservativeStateGetMeshTransactionsCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetNonceCall ¶ added in v1.4.0
MockconservativeStateGetNonceCall wrap *gomock.Call
func (*MockconservativeStateGetNonceCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetNonceCall) Do(f func(types.Address) (types.Nonce, error)) *MockconservativeStateGetNonceCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetNonceCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetNonceCall) DoAndReturn(f func(types.Address) (types.Nonce, error)) *MockconservativeStateGetNonceCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetNonceCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetNonceCall) Return(arg0 types.Nonce, arg1 error) *MockconservativeStateGetNonceCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetProjectionCall ¶ added in v1.4.0
MockconservativeStateGetProjectionCall wrap *gomock.Call
func (*MockconservativeStateGetProjectionCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetProjectionCall) Do(f func(types.Address) (uint64, uint64)) *MockconservativeStateGetProjectionCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetProjectionCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetProjectionCall) DoAndReturn(f func(types.Address) (uint64, uint64)) *MockconservativeStateGetProjectionCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetProjectionCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetProjectionCall) Return(arg0, arg1 uint64) *MockconservativeStateGetProjectionCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetStateRootCall ¶ added in v1.4.0
MockconservativeStateGetStateRootCall wrap *gomock.Call
func (*MockconservativeStateGetStateRootCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetStateRootCall) Do(f func() (types.Hash32, error)) *MockconservativeStateGetStateRootCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetStateRootCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetStateRootCall) DoAndReturn(f func() (types.Hash32, error)) *MockconservativeStateGetStateRootCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetStateRootCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetStateRootCall) Return(arg0 types.Hash32, arg1 error) *MockconservativeStateGetStateRootCall
Return rewrite *gomock.Call.Return
type MockconservativeStateGetTransactionsByAddressCall ¶ added in v1.4.0
MockconservativeStateGetTransactionsByAddressCall wrap *gomock.Call
func (*MockconservativeStateGetTransactionsByAddressCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateGetTransactionsByAddressCall) Do(f func(types.LayerID, types.LayerID, types.Address) ([]*types.MeshTransaction, error)) *MockconservativeStateGetTransactionsByAddressCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateGetTransactionsByAddressCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateGetTransactionsByAddressCall) DoAndReturn(f func(types.LayerID, types.LayerID, types.Address) ([]*types.MeshTransaction, error)) *MockconservativeStateGetTransactionsByAddressCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateGetTransactionsByAddressCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateGetTransactionsByAddressCall) Return(arg0 []*types.MeshTransaction, arg1 error) *MockconservativeStateGetTransactionsByAddressCall
Return rewrite *gomock.Call.Return
type MockconservativeStateMockRecorder ¶ added in v1.0.0
type MockconservativeStateMockRecorder struct {
// contains filtered or unexported fields
}
MockconservativeStateMockRecorder is the mock recorder for MockconservativeState.
func (*MockconservativeStateMockRecorder) GetAllAccounts ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetAllAccounts() *MockconservativeStateGetAllAccountsCall
GetAllAccounts indicates an expected call of GetAllAccounts.
func (*MockconservativeStateMockRecorder) GetBalance ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetBalance(arg0 any) *MockconservativeStateGetBalanceCall
GetBalance indicates an expected call of GetBalance.
func (*MockconservativeStateMockRecorder) GetLayerStateRoot ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetLayerStateRoot(arg0 any) *MockconservativeStateGetLayerStateRootCall
GetLayerStateRoot indicates an expected call of GetLayerStateRoot.
func (*MockconservativeStateMockRecorder) GetMeshTransaction ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetMeshTransaction(arg0 any) *MockconservativeStateGetMeshTransactionCall
GetMeshTransaction indicates an expected call of GetMeshTransaction.
func (*MockconservativeStateMockRecorder) GetMeshTransactions ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetMeshTransactions(arg0 any) *MockconservativeStateGetMeshTransactionsCall
GetMeshTransactions indicates an expected call of GetMeshTransactions.
func (*MockconservativeStateMockRecorder) GetNonce ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetNonce(arg0 any) *MockconservativeStateGetNonceCall
GetNonce indicates an expected call of GetNonce.
func (*MockconservativeStateMockRecorder) GetProjection ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetProjection(arg0 any) *MockconservativeStateGetProjectionCall
GetProjection indicates an expected call of GetProjection.
func (*MockconservativeStateMockRecorder) GetStateRoot ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetStateRoot() *MockconservativeStateGetStateRootCall
GetStateRoot indicates an expected call of GetStateRoot.
func (*MockconservativeStateMockRecorder) GetTransactionsByAddress ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) GetTransactionsByAddress(arg0, arg1, arg2 any) *MockconservativeStateGetTransactionsByAddressCall
GetTransactionsByAddress indicates an expected call of GetTransactionsByAddress.
func (*MockconservativeStateMockRecorder) Validation ¶ added in v1.0.0
func (mr *MockconservativeStateMockRecorder) Validation(raw any) *MockconservativeStateValidationCall
Validation indicates an expected call of Validation.
type MockconservativeStateValidationCall ¶ added in v1.4.0
MockconservativeStateValidationCall wrap *gomock.Call
func (*MockconservativeStateValidationCall) Do ¶ added in v1.4.0
func (c *MockconservativeStateValidationCall) Do(f func(types.RawTx) system.ValidationRequest) *MockconservativeStateValidationCall
Do rewrite *gomock.Call.Do
func (*MockconservativeStateValidationCall) DoAndReturn ¶ added in v1.4.0
func (c *MockconservativeStateValidationCall) DoAndReturn(f func(types.RawTx) system.ValidationRequest) *MockconservativeStateValidationCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockconservativeStateValidationCall) Return ¶ added in v1.4.0
func (c *MockconservativeStateValidationCall) Return(arg0 system.ValidationRequest) *MockconservativeStateValidationCall
Return rewrite *gomock.Call.Return
type MockgenesisTimeAPI ¶ added in v1.0.0
type MockgenesisTimeAPI struct {
// contains filtered or unexported fields
}
MockgenesisTimeAPI is a mock of genesisTimeAPI interface.
func NewMockgenesisTimeAPI ¶ added in v1.0.0
func NewMockgenesisTimeAPI(ctrl *gomock.Controller) *MockgenesisTimeAPI
NewMockgenesisTimeAPI creates a new mock instance.
func (*MockgenesisTimeAPI) CurrentLayer ¶ added in v1.0.0
func (m *MockgenesisTimeAPI) CurrentLayer() types.LayerID
CurrentLayer mocks base method.
func (*MockgenesisTimeAPI) EXPECT ¶ added in v1.0.0
func (m *MockgenesisTimeAPI) EXPECT() *MockgenesisTimeAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockgenesisTimeAPI) GenesisTime ¶ added in v1.0.0
func (m *MockgenesisTimeAPI) GenesisTime() time.Time
GenesisTime mocks base method.
type MockgenesisTimeAPICurrentLayerCall ¶ added in v1.4.0
MockgenesisTimeAPICurrentLayerCall wrap *gomock.Call
func (*MockgenesisTimeAPICurrentLayerCall) Do ¶ added in v1.4.0
func (c *MockgenesisTimeAPICurrentLayerCall) Do(f func() types.LayerID) *MockgenesisTimeAPICurrentLayerCall
Do rewrite *gomock.Call.Do
func (*MockgenesisTimeAPICurrentLayerCall) DoAndReturn ¶ added in v1.4.0
func (c *MockgenesisTimeAPICurrentLayerCall) DoAndReturn(f func() types.LayerID) *MockgenesisTimeAPICurrentLayerCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockgenesisTimeAPICurrentLayerCall) Return ¶ added in v1.4.0
func (c *MockgenesisTimeAPICurrentLayerCall) Return(arg0 types.LayerID) *MockgenesisTimeAPICurrentLayerCall
Return rewrite *gomock.Call.Return
type MockgenesisTimeAPIGenesisTimeCall ¶ added in v1.4.0
MockgenesisTimeAPIGenesisTimeCall wrap *gomock.Call
func (*MockgenesisTimeAPIGenesisTimeCall) Do ¶ added in v1.4.0
func (c *MockgenesisTimeAPIGenesisTimeCall) Do(f func() time.Time) *MockgenesisTimeAPIGenesisTimeCall
Do rewrite *gomock.Call.Do
func (*MockgenesisTimeAPIGenesisTimeCall) DoAndReturn ¶ added in v1.4.0
func (c *MockgenesisTimeAPIGenesisTimeCall) DoAndReturn(f func() time.Time) *MockgenesisTimeAPIGenesisTimeCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockgenesisTimeAPIGenesisTimeCall) Return ¶ added in v1.4.0
func (c *MockgenesisTimeAPIGenesisTimeCall) Return(arg0 time.Time) *MockgenesisTimeAPIGenesisTimeCall
Return rewrite *gomock.Call.Return
type MockgenesisTimeAPIMockRecorder ¶ added in v1.0.0
type MockgenesisTimeAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockgenesisTimeAPIMockRecorder is the mock recorder for MockgenesisTimeAPI.
func (*MockgenesisTimeAPIMockRecorder) CurrentLayer ¶ added in v1.0.0
func (mr *MockgenesisTimeAPIMockRecorder) CurrentLayer() *MockgenesisTimeAPICurrentLayerCall
CurrentLayer indicates an expected call of CurrentLayer.
func (*MockgenesisTimeAPIMockRecorder) GenesisTime ¶ added in v1.0.0
func (mr *MockgenesisTimeAPIMockRecorder) GenesisTime() *MockgenesisTimeAPIGenesisTimeCall
GenesisTime indicates an expected call of GenesisTime.
type MockmeshAPI ¶ added in v1.0.0
type MockmeshAPI struct {
// contains filtered or unexported fields
}
MockmeshAPI is a mock of meshAPI interface.
func NewMockmeshAPI ¶ added in v1.0.0
func NewMockmeshAPI(ctrl *gomock.Controller) *MockmeshAPI
NewMockmeshAPI creates a new mock instance.
func (*MockmeshAPI) EXPECT ¶ added in v1.0.0
func (m *MockmeshAPI) EXPECT() *MockmeshAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockmeshAPI) GetLayerVerified ¶ added in v1.3.3
GetLayerVerified mocks base method.
func (*MockmeshAPI) GetRewardsByCoinbase ¶ added in v1.3.0
GetRewardsByCoinbase mocks base method.
func (*MockmeshAPI) GetRewardsBySmesherId ¶ added in v1.3.0
GetRewardsBySmesherId mocks base method.
func (*MockmeshAPI) LatestLayer ¶ added in v1.0.0
func (m *MockmeshAPI) LatestLayer() types.LayerID
LatestLayer mocks base method.
func (*MockmeshAPI) LatestLayerInState ¶ added in v1.0.0
func (m *MockmeshAPI) LatestLayerInState() types.LayerID
LatestLayerInState mocks base method.
func (*MockmeshAPI) ProcessedLayer ¶ added in v1.0.0
func (m *MockmeshAPI) ProcessedLayer() types.LayerID
ProcessedLayer mocks base method.
type MockmeshAPIGetLayerCall ¶ added in v1.4.0
MockmeshAPIGetLayerCall wrap *gomock.Call
func (*MockmeshAPIGetLayerCall) Do ¶ added in v1.4.0
func (c *MockmeshAPIGetLayerCall) Do(f func(types.LayerID) (*types.Layer, error)) *MockmeshAPIGetLayerCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPIGetLayerCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPIGetLayerCall) DoAndReturn(f func(types.LayerID) (*types.Layer, error)) *MockmeshAPIGetLayerCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPIGetLayerCall) Return ¶ added in v1.4.0
func (c *MockmeshAPIGetLayerCall) Return(arg0 *types.Layer, arg1 error) *MockmeshAPIGetLayerCall
Return rewrite *gomock.Call.Return
type MockmeshAPIGetLayerVerifiedCall ¶ added in v1.4.0
MockmeshAPIGetLayerVerifiedCall wrap *gomock.Call
func (*MockmeshAPIGetLayerVerifiedCall) Do ¶ added in v1.4.0
func (c *MockmeshAPIGetLayerVerifiedCall) Do(f func(types.LayerID) (*types.Block, error)) *MockmeshAPIGetLayerVerifiedCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPIGetLayerVerifiedCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPIGetLayerVerifiedCall) DoAndReturn(f func(types.LayerID) (*types.Block, error)) *MockmeshAPIGetLayerVerifiedCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPIGetLayerVerifiedCall) Return ¶ added in v1.4.0
func (c *MockmeshAPIGetLayerVerifiedCall) Return(arg0 *types.Block, arg1 error) *MockmeshAPIGetLayerVerifiedCall
Return rewrite *gomock.Call.Return
type MockmeshAPIGetRewardsByCoinbaseCall ¶ added in v1.4.0
MockmeshAPIGetRewardsByCoinbaseCall wrap *gomock.Call
func (*MockmeshAPIGetRewardsByCoinbaseCall) Do ¶ added in v1.4.0
func (c *MockmeshAPIGetRewardsByCoinbaseCall) Do(f func(types.Address) ([]*types.Reward, error)) *MockmeshAPIGetRewardsByCoinbaseCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPIGetRewardsByCoinbaseCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPIGetRewardsByCoinbaseCall) DoAndReturn(f func(types.Address) ([]*types.Reward, error)) *MockmeshAPIGetRewardsByCoinbaseCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPIGetRewardsByCoinbaseCall) Return ¶ added in v1.4.0
func (c *MockmeshAPIGetRewardsByCoinbaseCall) Return(arg0 []*types.Reward, arg1 error) *MockmeshAPIGetRewardsByCoinbaseCall
Return rewrite *gomock.Call.Return
type MockmeshAPIGetRewardsBySmesherIdCall ¶ added in v1.4.0
MockmeshAPIGetRewardsBySmesherIdCall wrap *gomock.Call
func (*MockmeshAPIGetRewardsBySmesherIdCall) Do ¶ added in v1.4.0
func (c *MockmeshAPIGetRewardsBySmesherIdCall) Do(f func(types.NodeID) ([]*types.Reward, error)) *MockmeshAPIGetRewardsBySmesherIdCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPIGetRewardsBySmesherIdCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPIGetRewardsBySmesherIdCall) DoAndReturn(f func(types.NodeID) ([]*types.Reward, error)) *MockmeshAPIGetRewardsBySmesherIdCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPIGetRewardsBySmesherIdCall) Return ¶ added in v1.4.0
func (c *MockmeshAPIGetRewardsBySmesherIdCall) Return(arg0 []*types.Reward, arg1 error) *MockmeshAPIGetRewardsBySmesherIdCall
Return rewrite *gomock.Call.Return
type MockmeshAPILatestLayerCall ¶ added in v1.4.0
MockmeshAPILatestLayerCall wrap *gomock.Call
func (*MockmeshAPILatestLayerCall) Do ¶ added in v1.4.0
func (c *MockmeshAPILatestLayerCall) Do(f func() types.LayerID) *MockmeshAPILatestLayerCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPILatestLayerCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPILatestLayerCall) DoAndReturn(f func() types.LayerID) *MockmeshAPILatestLayerCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPILatestLayerCall) Return ¶ added in v1.4.0
func (c *MockmeshAPILatestLayerCall) Return(arg0 types.LayerID) *MockmeshAPILatestLayerCall
Return rewrite *gomock.Call.Return
type MockmeshAPILatestLayerInStateCall ¶ added in v1.4.0
MockmeshAPILatestLayerInStateCall wrap *gomock.Call
func (*MockmeshAPILatestLayerInStateCall) Do ¶ added in v1.4.0
func (c *MockmeshAPILatestLayerInStateCall) Do(f func() types.LayerID) *MockmeshAPILatestLayerInStateCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPILatestLayerInStateCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPILatestLayerInStateCall) DoAndReturn(f func() types.LayerID) *MockmeshAPILatestLayerInStateCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPILatestLayerInStateCall) Return ¶ added in v1.4.0
func (c *MockmeshAPILatestLayerInStateCall) Return(arg0 types.LayerID) *MockmeshAPILatestLayerInStateCall
Return rewrite *gomock.Call.Return
type MockmeshAPIMeshHashCall ¶ added in v1.4.0
MockmeshAPIMeshHashCall wrap *gomock.Call
func (*MockmeshAPIMeshHashCall) Do ¶ added in v1.4.0
func (c *MockmeshAPIMeshHashCall) Do(f func(types.LayerID) (types.Hash32, error)) *MockmeshAPIMeshHashCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPIMeshHashCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPIMeshHashCall) DoAndReturn(f func(types.LayerID) (types.Hash32, error)) *MockmeshAPIMeshHashCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPIMeshHashCall) Return ¶ added in v1.4.0
func (c *MockmeshAPIMeshHashCall) Return(arg0 types.Hash32, arg1 error) *MockmeshAPIMeshHashCall
Return rewrite *gomock.Call.Return
type MockmeshAPIMockRecorder ¶ added in v1.0.0
type MockmeshAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockmeshAPIMockRecorder is the mock recorder for MockmeshAPI.
func (*MockmeshAPIMockRecorder) GetLayer ¶ added in v1.0.0
func (mr *MockmeshAPIMockRecorder) GetLayer(arg0 any) *MockmeshAPIGetLayerCall
GetLayer indicates an expected call of GetLayer.
func (*MockmeshAPIMockRecorder) GetLayerVerified ¶ added in v1.3.3
func (mr *MockmeshAPIMockRecorder) GetLayerVerified(arg0 any) *MockmeshAPIGetLayerVerifiedCall
GetLayerVerified indicates an expected call of GetLayerVerified.
func (*MockmeshAPIMockRecorder) GetRewardsByCoinbase ¶ added in v1.3.0
func (mr *MockmeshAPIMockRecorder) GetRewardsByCoinbase(arg0 any) *MockmeshAPIGetRewardsByCoinbaseCall
GetRewardsByCoinbase indicates an expected call of GetRewardsByCoinbase.
func (*MockmeshAPIMockRecorder) GetRewardsBySmesherId ¶ added in v1.3.0
func (mr *MockmeshAPIMockRecorder) GetRewardsBySmesherId(id any) *MockmeshAPIGetRewardsBySmesherIdCall
GetRewardsBySmesherId indicates an expected call of GetRewardsBySmesherId.
func (*MockmeshAPIMockRecorder) LatestLayer ¶ added in v1.0.0
func (mr *MockmeshAPIMockRecorder) LatestLayer() *MockmeshAPILatestLayerCall
LatestLayer indicates an expected call of LatestLayer.
func (*MockmeshAPIMockRecorder) LatestLayerInState ¶ added in v1.0.0
func (mr *MockmeshAPIMockRecorder) LatestLayerInState() *MockmeshAPILatestLayerInStateCall
LatestLayerInState indicates an expected call of LatestLayerInState.
func (*MockmeshAPIMockRecorder) MeshHash ¶ added in v1.0.0
func (mr *MockmeshAPIMockRecorder) MeshHash(arg0 any) *MockmeshAPIMeshHashCall
MeshHash indicates an expected call of MeshHash.
func (*MockmeshAPIMockRecorder) ProcessedLayer ¶ added in v1.0.0
func (mr *MockmeshAPIMockRecorder) ProcessedLayer() *MockmeshAPIProcessedLayerCall
ProcessedLayer indicates an expected call of ProcessedLayer.
type MockmeshAPIProcessedLayerCall ¶ added in v1.4.0
MockmeshAPIProcessedLayerCall wrap *gomock.Call
func (*MockmeshAPIProcessedLayerCall) Do ¶ added in v1.4.0
func (c *MockmeshAPIProcessedLayerCall) Do(f func() types.LayerID) *MockmeshAPIProcessedLayerCall
Do rewrite *gomock.Call.Do
func (*MockmeshAPIProcessedLayerCall) DoAndReturn ¶ added in v1.4.0
func (c *MockmeshAPIProcessedLayerCall) DoAndReturn(f func() types.LayerID) *MockmeshAPIProcessedLayerCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockmeshAPIProcessedLayerCall) Return ¶ added in v1.4.0
func (c *MockmeshAPIProcessedLayerCall) Return(arg0 types.LayerID) *MockmeshAPIProcessedLayerCall
Return rewrite *gomock.Call.Return
type MocknetworkInfo ¶ added in v1.3.0
type MocknetworkInfo struct {
// contains filtered or unexported fields
}
MocknetworkInfo is a mock of networkInfo interface.
func NewMocknetworkInfo ¶ added in v1.3.0
func NewMocknetworkInfo(ctrl *gomock.Controller) *MocknetworkInfo
NewMocknetworkInfo creates a new mock instance.
func (*MocknetworkInfo) DHTServerEnabled ¶ added in v1.3.0
func (m *MocknetworkInfo) DHTServerEnabled() bool
DHTServerEnabled mocks base method.
func (*MocknetworkInfo) EXPECT ¶ added in v1.3.0
func (m *MocknetworkInfo) EXPECT() *MocknetworkInfoMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MocknetworkInfo) ID ¶ added in v1.3.0
func (m *MocknetworkInfo) ID() p2p.Peer
ID mocks base method.
func (*MocknetworkInfo) KnownAddresses ¶ added in v1.3.0
func (m *MocknetworkInfo) KnownAddresses() []multiaddr.Multiaddr
KnownAddresses mocks base method.
func (*MocknetworkInfo) ListenAddresses ¶ added in v1.3.0
func (m *MocknetworkInfo) ListenAddresses() []multiaddr.Multiaddr
ListenAddresses mocks base method.
func (*MocknetworkInfo) NATDeviceType ¶ added in v1.3.0
func (m *MocknetworkInfo) NATDeviceType() (network.NATDeviceType, network.NATDeviceType)
NATDeviceType mocks base method.
func (*MocknetworkInfo) Reachability ¶ added in v1.3.0
func (m *MocknetworkInfo) Reachability() network.Reachability
Reachability mocks base method.
type MocknetworkInfoDHTServerEnabledCall ¶ added in v1.4.0
MocknetworkInfoDHTServerEnabledCall wrap *gomock.Call
func (*MocknetworkInfoDHTServerEnabledCall) Do ¶ added in v1.4.0
func (c *MocknetworkInfoDHTServerEnabledCall) Do(f func() bool) *MocknetworkInfoDHTServerEnabledCall
Do rewrite *gomock.Call.Do
func (*MocknetworkInfoDHTServerEnabledCall) DoAndReturn ¶ added in v1.4.0
func (c *MocknetworkInfoDHTServerEnabledCall) DoAndReturn(f func() bool) *MocknetworkInfoDHTServerEnabledCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocknetworkInfoDHTServerEnabledCall) Return ¶ added in v1.4.0
func (c *MocknetworkInfoDHTServerEnabledCall) Return(arg0 bool) *MocknetworkInfoDHTServerEnabledCall
Return rewrite *gomock.Call.Return
type MocknetworkInfoIDCall ¶ added in v1.4.0
MocknetworkInfoIDCall wrap *gomock.Call
func (*MocknetworkInfoIDCall) Do ¶ added in v1.4.0
func (c *MocknetworkInfoIDCall) Do(f func() p2p.Peer) *MocknetworkInfoIDCall
Do rewrite *gomock.Call.Do
func (*MocknetworkInfoIDCall) DoAndReturn ¶ added in v1.4.0
func (c *MocknetworkInfoIDCall) DoAndReturn(f func() p2p.Peer) *MocknetworkInfoIDCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocknetworkInfoIDCall) Return ¶ added in v1.4.0
func (c *MocknetworkInfoIDCall) Return(arg0 p2p.Peer) *MocknetworkInfoIDCall
Return rewrite *gomock.Call.Return
type MocknetworkInfoKnownAddressesCall ¶ added in v1.4.0
MocknetworkInfoKnownAddressesCall wrap *gomock.Call
func (*MocknetworkInfoKnownAddressesCall) Do ¶ added in v1.4.0
func (c *MocknetworkInfoKnownAddressesCall) Do(f func() []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall
Do rewrite *gomock.Call.Do
func (*MocknetworkInfoKnownAddressesCall) DoAndReturn ¶ added in v1.4.0
func (c *MocknetworkInfoKnownAddressesCall) DoAndReturn(f func() []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocknetworkInfoKnownAddressesCall) Return ¶ added in v1.4.0
func (c *MocknetworkInfoKnownAddressesCall) Return(arg0 []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall
Return rewrite *gomock.Call.Return
type MocknetworkInfoListenAddressesCall ¶ added in v1.4.0
MocknetworkInfoListenAddressesCall wrap *gomock.Call
func (*MocknetworkInfoListenAddressesCall) Do ¶ added in v1.4.0
func (c *MocknetworkInfoListenAddressesCall) Do(f func() []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall
Do rewrite *gomock.Call.Do
func (*MocknetworkInfoListenAddressesCall) DoAndReturn ¶ added in v1.4.0
func (c *MocknetworkInfoListenAddressesCall) DoAndReturn(f func() []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocknetworkInfoListenAddressesCall) Return ¶ added in v1.4.0
func (c *MocknetworkInfoListenAddressesCall) Return(arg0 []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall
Return rewrite *gomock.Call.Return
type MocknetworkInfoMockRecorder ¶ added in v1.3.0
type MocknetworkInfoMockRecorder struct {
// contains filtered or unexported fields
}
MocknetworkInfoMockRecorder is the mock recorder for MocknetworkInfo.
func (*MocknetworkInfoMockRecorder) DHTServerEnabled ¶ added in v1.3.0
func (mr *MocknetworkInfoMockRecorder) DHTServerEnabled() *MocknetworkInfoDHTServerEnabledCall
DHTServerEnabled indicates an expected call of DHTServerEnabled.
func (*MocknetworkInfoMockRecorder) ID ¶ added in v1.3.0
func (mr *MocknetworkInfoMockRecorder) ID() *MocknetworkInfoIDCall
ID indicates an expected call of ID.
func (*MocknetworkInfoMockRecorder) KnownAddresses ¶ added in v1.3.0
func (mr *MocknetworkInfoMockRecorder) KnownAddresses() *MocknetworkInfoKnownAddressesCall
KnownAddresses indicates an expected call of KnownAddresses.
func (*MocknetworkInfoMockRecorder) ListenAddresses ¶ added in v1.3.0
func (mr *MocknetworkInfoMockRecorder) ListenAddresses() *MocknetworkInfoListenAddressesCall
ListenAddresses indicates an expected call of ListenAddresses.
func (*MocknetworkInfoMockRecorder) NATDeviceType ¶ added in v1.3.0
func (mr *MocknetworkInfoMockRecorder) NATDeviceType() *MocknetworkInfoNATDeviceTypeCall
NATDeviceType indicates an expected call of NATDeviceType.
func (*MocknetworkInfoMockRecorder) Reachability ¶ added in v1.3.0
func (mr *MocknetworkInfoMockRecorder) Reachability() *MocknetworkInfoReachabilityCall
Reachability indicates an expected call of Reachability.
type MocknetworkInfoNATDeviceTypeCall ¶ added in v1.4.0
MocknetworkInfoNATDeviceTypeCall wrap *gomock.Call
func (*MocknetworkInfoNATDeviceTypeCall) Do ¶ added in v1.4.0
func (c *MocknetworkInfoNATDeviceTypeCall) Do(f func() (network.NATDeviceType, network.NATDeviceType)) *MocknetworkInfoNATDeviceTypeCall
Do rewrite *gomock.Call.Do
func (*MocknetworkInfoNATDeviceTypeCall) DoAndReturn ¶ added in v1.4.0
func (c *MocknetworkInfoNATDeviceTypeCall) DoAndReturn(f func() (network.NATDeviceType, network.NATDeviceType)) *MocknetworkInfoNATDeviceTypeCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocknetworkInfoNATDeviceTypeCall) Return ¶ added in v1.4.0
func (c *MocknetworkInfoNATDeviceTypeCall) Return(udpNATType, tcpNATType network.NATDeviceType) *MocknetworkInfoNATDeviceTypeCall
Return rewrite *gomock.Call.Return
type MocknetworkInfoReachabilityCall ¶ added in v1.4.0
MocknetworkInfoReachabilityCall wrap *gomock.Call
func (*MocknetworkInfoReachabilityCall) Do ¶ added in v1.4.0
func (c *MocknetworkInfoReachabilityCall) Do(f func() network.Reachability) *MocknetworkInfoReachabilityCall
Do rewrite *gomock.Call.Do
func (*MocknetworkInfoReachabilityCall) DoAndReturn ¶ added in v1.4.0
func (c *MocknetworkInfoReachabilityCall) DoAndReturn(f func() network.Reachability) *MocknetworkInfoReachabilityCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocknetworkInfoReachabilityCall) Return ¶ added in v1.4.0
func (c *MocknetworkInfoReachabilityCall) Return(arg0 network.Reachability) *MocknetworkInfoReachabilityCall
Return rewrite *gomock.Call.Return
type Mockoracle ¶ added in v1.0.0
type Mockoracle struct {
// contains filtered or unexported fields
}
Mockoracle is a mock of oracle interface.
func NewMockoracle ¶ added in v1.0.0
func NewMockoracle(ctrl *gomock.Controller) *Mockoracle
NewMockoracle creates a new mock instance.
func (*Mockoracle) EXPECT ¶ added in v1.0.0
func (m *Mockoracle) EXPECT() *MockoracleMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockoracleActiveSetCall ¶ added in v1.4.0
MockoracleActiveSetCall wrap *gomock.Call
func (*MockoracleActiveSetCall) Do ¶ added in v1.4.0
func (c *MockoracleActiveSetCall) Do(f func(context.Context, types.EpochID) ([]types.ATXID, error)) *MockoracleActiveSetCall
Do rewrite *gomock.Call.Do
func (*MockoracleActiveSetCall) DoAndReturn ¶ added in v1.4.0
func (c *MockoracleActiveSetCall) DoAndReturn(f func(context.Context, types.EpochID) ([]types.ATXID, error)) *MockoracleActiveSetCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockoracleActiveSetCall) Return ¶ added in v1.4.0
func (c *MockoracleActiveSetCall) Return(arg0 []types.ATXID, arg1 error) *MockoracleActiveSetCall
Return rewrite *gomock.Call.Return
type MockoracleMockRecorder ¶ added in v1.0.0
type MockoracleMockRecorder struct {
// contains filtered or unexported fields
}
MockoracleMockRecorder is the mock recorder for Mockoracle.
func (*MockoracleMockRecorder) ActiveSet ¶ added in v1.0.0
func (mr *MockoracleMockRecorder) ActiveSet(arg0, arg1 any) *MockoracleActiveSetCall
ActiveSet indicates an expected call of ActiveSet.
type MockpeerCounter ¶ added in v1.0.0
type MockpeerCounter struct {
// contains filtered or unexported fields
}
MockpeerCounter is a mock of peerCounter interface.
func NewMockpeerCounter ¶ added in v1.0.0
func NewMockpeerCounter(ctrl *gomock.Controller) *MockpeerCounter
NewMockpeerCounter creates a new mock instance.
func (*MockpeerCounter) EXPECT ¶ added in v1.0.0
func (m *MockpeerCounter) EXPECT() *MockpeerCounterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockpeerCounter) PeerCount ¶ added in v1.0.0
func (m *MockpeerCounter) PeerCount() uint64
PeerCount mocks base method.
type MockpeerCounterMockRecorder ¶ added in v1.0.0
type MockpeerCounterMockRecorder struct {
// contains filtered or unexported fields
}
MockpeerCounterMockRecorder is the mock recorder for MockpeerCounter.
func (*MockpeerCounterMockRecorder) PeerCount ¶ added in v1.0.0
func (mr *MockpeerCounterMockRecorder) PeerCount() *MockpeerCounterPeerCountCall
PeerCount indicates an expected call of PeerCount.
type MockpeerCounterPeerCountCall ¶ added in v1.4.0
MockpeerCounterPeerCountCall wrap *gomock.Call
func (*MockpeerCounterPeerCountCall) Do ¶ added in v1.4.0
func (c *MockpeerCounterPeerCountCall) Do(f func() uint64) *MockpeerCounterPeerCountCall
Do rewrite *gomock.Call.Do
func (*MockpeerCounterPeerCountCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpeerCounterPeerCountCall) DoAndReturn(f func() uint64) *MockpeerCounterPeerCountCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpeerCounterPeerCountCall) Return ¶ added in v1.4.0
func (c *MockpeerCounterPeerCountCall) Return(arg0 uint64) *MockpeerCounterPeerCountCall
Return rewrite *gomock.Call.Return
type Mockpeers ¶ added in v1.1.2
type Mockpeers struct {
// contains filtered or unexported fields
}
Mockpeers is a mock of peers interface.
func NewMockpeers ¶ added in v1.1.2
func NewMockpeers(ctrl *gomock.Controller) *Mockpeers
NewMockpeers creates a new mock instance.
func (*Mockpeers) ConnectedPeerInfo ¶ added in v1.1.2
ConnectedPeerInfo mocks base method.
func (*Mockpeers) EXPECT ¶ added in v1.1.2
func (m *Mockpeers) EXPECT() *MockpeersMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockpeersConnectedPeerInfoCall ¶ added in v1.4.0
MockpeersConnectedPeerInfoCall wrap *gomock.Call
func (*MockpeersConnectedPeerInfoCall) Do ¶ added in v1.4.0
func (c *MockpeersConnectedPeerInfoCall) Do(f func(p2p.Peer) *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall
Do rewrite *gomock.Call.Do
func (*MockpeersConnectedPeerInfoCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpeersConnectedPeerInfoCall) DoAndReturn(f func(p2p.Peer) *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpeersConnectedPeerInfoCall) Return ¶ added in v1.4.0
func (c *MockpeersConnectedPeerInfoCall) Return(arg0 *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall
Return rewrite *gomock.Call.Return
type MockpeersGetPeersCall ¶ added in v1.4.0
MockpeersGetPeersCall wrap *gomock.Call
func (*MockpeersGetPeersCall) Do ¶ added in v1.4.0
func (c *MockpeersGetPeersCall) Do(f func() []p2p.Peer) *MockpeersGetPeersCall
Do rewrite *gomock.Call.Do
func (*MockpeersGetPeersCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpeersGetPeersCall) DoAndReturn(f func() []p2p.Peer) *MockpeersGetPeersCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpeersGetPeersCall) Return ¶ added in v1.4.0
func (c *MockpeersGetPeersCall) Return(arg0 []p2p.Peer) *MockpeersGetPeersCall
Return rewrite *gomock.Call.Return
type MockpeersMockRecorder ¶ added in v1.1.2
type MockpeersMockRecorder struct {
// contains filtered or unexported fields
}
MockpeersMockRecorder is the mock recorder for Mockpeers.
func (*MockpeersMockRecorder) ConnectedPeerInfo ¶ added in v1.1.2
func (mr *MockpeersMockRecorder) ConnectedPeerInfo(arg0 any) *MockpeersConnectedPeerInfoCall
ConnectedPeerInfo indicates an expected call of ConnectedPeerInfo.
func (*MockpeersMockRecorder) GetPeers ¶ added in v1.1.2
func (mr *MockpeersMockRecorder) GetPeers() *MockpeersGetPeersCall
GetPeers indicates an expected call of GetPeers.
type MockpostSupervisor ¶ added in v1.3.0
type MockpostSupervisor struct {
// contains filtered or unexported fields
}
MockpostSupervisor is a mock of postSupervisor interface.
func NewMockpostSupervisor ¶ added in v1.3.0
func NewMockpostSupervisor(ctrl *gomock.Controller) *MockpostSupervisor
NewMockpostSupervisor creates a new mock instance.
func (*MockpostSupervisor) Benchmark ¶ added in v1.3.0
func (m *MockpostSupervisor) Benchmark(p activation.PostSetupProvider) (int, error)
Benchmark mocks base method.
func (*MockpostSupervisor) Config ¶ added in v1.3.0
func (m *MockpostSupervisor) Config() activation.PostConfig
Config mocks base method.
func (*MockpostSupervisor) EXPECT ¶ added in v1.3.0
func (m *MockpostSupervisor) EXPECT() *MockpostSupervisorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockpostSupervisor) Providers ¶ added in v1.3.0
func (m *MockpostSupervisor) Providers() ([]activation.PostSetupProvider, error)
Providers mocks base method.
func (*MockpostSupervisor) Start ¶ added in v1.3.0
func (m *MockpostSupervisor) Start(opts activation.PostSetupOpts, id types.NodeID) error
Start mocks base method.
func (*MockpostSupervisor) Status ¶ added in v1.3.0
func (m *MockpostSupervisor) Status() *activation.PostSetupStatus
Status mocks base method.
func (*MockpostSupervisor) Stop ¶ added in v1.3.0
func (m *MockpostSupervisor) Stop(deleteFiles bool) error
Stop mocks base method.
type MockpostSupervisorBenchmarkCall ¶ added in v1.4.0
MockpostSupervisorBenchmarkCall wrap *gomock.Call
func (*MockpostSupervisorBenchmarkCall) Do ¶ added in v1.4.0
func (c *MockpostSupervisorBenchmarkCall) Do(f func(activation.PostSetupProvider) (int, error)) *MockpostSupervisorBenchmarkCall
Do rewrite *gomock.Call.Do
func (*MockpostSupervisorBenchmarkCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpostSupervisorBenchmarkCall) DoAndReturn(f func(activation.PostSetupProvider) (int, error)) *MockpostSupervisorBenchmarkCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpostSupervisorBenchmarkCall) Return ¶ added in v1.4.0
func (c *MockpostSupervisorBenchmarkCall) Return(arg0 int, arg1 error) *MockpostSupervisorBenchmarkCall
Return rewrite *gomock.Call.Return
type MockpostSupervisorConfigCall ¶ added in v1.4.0
MockpostSupervisorConfigCall wrap *gomock.Call
func (*MockpostSupervisorConfigCall) Do ¶ added in v1.4.0
func (c *MockpostSupervisorConfigCall) Do(f func() activation.PostConfig) *MockpostSupervisorConfigCall
Do rewrite *gomock.Call.Do
func (*MockpostSupervisorConfigCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpostSupervisorConfigCall) DoAndReturn(f func() activation.PostConfig) *MockpostSupervisorConfigCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpostSupervisorConfigCall) Return ¶ added in v1.4.0
func (c *MockpostSupervisorConfigCall) Return(arg0 activation.PostConfig) *MockpostSupervisorConfigCall
Return rewrite *gomock.Call.Return
type MockpostSupervisorMockRecorder ¶ added in v1.3.0
type MockpostSupervisorMockRecorder struct {
// contains filtered or unexported fields
}
MockpostSupervisorMockRecorder is the mock recorder for MockpostSupervisor.
func (*MockpostSupervisorMockRecorder) Benchmark ¶ added in v1.3.0
func (mr *MockpostSupervisorMockRecorder) Benchmark(p any) *MockpostSupervisorBenchmarkCall
Benchmark indicates an expected call of Benchmark.
func (*MockpostSupervisorMockRecorder) Config ¶ added in v1.3.0
func (mr *MockpostSupervisorMockRecorder) Config() *MockpostSupervisorConfigCall
Config indicates an expected call of Config.
func (*MockpostSupervisorMockRecorder) Providers ¶ added in v1.3.0
func (mr *MockpostSupervisorMockRecorder) Providers() *MockpostSupervisorProvidersCall
Providers indicates an expected call of Providers.
func (*MockpostSupervisorMockRecorder) Start ¶ added in v1.3.0
func (mr *MockpostSupervisorMockRecorder) Start(opts, id any) *MockpostSupervisorStartCall
Start indicates an expected call of Start.
func (*MockpostSupervisorMockRecorder) Status ¶ added in v1.3.0
func (mr *MockpostSupervisorMockRecorder) Status() *MockpostSupervisorStatusCall
Status indicates an expected call of Status.
func (*MockpostSupervisorMockRecorder) Stop ¶ added in v1.3.0
func (mr *MockpostSupervisorMockRecorder) Stop(deleteFiles any) *MockpostSupervisorStopCall
Stop indicates an expected call of Stop.
type MockpostSupervisorProvidersCall ¶ added in v1.4.0
MockpostSupervisorProvidersCall wrap *gomock.Call
func (*MockpostSupervisorProvidersCall) Do ¶ added in v1.4.0
func (c *MockpostSupervisorProvidersCall) Do(f func() ([]activation.PostSetupProvider, error)) *MockpostSupervisorProvidersCall
Do rewrite *gomock.Call.Do
func (*MockpostSupervisorProvidersCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpostSupervisorProvidersCall) DoAndReturn(f func() ([]activation.PostSetupProvider, error)) *MockpostSupervisorProvidersCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpostSupervisorProvidersCall) Return ¶ added in v1.4.0
func (c *MockpostSupervisorProvidersCall) Return(arg0 []activation.PostSetupProvider, arg1 error) *MockpostSupervisorProvidersCall
Return rewrite *gomock.Call.Return
type MockpostSupervisorStartCall ¶ added in v1.4.0
MockpostSupervisorStartCall wrap *gomock.Call
func (*MockpostSupervisorStartCall) Do ¶ added in v1.4.0
func (c *MockpostSupervisorStartCall) Do(f func(activation.PostSetupOpts, types.NodeID) error) *MockpostSupervisorStartCall
Do rewrite *gomock.Call.Do
func (*MockpostSupervisorStartCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpostSupervisorStartCall) DoAndReturn(f func(activation.PostSetupOpts, types.NodeID) error) *MockpostSupervisorStartCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpostSupervisorStartCall) Return ¶ added in v1.4.0
func (c *MockpostSupervisorStartCall) Return(arg0 error) *MockpostSupervisorStartCall
Return rewrite *gomock.Call.Return
type MockpostSupervisorStatusCall ¶ added in v1.4.0
MockpostSupervisorStatusCall wrap *gomock.Call
func (*MockpostSupervisorStatusCall) Do ¶ added in v1.4.0
func (c *MockpostSupervisorStatusCall) Do(f func() *activation.PostSetupStatus) *MockpostSupervisorStatusCall
Do rewrite *gomock.Call.Do
func (*MockpostSupervisorStatusCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpostSupervisorStatusCall) DoAndReturn(f func() *activation.PostSetupStatus) *MockpostSupervisorStatusCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpostSupervisorStatusCall) Return ¶ added in v1.4.0
func (c *MockpostSupervisorStatusCall) Return(arg0 *activation.PostSetupStatus) *MockpostSupervisorStatusCall
Return rewrite *gomock.Call.Return
type MockpostSupervisorStopCall ¶ added in v1.4.0
MockpostSupervisorStopCall wrap *gomock.Call
func (*MockpostSupervisorStopCall) Do ¶ added in v1.4.0
func (c *MockpostSupervisorStopCall) Do(f func(bool) error) *MockpostSupervisorStopCall
Do rewrite *gomock.Call.Do
func (*MockpostSupervisorStopCall) DoAndReturn ¶ added in v1.4.0
func (c *MockpostSupervisorStopCall) DoAndReturn(f func(bool) error) *MockpostSupervisorStopCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockpostSupervisorStopCall) Return ¶ added in v1.4.0
func (c *MockpostSupervisorStopCall) Return(arg0 error) *MockpostSupervisorStopCall
Return rewrite *gomock.Call.Return
type Mocksyncer ¶ added in v1.0.0
type Mocksyncer struct {
// contains filtered or unexported fields
}
Mocksyncer is a mock of syncer interface.
func NewMocksyncer ¶ added in v1.0.0
func NewMocksyncer(ctrl *gomock.Controller) *Mocksyncer
NewMocksyncer creates a new mock instance.
func (*Mocksyncer) EXPECT ¶ added in v1.0.0
func (m *Mocksyncer) EXPECT() *MocksyncerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MocksyncerIsSyncedCall ¶ added in v1.4.0
MocksyncerIsSyncedCall wrap *gomock.Call
func (*MocksyncerIsSyncedCall) Do ¶ added in v1.4.0
func (c *MocksyncerIsSyncedCall) Do(f func(context.Context) bool) *MocksyncerIsSyncedCall
Do rewrite *gomock.Call.Do
func (*MocksyncerIsSyncedCall) DoAndReturn ¶ added in v1.4.0
func (c *MocksyncerIsSyncedCall) DoAndReturn(f func(context.Context) bool) *MocksyncerIsSyncedCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocksyncerIsSyncedCall) Return ¶ added in v1.4.0
func (c *MocksyncerIsSyncedCall) Return(arg0 bool) *MocksyncerIsSyncedCall
Return rewrite *gomock.Call.Return
type MocksyncerMockRecorder ¶ added in v1.0.0
type MocksyncerMockRecorder struct {
// contains filtered or unexported fields
}
MocksyncerMockRecorder is the mock recorder for Mocksyncer.
func (*MocksyncerMockRecorder) IsSynced ¶ added in v1.0.0
func (mr *MocksyncerMockRecorder) IsSynced(arg0 any) *MocksyncerIsSyncedCall
IsSynced indicates an expected call of IsSynced.
type MocktxValidator ¶ added in v1.0.0
type MocktxValidator struct {
// contains filtered or unexported fields
}
MocktxValidator is a mock of txValidator interface.
func NewMocktxValidator ¶ added in v1.0.0
func NewMocktxValidator(ctrl *gomock.Controller) *MocktxValidator
NewMocktxValidator creates a new mock instance.
func (*MocktxValidator) EXPECT ¶ added in v1.0.0
func (m *MocktxValidator) EXPECT() *MocktxValidatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MocktxValidator) VerifyAndCacheTx ¶ added in v1.0.0
func (m *MocktxValidator) VerifyAndCacheTx(arg0 context.Context, arg1 []byte) error
VerifyAndCacheTx mocks base method.
type MocktxValidatorMockRecorder ¶ added in v1.0.0
type MocktxValidatorMockRecorder struct {
// contains filtered or unexported fields
}
MocktxValidatorMockRecorder is the mock recorder for MocktxValidator.
func (*MocktxValidatorMockRecorder) VerifyAndCacheTx ¶ added in v1.0.0
func (mr *MocktxValidatorMockRecorder) VerifyAndCacheTx(arg0, arg1 any) *MocktxValidatorVerifyAndCacheTxCall
VerifyAndCacheTx indicates an expected call of VerifyAndCacheTx.
type MocktxValidatorVerifyAndCacheTxCall ¶ added in v1.4.0
MocktxValidatorVerifyAndCacheTxCall wrap *gomock.Call
func (*MocktxValidatorVerifyAndCacheTxCall) Do ¶ added in v1.4.0
func (c *MocktxValidatorVerifyAndCacheTxCall) Do(f func(context.Context, []byte) error) *MocktxValidatorVerifyAndCacheTxCall
Do rewrite *gomock.Call.Do
func (*MocktxValidatorVerifyAndCacheTxCall) DoAndReturn ¶ added in v1.4.0
func (c *MocktxValidatorVerifyAndCacheTxCall) DoAndReturn(f func(context.Context, []byte) error) *MocktxValidatorVerifyAndCacheTxCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MocktxValidatorVerifyAndCacheTxCall) Return ¶ added in v1.4.0
func (c *MocktxValidatorVerifyAndCacheTxCall) Return(arg0 error) *MocktxValidatorVerifyAndCacheTxCall
Return rewrite *gomock.Call.Return
type NodeService ¶
type NodeService struct {
// contains filtered or unexported fields
}
NodeService is a grpc server that provides the NodeService, which exposes node-related data such as node status, software version, errors, etc. It can also be used to start the sync process, or to shut down the node.
func NewNodeService ¶
func NewNodeService( peers peerCounter, msh meshAPI, genTime genesisTimeAPI, syncer syncer, appVersion string, appCommit string, ) *NodeService
NewNodeService creates a new grpc service using config data.
func (NodeService) Build ¶
func (s NodeService) Build(context.Context, *emptypb.Empty) (*pb.BuildResponse, error)
Build returns the build of the node software.
func (NodeService) Echo ¶
func (s NodeService) Echo(_ context.Context, in *pb.EchoRequest) (*pb.EchoResponse, error)
Echo returns the response for an echo api request. It's used for E2E tests.
func (NodeService) ErrorStream ¶
func (s NodeService) ErrorStream(_ *pb.ErrorStreamRequest, stream pb.NodeService_ErrorStreamServer) error
ErrorStream exposes a stream of node errors.
func (NodeService) NodeInfo ¶ added in v1.0.0
func (s NodeService) NodeInfo(context.Context, *emptypb.Empty) (*pb.NodeInfoResponse, error)
func (NodeService) RegisterHandlerService ¶ added in v1.3.0
func (s NodeService) RegisterHandlerService(mux *runtime.ServeMux) error
func (NodeService) RegisterService ¶
func (s NodeService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (NodeService) Status ¶
func (s NodeService) Status(ctx context.Context, _ *pb.StatusRequest) (*pb.StatusResponse, error)
Status returns a status object providing information about the connected peers, sync status, current and verified layer.
func (NodeService) StatusStream ¶
func (s NodeService) StatusStream(_ *pb.StatusStreamRequest, stream pb.NodeService_StatusStreamServer) error
StatusStream exposes a stream of node status updates.
func (NodeService) String ¶ added in v1.3.0
func (s NodeService) String() string
String returns the name of this service.
func (NodeService) Version ¶
func (s NodeService) Version(context.Context, *emptypb.Empty) (*pb.VersionResponse, error)
Version returns the version of the node software as a semver string.
type PostService ¶ added in v1.3.0
type PostService struct {
// contains filtered or unexported fields
}
PostService is a grpc server that PoST nodes can connect to in order to register. The bidirectional stream established between the node and the PoST node can be used to send challenges and receive proofs.
func NewPostService ¶ added in v1.3.0
func NewPostService(log *zap.Logger) *PostService
NewPostService creates a new grpc service using config data.
func (*PostService) Client ¶ added in v1.3.0
func (s *PostService) Client(nodeId types.NodeID) (activation.PostClient, error)
func (*PostService) Register ¶ added in v1.3.0
func (s *PostService) Register(stream pb.PostService_RegisterServer) error
Register is called by the PoST service to connect with the node. It creates a bidirectional stream that is kept open until either side closes it. The other functions on this service are called by services of the node to send requests to the PoST node and receive responses.
func (*PostService) RegisterHandlerService ¶ added in v1.3.0
func (s *PostService) RegisterHandlerService(mux *runtime.ServeMux) error
func (*PostService) RegisterService ¶ added in v1.3.0
func (s *PostService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (*PostService) String ¶ added in v1.3.0
func (s *PostService) String() string
String returns the name of this service.
type Server ¶
type Server struct { // BoundAddress contains the address that the server bound to, useful if // the server uses a dynamic port. It is set during startup and can be // safely accessed after Start has completed (I.E. the returned channel has // been waited on) BoundAddress string GrpcServer *grpc.Server // contains filtered or unexported fields }
Server is a very basic grpc server.
func New ¶ added in v1.0.0
New creates and returns a new Server listening on the given address. The server is configured with the given logger and config. Additional grpc options can be passed.
func NewTLS ¶ added in v1.3.0
NewTLS creates a new Server listening on the TLSListener address with the given logger and config. Services passed in the svc slice are registered with the server.
func NewWithServices ¶ added in v1.4.0
func NewWithServices(listener string, logger *zap.Logger, config Config, svc []ServiceAPI) (*Server, error)
NewWithServices creates a new Server listening on the provided address with the given logger and config. Services passed in the svc slice are registered with the server.
type Service ¶ added in v1.0.0
type Service = string
const ( Admin Service = "admin" Debug Service = "debug" GlobalState Service = "global" Mesh Service = "mesh" Transaction Service = "transaction" Activation Service = "activation" Smesher Service = "smesher" Post Service = "post" Node Service = "node" ActivationV2Alpha1 Service = "activation_v2alpha1" ActivationStreamV2Alpha1 Service = "activation_stream_v2alpha1" RewardV2Alpha1 Service = "reward_v2alpha1" RewardStreamV2Alpha1 Service = "reward_stream_v2alpha1" )
type ServiceAPI ¶
type ServiceAPI interface { RegisterService(*grpc.Server) RegisterHandlerService(*runtime.ServeMux) error String() string }
ServiceAPI allows individual grpc services to register the grpc server.
type SmesherService ¶
type SmesherService struct {
// contains filtered or unexported fields
}
SmesherService exposes endpoints to manage smeshing.
func NewSmesherService ¶
func NewSmesherService( smeshing activation.SmeshingProvider, postSupervisor postSupervisor, streamInterval time.Duration, nodeID *types.NodeID, postOpts activation.PostSetupOpts, ) *SmesherService
NewSmesherService creates a new grpc service using config data.
func (SmesherService) Coinbase ¶
func (s SmesherService) Coinbase(context.Context, *emptypb.Empty) (*pb.CoinbaseResponse, error)
Coinbase returns the current coinbase setting of this node.
func (SmesherService) EstimatedRewards ¶ added in v0.1.16
func (s SmesherService) EstimatedRewards( context.Context, *pb.EstimatedRewardsRequest, ) (*pb.EstimatedRewardsResponse, error)
EstimatedRewards returns estimated smeshing rewards over the next epoch.
func (SmesherService) IsSmeshing ¶
func (s SmesherService) IsSmeshing(context.Context, *emptypb.Empty) (*pb.IsSmeshingResponse, error)
IsSmeshing reports whether the node is smeshing.
func (SmesherService) MinGas ¶
func (s SmesherService) MinGas(context.Context, *emptypb.Empty) (*pb.MinGasResponse, error)
MinGas returns the current mingas setting of this node.
func (SmesherService) PostConfig ¶ added in v1.0.0
func (s SmesherService) PostConfig(context.Context, *emptypb.Empty) (*pb.PostConfigResponse, error)
PostConfig returns the Post protocol config.
func (SmesherService) PostSetupProviders ¶ added in v1.0.0
func (s SmesherService) PostSetupProviders( ctx context.Context, in *pb.PostSetupProvidersRequest, ) (*pb.PostSetupProvidersResponse, error)
PostSetupComputeProviders returns a list of available Post setup compute providers.
func (SmesherService) PostSetupStatus ¶ added in v1.0.0
func (s SmesherService) PostSetupStatus(ctx context.Context, _ *emptypb.Empty) (*pb.PostSetupStatusResponse, error)
PostSetupStatus returns post data status.
func (SmesherService) PostSetupStatusStream ¶ added in v1.0.0
func (s SmesherService) PostSetupStatusStream( _ *emptypb.Empty, stream pb.SmesherService_PostSetupStatusStreamServer, ) error
PostSetupStatusStream exposes a stream of status updates during post setup.
func (SmesherService) RegisterHandlerService ¶ added in v1.3.0
func (s SmesherService) RegisterHandlerService(mux *runtime.ServeMux) error
func (SmesherService) RegisterService ¶
func (s SmesherService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (SmesherService) SetCoinbase ¶
func (s SmesherService) SetCoinbase(_ context.Context, in *pb.SetCoinbaseRequest) (*pb.SetCoinbaseResponse, error)
SetCoinbase sets the current coinbase setting of this node.
func (SmesherService) SetMinGas ¶
func (s SmesherService) SetMinGas(context.Context, *pb.SetMinGasRequest) (*pb.SetMinGasResponse, error)
SetMinGas sets the mingas setting of this node.
func (SmesherService) SmesherID ¶
func (s SmesherService) SmesherID(context.Context, *emptypb.Empty) (*pb.SmesherIDResponse, error)
SmesherID returns the smesher ID of this node.
func (SmesherService) SmesherIDs ¶ added in v1.4.0
func (s SmesherService) SmesherIDs(context.Context, *emptypb.Empty) (*pb.SmesherIDsResponse, error)
func (SmesherService) StartSmeshing ¶
func (s SmesherService) StartSmeshing( ctx context.Context, in *pb.StartSmeshingRequest, ) (*pb.StartSmeshingResponse, error)
StartSmeshing requests that the node begin smeshing.
func (SmesherService) StopSmeshing ¶
func (s SmesherService) StopSmeshing( ctx context.Context, in *pb.StopSmeshingRequest, ) (*pb.StopSmeshingResponse, error)
StopSmeshing requests that the node stop smeshing.
func (SmesherService) String ¶ added in v1.3.0
func (s SmesherService) String() string
String returns the name of this service.
type TransactionService ¶
type TransactionService struct {
// contains filtered or unexported fields
}
TransactionService exposes transaction data, and a submit tx endpoint.
func NewTransactionService ¶
func NewTransactionService( db *sql.Database, publisher pubsub.Publisher, msh meshAPI, conState conservativeState, syncer syncer, txHandler txValidator, ) *TransactionService
NewTransactionService creates a new grpc service using config data.
func (TransactionService) ParseTransaction ¶ added in v1.0.0
func (s TransactionService) ParseTransaction( ctx context.Context, in *pb.ParseTransactionRequest, ) (*pb.ParseTransactionResponse, error)
func (TransactionService) RegisterHandlerService ¶ added in v1.3.0
func (s TransactionService) RegisterHandlerService(mux *runtime.ServeMux) error
func (TransactionService) RegisterService ¶
func (s TransactionService) RegisterService(server *grpc.Server)
RegisterService registers this service with a grpc server instance.
func (TransactionService) StreamResults ¶ added in v1.0.0
func (s TransactionService) StreamResults( in *pb.TransactionResultsRequest, stream pb.TransactionService_StreamResultsServer, ) error
StreamResults allows to query historical results and subscribe to live data using the same filter.
func (TransactionService) String ¶ added in v1.3.0
func (s TransactionService) String() string
String returns the name of this service.
func (TransactionService) SubmitTransaction ¶
func (s TransactionService) SubmitTransaction( ctx context.Context, in *pb.SubmitTransactionRequest, ) (*pb.SubmitTransactionResponse, error)
SubmitTransaction allows a new tx to be submitted.
func (TransactionService) TransactionsState ¶
func (s TransactionService) TransactionsState( _ context.Context, in *pb.TransactionsStateRequest, ) (*pb.TransactionsStateResponse, error)
TransactionsState returns current tx data for one or more txs.
func (TransactionService) TransactionsStateStream ¶
func (s TransactionService) TransactionsStateStream( in *pb.TransactionsStateStreamRequest, stream pb.TransactionService_TransactionsStateStreamServer, ) error
TransactionsStateStream exposes a stream of tx data.