v2beta1

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: 44 Imported by: 0

Documentation

Overview

Package v2alpha1 is a generated GoMock package.

Package v2beta1 is a generated GoMock package.

Package v2beta1 is a generated GoMock package.

Package v2beta1 is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountService 

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

func NewAccountService 

func NewAccountService(db sql.Executor, conState accountConState) *AccountService

func (*AccountService) List 

func (s *AccountService) List(
	_ context.Context,
	request *spacemeshv2beta1.AccountRequest,
) (*spacemeshv2beta1.AccountList, error)

func (*AccountService) RegisterHandlerService 

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

func (*AccountService) RegisterService 

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

func (*AccountService) String 

func (s *AccountService) String() string

String returns the service name.

type ActivationService 

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

func NewActivationService 

func NewActivationService(db sql.Executor, goldenAtx types.ATXID, atxdata *atxsdata.Data) *ActivationService

func (*ActivationService) ActivationsCount 

func (s *ActivationService) ActivationsCount(
	ctx context.Context,
	request *spacemeshv2beta1.ActivationsCountRequest,
) (*spacemeshv2beta1.ActivationsCountResponse, error)

func (*ActivationService) Highest 

func (s *ActivationService) Highest(
	_ context.Context,
	_ *spacemeshv2beta1.HighestRequest,
) (*spacemeshv2beta1.HighestResponse, error)

func (*ActivationService) List 

func (s *ActivationService) List(
	ctx context.Context,
	request *spacemeshv2beta1.ActivationRequest,
) (*spacemeshv2beta1.ActivationList, error)

func (*ActivationService) RegisterHandlerService 

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

func (*ActivationService) RegisterService 

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

func (*ActivationService) String 

func (s *ActivationService) String() string

String returns the service name.

type ActivationStreamService 

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

func NewActivationStreamService 

func NewActivationStreamService(db sql.Executor) *ActivationStreamService

func (*ActivationStreamService) RegisterHandlerService 

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

func (*ActivationStreamService) RegisterService 

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

func (*ActivationStreamService) Stream 

func (s *ActivationStreamService) Stream(
	request *spacemeshv2beta1.ActivationStreamRequest,
	stream spacemeshv2beta1.ActivationStreamService_StreamServer,
) error

func (*ActivationStreamService) String 

func (s *ActivationStreamService) String() string

type LayerService 

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

func NewLayerService 

func NewLayerService(db sql.Executor) *LayerService

func (*LayerService) List 

func (s *LayerService) List(
	ctx context.Context,
	request *spacemeshv2beta1.LayerRequest,
) (*spacemeshv2beta1.LayerList, error)

func (*LayerService) RegisterHandlerService 

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

func (*LayerService) RegisterService 

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

func (*LayerService) String 

func (s *LayerService) String() string

String returns the service name.

type LayerStreamService 

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

func NewLayerStreamService 

func NewLayerStreamService(db sql.Executor) *LayerStreamService

func (*LayerStreamService) RegisterHandlerService 

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

func (*LayerStreamService) RegisterService 

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

func (*LayerStreamService) Stream 

func (s *LayerStreamService) Stream(
	request *spacemeshv2beta1.LayerStreamRequest,
	stream spacemeshv2beta1.LayerStreamService_StreamServer,
) error

func (*LayerStreamService) String 

func (s *LayerStreamService) String() string

type MalfeasanceService 

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

func NewMalfeasanceService 

func NewMalfeasanceService(db sql.StateDatabase, malHandler, legacyHandler malfeasanceInfo) *MalfeasanceService

func (*MalfeasanceService) List 

func (s *MalfeasanceService) List(
	ctx context.Context,
	request *spacemeshv2beta1.MalfeasanceRequest,
) (*spacemeshv2beta1.MalfeasanceList, error)

func (*MalfeasanceService) RegisterHandlerService 

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

func (*MalfeasanceService) RegisterService 

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

func (*MalfeasanceService) String 

func (s *MalfeasanceService) String() string

type MalfeasanceStreamService 

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

func NewMalfeasanceStreamService 

func NewMalfeasanceStreamService(
	db sql.Executor,
	malfeasanceHandler,
	legacyHandler malfeasanceInfo,
	opts ...malStreamOpts,
) *MalfeasanceStreamService

func (*MalfeasanceStreamService) RegisterHandlerService 

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

func (*MalfeasanceStreamService) RegisterService 

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

