v1

package
v1.8.3 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2025 License: MIT Imports: 48 Imported by: 0

Documentation

Overview

Package v1 is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewActivationService 

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

Types

type AdminService 

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

AdminService exposes endpoints for node administration.

func NewAdminService 

func NewAdminService(db sql.StateDatabase, dataDir string, p peers) *AdminService

NewAdminService creates a new admin grpc service.

func (*AdminService) CheckpointStream 

func (a *AdminService) CheckpointStream(
	req *pb.CheckpointStreamRequest,
	stream pb.AdminService_CheckpointStreamServer,
) error

func (*AdminService) EventsStream 

func (a *AdminService) EventsStream(_ *pb.EventStreamRequest, stream pb.AdminService_EventsStreamServer) error

func (*AdminService) PeerInfoStream 

func (a *AdminService) PeerInfoStream(_ *emptypb.Empty, stream pb.AdminService_PeerInfoStreamServer) error

func (*AdminService) Recover 

func (a *AdminService) Recover(ctx context.Context, _ *pb.RecoverRequest) (*emptypb.Empty, error)

func (*AdminService) RegisterHandlerService 

func (a *AdminService) RegisterHandlerService(mux *runtime.ServeMux) error

func (*AdminService) RegisterService 

func (a *AdminService) RegisterService(server *grpc.Server)

RegisterService registers this service with a grpc server instance.

func (*AdminService) String 

func (a *AdminService) String() string

String returns the name of this service.

type DebugService 

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

DebugService exposes global state data, output from the STF.

func NewDebugService 

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 

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 

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 

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

func (*DebugService) NetworkInfo 

func (d *DebugService) NetworkInfo(ctx context.Context, _ *emptypb.Empty) (*pb.NetworkInfoResponse, error)

NetworkInfo query provides NetworkInfoResponse.

func (*DebugService) ProposalsStream 

func (d *DebugService) ProposalsStream(_ *emptypb.Empty, stream pb.DebugService_ProposalsStreamServer) error

ProposalsStream streams all proposals confirmed by hare.

func (*DebugService) RegisterHandlerService 

func (d *DebugService) RegisterHandlerService(mux *runtime.ServeMux) error

func (*DebugService) RegisterService 

func (d *DebugService) RegisterService(server *grpc.Server)

RegisterService registers this service with a grpc server instance.

func (*DebugService) String 

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) 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 

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) String 

func (s *GlobalStateService) String() string

String returns the name of the service.

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 

func (s *MeshService) EpochStream(req *pb.EpochStreamRequest, stream pb.MeshService_EpochStreamServer) error

func (*MeshService) GenesisID 

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 

func (s *MeshService) MalfeasanceQuery(
	ctx context.Context,
	req *pb.MalfeasanceRequest,
) (*pb.MalfeasanceResponse, error)

func (*MeshService) MalfeasanceStream 

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 

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 

func (s *MeshService) String() string

String returns the name of this service.

type MockatxProvider 

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

MockatxProvider is a mock of atxProvider interface.

func NewMockatxProvider 

func NewMockatxProvider(ctrl *gomock.Controller) *MockatxProvider

NewMockatxProvider creates a new mock instance.

func (*MockatxProvider) EXPECT 

func (m *MockatxProvider) EXPECT() *MockatxProviderMockRecorder

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

func (*MockatxProvider) GetAtx 

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

GetAtx mocks base method.

func (*MockatxProvider) MalfeasanceProof 

func (m *MockatxProvider) MalfeasanceProof(id types.NodeID) ([]byte, error)

MalfeasanceProof mocks base method.

func (*MockatxProvider) MaxHeightAtx 

func (m *MockatxProvider) MaxHeightAtx() (types.ATXID, error)

MaxHeightAtx mocks base method.

func (*MockatxProvider) Previous 

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

Previous mocks base method.

type MockatxProviderGetAtxCall 

type MockatxProviderGetAtxCall struct {
	*gomock.Call
}

MockatxProviderGetAtxCall wrap *gomock.Call

func (*MockatxProviderGetAtxCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MockatxProviderGetAtxCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockatxProviderGetAtxCall) Return 

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

Return rewrite *gomock.Call.Return

type MockatxProviderMalfeasanceProofCall 

type MockatxProviderMalfeasanceProofCall struct {
	*gomock.Call
}

MockatxProviderMalfeasanceProofCall wrap *gomock.Call

func (*MockatxProviderMalfeasanceProofCall) Do 

func (c *MockatxProviderMalfeasanceProofCall) Do(f func(types.NodeID) ([]byte, error)) *MockatxProviderMalfeasanceProofCall

Do rewrite *gomock.Call.Do

func (*MockatxProviderMalfeasanceProofCall) DoAndReturn 

func (c *MockatxProviderMalfeasanceProofCall) DoAndReturn(f func(types.NodeID) ([]byte, error)) *MockatxProviderMalfeasanceProofCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockatxProviderMalfeasanceProofCall) Return 

func (c *MockatxProviderMalfeasanceProofCall) Return(arg0 []byte, arg1 error) *MockatxProviderMalfeasanceProofCall

Return rewrite *gomock.Call.Return

type MockatxProviderMaxHeightAtxCall 

type MockatxProviderMaxHeightAtxCall struct {
	*gomock.Call
}

MockatxProviderMaxHeightAtxCall wrap *gomock.Call

func (*MockatxProviderMaxHeightAtxCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MockatxProviderMaxHeightAtxCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockatxProviderMaxHeightAtxCall) Return 

func (c *MockatxProviderMaxHeightAtxCall) Return(arg0 types.ATXID, arg1 error) *MockatxProviderMaxHeightAtxCall

Return rewrite *gomock.Call.Return

type MockatxProviderMockRecorder 

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

MockatxProviderMockRecorder is the mock recorder for MockatxProvider.

func (*MockatxProviderMockRecorder) GetAtx 

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

GetAtx indicates an expected call of GetAtx.

func (*MockatxProviderMockRecorder) MalfeasanceProof 

func (mr *MockatxProviderMockRecorder) MalfeasanceProof(id any) *MockatxProviderMalfeasanceProofCall

MalfeasanceProof indicates an expected call of MalfeasanceProof.

func (*MockatxProviderMockRecorder) MaxHeightAtx 

func (mr *MockatxProviderMockRecorder) MaxHeightAtx() *MockatxProviderMaxHeightAtxCall

MaxHeightAtx indicates an expected call of MaxHeightAtx.

func (*MockatxProviderMockRecorder) Previous 

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

Previous indicates an expected call of Previous.

type MockatxProviderPreviousCall 

type MockatxProviderPreviousCall struct {
	*gomock.Call
}

MockatxProviderPreviousCall wrap *gomock.Call

func (*MockatxProviderPreviousCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MockatxProviderPreviousCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockatxProviderPreviousCall) Return 

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

Return rewrite *gomock.Call.Return

type MockconservativeState 

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

MockconservativeState is a mock of conservativeState interface.

func NewMockconservativeState 

func NewMockconservativeState(ctrl *gomock.Controller) *MockconservativeState

NewMockconservativeState creates a new mock instance.

func (*MockconservativeState) EXPECT 

func (m *MockconservativeState) EXPECT() *MockconservativeStateMockRecorder

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

func (*MockconservativeState) GetAllAccounts 

func (m *MockconservativeState) GetAllAccounts() ([]*types.Account, error)

GetAllAccounts mocks base method.

func (*MockconservativeState) GetBalance 

func (m *MockconservativeState) GetBalance(arg0 types.Address) (uint64, error)

GetBalance mocks base method.

func (*MockconservativeState) GetLayerStateRoot 

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

GetLayerStateRoot mocks base method.

func (*MockconservativeState) GetMeshTransaction 

func (m *MockconservativeState) GetMeshTransaction(arg0 types.TransactionID) (*types.MeshTransaction, error)

GetMeshTransaction mocks base method.

func (*MockconservativeState) GetMeshTransactions 

func (m *MockconservativeState) GetMeshTransactions(arg0 []types.TransactionID) ([]*types.MeshTransaction, map[types.TransactionID]struct{})

