grpcserver

package
v1.7.0-alpha.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 28, 2024 License: MIT Imports: 62 Imported by: 0

Documentation

Overview

Package config provides configuration for GRPC and HTTP api servers

Package grpcserver is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewActivationService added in v1.0.0 

func NewActivationService(atxProvider atxProvider, goldenAtx types.ATXID) *activationService

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.StateDatabase, 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(_ *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 (a *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"`
	JSONCorsAllowedOrigins []string  `mapstructure:"grpc-cors-allowed-origins"`

	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.StateDatabase, conState conservativeState, host networkInfo, oracle oracle,
	loggers map[string]*zap.AtomicLevel,
) *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) ChangeLogLevel added in v1.4.0 

func (d *DebugService) ChangeLogLevel(ctx context.Context, req *pb.ChangeLogLevelRequest) (*emptypb.Empty, error)

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 (d *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(
	lg *zap.Logger,
	listener string,
	corsAllowedOrigins []string,
	collectMetrics bool,
) *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(
	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) GetAtx added in v1.6.0 

func (m *MockatxProvider) GetAtx(id types.ATXID) (*types.ActivationTx, error)

GetAtx mocks base method.

func (*MockatxProvider) GetMalfeasanceProof added in v1.1.0 

func (m *MockatxProvider) GetMalfeasanceProof(id types.NodeID) (*wire.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.

func (*MockatxProvider) Previous added in v1.7.0 

func (m *MockatxProvider) Previous(id types.ATXID) ([]types.ATXID, error)

Previous mocks base method.

type MockatxProviderGetAtxCall added in v1.6.0 

type MockatxProviderGetAtxCall struct {
	*gomock.Call
}

MockatxProviderGetAtxCall wrap *gomock.Call

func (*MockatxProviderGetAtxCall) Do added in v1.6.0 

func (c *MockatxProviderGetAtxCall) Do(f func(types.ATXID) (*types.ActivationTx, error)) *MockatxProviderGetAtxCall

Do rewrite *gomock.Call.Do

func (*MockatxProviderGetAtxCall) DoAndReturn added in v1.6.0 

func (c *MockatxProviderGetAtxCall) DoAndReturn(f func(types.ATXID) (*types.ActivationTx, error)) *MockatxProviderGetAtxCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockatxProviderGetAtxCall) Return added in v1.6.0 

func (c *MockatxProviderGetAtxCall) Return(arg0 *types.ActivationTx, arg1 error) *MockatxProviderGetAtxCall

Return rewrite *gomock.Call.Return

type MockatxProviderGetMalfeasanceProofCall added in v1.4.0 

type MockatxProviderGetMalfeasanceProofCall struct {
	*gomock.Call
}

MockatxProviderGetMalfeasanceProofCall wrap *gomock.Call

func (*MockatxProviderGetMalfeasanceProofCall) Do added in v1.4.0 

func (c *MockatxProviderGetMalfeasanceProofCall) Do(f func(types.NodeID) (*wire.MalfeasanceProof, error)) *MockatxProviderGetMalfeasanceProofCall

Do rewrite *gomock.Call.Do

func (*MockatxProviderGetMalfeasanceProofCall) DoAndReturn added in v1.4.0 

func (c *MockatxProviderGetMalfeasanceProofCall) DoAndReturn(f func(types.NodeID) (*wire.MalfeasanceProof, error)) *MockatxProviderGetMalfeasanceProofCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockatxProviderGetMalfeasanceProofCall) Return added in v1.4.0 

func (c *MockatxProviderGetMalfeasanceProofCall) Return(arg0 *wire.MalfeasanceProof, arg1 error) *MockatxProviderGetMalfeasanceProofCall

Return rewrite *gomock.Call.Return

type MockatxProviderMaxHeightAtxCall added in v1.4.0 

type MockatxProviderMaxHeightAtxCall struct {
	*gomock.Call
}

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) GetAtx added in v1.6.0 

func (mr *MockatxProviderMockRecorder) GetAtx(id any) *MockatxProviderGetAtxCall