func (*MalfeasanceStreamService) Stream 

func (s *MalfeasanceStreamService) Stream(
	request *spacemeshv2beta1.MalfeasanceStreamRequest,
	stream spacemeshv2beta1.MalfeasanceStreamService_StreamServer,
) error

func (*MalfeasanceStreamService) String 

func (s *MalfeasanceStreamService) String() string

type MockaccountConState 

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

MockaccountConState is a mock of accountConState interface.

func NewMockaccountConState 

func NewMockaccountConState(ctrl *gomock.Controller) *MockaccountConState

NewMockaccountConState creates a new mock instance.

func (*MockaccountConState) EXPECT 

func (m *MockaccountConState) EXPECT() *MockaccountConStateMockRecorder

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

func (*MockaccountConState) GetProjection 

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

GetProjection mocks base method.

type MockaccountConStateGetProjectionCall 

type MockaccountConStateGetProjectionCall struct {
	*gomock.Call
}

MockaccountConStateGetProjectionCall wrap *gomock.Call

func (*MockaccountConStateGetProjectionCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MockaccountConStateGetProjectionCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockaccountConStateGetProjectionCall) Return 

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

Return rewrite *gomock.Call.Return

type MockaccountConStateMockRecorder 

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

MockaccountConStateMockRecorder is the mock recorder for MockaccountConState.

func (*MockaccountConStateMockRecorder) GetProjection 

func (mr *MockaccountConStateMockRecorder) GetProjection(arg0 any) *MockaccountConStateGetProjectionCall

GetProjection indicates an expected call of GetProjection.

type MockeventProvider added in v1.7.16 

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

MockeventProvider is a mock of eventProvider interface.

func NewMockeventProvider added in v1.7.16 

func NewMockeventProvider(ctrl *gomock.Controller) *MockeventProvider

NewMockeventProvider creates a new mock instance.

func (*MockeventProvider) EXPECT added in v1.7.16 

func (m *MockeventProvider) EXPECT() *MockeventProviderMockRecorder

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

func (*MockeventProvider) SubscribeMatched added in v1.7.16 

func (m *MockeventProvider) SubscribeMatched(request *spacemeshv2beta1.MalfeasanceStreamRequest) (subscription, error)

SubscribeMatched mocks base method.

type MockeventProviderMockRecorder added in v1.7.16 

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

MockeventProviderMockRecorder is the mock recorder for MockeventProvider.

func (*MockeventProviderMockRecorder) SubscribeMatched added in v1.7.16 

func (mr *MockeventProviderMockRecorder) SubscribeMatched(request any) *MockeventProviderSubscribeMatchedCall

SubscribeMatched indicates an expected call of SubscribeMatched.

type MockeventProviderSubscribeMatchedCall added in v1.7.16 

type MockeventProviderSubscribeMatchedCall struct {
	*gomock.Call
}

MockeventProviderSubscribeMatchedCall wrap *gomock.Call

func (*MockeventProviderSubscribeMatchedCall) Do added in v1.7.16 

func (c *MockeventProviderSubscribeMatchedCall) Do(f func(*spacemeshv2beta1.MalfeasanceStreamRequest) (subscription, error)) *MockeventProviderSubscribeMatchedCall

Do rewrite *gomock.Call.Do

func (*MockeventProviderSubscribeMatchedCall) DoAndReturn added in v1.7.16 

func (c *MockeventProviderSubscribeMatchedCall) DoAndReturn(f func(*spacemeshv2beta1.MalfeasanceStreamRequest) (subscription, error)) *MockeventProviderSubscribeMatchedCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockeventProviderSubscribeMatchedCall) Return added in v1.7.16 

func (c *MockeventProviderSubscribeMatchedCall) Return(arg0 subscription, arg1 error) *MockeventProviderSubscribeMatchedCall

Return rewrite *gomock.Call.Return

type MockmalfeasanceInfo 

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

MockmalfeasanceInfo is a mock of malfeasanceInfo interface.

func NewMockmalfeasanceInfo 

func NewMockmalfeasanceInfo(ctrl *gomock.Controller) *MockmalfeasanceInfo

NewMockmalfeasanceInfo creates a new mock instance.

func (*MockmalfeasanceInfo) EXPECT 

func (m *MockmalfeasanceInfo) EXPECT() *MockmalfeasanceInfoMockRecorder

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