GetMeshTransactions mocks base method.

func (*MockconservativeState) GetNonce 

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

GetNonce mocks base method.

func (*MockconservativeState) GetProjection 

func (m *MockconservativeState) GetProjection(arg0 types.Address) (uint64, uint64)

GetProjection mocks base method.

func (*MockconservativeState) GetStateRoot 

func (m *MockconservativeState) GetStateRoot() (types.Hash32, error)

GetStateRoot mocks base method.

func (*MockconservativeState) GetTransactionsByAddress 

func (m *MockconservativeState) GetTransactionsByAddress(arg0, arg1 types.LayerID, arg2 types.Address) ([]*types.MeshTransaction, error)

GetTransactionsByAddress mocks base method.

func (*MockconservativeState) HasEvicted 

func (m *MockconservativeState) HasEvicted(tid types.TransactionID) (bool, error)

HasEvicted mocks base method.

func (*MockconservativeState) Validation 

func (m *MockconservativeState) Validation(raw types.RawTx) system.ValidationRequest

Validation mocks base method.

type MockconservativeStateGetAllAccountsCall 

type MockconservativeStateGetAllAccountsCall struct {
	*gomock.Call
}

MockconservativeStateGetAllAccountsCall wrap *gomock.Call

func (*MockconservativeStateGetAllAccountsCall) Do 

func (c *MockconservativeStateGetAllAccountsCall) Do(f func() ([]*types.Account, error)) *MockconservativeStateGetAllAccountsCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetAllAccountsCall) DoAndReturn 

func (c *MockconservativeStateGetAllAccountsCall) DoAndReturn(f func() ([]*types.Account, error)) *MockconservativeStateGetAllAccountsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetAllAccountsCall) Return 

func (c *MockconservativeStateGetAllAccountsCall) Return(arg0 []*types.Account, arg1 error) *MockconservativeStateGetAllAccountsCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetBalanceCall 

type MockconservativeStateGetBalanceCall struct {
	*gomock.Call
}

MockconservativeStateGetBalanceCall wrap *gomock.Call

func (*MockconservativeStateGetBalanceCall) Do 

func (c *MockconservativeStateGetBalanceCall) Do(f func(types.Address) (uint64, error)) *MockconservativeStateGetBalanceCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetBalanceCall) DoAndReturn 

func (c *MockconservativeStateGetBalanceCall) DoAndReturn(f func(types.Address) (uint64, error)) *MockconservativeStateGetBalanceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetBalanceCall) Return 

func (c *MockconservativeStateGetBalanceCall) Return(arg0 uint64, arg1 error) *MockconservativeStateGetBalanceCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetLayerStateRootCall 

type MockconservativeStateGetLayerStateRootCall struct {
	*gomock.Call
}

MockconservativeStateGetLayerStateRootCall wrap *gomock.Call

func (*MockconservativeStateGetLayerStateRootCall) Do 

func (c *MockconservativeStateGetLayerStateRootCall) Do(f func(types.LayerID) (types.Hash32, error)) *MockconservativeStateGetLayerStateRootCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetLayerStateRootCall) DoAndReturn 

func (c *MockconservativeStateGetLayerStateRootCall) DoAndReturn(f func(types.LayerID) (types.Hash32, error)) *MockconservativeStateGetLayerStateRootCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetLayerStateRootCall) Return 

func (c *MockconservativeStateGetLayerStateRootCall) Return(arg0 types.Hash32, arg1 error) *MockconservativeStateGetLayerStateRootCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetMeshTransactionCall 

type MockconservativeStateGetMeshTransactionCall struct {
	*gomock.Call
}

MockconservativeStateGetMeshTransactionCall wrap *gomock.Call

func (*MockconservativeStateGetMeshTransactionCall) Do 

func (c *MockconservativeStateGetMeshTransactionCall) Do(f func(types.TransactionID) (*types.MeshTransaction, error)) *MockconservativeStateGetMeshTransactionCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetMeshTransactionCall) DoAndReturn 

func (c *MockconservativeStateGetMeshTransactionCall) DoAndReturn(f func(types.TransactionID) (*types.MeshTransaction, error)) *MockconservativeStateGetMeshTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetMeshTransactionCall) Return 

func (c *MockconservativeStateGetMeshTransactionCall) Return(arg0 *types.MeshTransaction, arg1 error) *MockconservativeStateGetMeshTransactionCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetMeshTransactionsCall 

type MockconservativeStateGetMeshTransactionsCall struct {
	*gomock.Call
}

MockconservativeStateGetMeshTransactionsCall wrap *gomock.Call

func (*MockconservativeStateGetMeshTransactionsCall) Do 

func (c *MockconservativeStateGetMeshTransactionsCall) Do(f func([]types.TransactionID) ([]*types.MeshTransaction, map[types.TransactionID]struct{})) *MockconservativeStateGetMeshTransactionsCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetMeshTransactionsCall) DoAndReturn 

func (c *MockconservativeStateGetMeshTransactionsCall) DoAndReturn(f func([]types.TransactionID) ([]*types.MeshTransaction, map[types.TransactionID]struct{})) *MockconservativeStateGetMeshTransactionsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetMeshTransactionsCall) Return 

func (c *MockconservativeStateGetMeshTransactionsCall) Return(arg0 []*types.MeshTransaction, arg1 map[types.TransactionID]struct{}) *MockconservativeStateGetMeshTransactionsCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetNonceCall 

type MockconservativeStateGetNonceCall struct {
	*gomock.Call
}

MockconservativeStateGetNonceCall wrap *gomock.Call

func (*MockconservativeStateGetNonceCall) Do 

func (c *MockconservativeStateGetNonceCall) Do(f func(types.Address) (types.Nonce, error)) *MockconservativeStateGetNonceCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetNonceCall) DoAndReturn 

func (c *MockconservativeStateGetNonceCall) DoAndReturn(f func(types.Address) (types.Nonce, error)) *MockconservativeStateGetNonceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetNonceCall) Return 

func (c *MockconservativeStateGetNonceCall) Return(arg0 types.Nonce, arg1 error) *MockconservativeStateGetNonceCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetProjectionCall 

type MockconservativeStateGetProjectionCall struct {
	*gomock.Call
}

MockconservativeStateGetProjectionCall wrap *gomock.Call

func (*MockconservativeStateGetProjectionCall) Do 

func (c *MockconservativeStateGetProjectionCall) Do(f func(types.Address) (uint64, uint64)) *MockconservativeStateGetProjectionCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetProjectionCall) DoAndReturn 

func (c *MockconservativeStateGetProjectionCall) DoAndReturn(f func(types.Address) (uint64, uint64)) *MockconservativeStateGetProjectionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetProjectionCall) Return 

func (c *MockconservativeStateGetProjectionCall) Return(arg0, arg1 uint64) *MockconservativeStateGetProjectionCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetStateRootCall 

type MockconservativeStateGetStateRootCall struct {
	*gomock.Call
}

MockconservativeStateGetStateRootCall wrap *gomock.Call

func (*MockconservativeStateGetStateRootCall) Do 

func (c *MockconservativeStateGetStateRootCall) Do(f func() (types.Hash32, error)) *MockconservativeStateGetStateRootCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetStateRootCall) DoAndReturn 

func (c *MockconservativeStateGetStateRootCall) DoAndReturn(f func() (types.Hash32, error)) *MockconservativeStateGetStateRootCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetStateRootCall) Return 

func (c *MockconservativeStateGetStateRootCall) Return(arg0 types.Hash32, arg1 error) *MockconservativeStateGetStateRootCall

Return rewrite *gomock.Call.Return

type MockconservativeStateGetTransactionsByAddressCall 

type MockconservativeStateGetTransactionsByAddressCall struct {
	*gomock.Call
}

MockconservativeStateGetTransactionsByAddressCall wrap *gomock.Call

func (*MockconservativeStateGetTransactionsByAddressCall) Do 

func (c *MockconservativeStateGetTransactionsByAddressCall) Do(f func(types.LayerID, types.LayerID, types.Address) ([]*types.MeshTransaction, error)) *MockconservativeStateGetTransactionsByAddressCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateGetTransactionsByAddressCall) DoAndReturn 