GetAtx indicates an expected call of GetAtx.

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.

func (*MockatxProviderMockRecorder) Previous added in v1.7.0 

func (mr *MockatxProviderMockRecorder) Previous(id any) *MockatxProviderPreviousCall

Previous indicates an expected call of Previous.

type MockatxProviderPreviousCall added in v1.7.0 

type MockatxProviderPreviousCall struct {
	*gomock.Call
}

MockatxProviderPreviousCall wrap *gomock.Call

func (*MockatxProviderPreviousCall) Do added in v1.7.0 

func (c *MockatxProviderPreviousCall) Do(f func(types.ATXID) ([]types.ATXID, error)) *MockatxProviderPreviousCall

Do rewrite *gomock.Call.Do

func (*MockatxProviderPreviousCall) DoAndReturn added in v1.7.0 

func (c *MockatxProviderPreviousCall) DoAndReturn(f func(types.ATXID) ([]types.ATXID, error)) *MockatxProviderPreviousCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockatxProviderPreviousCall) Return added in v1.7.0 

func (c *MockatxProviderPreviousCall) Return(arg0 []types.ATXID, arg1 error) *MockatxProviderPreviousCall

Return rewrite *gomock.Call.Return

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 

func (m *MockconservativeState) GetLayerStateRoot(arg0 types.LayerID) (types.Hash32, error)

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) GetNonce added in v1.0.0 

func (m *MockconservativeState) GetNonce(arg0 types.Address) (types.Nonce, error)

GetNonce 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 

type MockconservativeStateGetAllAccountsCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetBalanceCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetLayerStateRootCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetMeshTransactionCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetMeshTransactionsCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetNonceCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetProjectionCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetStateRootCall struct {
	*gomock.Call
}

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 

type MockconservativeStateGetTransactionsByAddressCall struct {
	*gomock.Call
}

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 

type MockconservativeStateValidationCall struct {
	*gomock.Call
}

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 

type MockgenesisTimeAPICurrentLayerCall struct {
	*gomock.Call
}

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 

type MockgenesisTimeAPIGenesisTimeCall struct {
	*gomock.Call
}

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 MockgrpcPostService added in v1.4.5 

type MockgrpcPostService struct {
	// contains filtered or unexported fields
}

MockgrpcPostService is a mock of grpcPostService interface.

func NewMockgrpcPostService added in v1.4.5 

func NewMockgrpcPostService(ctrl *gomock.Controller) *MockgrpcPostService

NewMockgrpcPostService creates a new mock instance.

func (*MockgrpcPostService) AllowConnections added in v1.4.5 

func (m *MockgrpcPostService) AllowConnections(allow bool)

AllowConnections mocks base method.

func (*MockgrpcPostService) EXPECT added in v1.4.5 

func (m *MockgrpcPostService) EXPECT() *MockgrpcPostServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockgrpcPostServiceAllowConnectionsCall added in v1.4.5 

type MockgrpcPostServiceAllowConnectionsCall struct {
	*gomock.Call
}

MockgrpcPostServiceAllowConnectionsCall wrap *gomock.Call

func (*MockgrpcPostServiceAllowConnectionsCall) Do added in v1.4.5 

func (c *MockgrpcPostServiceAllowConnectionsCall) Do(f func(bool)) *MockgrpcPostServiceAllowConnectionsCall

Do rewrite *gomock.Call.Do

func (*MockgrpcPostServiceAllowConnectionsCall) DoAndReturn added in v1.4.5 

func (c *MockgrpcPostServiceAllowConnectionsCall) DoAndReturn(f func(bool)) *MockgrpcPostServiceAllowConnectionsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockgrpcPostServiceAllowConnectionsCall) Return added in v1.4.5 

func (c *MockgrpcPostServiceAllowConnectionsCall) Return() *MockgrpcPostServiceAllowConnectionsCall

Return rewrite *gomock.Call.Return

type MockgrpcPostServiceMockRecorder added in v1.4.5 

type MockgrpcPostServiceMockRecorder struct {
	// contains filtered or unexported fields
}