func (*MockmalfeasanceInfo) Info 

func (m *MockmalfeasanceInfo) Info(ctx context.Context, nodeID types.NodeID) (map[string]string, error)

Info mocks base method.

type MockmalfeasanceInfoInfoCall 

type MockmalfeasanceInfoInfoCall struct {
	*gomock.Call
}

MockmalfeasanceInfoInfoCall wrap *gomock.Call

func (*MockmalfeasanceInfoInfoCall) Do 

func (c *MockmalfeasanceInfoInfoCall) Do(f func(context.Context, types.NodeID) (map[string]string, error)) *MockmalfeasanceInfoInfoCall

Do rewrite *gomock.Call.Do

func (*MockmalfeasanceInfoInfoCall) DoAndReturn 

func (c *MockmalfeasanceInfoInfoCall) DoAndReturn(f func(context.Context, types.NodeID) (map[string]string, error)) *MockmalfeasanceInfoInfoCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockmalfeasanceInfoInfoCall) Return 

func (c *MockmalfeasanceInfoInfoCall) Return(arg0 map[string]string, arg1 error) *MockmalfeasanceInfoInfoCall

Return rewrite *gomock.Call.Return

type MockmalfeasanceInfoMockRecorder 

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

MockmalfeasanceInfoMockRecorder is the mock recorder for MockmalfeasanceInfo.

func (*MockmalfeasanceInfoMockRecorder) Info 

func (mr *MockmalfeasanceInfoMockRecorder) Info(ctx, nodeID any) *MockmalfeasanceInfoInfoCall

Info indicates an expected call of Info.

type MocknodeMeshAPI 

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

MocknodeMeshAPI is a mock of nodeMeshAPI interface.

func NewMocknodeMeshAPI 

func NewMocknodeMeshAPI(ctrl *gomock.Controller) *MocknodeMeshAPI

NewMocknodeMeshAPI creates a new mock instance.

func (*MocknodeMeshAPI) EXPECT 

func (m *MocknodeMeshAPI) EXPECT() *MocknodeMeshAPIMockRecorder

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

func (*MocknodeMeshAPI) LatestLayer 

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

LatestLayer mocks base method.

func (*MocknodeMeshAPI) LatestLayerInState 

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

LatestLayerInState mocks base method.

func (*MocknodeMeshAPI) ProcessedLayer 

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

ProcessedLayer mocks base method.

type MocknodeMeshAPILatestLayerCall 

type MocknodeMeshAPILatestLayerCall struct {
	*gomock.Call
}

MocknodeMeshAPILatestLayerCall wrap *gomock.Call

func (*MocknodeMeshAPILatestLayerCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocknodeMeshAPILatestLayerCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknodeMeshAPILatestLayerCall) Return 

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

Return rewrite *gomock.Call.Return

type MocknodeMeshAPILatestLayerInStateCall 

type MocknodeMeshAPILatestLayerInStateCall struct {
	*gomock.Call
}

MocknodeMeshAPILatestLayerInStateCall wrap *gomock.Call

func (*MocknodeMeshAPILatestLayerInStateCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocknodeMeshAPILatestLayerInStateCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknodeMeshAPILatestLayerInStateCall) Return 

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

Return rewrite *gomock.Call.Return

type MocknodeMeshAPIMockRecorder 

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

MocknodeMeshAPIMockRecorder is the mock recorder for MocknodeMeshAPI.

func (*MocknodeMeshAPIMockRecorder) LatestLayer 

func (mr *MocknodeMeshAPIMockRecorder) LatestLayer() *MocknodeMeshAPILatestLayerCall

LatestLayer indicates an expected call of LatestLayer.

func (*MocknodeMeshAPIMockRecorder) LatestLayerInState 

func (mr *MocknodeMeshAPIMockRecorder) LatestLayerInState() *MocknodeMeshAPILatestLayerInStateCall

LatestLayerInState indicates an expected call of LatestLayerInState.

func (*MocknodeMeshAPIMockRecorder) ProcessedLayer 

func (mr *MocknodeMeshAPIMockRecorder) ProcessedLayer() *MocknodeMeshAPIProcessedLayerCall

ProcessedLayer indicates an expected call of ProcessedLayer.

type MocknodeMeshAPIProcessedLayerCall 

type MocknodeMeshAPIProcessedLayerCall struct {
	*gomock.Call
}