func (c *MockconservativeStateGetTransactionsByAddressCall) DoAndReturn(f func(types.LayerID, types.LayerID, types.Address) ([]*types.MeshTransaction, error)) *MockconservativeStateGetTransactionsByAddressCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateGetTransactionsByAddressCall) Return 

func (c *MockconservativeStateGetTransactionsByAddressCall) Return(arg0 []*types.MeshTransaction, arg1 error) *MockconservativeStateGetTransactionsByAddressCall

Return rewrite *gomock.Call.Return

type MockconservativeStateHasEvictedCall 

type MockconservativeStateHasEvictedCall struct {
	*gomock.Call
}

MockconservativeStateHasEvictedCall wrap *gomock.Call

func (*MockconservativeStateHasEvictedCall) Do 

func (c *MockconservativeStateHasEvictedCall) Do(f func(types.TransactionID) (bool, error)) *MockconservativeStateHasEvictedCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateHasEvictedCall) DoAndReturn 

func (c *MockconservativeStateHasEvictedCall) DoAndReturn(f func(types.TransactionID) (bool, error)) *MockconservativeStateHasEvictedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateHasEvictedCall) Return 

func (c *MockconservativeStateHasEvictedCall) Return(arg0 bool, arg1 error) *MockconservativeStateHasEvictedCall

Return rewrite *gomock.Call.Return

type MockconservativeStateMockRecorder 

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

MockconservativeStateMockRecorder is the mock recorder for MockconservativeState.

func (*MockconservativeStateMockRecorder) GetAllAccounts 

func (mr *MockconservativeStateMockRecorder) GetAllAccounts() *MockconservativeStateGetAllAccountsCall

GetAllAccounts indicates an expected call of GetAllAccounts.

func (*MockconservativeStateMockRecorder) GetBalance 

func (mr *MockconservativeStateMockRecorder) GetBalance(arg0 any) *MockconservativeStateGetBalanceCall

GetBalance indicates an expected call of GetBalance.

func (*MockconservativeStateMockRecorder) GetLayerStateRoot 

func (mr *MockconservativeStateMockRecorder) GetLayerStateRoot(arg0 any) *MockconservativeStateGetLayerStateRootCall

GetLayerStateRoot indicates an expected call of GetLayerStateRoot.

func (*MockconservativeStateMockRecorder) GetMeshTransaction 

func (mr *MockconservativeStateMockRecorder) GetMeshTransaction(arg0 any) *MockconservativeStateGetMeshTransactionCall

GetMeshTransaction indicates an expected call of GetMeshTransaction.

func (*MockconservativeStateMockRecorder) GetMeshTransactions 

func (mr *MockconservativeStateMockRecorder) GetMeshTransactions(arg0 any) *MockconservativeStateGetMeshTransactionsCall

GetMeshTransactions indicates an expected call of GetMeshTransactions.

func (*MockconservativeStateMockRecorder) GetNonce 

func (mr *MockconservativeStateMockRecorder) GetNonce(arg0 any) *MockconservativeStateGetNonceCall

GetNonce indicates an expected call of GetNonce.

func (*MockconservativeStateMockRecorder) GetProjection 

func (mr *MockconservativeStateMockRecorder) GetProjection(arg0 any) *MockconservativeStateGetProjectionCall

GetProjection indicates an expected call of GetProjection.

func (*MockconservativeStateMockRecorder) GetStateRoot 

func (mr *MockconservativeStateMockRecorder) GetStateRoot() *MockconservativeStateGetStateRootCall

GetStateRoot indicates an expected call of GetStateRoot.

func (*MockconservativeStateMockRecorder) GetTransactionsByAddress 

func (mr *MockconservativeStateMockRecorder) GetTransactionsByAddress(arg0, arg1, arg2 any) *MockconservativeStateGetTransactionsByAddressCall

GetTransactionsByAddress indicates an expected call of GetTransactionsByAddress.

func (*MockconservativeStateMockRecorder) HasEvicted 

func (mr *MockconservativeStateMockRecorder) HasEvicted(tid any) *MockconservativeStateHasEvictedCall

HasEvicted indicates an expected call of HasEvicted.

func (*MockconservativeStateMockRecorder) Validation 

func (mr *MockconservativeStateMockRecorder) Validation(raw any) *MockconservativeStateValidationCall

Validation indicates an expected call of Validation.

type MockconservativeStateValidationCall 

type MockconservativeStateValidationCall struct {
	*gomock.Call
}

MockconservativeStateValidationCall wrap *gomock.Call

func (*MockconservativeStateValidationCall) Do 

func (c *MockconservativeStateValidationCall) Do(f func(types.RawTx) system.ValidationRequest) *MockconservativeStateValidationCall

Do rewrite *gomock.Call.Do

func (*MockconservativeStateValidationCall) DoAndReturn 

func (c *MockconservativeStateValidationCall) DoAndReturn(f func(types.RawTx) system.ValidationRequest) *MockconservativeStateValidationCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockconservativeStateValidationCall) Return 

func (c *MockconservativeStateValidationCall) Return(arg0 system.ValidationRequest) *MockconservativeStateValidationCall

Return rewrite *gomock.Call.Return

type MockgenesisTimeAPI 

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

MockgenesisTimeAPI is a mock of genesisTimeAPI interface.

func NewMockgenesisTimeAPI 

func NewMockgenesisTimeAPI(ctrl *gomock.Controller) *MockgenesisTimeAPI

NewMockgenesisTimeAPI creates a new mock instance.

func (*MockgenesisTimeAPI) CurrentLayer 

func (m *MockgenesisTimeAPI) CurrentLayer() types.LayerID

CurrentLayer mocks base method.

func (*MockgenesisTimeAPI) EXPECT 

func (m *MockgenesisTimeAPI) EXPECT() *MockgenesisTimeAPIMockRecorder

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

func (*MockgenesisTimeAPI) GenesisTime 

func (m *MockgenesisTimeAPI) GenesisTime() time.Time

GenesisTime mocks base method.

type MockgenesisTimeAPICurrentLayerCall 

type MockgenesisTimeAPICurrentLayerCall struct {
	*gomock.Call
}

MockgenesisTimeAPICurrentLayerCall wrap *gomock.Call

func (*MockgenesisTimeAPICurrentLayerCall) Do 

func (c *MockgenesisTimeAPICurrentLayerCall) Do(f func() types.LayerID) *MockgenesisTimeAPICurrentLayerCall

Do rewrite *gomock.Call.Do

func (*MockgenesisTimeAPICurrentLayerCall) DoAndReturn 

func (c *MockgenesisTimeAPICurrentLayerCall) DoAndReturn(f func() types.LayerID) *MockgenesisTimeAPICurrentLayerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockgenesisTimeAPICurrentLayerCall) Return 

func (c *MockgenesisTimeAPICurrentLayerCall) Return(arg0 types.LayerID) *MockgenesisTimeAPICurrentLayerCall

Return rewrite *gomock.Call.Return

type MockgenesisTimeAPIGenesisTimeCall 

type MockgenesisTimeAPIGenesisTimeCall struct {
	*gomock.Call
}

MockgenesisTimeAPIGenesisTimeCall wrap *gomock.Call

func (*MockgenesisTimeAPIGenesisTimeCall) Do 

func (c *MockgenesisTimeAPIGenesisTimeCall) Do(f func() time.Time) *MockgenesisTimeAPIGenesisTimeCall

Do rewrite *gomock.Call.Do

func (*MockgenesisTimeAPIGenesisTimeCall) DoAndReturn 

func (c *MockgenesisTimeAPIGenesisTimeCall) DoAndReturn(f func() time.Time) *MockgenesisTimeAPIGenesisTimeCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockgenesisTimeAPIGenesisTimeCall) Return 

func (c *MockgenesisTimeAPIGenesisTimeCall) Return(arg0 time.Time) *MockgenesisTimeAPIGenesisTimeCall

Return rewrite *gomock.Call.Return

type MockgenesisTimeAPIMockRecorder 

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