MockgrpcPostServiceMockRecorder is the mock recorder for MockgrpcPostService.

func (*MockgrpcPostServiceMockRecorder) AllowConnections added in v1.4.5 

func (mr *MockgrpcPostServiceMockRecorder) AllowConnections(allow any) *MockgrpcPostServiceAllowConnectionsCall

AllowConnections indicates an expected call of AllowConnections.

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) GetLayer added in v1.0.0 

func (m *MockmeshAPI) GetLayer(arg0 types.LayerID) (*types.Layer, error)

GetLayer mocks base method.

func (*MockmeshAPI) GetLayerVerified added in v1.3.3 

func (m *MockmeshAPI) GetLayerVerified(arg0 types.LayerID) (*types.Block, error)

GetLayerVerified mocks base method.

func (*MockmeshAPI) GetRewardsByCoinbase added in v1.3.0 

func (m *MockmeshAPI) GetRewardsByCoinbase(arg0 types.Address) ([]*types.Reward, error)

GetRewardsByCoinbase mocks base method.

func (*MockmeshAPI) GetRewardsBySmesherId added in v1.3.0 

func (m *MockmeshAPI) GetRewardsBySmesherId(id types.NodeID) ([]*types.Reward, error)

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) MeshHash added in v1.0.0 

func (m *MockmeshAPI) MeshHash(arg0 types.LayerID) (types.Hash32, error)

MeshHash 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 

type MockmeshAPIGetLayerCall struct {
	*gomock.Call
}

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 

type MockmeshAPIGetLayerVerifiedCall struct {
	*gomock.Call
}

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 

type MockmeshAPIGetRewardsByCoinbaseCall struct {
	*gomock.Call
}

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 

type MockmeshAPIGetRewardsBySmesherIdCall struct {
	*gomock.Call
}

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 

type MockmeshAPILatestLayerCall struct {
	*gomock.Call
}

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 

type MockmeshAPILatestLayerInStateCall struct {
	*gomock.Call
}

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 

type MockmeshAPIMeshHashCall struct {
	*gomock.Call
}

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 

type MockmeshAPIProcessedLayerCall struct {
	*gomock.Call
}

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) PeerInfo added in v1.6.0 

func (m *MocknetworkInfo) PeerInfo() peerinfo.PeerInfo

PeerInfo 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 

type MocknetworkInfoDHTServerEnabledCall struct {
	*gomock.Call
}

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 

type MocknetworkInfoIDCall struct {
	*gomock.Call
}

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 

type MocknetworkInfoKnownAddressesCall struct {
	*gomock.Call
}

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 

type MocknetworkInfoListenAddressesCall struct {
	*gomock.Call
}

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) PeerInfo added in v1.6.0 

func (mr *MocknetworkInfoMockRecorder) PeerInfo() *MocknetworkInfoPeerInfoCall

PeerInfo indicates an expected call of PeerInfo.

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 

type MocknetworkInfoNATDeviceTypeCall struct {
	*gomock.Call
}

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 MocknetworkInfoPeerInfoCall added in v1.6.0 

type MocknetworkInfoPeerInfoCall struct {
	*gomock.Call
}

MocknetworkInfoPeerInfoCall wrap *gomock.Call

func (*MocknetworkInfoPeerInfoCall) Do added in v1.6.0 

func (c *MocknetworkInfoPeerInfoCall) Do(f func() peerinfo.PeerInfo) *MocknetworkInfoPeerInfoCall

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoPeerInfoCall) DoAndReturn added in v1.6.0 

func (c *MocknetworkInfoPeerInfoCall) DoAndReturn(f func() peerinfo.PeerInfo) *MocknetworkInfoPeerInfoCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoPeerInfoCall) Return added in v1.6.0 

func (c *MocknetworkInfoPeerInfoCall) Return(arg0 peerinfo.PeerInfo) *MocknetworkInfoPeerInfoCall

Return rewrite *gomock.Call.Return

type MocknetworkInfoReachabilityCall added in v1.4.0 