MocknodeMeshAPIProcessedLayerCall wrap *gomock.Call

func (*MocknodeMeshAPIProcessedLayerCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocknodeMeshAPIProcessedLayerCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknodeMeshAPIProcessedLayerCall) Return 

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

Return rewrite *gomock.Call.Return

type MocknodePeerCounter 

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

MocknodePeerCounter is a mock of nodePeerCounter interface.

func NewMocknodePeerCounter 

func NewMocknodePeerCounter(ctrl *gomock.Controller) *MocknodePeerCounter

NewMocknodePeerCounter creates a new mock instance.

func (*MocknodePeerCounter) EXPECT 

func (m *MocknodePeerCounter) EXPECT() *MocknodePeerCounterMockRecorder

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

func (*MocknodePeerCounter) PeerCount 

func (m *MocknodePeerCounter) PeerCount() uint64

PeerCount mocks base method.

type MocknodePeerCounterMockRecorder 

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

MocknodePeerCounterMockRecorder is the mock recorder for MocknodePeerCounter.

func (*MocknodePeerCounterMockRecorder) PeerCount 

func (mr *MocknodePeerCounterMockRecorder) PeerCount() *MocknodePeerCounterPeerCountCall

PeerCount indicates an expected call of PeerCount.

type MocknodePeerCounterPeerCountCall 

type MocknodePeerCounterPeerCountCall struct {
	*gomock.Call
}

MocknodePeerCounterPeerCountCall wrap *gomock.Call

func (*MocknodePeerCounterPeerCountCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocknodePeerCounterPeerCountCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknodePeerCounterPeerCountCall) Return 

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

Return rewrite *gomock.Call.Return

type MocknodeSyncer 

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

MocknodeSyncer is a mock of nodeSyncer interface.

func NewMocknodeSyncer 

func NewMocknodeSyncer(ctrl *gomock.Controller) *MocknodeSyncer

NewMocknodeSyncer creates a new mock instance.

func (*MocknodeSyncer) EXPECT 

func (m *MocknodeSyncer) EXPECT() *MocknodeSyncerMockRecorder

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

func (*MocknodeSyncer) IsSynced 

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

IsSynced mocks base method.

type MocknodeSyncerIsSyncedCall 

type MocknodeSyncerIsSyncedCall struct {
	*gomock.Call
}

MocknodeSyncerIsSyncedCall wrap *gomock.Call

func (*MocknodeSyncerIsSyncedCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocknodeSyncerIsSyncedCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocknodeSyncerIsSyncedCall) Return 

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

Return rewrite *gomock.Call.Return

type MocknodeSyncerMockRecorder 

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

MocknodeSyncerMockRecorder is the mock recorder for MocknodeSyncer.

func (*MocknodeSyncerMockRecorder) IsSynced 

func (mr *MocknodeSyncerMockRecorder) IsSynced(arg0 any) *MocknodeSyncerIsSyncedCall

IsSynced indicates an expected call of IsSynced.

type Mocksubscription added in v1.7.16 

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

Mocksubscription is a mock of subscription interface.

func NewMocksubscription added in v1.7.16 

func NewMocksubscription(ctrl *gomock.Controller) *Mocksubscription

NewMocksubscription creates a new mock instance.

func (*Mocksubscription) Close added in v1.7.16 

func (m *Mocksubscription) Close()

Close mocks base method.

func (*Mocksubscription) EXPECT added in v1.7.16 

func (m *Mocksubscription) EXPECT() *MocksubscriptionMockRecorder

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

func (*Mocksubscription) Full added in v1.7.16 

func (m *Mocksubscription) Full() <-chan struct{}

Full mocks base method.

func (*Mocksubscription) Out added in v1.7.16 

func (m *Mocksubscription) Out() <-chan events.EventMalfeasance

Out mocks base method.

type MocksubscriptionCloseCall added in v1.7.16 

type MocksubscriptionCloseCall struct {
	*gomock.Call
}

MocksubscriptionCloseCall wrap *gomock.Call

func (*MocksubscriptionCloseCall) Do added in v1.7.16 

func (c *MocksubscriptionCloseCall) Do(f func()) *MocksubscriptionCloseCall

Do rewrite *gomock.Call.Do

func (*MocksubscriptionCloseCall) DoAndReturn added in v1.7.16 