MockgenesisTimeAPIMockRecorder is the mock recorder for MockgenesisTimeAPI.

func (*MockgenesisTimeAPIMockRecorder) CurrentLayer 

func (mr *MockgenesisTimeAPIMockRecorder) CurrentLayer() *MockgenesisTimeAPICurrentLayerCall

CurrentLayer indicates an expected call of CurrentLayer.

func (*MockgenesisTimeAPIMockRecorder) GenesisTime 

func (mr *MockgenesisTimeAPIMockRecorder) GenesisTime() *MockgenesisTimeAPIGenesisTimeCall

GenesisTime indicates an expected call of GenesisTime.

type MockgrpcPostService 

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

MockgrpcPostService is a mock of grpcPostService interface.

func NewMockgrpcPostService 

func NewMockgrpcPostService(ctrl *gomock.Controller) *MockgrpcPostService

NewMockgrpcPostService creates a new mock instance.

func (*MockgrpcPostService) AllowConnections 

func (m *MockgrpcPostService) AllowConnections(allow bool)

AllowConnections mocks base method.

func (*MockgrpcPostService) EXPECT 

func (m *MockgrpcPostService) EXPECT() *MockgrpcPostServiceMockRecorder

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

type MockgrpcPostServiceAllowConnectionsCall 

type MockgrpcPostServiceAllowConnectionsCall struct {
	*gomock.Call
}

MockgrpcPostServiceAllowConnectionsCall wrap *gomock.Call

func (*MockgrpcPostServiceAllowConnectionsCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MockgrpcPostServiceAllowConnectionsCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockgrpcPostServiceAllowConnectionsCall) Return 

func (c *MockgrpcPostServiceAllowConnectionsCall) Return() *MockgrpcPostServiceAllowConnectionsCall

Return rewrite *gomock.Call.Return

type MockgrpcPostServiceMockRecorder 

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

MockgrpcPostServiceMockRecorder is the mock recorder for MockgrpcPostService.

func (*MockgrpcPostServiceMockRecorder) AllowConnections 

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

AllowConnections indicates an expected call of AllowConnections.

type MockmeshAPI 

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

MockmeshAPI is a mock of meshAPI interface.

func NewMockmeshAPI 

func NewMockmeshAPI(ctrl *gomock.Controller) *MockmeshAPI

NewMockmeshAPI creates a new mock instance.

func (*MockmeshAPI) EXPECT 

func (m *MockmeshAPI) EXPECT() *MockmeshAPIMockRecorder

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

func (*MockmeshAPI) GetLayer 

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

GetLayer mocks base method.

func (*MockmeshAPI) GetLayerVerified 

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

GetLayerVerified mocks base method.

func (*MockmeshAPI) GetRewardsByCoinbase 

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

GetRewardsByCoinbase mocks base method.

func (*MockmeshAPI) LatestLayer 

func (m *MockmeshAPI) LatestLayer() types.LayerID

LatestLayer mocks base method.

func (*MockmeshAPI) LatestLayerInState 

func (m *MockmeshAPI) LatestLayerInState() types.LayerID

LatestLayerInState mocks base method.

func (*MockmeshAPI) MeshHash 

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

MeshHash mocks base method.

func (*MockmeshAPI) ProcessedLayer 

func (m *MockmeshAPI) ProcessedLayer() types.LayerID

ProcessedLayer mocks base method.

type MockmeshAPIGetLayerCall 

type MockmeshAPIGetLayerCall struct {
	*gomock.Call
}

MockmeshAPIGetLayerCall wrap *gomock.Call

func (*MockmeshAPIGetLayerCall) Do 

func (c *MockmeshAPIGetLayerCall) Do(f func(types.LayerID) (*types.Layer, error)) *MockmeshAPIGetLayerCall

Do rewrite *gomock.Call.Do

func (*MockmeshAPIGetLayerCall) DoAndReturn 

func (c *MockmeshAPIGetLayerCall) DoAndReturn(f func(types.LayerID) (*types.Layer, error)) *MockmeshAPIGetLayerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmeshAPIGetLayerCall) Return 

func (c *MockmeshAPIGetLayerCall) Return(arg0 *types.Layer, arg1 error) *MockmeshAPIGetLayerCall

Return rewrite *gomock.Call.Return

type MockmeshAPIGetLayerVerifiedCall 

type MockmeshAPIGetLayerVerifiedCall struct {
	*gomock.Call
}

MockmeshAPIGetLayerVerifiedCall wrap *gomock.Call

func (*MockmeshAPIGetLayerVerifiedCall) Do 

func (c *MockmeshAPIGetLayerVerifiedCall) Do(f func(types.LayerID) (*types.Block, error)) *MockmeshAPIGetLayerVerifiedCall

Do rewrite *gomock.Call.Do

func (*MockmeshAPIGetLayerVerifiedCall) DoAndReturn 

func (c *MockmeshAPIGetLayerVerifiedCall) DoAndReturn(f func(types.LayerID) (*types.Block, error)) *MockmeshAPIGetLayerVerifiedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmeshAPIGetLayerVerifiedCall) Return 

func (c *MockmeshAPIGetLayerVerifiedCall) Return(arg0 *types.Block, arg1 error) *MockmeshAPIGetLayerVerifiedCall

Return rewrite *gomock.Call.Return

type MockmeshAPIGetRewardsByCoinbaseCall 

type MockmeshAPIGetRewardsByCoinbaseCall struct {
	*gomock.Call
}

MockmeshAPIGetRewardsByCoinbaseCall wrap *gomock.Call

func (*MockmeshAPIGetRewardsByCoinbaseCall) Do 

func (c *MockmeshAPIGetRewardsByCoinbaseCall) Do(f func(types.Address) ([]*types.Reward, error)) *MockmeshAPIGetRewardsByCoinbaseCall

Do rewrite *gomock.Call.Do

func (*MockmeshAPIGetRewardsByCoinbaseCall) DoAndReturn 

func (c *MockmeshAPIGetRewardsByCoinbaseCall) DoAndReturn(f func(types.Address) ([]*types.Reward, error)) *MockmeshAPIGetRewardsByCoinbaseCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmeshAPIGetRewardsByCoinbaseCall) Return 

func (c *MockmeshAPIGetRewardsByCoinbaseCall) Return(arg0 []*types.Reward, arg1 error) *MockmeshAPIGetRewardsByCoinbaseCall

Return rewrite *gomock.Call.Return

type MockmeshAPILatestLayerCall 

type MockmeshAPILatestLayerCall struct {
	*gomock.Call
}

MockmeshAPILatestLayerCall wrap *gomock.Call

func (*MockmeshAPILatestLayerCall) Do 

func (c *MockmeshAPILatestLayerCall) Do(f func() types.LayerID) *MockmeshAPILatestLayerCall

Do rewrite *gomock.Call.Do

func (*MockmeshAPILatestLayerCall) DoAndReturn 

func (c *MockmeshAPILatestLayerCall) DoAndReturn(f func() types.LayerID) *MockmeshAPILatestLayerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmeshAPILatestLayerCall) Return 

func (c *MockmeshAPILatestLayerCall) Return(arg0 types.LayerID) *MockmeshAPILatestLayerCall

Return rewrite *gomock.Call.Return

type MockmeshAPILatestLayerInStateCall 

type MockmeshAPILatestLayerInStateCall struct {
	*gomock.Call
}

MockmeshAPILatestLayerInStateCall wrap *gomock.Call

func (*MockmeshAPILatestLayerInStateCall) Do 

func (c *MockmeshAPILatestLayerInStateCall) Do(f func() types.LayerID) *MockmeshAPILatestLayerInStateCall

Do rewrite *gomock.Call.Do

func (*MockmeshAPILatestLayerInStateCall) DoAndReturn 

func (c *MockmeshAPILatestLayerInStateCall) DoAndReturn(f func() types.LayerID) *MockmeshAPILatestLayerInStateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmeshAPILatestLayerInStateCall) Return 

func (c *MockmeshAPILatestLayerInStateCall) Return(arg0 types.LayerID) *MockmeshAPILatestLayerInStateCall

Return rewrite *gomock.Call.Return

type MockmeshAPIMeshHashCall 