type MocknetworkInfoReachabilityCall struct {
	*gomock.Call
}

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) ActiveSet added in v1.0.0 

func (m *Mockoracle) ActiveSet(arg0 context.Context, arg1 types.EpochID) ([]types.ATXID, error)

ActiveSet mocks base method.

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 

type MockoracleActiveSetCall struct {
	*gomock.Call
}

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 

type MockpeerCounterPeerCountCall struct {
	*gomock.Call
}

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 

func (m *Mockpeers) ConnectedPeerInfo(arg0 p2p.Peer) *p2p.PeerInfo

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.

func (*Mockpeers) GetPeers added in v1.1.2 

func (m *Mockpeers) GetPeers() []p2p.Peer

GetPeers mocks base method.

type MockpeersConnectedPeerInfoCall added in v1.4.0 

type MockpeersConnectedPeerInfoCall struct {
	*gomock.Call
}

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 

type MockpeersGetPeersCall struct {
	*gomock.Call
}

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 MockpostState added in v1.4.0 

type MockpostState struct {
	// contains filtered or unexported fields
}

MockpostState is a mock of postState interface.

func NewMockpostState added in v1.4.0 

func NewMockpostState(ctrl *gomock.Controller) *MockpostState

NewMockpostState creates a new mock instance.

func (*MockpostState) EXPECT added in v1.4.0 

func (m *MockpostState) EXPECT() *MockpostStateMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockpostState) PostStates added in v1.4.0 

func (m *MockpostState) PostStates() map[types.IdentityDescriptor]types.PostState

PostStates mocks base method.

type MockpostStateMockRecorder added in v1.4.0 

type MockpostStateMockRecorder struct {
	// contains filtered or unexported fields
}

MockpostStateMockRecorder is the mock recorder for MockpostState.

func (*MockpostStateMockRecorder) PostStates added in v1.4.0 

func (mr *MockpostStateMockRecorder) PostStates() *MockpostStatePostStatesCall

PostStates indicates an expected call of PostStates.

type MockpostStatePostStatesCall added in v1.4.0 

type MockpostStatePostStatesCall struct {
	*gomock.Call
}

MockpostStatePostStatesCall wrap *gomock.Call

func (*MockpostStatePostStatesCall) Do added in v1.4.0 

func (c *MockpostStatePostStatesCall) Do(f func() map[types.IdentityDescriptor]types.PostState) *MockpostStatePostStatesCall

Do rewrite *gomock.Call.Do

func (*MockpostStatePostStatesCall) DoAndReturn added in v1.4.0 

func (c *MockpostStatePostStatesCall) DoAndReturn(f func() map[types.IdentityDescriptor]types.PostState) *MockpostStatePostStatesCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostStatePostStatesCall) Return added in v1.4.0 

func (c *MockpostStatePostStatesCall) Return(arg0 map[types.IdentityDescriptor]types.PostState) *MockpostStatePostStatesCall

Return rewrite *gomock.Call.Return

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(cmdCfg activation.PostSupervisorConfig, opts activation.PostSetupOpts, sig *signing.EdSigner) 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 

type MockpostSupervisorBenchmarkCall struct {
	*gomock.Call
}

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 