func (c *MocksubscriptionCloseCall) DoAndReturn(f func()) *MocksubscriptionCloseCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocksubscriptionCloseCall) Return added in v1.7.16 

func (c *MocksubscriptionCloseCall) Return() *MocksubscriptionCloseCall

Return rewrite *gomock.Call.Return

type MocksubscriptionFullCall added in v1.7.16 

type MocksubscriptionFullCall struct {
	*gomock.Call
}

MocksubscriptionFullCall wrap *gomock.Call

func (*MocksubscriptionFullCall) Do added in v1.7.16 

func (c *MocksubscriptionFullCall) Do(f func() <-chan struct{}) *MocksubscriptionFullCall

Do rewrite *gomock.Call.Do

func (*MocksubscriptionFullCall) DoAndReturn added in v1.7.16 

func (c *MocksubscriptionFullCall) DoAndReturn(f func() <-chan struct{}) *MocksubscriptionFullCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocksubscriptionFullCall) Return added in v1.7.16 

func (c *MocksubscriptionFullCall) Return(arg0 <-chan struct{}) *MocksubscriptionFullCall

Return rewrite *gomock.Call.Return

type MocksubscriptionMockRecorder added in v1.7.16 

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

MocksubscriptionMockRecorder is the mock recorder for Mocksubscription.

func (*MocksubscriptionMockRecorder) Close added in v1.7.16 

func (mr *MocksubscriptionMockRecorder) Close() *MocksubscriptionCloseCall

Close indicates an expected call of Close.

func (*MocksubscriptionMockRecorder) Full added in v1.7.16 

func (mr *MocksubscriptionMockRecorder) Full() *MocksubscriptionFullCall

Full indicates an expected call of Full.

func (*MocksubscriptionMockRecorder) Out added in v1.7.16 

func (mr *MocksubscriptionMockRecorder) Out() *MocksubscriptionOutCall

Out indicates an expected call of Out.

type MocksubscriptionOutCall added in v1.7.16 

type MocksubscriptionOutCall struct {
	*gomock.Call
}

MocksubscriptionOutCall wrap *gomock.Call

func (*MocksubscriptionOutCall) Do added in v1.7.16 

func (c *MocksubscriptionOutCall) Do(f func() <-chan events.EventMalfeasance) *MocksubscriptionOutCall

Do rewrite *gomock.Call.Do

func (*MocksubscriptionOutCall) DoAndReturn added in v1.7.16 

func (c *MocksubscriptionOutCall) DoAndReturn(f func() <-chan events.EventMalfeasance) *MocksubscriptionOutCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocksubscriptionOutCall) Return added in v1.7.16 

func (c *MocksubscriptionOutCall) Return(arg0 <-chan events.EventMalfeasance) *MocksubscriptionOutCall

Return rewrite *gomock.Call.Return

type Mocksyncer added in v1.8.0 

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

Mocksyncer is a mock of syncer interface.

func NewMocksyncer added in v1.8.0 

func NewMocksyncer(ctrl *gomock.Controller) *Mocksyncer

NewMocksyncer creates a new mock instance.

func (*Mocksyncer) EXPECT added in v1.8.0 

func (m *Mocksyncer) EXPECT() *MocksyncerMockRecorder

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

func (*Mocksyncer) IsSynced added in v1.8.0 

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

IsSynced mocks base method.

type MocksyncerIsSyncedCall added in v1.8.0 

type MocksyncerIsSyncedCall struct {
	*gomock.Call
}

MocksyncerIsSyncedCall wrap *gomock.Call

func (*MocksyncerIsSyncedCall) Do added in v1.8.0 

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

Do rewrite *gomock.Call.Do

func (*MocksyncerIsSyncedCall) DoAndReturn added in v1.8.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocksyncerIsSyncedCall) Return added in v1.8.0 

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

Return rewrite *gomock.Call.Return

type MocksyncerMockRecorder added in v1.8.0 

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

MocksyncerMockRecorder is the mock recorder for Mocksyncer.

func (*MocksyncerMockRecorder) IsSynced added in v1.8.0 

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

IsSynced indicates an expected call of IsSynced.

type MocktransactionConState 

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

MocktransactionConState is a mock of transactionConState interface.

func NewMocktransactionConState 

func NewMocktransactionConState(ctrl *gomock.Controller) *MocktransactionConState

NewMocktransactionConState creates a new mock instance.

func (*MocktransactionConState) EXPECT 