type MockmeshAPIMeshHashCall struct {
	*gomock.Call
}

MockmeshAPIMeshHashCall wrap *gomock.Call

func (*MockmeshAPIMeshHashCall) Do 

func (c *MockmeshAPIMeshHashCall) Do(f func(types.LayerID) (types.Hash32, error)) *MockmeshAPIMeshHashCall

Do rewrite *gomock.Call.Do

func (*MockmeshAPIMeshHashCall) DoAndReturn 

func (c *MockmeshAPIMeshHashCall) DoAndReturn(f func(types.LayerID) (types.Hash32, error)) *MockmeshAPIMeshHashCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmeshAPIMeshHashCall) Return 

func (c *MockmeshAPIMeshHashCall) Return(arg0 types.Hash32, arg1 error) *MockmeshAPIMeshHashCall

Return rewrite *gomock.Call.Return

type MockmeshAPIMockRecorder 

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

MockmeshAPIMockRecorder is the mock recorder for MockmeshAPI.

func (*MockmeshAPIMockRecorder) GetLayer 

func (mr *MockmeshAPIMockRecorder) GetLayer(arg0 any) *MockmeshAPIGetLayerCall

GetLayer indicates an expected call of GetLayer.

func (*MockmeshAPIMockRecorder) GetLayerVerified 

func (mr *MockmeshAPIMockRecorder) GetLayerVerified(arg0 any) *MockmeshAPIGetLayerVerifiedCall

GetLayerVerified indicates an expected call of GetLayerVerified.

func (*MockmeshAPIMockRecorder) GetRewardsByCoinbase 

func (mr *MockmeshAPIMockRecorder) GetRewardsByCoinbase(arg0 any) *MockmeshAPIGetRewardsByCoinbaseCall

GetRewardsByCoinbase indicates an expected call of GetRewardsByCoinbase.

func (*MockmeshAPIMockRecorder) LatestLayer 

func (mr *MockmeshAPIMockRecorder) LatestLayer() *MockmeshAPILatestLayerCall

LatestLayer indicates an expected call of LatestLayer.

func (*MockmeshAPIMockRecorder) LatestLayerInState 

func (mr *MockmeshAPIMockRecorder) LatestLayerInState() *MockmeshAPILatestLayerInStateCall

LatestLayerInState indicates an expected call of LatestLayerInState.

func (*MockmeshAPIMockRecorder) MeshHash 

func (mr *MockmeshAPIMockRecorder) MeshHash(arg0 any) *MockmeshAPIMeshHashCall

MeshHash indicates an expected call of MeshHash.

func (*MockmeshAPIMockRecorder) ProcessedLayer 

func (mr *MockmeshAPIMockRecorder) ProcessedLayer() *MockmeshAPIProcessedLayerCall

ProcessedLayer indicates an expected call of ProcessedLayer.

type MockmeshAPIProcessedLayerCall 

type MockmeshAPIProcessedLayerCall struct {
	*gomock.Call
}

MockmeshAPIProcessedLayerCall wrap *gomock.Call

func (*MockmeshAPIProcessedLayerCall) Do 

func (c *MockmeshAPIProcessedLayerCall) Do(f func() types.LayerID) *MockmeshAPIProcessedLayerCall

Do rewrite *gomock.Call.Do

func (*MockmeshAPIProcessedLayerCall) DoAndReturn 

func (c *MockmeshAPIProcessedLayerCall) DoAndReturn(f func() types.LayerID) *MockmeshAPIProcessedLayerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmeshAPIProcessedLayerCall) Return 

func (c *MockmeshAPIProcessedLayerCall) Return(arg0 types.LayerID) *MockmeshAPIProcessedLayerCall

Return rewrite *gomock.Call.Return

type MocknetworkInfo 

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

MocknetworkInfo is a mock of networkInfo interface.

func NewMocknetworkInfo 

func NewMocknetworkInfo(ctrl *gomock.Controller) *MocknetworkInfo

NewMocknetworkInfo creates a new mock instance.

func (*MocknetworkInfo) DHTServerEnabled 

func (m *MocknetworkInfo) DHTServerEnabled() bool

DHTServerEnabled mocks base method.

func (*MocknetworkInfo) EXPECT 

func (m *MocknetworkInfo) EXPECT() *MocknetworkInfoMockRecorder

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

func (*MocknetworkInfo) ID 

func (m *MocknetworkInfo) ID() p2p.Peer

ID mocks base method.

func (*MocknetworkInfo) KnownAddresses 

func (m *MocknetworkInfo) KnownAddresses() []multiaddr.Multiaddr

KnownAddresses mocks base method.

func (*MocknetworkInfo) ListenAddresses 

func (m *MocknetworkInfo) ListenAddresses() []multiaddr.Multiaddr

ListenAddresses mocks base method.

func (*MocknetworkInfo) NATDeviceType 

func (m *MocknetworkInfo) NATDeviceType() (network.NATDeviceType, network.NATDeviceType)

NATDeviceType mocks base method.

func (*MocknetworkInfo) PeerInfo 

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

PeerInfo mocks base method.

func (*MocknetworkInfo) Reachability 

func (m *MocknetworkInfo) Reachability() network.Reachability

Reachability mocks base method.

type MocknetworkInfoDHTServerEnabledCall 

type MocknetworkInfoDHTServerEnabledCall struct {
	*gomock.Call
}

MocknetworkInfoDHTServerEnabledCall wrap *gomock.Call

func (*MocknetworkInfoDHTServerEnabledCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoDHTServerEnabledCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoDHTServerEnabledCall) Return 

func (c *MocknetworkInfoDHTServerEnabledCall) Return(arg0 bool) *MocknetworkInfoDHTServerEnabledCall

Return rewrite *gomock.Call.Return

type MocknetworkInfoIDCall 

type MocknetworkInfoIDCall struct {
	*gomock.Call
}

MocknetworkInfoIDCall wrap *gomock.Call

func (*MocknetworkInfoIDCall) Do 

func (c *MocknetworkInfoIDCall) Do(f func() p2p.Peer) *MocknetworkInfoIDCall

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoIDCall) DoAndReturn 

func (c *MocknetworkInfoIDCall) DoAndReturn(f func() p2p.Peer) *MocknetworkInfoIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoIDCall) Return 

func (c *MocknetworkInfoIDCall) Return(arg0 p2p.Peer) *MocknetworkInfoIDCall

Return rewrite *gomock.Call.Return

type MocknetworkInfoKnownAddressesCall 

type MocknetworkInfoKnownAddressesCall struct {
	*gomock.Call
}

MocknetworkInfoKnownAddressesCall wrap *gomock.Call

func (*MocknetworkInfoKnownAddressesCall) Do 

func (c *MocknetworkInfoKnownAddressesCall) Do(f func() []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoKnownAddressesCall) DoAndReturn 

func (c *MocknetworkInfoKnownAddressesCall) DoAndReturn(f func() []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoKnownAddressesCall) Return 

func (c *MocknetworkInfoKnownAddressesCall) Return(arg0 []multiaddr.Multiaddr) *MocknetworkInfoKnownAddressesCall

Return rewrite *gomock.Call.Return

type MocknetworkInfoListenAddressesCall 

type MocknetworkInfoListenAddressesCall struct {
	*gomock.Call
}

MocknetworkInfoListenAddressesCall wrap *gomock.Call

func (*MocknetworkInfoListenAddressesCall) Do 

func (c *MocknetworkInfoListenAddressesCall) Do(f func() []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoListenAddressesCall) DoAndReturn 

func (c *MocknetworkInfoListenAddressesCall) DoAndReturn(f func() []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoListenAddressesCall) Return 

func (c *MocknetworkInfoListenAddressesCall) Return(arg0 []multiaddr.Multiaddr) *MocknetworkInfoListenAddressesCall

Return rewrite *gomock.Call.Return

type MocknetworkInfoMockRecorder 

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

MocknetworkInfoMockRecorder is the mock recorder for MocknetworkInfo.

func (*MocknetworkInfoMockRecorder) DHTServerEnabled 