type MockpostSupervisorConfigCall struct {
	*gomock.Call
}

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(cmdCfg, opts, sig 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 

type MockpostSupervisorProvidersCall struct {
	*gomock.Call
}

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 

type MockpostSupervisorStartCall struct {
	*gomock.Call
}

MockpostSupervisorStartCall wrap *gomock.Call

func (*MockpostSupervisorStartCall) Do added in v1.4.0 

func (c *MockpostSupervisorStartCall) Do(f func(activation.PostSupervisorConfig, activation.PostSetupOpts, *signing.EdSigner) error) *MockpostSupervisorStartCall

Do rewrite *gomock.Call.Do

func (*MockpostSupervisorStartCall) DoAndReturn added in v1.4.0 

func (c *MockpostSupervisorStartCall) DoAndReturn(f func(activation.PostSupervisorConfig, activation.PostSetupOpts, *signing.EdSigner) 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 

type MockpostSupervisorStatusCall struct {
	*gomock.Call
}

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 

type MockpostSupervisorStopCall struct {
	*gomock.Call
}

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.

func (*Mocksyncer) IsSynced added in v1.0.0 

func (m *Mocksyncer) IsSynced(arg0 context.Context) bool

IsSynced mocks base method.

type MocksyncerIsSyncedCall added in v1.4.0 

type MocksyncerIsSyncedCall struct {
	*gomock.Call
}

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 

type MocktxValidatorVerifyAndCacheTxCall struct {
	*gomock.Call
}

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 PostInfoService added in v1.4.0 

type PostInfoService struct {
	// contains filtered or unexported fields
}

PostInfoService provides information about connected PostServices.

func NewPostInfoService added in v1.4.0 

func NewPostInfoService(log *zap.Logger, states postState) *PostInfoService

NewPostInfoService creates a new instance of the post info grpc service.

func (*PostInfoService) PostStates added in v1.4.0 

func (s *PostInfoService) PostStates(context.Context, *pb.PostStatesRequest) (*pb.PostStatesResponse, error)

func (*PostInfoService) RegisterHandlerService added in v1.4.0 

func (s *PostInfoService) RegisterHandlerService(mux *runtime.ServeMux) error

func (*PostInfoService) RegisterService added in v1.4.0 

func (s *PostInfoService) RegisterService(server *grpc.Server)

RegisterService registers this service with a grpc server instance.

func (*PostInfoService) String added in v1.4.0 

func (s *PostInfoService) String() string

String returns the name of this service.

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, opts ...PostServiceOpt) *PostService

NewPostService creates a new instance of the post grpc service.

func (*PostService) AllowConnections added in v1.4.5 

func (s *PostService) AllowConnections(allow bool)

AllowConnections sets if the grpc service accepts new incoming connections from post services.

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 PostServiceOpt added in v1.7.0 

type PostServiceOpt func(*PostService)

func PostServiceQueryInterval added in v1.7.0 

func PostServiceQueryInterval(interval time.Duration) PostServiceOpt

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 

func New(listener string, logger *zap.Logger, config Config, grpcOpts ...grpc.ServerOption) *Server

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 

func NewTLS(logger *zap.Logger, config Config, svc []ServiceAPI) (*Server, error)

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,
	grpcOpts ...grpc.ServerOption,
) (*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.

func (*Server) Close 

func (s *Server) Close() error

Close stops the server.

func (*Server) Start 

func (s *Server) Start() error

Start starts 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"
	PostInfo                  Service = "postInfo"
	Node                      Service = "node"
	ActivationV2Alpha1        Service = "activation_v2alpha1"
	ActivationStreamV2Alpha1  Service = "activation_stream_v2alpha1"
	RewardV2Alpha1            Service = "reward_v2alpha1"
	RewardStreamV2Alpha1      Service = "reward_stream_v2alpha1"
	NetworkV2Alpha1           Service = "network_v2alpha1"
	NodeV2Alpha1              Service = "node_v2alpha1"
	LayerV2Alpha1             Service = "layer_v2alpha1"
	LayerStreamV2Alpha1       Service = "layer_stream_v2alpha1"
	TransactionV2Alpha1       Service = "transaction_v2alpha1"
	TransactionStreamV2Alpha1 Service = "transaction_stream_v2alpha1"
	AccountV2Alpha1           Service = "account_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,
	grpcPostService grpcPostService,
	streamInterval time.Duration,
	postOpts activation.PostSetupOpts,
	sig *signing.EdSigner,
) *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)

PostSetupProviders 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) SetPostServiceConfig added in v1.4.2 

func (s *SmesherService) SetPostServiceConfig(cfg activation.PostSupervisorConfig)

SetPostServiceConfig sets the post supervisor config.

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.StateDatabase,
	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.

Source Files

View all Source files

Directories

Path Synopsis
Package v2alpha1 is a generated GoMock package.
 Package v2alpha1 is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.