func (m *MocktransactionConState) EXPECT() *MocktransactionConStateMockRecorder

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

func (*MocktransactionConState) HasEvicted 

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

HasEvicted mocks base method.

func (*MocktransactionConState) Validation 

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

Validation mocks base method.

type MocktransactionConStateHasEvictedCall 

type MocktransactionConStateHasEvictedCall struct {
	*gomock.Call
}

MocktransactionConStateHasEvictedCall wrap *gomock.Call

func (*MocktransactionConStateHasEvictedCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocktransactionConStateHasEvictedCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocktransactionConStateHasEvictedCall) Return 

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

Return rewrite *gomock.Call.Return

type MocktransactionConStateMockRecorder 

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

MocktransactionConStateMockRecorder is the mock recorder for MocktransactionConState.

func (*MocktransactionConStateMockRecorder) HasEvicted 

func (mr *MocktransactionConStateMockRecorder) HasEvicted(tid any) *MocktransactionConStateHasEvictedCall

HasEvicted indicates an expected call of HasEvicted.

func (*MocktransactionConStateMockRecorder) Validation 

func (mr *MocktransactionConStateMockRecorder) Validation(raw any) *MocktransactionConStateValidationCall

Validation indicates an expected call of Validation.

type MocktransactionConStateValidationCall 

type MocktransactionConStateValidationCall struct {
	*gomock.Call
}

MocktransactionConStateValidationCall wrap *gomock.Call

func (*MocktransactionConStateValidationCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocktransactionConStateValidationCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocktransactionConStateValidationCall) Return 

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

Return rewrite *gomock.Call.Return

type MocktransactionSyncer 

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

MocktransactionSyncer is a mock of transactionSyncer interface.

func NewMocktransactionSyncer 

func NewMocktransactionSyncer(ctrl *gomock.Controller) *MocktransactionSyncer

NewMocktransactionSyncer creates a new mock instance.

func (*MocktransactionSyncer) EXPECT 

func (m *MocktransactionSyncer) EXPECT() *MocktransactionSyncerMockRecorder

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

func (*MocktransactionSyncer) IsSynced 

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

IsSynced mocks base method.

type MocktransactionSyncerIsSyncedCall 

type MocktransactionSyncerIsSyncedCall struct {
	*gomock.Call
}

MocktransactionSyncerIsSyncedCall wrap *gomock.Call

func (*MocktransactionSyncerIsSyncedCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocktransactionSyncerIsSyncedCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocktransactionSyncerIsSyncedCall) Return 

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

Return rewrite *gomock.Call.Return

type MocktransactionSyncerMockRecorder 

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

MocktransactionSyncerMockRecorder is the mock recorder for MocktransactionSyncer.

func (*MocktransactionSyncerMockRecorder) IsSynced 

func (mr *MocktransactionSyncerMockRecorder) IsSynced(arg0 any) *MocktransactionSyncerIsSyncedCall

IsSynced indicates an expected call of IsSynced.

type MocktransactionValidator 

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

MocktransactionValidator is a mock of transactionValidator interface.

func NewMocktransactionValidator 

func NewMocktransactionValidator(ctrl *gomock.Controller) *MocktransactionValidator

NewMocktransactionValidator creates a new mock instance.

func (*MocktransactionValidator) EXPECT 

func (m *MocktransactionValidator) EXPECT() *MocktransactionValidatorMockRecorder

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

func (*MocktransactionValidator) VerifyAndCacheTx 

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

VerifyAndCacheTx mocks base method.

type MocktransactionValidatorMockRecorder 

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

MocktransactionValidatorMockRecorder is the mock recorder for MocktransactionValidator.

func (*MocktransactionValidatorMockRecorder) VerifyAndCacheTx 

func (mr *MocktransactionValidatorMockRecorder) VerifyAndCacheTx(arg0, arg1 any) *MocktransactionValidatorVerifyAndCacheTxCall

VerifyAndCacheTx indicates an expected call of VerifyAndCacheTx.

type MocktransactionValidatorVerifyAndCacheTxCall 

type MocktransactionValidatorVerifyAndCacheTxCall struct {
	*gomock.Call
}

MocktransactionValidatorVerifyAndCacheTxCall wrap *gomock.Call

func (*MocktransactionValidatorVerifyAndCacheTxCall) Do 

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

Do rewrite *gomock.Call.Do