func (mr *MocknetworkInfoMockRecorder) DHTServerEnabled() *MocknetworkInfoDHTServerEnabledCall

DHTServerEnabled indicates an expected call of DHTServerEnabled.

func (*MocknetworkInfoMockRecorder) ID 

func (mr *MocknetworkInfoMockRecorder) ID() *MocknetworkInfoIDCall

ID indicates an expected call of ID.

func (*MocknetworkInfoMockRecorder) KnownAddresses 

func (mr *MocknetworkInfoMockRecorder) KnownAddresses() *MocknetworkInfoKnownAddressesCall

KnownAddresses indicates an expected call of KnownAddresses.

func (*MocknetworkInfoMockRecorder) ListenAddresses 

func (mr *MocknetworkInfoMockRecorder) ListenAddresses() *MocknetworkInfoListenAddressesCall

ListenAddresses indicates an expected call of ListenAddresses.

func (*MocknetworkInfoMockRecorder) NATDeviceType 

func (mr *MocknetworkInfoMockRecorder) NATDeviceType() *MocknetworkInfoNATDeviceTypeCall

NATDeviceType indicates an expected call of NATDeviceType.

func (*MocknetworkInfoMockRecorder) PeerInfo 

func (mr *MocknetworkInfoMockRecorder) PeerInfo() *MocknetworkInfoPeerInfoCall

PeerInfo indicates an expected call of PeerInfo.

func (*MocknetworkInfoMockRecorder) Reachability 

func (mr *MocknetworkInfoMockRecorder) Reachability() *MocknetworkInfoReachabilityCall

Reachability indicates an expected call of Reachability.

type MocknetworkInfoNATDeviceTypeCall 

type MocknetworkInfoNATDeviceTypeCall struct {
	*gomock.Call
}

MocknetworkInfoNATDeviceTypeCall wrap *gomock.Call

func (*MocknetworkInfoNATDeviceTypeCall) Do 

func (c *MocknetworkInfoNATDeviceTypeCall) Do(f func() (network.NATDeviceType, network.NATDeviceType)) *MocknetworkInfoNATDeviceTypeCall

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoNATDeviceTypeCall) DoAndReturn 

func (c *MocknetworkInfoNATDeviceTypeCall) DoAndReturn(f func() (network.NATDeviceType, network.NATDeviceType)) *MocknetworkInfoNATDeviceTypeCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoNATDeviceTypeCall) Return 

func (c *MocknetworkInfoNATDeviceTypeCall) Return(udpNATType, tcpNATType network.NATDeviceType) *MocknetworkInfoNATDeviceTypeCall

Return rewrite *gomock.Call.Return

type MocknetworkInfoPeerInfoCall 

type MocknetworkInfoPeerInfoCall struct {
	*gomock.Call
}

MocknetworkInfoPeerInfoCall wrap *gomock.Call

func (*MocknetworkInfoPeerInfoCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoPeerInfoCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoPeerInfoCall) Return 

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

Return rewrite *gomock.Call.Return

type MocknetworkInfoReachabilityCall 

type MocknetworkInfoReachabilityCall struct {
	*gomock.Call
}

MocknetworkInfoReachabilityCall wrap *gomock.Call

func (*MocknetworkInfoReachabilityCall) Do 

func (c *MocknetworkInfoReachabilityCall) Do(f func() network.Reachability) *MocknetworkInfoReachabilityCall

Do rewrite *gomock.Call.Do

func (*MocknetworkInfoReachabilityCall) DoAndReturn 

func (c *MocknetworkInfoReachabilityCall) DoAndReturn(f func() network.Reachability) *MocknetworkInfoReachabilityCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknetworkInfoReachabilityCall) Return 

func (c *MocknetworkInfoReachabilityCall) Return(arg0 network.Reachability) *MocknetworkInfoReachabilityCall

Return rewrite *gomock.Call.Return

type Mockoracle 

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

Mockoracle is a mock of oracle interface.

func NewMockoracle 

func NewMockoracle(ctrl *gomock.Controller) *Mockoracle

NewMockoracle creates a new mock instance.

func (*Mockoracle) ActiveSet 

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

ActiveSet mocks base method.

func (*Mockoracle) EXPECT 

func (m *Mockoracle) EXPECT() *MockoracleMockRecorder

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

type MockoracleActiveSetCall 

type MockoracleActiveSetCall struct {
	*gomock.Call
}

MockoracleActiveSetCall wrap *gomock.Call

func (*MockoracleActiveSetCall) Do 

func (c *MockoracleActiveSetCall) Do(f func(context.Context, types.EpochID) ([]types.ATXID, error)) *MockoracleActiveSetCall

Do rewrite *gomock.Call.Do

func (*MockoracleActiveSetCall) DoAndReturn 

func (c *MockoracleActiveSetCall) DoAndReturn(f func(context.Context, types.EpochID) ([]types.ATXID, error)) *MockoracleActiveSetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockoracleActiveSetCall) Return 

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

Return rewrite *gomock.Call.Return

type MockoracleMockRecorder 

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

MockoracleMockRecorder is the mock recorder for Mockoracle.

func (*MockoracleMockRecorder) ActiveSet 

func (mr *MockoracleMockRecorder) ActiveSet(arg0, arg1 any) *MockoracleActiveSetCall

ActiveSet indicates an expected call of ActiveSet.

type MockpeerCounter 

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

MockpeerCounter is a mock of peerCounter interface.

func NewMockpeerCounter 

func NewMockpeerCounter(ctrl *gomock.Controller) *MockpeerCounter

NewMockpeerCounter creates a new mock instance.

func (*MockpeerCounter) EXPECT 

func (m *MockpeerCounter) EXPECT() *MockpeerCounterMockRecorder

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

func (*MockpeerCounter) PeerCount 

func (m *MockpeerCounter) PeerCount() uint64

PeerCount mocks base method.

type MockpeerCounterMockRecorder 

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

MockpeerCounterMockRecorder is the mock recorder for MockpeerCounter.

func (*MockpeerCounterMockRecorder) PeerCount 

func (mr *MockpeerCounterMockRecorder) PeerCount() *MockpeerCounterPeerCountCall

PeerCount indicates an expected call of PeerCount.

type MockpeerCounterPeerCountCall 

type MockpeerCounterPeerCountCall struct {
	*gomock.Call
}

MockpeerCounterPeerCountCall wrap *gomock.Call

func (*MockpeerCounterPeerCountCall) Do 

func (c *MockpeerCounterPeerCountCall) Do(f func() uint64) *MockpeerCounterPeerCountCall

Do rewrite *gomock.Call.Do

func (*MockpeerCounterPeerCountCall) DoAndReturn 

func (c *MockpeerCounterPeerCountCall) DoAndReturn(f func() uint64) *MockpeerCounterPeerCountCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpeerCounterPeerCountCall) Return 

func (c *MockpeerCounterPeerCountCall) Return(arg0 uint64) *MockpeerCounterPeerCountCall

Return rewrite *gomock.Call.Return

type Mockpeers 

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

Mockpeers is a mock of peers interface.

func NewMockpeers 

func NewMockpeers(ctrl *gomock.Controller) *Mockpeers

NewMockpeers creates a new mock instance.

func (*Mockpeers) ConnectedPeerInfo 

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

ConnectedPeerInfo mocks base method.

func (*Mockpeers) EXPECT 

func (m *Mockpeers) EXPECT() *MockpeersMockRecorder

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

func (*Mockpeers) GetPeers 

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

GetPeers mocks base method.

type MockpeersConnectedPeerInfoCall 

type MockpeersConnectedPeerInfoCall struct {
	*gomock.Call
}

MockpeersConnectedPeerInfoCall wrap *gomock.Call

func (*MockpeersConnectedPeerInfoCall) Do 

func (c *MockpeersConnectedPeerInfoCall) Do(f func(p2p.Peer) *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall

Do rewrite *gomock.Call.Do

func (*MockpeersConnectedPeerInfoCall) DoAndReturn 

func (c *MockpeersConnectedPeerInfoCall) DoAndReturn(f func(p2p.Peer) *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpeersConnectedPeerInfoCall) Return 

func (c *MockpeersConnectedPeerInfoCall) Return(arg0 *p2p.PeerInfo) *MockpeersConnectedPeerInfoCall

Return rewrite *gomock.Call.Return

type MockpeersGetPeersCall 

type MockpeersGetPeersCall struct {
	*gomock.Call
}

MockpeersGetPeersCall wrap *gomock.Call

func (*MockpeersGetPeersCall) Do 

func (c *MockpeersGetPeersCall) Do(f func() []p2p.Peer) *MockpeersGetPeersCall

Do rewrite *gomock.Call.Do

func (*MockpeersGetPeersCall) DoAndReturn 

func (c *MockpeersGetPeersCall) DoAndReturn(f func() []p2p.Peer) *MockpeersGetPeersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpeersGetPeersCall) Return 

func (c *MockpeersGetPeersCall) Return(arg0 []p2p.Peer) *MockpeersGetPeersCall

Return rewrite *gomock.Call.Return

type MockpeersMockRecorder 

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

MockpeersMockRecorder is the mock recorder for Mockpeers.

func (*MockpeersMockRecorder) ConnectedPeerInfo 

func (mr *MockpeersMockRecorder) ConnectedPeerInfo(arg0 any) *MockpeersConnectedPeerInfoCall

ConnectedPeerInfo indicates an expected call of ConnectedPeerInfo.

func (*MockpeersMockRecorder) GetPeers 

func (mr *MockpeersMockRecorder) GetPeers() *MockpeersGetPeersCall

GetPeers indicates an expected call of GetPeers.

type MockpostState 

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

MockpostState is a mock of postState interface.

func NewMockpostState 

func NewMockpostState(ctrl *gomock.Controller) *MockpostState

NewMockpostState creates a new mock instance.

func (*MockpostState) EXPECT 

func (m *MockpostState) EXPECT() *MockpostStateMockRecorder

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

func (*MockpostState) PostStates 

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

PostStates mocks base method.

type MockpostStateMockRecorder 

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

MockpostStateMockRecorder is the mock recorder for MockpostState.

func (*MockpostStateMockRecorder) PostStates 

func (mr *MockpostStateMockRecorder) PostStates() *MockpostStatePostStatesCall

PostStates indicates an expected call of PostStates.

type MockpostStatePostStatesCall 

type MockpostStatePostStatesCall struct {
	*gomock.Call
}

MockpostStatePostStatesCall wrap *gomock.Call

func (*MockpostStatePostStatesCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MockpostStatePostStatesCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostStatePostStatesCall) Return 

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

Return rewrite *gomock.Call.Return

type MockpostSupervisor 

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

MockpostSupervisor is a mock of postSupervisor interface.

func NewMockpostSupervisor 

func NewMockpostSupervisor(ctrl *gomock.Controller) *MockpostSupervisor

NewMockpostSupervisor creates a new mock instance.

func (*MockpostSupervisor) Benchmark 

func (m *MockpostSupervisor) Benchmark(p activation.PostSetupProvider) (int, error)

Benchmark mocks base method.

func (*MockpostSupervisor) Config 

func (m *MockpostSupervisor) Config() activation.PostConfig

Config mocks base method.

func (*MockpostSupervisor) EXPECT 

func (m *MockpostSupervisor) EXPECT() *MockpostSupervisorMockRecorder

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

func (*MockpostSupervisor) Providers 

func (m *MockpostSupervisor) Providers() ([]activation.PostSetupProvider, error)

Providers mocks base method.

func (*MockpostSupervisor) Start 

func (m *MockpostSupervisor) Start(cmdCfg activation.PostSupervisorConfig, opts activation.PostSetupOpts, sig *signing.EdSigner) error

Start mocks base method.

func (*MockpostSupervisor) Status 

func (m *MockpostSupervisor) Status() *activation.PostSetupStatus

Status mocks base method.

func (*MockpostSupervisor) Stop 

func (m *MockpostSupervisor) Stop(deleteFiles bool) error

Stop mocks base method.

type MockpostSupervisorBenchmarkCall 

type MockpostSupervisorBenchmarkCall struct {
	*gomock.Call
}

MockpostSupervisorBenchmarkCall wrap *gomock.Call

func (*MockpostSupervisorBenchmarkCall) Do 

func (c *MockpostSupervisorBenchmarkCall) Do(f func(activation.PostSetupProvider) (int, error)) *MockpostSupervisorBenchmarkCall

Do rewrite *gomock.Call.Do

func (*MockpostSupervisorBenchmarkCall) DoAndReturn 

func (c *MockpostSupervisorBenchmarkCall) DoAndReturn(f func(activation.PostSetupProvider) (int, error)) *MockpostSupervisorBenchmarkCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostSupervisorBenchmarkCall) Return 

func (c *MockpostSupervisorBenchmarkCall) Return(arg0 int, arg1 error) *MockpostSupervisorBenchmarkCall

Return rewrite *gomock.Call.Return

type MockpostSupervisorConfigCall 

type MockpostSupervisorConfigCall struct {
	*gomock.Call
}

MockpostSupervisorConfigCall wrap *gomock.Call

func (*MockpostSupervisorConfigCall) Do 

func (c *MockpostSupervisorConfigCall) Do(f func() activation.PostConfig) *MockpostSupervisorConfigCall

Do rewrite *gomock.Call.Do

func (*MockpostSupervisorConfigCall) DoAndReturn 

func (c *MockpostSupervisorConfigCall) DoAndReturn(f func() activation.PostConfig) *MockpostSupervisorConfigCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostSupervisorConfigCall) Return 

func (c *MockpostSupervisorConfigCall) Return(arg0 activation.PostConfig) *MockpostSupervisorConfigCall

Return rewrite *gomock.Call.Return

type MockpostSupervisorMockRecorder 

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

MockpostSupervisorMockRecorder is the mock recorder for MockpostSupervisor.

func (*MockpostSupervisorMockRecorder) Benchmark 

func (mr *MockpostSupervisorMockRecorder) Benchmark(p any) *MockpostSupervisorBenchmarkCall

Benchmark indicates an expected call of Benchmark.

func (*MockpostSupervisorMockRecorder) Config 

func (mr *MockpostSupervisorMockRecorder) Config() *MockpostSupervisorConfigCall

Config indicates an expected call of Config.

func (*MockpostSupervisorMockRecorder) Providers 

func (mr *MockpostSupervisorMockRecorder) Providers() *MockpostSupervisorProvidersCall

Providers indicates an expected call of Providers.

func (*MockpostSupervisorMockRecorder) Start 

func (mr *MockpostSupervisorMockRecorder) Start(cmdCfg, opts, sig any) *MockpostSupervisorStartCall

Start indicates an expected call of Start.

func (*MockpostSupervisorMockRecorder) Status 

func (mr *MockpostSupervisorMockRecorder) Status() *MockpostSupervisorStatusCall

Status indicates an expected call of Status.

func (*MockpostSupervisorMockRecorder) Stop 

func (mr *MockpostSupervisorMockRecorder) Stop(deleteFiles any) *MockpostSupervisorStopCall

Stop indicates an expected call of Stop.

type MockpostSupervisorProvidersCall 

type MockpostSupervisorProvidersCall struct {
	*gomock.Call
}

MockpostSupervisorProvidersCall wrap *gomock.Call

func (*MockpostSupervisorProvidersCall) Do 

func (c *MockpostSupervisorProvidersCall) Do(f func() ([]activation.PostSetupProvider, error)) *MockpostSupervisorProvidersCall

Do rewrite *gomock.Call.Do

func (*MockpostSupervisorProvidersCall) DoAndReturn 

func (c *MockpostSupervisorProvidersCall) DoAndReturn(f func() ([]activation.PostSetupProvider, error)) *MockpostSupervisorProvidersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostSupervisorProvidersCall) Return 

func (c *MockpostSupervisorProvidersCall) Return(arg0 []activation.PostSetupProvider, arg1 error) *MockpostSupervisorProvidersCall

Return rewrite *gomock.Call.Return

type MockpostSupervisorStartCall 

type MockpostSupervisorStartCall struct {
	*gomock.Call
}