func (*MocktransactionValidatorVerifyAndCacheTxCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MocktransactionValidatorVerifyAndCacheTxCall) Return 

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

Return rewrite *gomock.Call.Return

type NetworkService 

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

func NewNetworkService 

func NewNetworkService(
	genesisTime time.Time,
	genesisID types.Hash20,
	layerDuration time.Duration,
	labelsPerUnit uint64,
) *NetworkService

func (*NetworkService) Info 

func (s *NetworkService) Info(context.Context,
	*spacemeshv2beta1.NetworkInfoRequest,
) (*spacemeshv2beta1.NetworkInfoResponse, error)

func (*NetworkService) RegisterHandlerService 

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

func (*NetworkService) RegisterService 

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

func (*NetworkService) String 

func (s *NetworkService) String() string

String returns the service name.

type NodeService 

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

func NewNodeService 

func NewNodeService(peers nodePeerCounter, msh nodeMeshAPI, clock *timesync.NodeClock, syncer syncer) *NodeService

func (*NodeService) RegisterHandlerService 

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

func (*NodeService) RegisterService 

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

func (*NodeService) Status 

func (s *NodeService) Status(ctx context.Context, _ *spacemeshv2beta1.NodeStatusRequest) (
	*spacemeshv2beta1.NodeStatusResponse, error,
)

func (*NodeService) String 

func (s *NodeService) String() string

String returns the service name.

type RewardService 

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

func NewRewardService 

func NewRewardService(db sql.Executor) *RewardService

func (*RewardService) List 

func (s *RewardService) List(
	_ context.Context,
	request *spacemeshv2beta1.RewardRequest,
) (*spacemeshv2beta1.RewardList, error)

func (*RewardService) RegisterHandlerService 

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

func (*RewardService) RegisterService 

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

func (*RewardService) String 

func (s *RewardService) String() string

String returns the service name.

type RewardStreamService 

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

func NewRewardStreamService 

func NewRewardStreamService(db sql.Executor) *RewardStreamService

func (*RewardStreamService) RegisterHandlerService 

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

func (*RewardStreamService) RegisterService 

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

func (*RewardStreamService) Stream 

func (s *RewardStreamService) Stream(
	request *spacemeshv2beta1.RewardStreamRequest,
	stream spacemeshv2beta1.RewardStreamService_StreamServer,
) error

func (*RewardStreamService) String 

func (s *RewardStreamService) String() string

type TransactionService 

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

func NewTransactionService 

func NewTransactionService(db sql.Executor, conState transactionConState,
	syncer syncer, validator transactionValidator,
	publisher pubsub.Publisher,
) *TransactionService

func (*TransactionService) EstimateGas 

func (s *TransactionService) EstimateGas(
	ctx context.Context,
	request *spacemeshv2beta1.EstimateGasRequest,
) (*spacemeshv2beta1.EstimateGasResponse, error)

func (*TransactionService) List 

func (s *TransactionService) List(
	ctx context.Context,
	request *spacemeshv2beta1.TransactionRequest,
) (*spacemeshv2beta1.TransactionList, error)

func (*TransactionService) ParseTransaction 

func (s *TransactionService) ParseTransaction(
	ctx context.Context,
	request *spacemeshv2beta1.ParseTransactionRequest,
) (*spacemeshv2beta1.ParseTransactionResponse, error)

func (*TransactionService) RegisterHandlerService 

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

func (*TransactionService) RegisterService 

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

func (*TransactionService) String 

func (s *TransactionService) String() string

String returns the service name.

func (*TransactionService) SubmitTransaction 

func (s *TransactionService) SubmitTransaction(
	ctx context.Context,
	request *spacemeshv2beta1.SubmitTransactionRequest,
) (*spacemeshv2beta1.SubmitTransactionResponse, error)

type TransactionStreamService 

type TransactionStreamService struct{}

func NewTransactionStreamService 

func NewTransactionStreamService() *TransactionStreamService

func (*TransactionStreamService) RegisterHandlerService 

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

func (*TransactionStreamService) RegisterService 

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

func (*TransactionStreamService) Stream 

func (s *TransactionStreamService) Stream(
	request *spacemeshv2beta1.TransactionStreamRequest,
	stream spacemeshv2beta1.TransactionStreamService_StreamServer,
) error

func (*TransactionStreamService) String 

func (s *TransactionStreamService) String() string

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 🇻🇳