MockpostSupervisorStartCall wrap *gomock.Call

func (*MockpostSupervisorStartCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MockpostSupervisorStartCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostSupervisorStartCall) Return 

func (c *MockpostSupervisorStartCall) Return(arg0 error) *MockpostSupervisorStartCall

Return rewrite *gomock.Call.Return

type MockpostSupervisorStatusCall 

type MockpostSupervisorStatusCall struct {
	*gomock.Call
}

MockpostSupervisorStatusCall wrap *gomock.Call

func (*MockpostSupervisorStatusCall) Do 

func (c *MockpostSupervisorStatusCall) Do(f func() *activation.PostSetupStatus) *MockpostSupervisorStatusCall

Do rewrite *gomock.Call.Do

func (*MockpostSupervisorStatusCall) DoAndReturn 

func (c *MockpostSupervisorStatusCall) DoAndReturn(f func() *activation.PostSetupStatus) *MockpostSupervisorStatusCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostSupervisorStatusCall) Return 

func (c *MockpostSupervisorStatusCall) Return(arg0 *activation.PostSetupStatus) *MockpostSupervisorStatusCall

Return rewrite *gomock.Call.Return

type MockpostSupervisorStopCall 

type MockpostSupervisorStopCall struct {
	*gomock.Call
}

MockpostSupervisorStopCall wrap *gomock.Call

func (*MockpostSupervisorStopCall) Do 

func (c *MockpostSupervisorStopCall) Do(f func(bool) error) *MockpostSupervisorStopCall

Do rewrite *gomock.Call.Do

func (*MockpostSupervisorStopCall) DoAndReturn 

func (c *MockpostSupervisorStopCall) DoAndReturn(f func(bool) error) *MockpostSupervisorStopCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockpostSupervisorStopCall) Return 

func (c *MockpostSupervisorStopCall) Return(arg0 error) *MockpostSupervisorStopCall

Return rewrite *gomock.Call.Return

type Mocksyncer 

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

Mocksyncer is a mock of syncer interface.

func NewMocksyncer 

func NewMocksyncer(ctrl *gomock.Controller) *Mocksyncer

NewMocksyncer creates a new mock instance.

func (*Mocksyncer) EXPECT 

func (m *Mocksyncer) EXPECT() *MocksyncerMockRecorder

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

func (*Mocksyncer) IsSynced 

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

IsSynced mocks base method.

type MocksyncerIsSyncedCall 

type MocksyncerIsSyncedCall struct {
	*gomock.Call
}

MocksyncerIsSyncedCall wrap *gomock.Call

func (*MocksyncerIsSyncedCall) Do 

func (c *MocksyncerIsSyncedCall) Do(f func(context.Context) bool) *MocksyncerIsSyncedCall

Do rewrite *gomock.Call.Do

func (*MocksyncerIsSyncedCall) DoAndReturn 

func (c *MocksyncerIsSyncedCall) DoAndReturn(f func(context.Context) bool) *MocksyncerIsSyncedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocksyncerIsSyncedCall) Return 

func (c *MocksyncerIsSyncedCall) Return(arg0 bool) *MocksyncerIsSyncedCall

Return rewrite *gomock.Call.Return

type MocksyncerMockRecorder 

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

MocksyncerMockRecorder is the mock recorder for Mocksyncer.

func (*MocksyncerMockRecorder) IsSynced 

func (mr *MocksyncerMockRecorder) IsSynced(arg0 any) *MocksyncerIsSyncedCall

IsSynced indicates an expected call of IsSynced.

type MocktxValidator 

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

MocktxValidator is a mock of txValidator interface.

func NewMocktxValidator 

func NewMocktxValidator(ctrl *gomock.Controller) *MocktxValidator

NewMocktxValidator creates a new mock instance.

func (*MocktxValidator) EXPECT 

func (m *MocktxValidator) EXPECT() *MocktxValidatorMockRecorder

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

func (*MocktxValidator) VerifyAndCacheTx 

func (m *MocktxValidator) VerifyAndCacheTx(arg0 context.Context, arg1 []byte) error

VerifyAndCacheTx mocks base method.

type MocktxValidatorMockRecorder 

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

MocktxValidatorMockRecorder is the mock recorder for MocktxValidator.

func (*MocktxValidatorMockRecorder) VerifyAndCacheTx 

func (mr *MocktxValidatorMockRecorder) VerifyAndCacheTx(arg0, arg1 any) *MocktxValidatorVerifyAndCacheTxCall

VerifyAndCacheTx indicates an expected call of VerifyAndCacheTx.

type MocktxValidatorVerifyAndCacheTxCall 

type MocktxValidatorVerifyAndCacheTxCall struct {
	*gomock.Call
}

MocktxValidatorVerifyAndCacheTxCall wrap *gomock.Call

func (*MocktxValidatorVerifyAndCacheTxCall) Do 

func (c *MocktxValidatorVerifyAndCacheTxCall) Do(f func(context.Context, []byte) error) *MocktxValidatorVerifyAndCacheTxCall

Do rewrite *gomock.Call.Do

func (*MocktxValidatorVerifyAndCacheTxCall) DoAndReturn 

func (c *MocktxValidatorVerifyAndCacheTxCall) DoAndReturn(f func(context.Context, []byte) error) *MocktxValidatorVerifyAndCacheTxCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocktxValidatorVerifyAndCacheTxCall) Return 

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 

func (s *NodeService) NodeInfo(context.Context, *emptypb.Empty) (*pb.NodeInfoResponse, error)

func (*NodeService) RegisterHandlerService 

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 

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 

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

PostInfoService provides information about connected PostServices.

func NewPostInfoService 

func NewPostInfoService(states postState) *PostInfoService

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

func (*PostInfoService) PostStates 

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

func (*PostInfoService) RegisterHandlerService 

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

func (*PostInfoService) RegisterService 

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

RegisterService registers this service with a grpc server instance.

func (*PostInfoService) String 

func (s *PostInfoService) String() string

String returns the name of this service.

type PostService 

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 

func NewPostService(log *zap.Logger, opts ...PostServiceOpt) *PostService

NewPostService creates a new instance of the post grpc service.

func (*PostService) AllowConnections 

func (s *PostService) AllowConnections(allow bool)

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

func (*PostService) Client 

func (s *PostService) Client(nodeId types.NodeID) (activation.PostClient, error)

func (*PostService) Register 

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 

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

func (*PostService) RegisterService 

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

RegisterService registers this service with a grpc server instance.

func (*PostService) String 

func (s *PostService) String() string

String returns the name of this service.

type PostServiceOpt 

type PostServiceOpt func(*PostService)

func PostServiceQueryInterval 

func PostServiceQueryInterval(interval time.Duration) PostServiceOpt

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) IsSmeshing 

func (s *SmesherService) IsSmeshing(context.Context, *emptypb.Empty) (*pb.IsSmeshingResponse, error)

IsSmeshing reports whether the node is smeshing.

func (*SmesherService) PostConfig 

func (s *SmesherService) PostConfig(context.Context, *emptypb.Empty) (*pb.PostConfigResponse, error)

PostConfig returns the Post protocol config.

func (*SmesherService) PostSetupProviders 

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 

func (s *SmesherService) PostSetupStatus(ctx context.Context, _ *emptypb.Empty) (*pb.PostSetupStatusResponse, error)

PostSetupStatus returns post data status.

func (*SmesherService) PostSetupStatusStream 

func (s *SmesherService) PostSetupStatusStream(
	_ *emptypb.Empty,
	stream pb.SmesherService_PostSetupStatusStreamServer,
) error

PostSetupStatusStream exposes a stream of status updates during post setup.

func (*SmesherService) RegisterHandlerService 

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) SetPostServiceConfig 

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

SetPostServiceConfig sets the post supervisor config.

func (*SmesherService) SmesherIDs 

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 

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 

func (s *TransactionService) ParseTransaction(
	ctx context.Context,
	in *pb.ParseTransactionRequest,
) (*pb.ParseTransactionResponse, error)

func (*TransactionService) RegisterHandlerService 

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 

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 

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

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.
JackTT - Gopher 🇻🇳