grpcserver

package
v0.3.2-beta.1 Latest Latest
Warning

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

 Go to latest Published: May 12, 2023 License: MIT Imports: 37 Imported by: 0

Documentation

Overview

Package config provides configuration for GRPC and HTTP api servers

Package grpcserver is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var ServerOptions = []grpc.ServerOption{

	grpc.KeepaliveParams(keepalive.ServerParameters{
		MaxConnectionIdle:     time.Minute * 120,
		MaxConnectionAge:      time.Minute * 180,
		MaxConnectionAgeGrace: time.Minute * 10,
		Time:                  time.Minute,
		Timeout:               time.Minute * 3,
	}),
}

ServerOptions are shared by all grpc servers.

Functions

func NewActivationService added in v1.0.0 

func NewActivationService(atxProvider atxProvider) *activationService

Types

type AdminService added in v1.0.0 

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

AdminService exposes endpoints for node administration.

func NewAdminService added in v1.0.0 

func NewAdminService(cp CheckpointRunnerFunc) *AdminService

NewAdminService creates a new admin grpc service.

func (AdminService) CheckpointStream added in v1.0.0 

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

func (AdminService) Recover added in v1.0.0 

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

func (AdminService) RegisterService added in v1.0.0 

func (a AdminService) RegisterService(server *Server)

RegisterService registers this service with a grpc server instance.

type CheckpointRunner 

type CheckpointRunner interface {
	Generate(context.Context, types.LayerID, types.LayerID) (string, error)
}

type CheckpointRunnerFunc 

type CheckpointRunnerFunc func() CheckpointRunner

type Config added in v1.0.0 

type Config struct {
	PublicServices  []Service `mapstructure:"grpc-public-services"`
	PublicListener  string    `mapstructure:"grpc-public-listener"`
	PrivateServices []Service `mapstructure:"grpc-private-services"`
	PrivateListener string    `mapstructure:"grpc-private-listener"`
	GrpcSendMsgSize int       `mapstructure:"grpc-send-msg-size"`
	GrpcRecvMsgSize int       `mapstructure:"grpc-recv-msg-size"`
	JSONListener    string    `mapstructure:"grpc-json-listener"`

	SmesherStreamInterval time.Duration
}

func DefaultConfig added in v1.0.0 

func DefaultConfig() Config

DefaultConfig defines the default configuration options for api.

func DefaultTestConfig added in v1.0.0 

func DefaultTestConfig() Config

DefaultTestConfig returns the default config for tests.

type DebugService added in v0.1.16 

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

DebugService exposes global state data, output from the STF.

func NewDebugService added in v0.1.16 

func NewDebugService(conState conservativeState, host networkIdentity, oracle oracle) *DebugService

NewDebugService creates a new grpc service using config data.

func (DebugService) Accounts added in v0.1.16 

func (d DebugService) Accounts(_ context.Context, in *empty.Empty) (*pb.AccountsResponse, error)

Accounts returns current counter and balance for all accounts.

func (DebugService) ActiveSet added in v1.0.0 

func (d DebugService) ActiveSet(ctx context.Context, req *pb.ActiveSetRequest) (*pb.ActiveSetResponse, error)

ActiveSet query provides hare active set for the specified epoch.

func (DebugService) NetworkInfo added in v1.0.0 

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

NetworkInfo query provides NetworkInfoResponse.

func (DebugService) ProposalsStream added in v1.0.0 

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

ProposalsStream streams all proposals confirmed by hare.

func (DebugService) RegisterService added in v0.1.16 

func (d DebugService) RegisterService(server *Server)

RegisterService registers this service with a grpc server instance.

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(_ 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(_ context.Context, in *pb.AccountDataQueryRequest) (*pb.AccountDataQueryResponse, error)

AccountDataQuery returns historical account data such as rewards and receipts.

func (GlobalStateService) AccountDataStream 

func (s GlobalStateService) AccountDataStream(in *pb.AccountDataStreamRequest, stream pb.GlobalStateService_AccountDataStreamServer) error

AccountDataStream exposes a stream of account-related data.

func (GlobalStateService) AppEventStream 

func (s GlobalStateService) AppEventStream(*pb.AppEventStreamRequest, pb.GlobalStateService_AppEventStreamServer) error

AppEventStream exposes a stream of emitted app events.

func (GlobalStateService) GlobalStateHash 

func (s GlobalStateService) GlobalStateHash(context.Context, *pb.GlobalStateHashRequest) (*pb.GlobalStateHashResponse, error)

GlobalStateHash returns the latest layer and its computed global state hash.

func (GlobalStateService) GlobalStateStream 

func (s GlobalStateService) GlobalStateStream(in *pb.GlobalStateStreamRequest, stream pb.GlobalStateService_GlobalStateStreamServer) error

GlobalStateStream exposes a stream of global data data items: rewards, receipts, account info, global state hash.

func (GlobalStateService) RegisterService 

func (s GlobalStateService) RegisterService(server *Server)

RegisterService registers this service with a grpc server instance.

func (GlobalStateService) SmesherDataQuery 

func (s GlobalStateService) SmesherDataQuery(_ context.Context, in *pb.SmesherDataQueryRequest) (*pb.SmesherDataQueryResponse, error)

SmesherDataQuery returns historical info on smesher rewards.

func (GlobalStateService) SmesherRewardStream 

func (s GlobalStateService) SmesherRewardStream(in *pb.SmesherRewardStreamRequest, stream pb.GlobalStateService_SmesherRewardStreamServer) error

SmesherRewardStream exposes a stream of smesher rewards.

type JSONHTTPServer 

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

JSONHTTPServer is a JSON http server providing the Spacemesh API. It is implemented using a grpc-gateway. See https://github.com/grpc-ecosystem/grpc-gateway .

func NewJSONHTTPServer 

func NewJSONHTTPServer(listener string) *JSONHTTPServer

NewJSONHTTPServer creates a new json http server.

func (*JSONHTTPServer) Shutdown added in v1.0.0 

func (s *JSONHTTPServer) Shutdown(ctx context.Context) error

Shutdown stops the server.

func (*JSONHTTPServer) StartService 

func (s *JSONHTTPServer) StartService(
	ctx context.Context,
	services ...ServiceAPI,
) <-chan struct{}

StartService starts the json api server and listens for status (started, stopped).

type MeshService 

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

MeshService exposes mesh data such as accounts, blocks, and transactions.

func NewMeshService 

func NewMeshService(
	msh meshAPI, cstate conservativeState, genTime genesisTimeAPI,
	layersPerEpoch uint32, genesisID types.Hash20, layerDuration time.Duration,
	layerAvgSize uint32, txsPerProposal uint32,
) *MeshService

NewMeshService creates a new service using config data.

func (MeshService) AccountMeshDataQuery 

func (s MeshService) AccountMeshDataQuery(ctx context.Context, in *pb.AccountMeshDataQueryRequest) (*pb.AccountMeshDataQueryResponse, error)

AccountMeshDataQuery returns account data.

func (MeshService) AccountMeshDataStream 

func (s MeshService) AccountMeshDataStream(in *pb.AccountMeshDataStreamRequest, stream pb.MeshService_AccountMeshDataStreamServer) error

AccountMeshDataStream exposes a stream of transactions and activations for an account.

func (MeshService) CurrentEpoch 

func (s MeshService) CurrentEpoch(context.Context, *pb.CurrentEpochRequest) (*pb.CurrentEpochResponse, error)

CurrentEpoch returns the current epoch number.

func (MeshService) CurrentLayer 

func (s MeshService) CurrentLayer(context.Context, *pb.CurrentLayerRequest) (*pb.CurrentLayerResponse, error)

CurrentLayer returns the current layer number.

func (MeshService) EpochNumLayers 

func (s MeshService) EpochNumLayers(context.Context, *pb.EpochNumLayersRequest) (*pb.EpochNumLayersResponse, error)

EpochNumLayers returns the number of layers per epoch (a network parameter).

func (MeshService) EpochStream added in v1.0.0 

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

func (MeshService) GenesisID added in v1.0.0 

func (s MeshService) GenesisID(context.Context, *pb.GenesisIDRequest) (*pb.GenesisIDResponse, error)

GenesisID returns the network ID.

func (MeshService) GenesisTime 

func (s MeshService) GenesisTime(context.Context, *pb.GenesisTimeRequest) (*pb.GenesisTimeResponse, error)

GenesisTime returns the network genesis time as UNIX time.

func (MeshService) LayerDuration 

func (s MeshService) LayerDuration(context.Context, *pb.LayerDurationRequest) (*pb.LayerDurationResponse, error)

LayerDuration returns the layer duration in seconds (a network parameter).

func (MeshService) LayerStream 

func (s MeshService) LayerStream(_ *pb.LayerStreamRequest, stream pb.MeshService_LayerStreamServer) error

LayerStream exposes a stream of all mesh data per layer.

func (MeshService) LayersQuery 

func (s MeshService) LayersQuery(ctx context.Context, in *pb.LayersQueryRequest) (*pb.LayersQueryResponse, error)

LayersQuery returns all mesh data, layer by layer.

func (MeshService) 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) RegisterService 

func (s MeshService) RegisterService(server *Server)

RegisterService registers this service with a grpc server instance.

type MockCheckpointRunner 

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

MockCheckpointRunner is a mock of CheckpointRunner interface.

func NewMockCheckpointRunner 

func NewMockCheckpointRunner(ctrl *gomock.Controller) *MockCheckpointRunner

NewMockCheckpointRunner creates a new mock instance.

func (*MockCheckpointRunner) EXPECT 

func (m *MockCheckpointRunner) EXPECT() *MockCheckpointRunnerMockRecorder

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

func (*MockCheckpointRunner) Generate 

func (m *MockCheckpointRunner) Generate(arg0 context.Context, arg1, arg2 types.LayerID) (string, error)

Generate mocks base method.

type MockCheckpointRunnerMockRecorder 

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

MockCheckpointRunnerMockRecorder is the mock recorder for MockCheckpointRunner.

func (*MockCheckpointRunnerMockRecorder) Generate 

func (mr *MockCheckpointRunnerMockRecorder) Generate(arg0, arg1, arg2 interface{}) *gomock.Call

Generate indicates an expected call of Generate.

type MockatxProvider added in v1.0.0 

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

MockatxProvider is a mock of atxProvider interface.

func NewMockatxProvider added in v1.0.0 

func NewMockatxProvider(ctrl *gomock.Controller) *MockatxProvider

NewMockatxProvider creates a new mock instance.

func (*MockatxProvider) EXPECT added in v1.0.0 

func (m *MockatxProvider) EXPECT() *MockatxProviderMockRecorder

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

func (*MockatxProvider) GetFullAtx added in v1.0.0 

func (m *MockatxProvider) GetFullAtx(id types.ATXID) (*types.VerifiedActivationTx, error)

GetFullAtx mocks base method.

type MockatxProviderMockRecorder added in v1.0.0 

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

MockatxProviderMockRecorder is the mock recorder for MockatxProvider.

func (*MockatxProviderMockRecorder) GetFullAtx added in v1.0.0 

func (mr *MockatxProviderMockRecorder) GetFullAtx(id interface{}) *gomock.Call

GetFullAtx indicates an expected call of GetFullAtx.

type MockconservativeState added in v1.0.0 

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

MockconservativeState is a mock of conservativeState interface.

func NewMockconservativeState added in v1.0.0 

func NewMockconservativeState(ctrl *gomock.Controller) *MockconservativeState

NewMockconservativeState creates a new mock instance.

func (*MockconservativeState) EXPECT added in v1.0.0 

func (m *MockconservativeState) EXPECT() *MockconservativeStateMockRecorder

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

func (*MockconservativeState) GetAllAccounts added in v1.0.0 

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

GetAllAccounts mocks base method.

func (*MockconservativeState) GetBalance added in v1.0.0 

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

GetBalance mocks base method.

func (*MockconservativeState) GetLayerStateRoot added in v1.0.0 

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

GetLayerStateRoot mocks base method.

func (*MockconservativeState) GetMeshTransaction added in v1.0.0 

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

GetMeshTransaction mocks base method.

func (*MockconservativeState) GetMeshTransactions added in v1.0.0 

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

GetMeshTransactions mocks base method.

func (*MockconservativeState) GetNonce added in v1.0.0 

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

GetNonce mocks base method.

func (*MockconservativeState) GetProjection added in v1.0.0 

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

GetProjection mocks base method.

func (*MockconservativeState) GetStateRoot added in v1.0.0 

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

GetStateRoot mocks base method.

func (*MockconservativeState) GetTransactionsByAddress added in v1.0.0 

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

GetTransactionsByAddress mocks base method.

func (*MockconservativeState) Validation added in v1.0.0 

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

Validation mocks base method.

type MockconservativeStateMockRecorder added in v1.0.0 

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

MockconservativeStateMockRecorder is the mock recorder for MockconservativeState.

func (*MockconservativeStateMockRecorder) GetAllAccounts added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetAllAccounts() *gomock.Call

GetAllAccounts indicates an expected call of GetAllAccounts.

func (*MockconservativeStateMockRecorder) GetBalance added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetBalance(arg0 interface{}) *gomock.Call

GetBalance indicates an expected call of GetBalance.

func (*MockconservativeStateMockRecorder) GetLayerStateRoot added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetLayerStateRoot(arg0 interface{}) *gomock.Call

GetLayerStateRoot indicates an expected call of GetLayerStateRoot.

func (*MockconservativeStateMockRecorder) GetMeshTransaction added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetMeshTransaction(arg0 interface{}) *gomock.Call

GetMeshTransaction indicates an expected call of GetMeshTransaction.

func (*MockconservativeStateMockRecorder) GetMeshTransactions added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetMeshTransactions(arg0 interface{}) *gomock.Call

GetMeshTransactions indicates an expected call of GetMeshTransactions.

func (*MockconservativeStateMockRecorder) GetNonce added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetNonce(arg0 interface{}) *gomock.Call

GetNonce indicates an expected call of GetNonce.

func (*MockconservativeStateMockRecorder) GetProjection added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetProjection(arg0 interface{}) *gomock.Call

GetProjection indicates an expected call of GetProjection.

func (*MockconservativeStateMockRecorder) GetStateRoot added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetStateRoot() *gomock.Call

GetStateRoot indicates an expected call of GetStateRoot.

func (*MockconservativeStateMockRecorder) GetTransactionsByAddress added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetTransactionsByAddress(arg0, arg1, arg2 interface{}) *gomock.Call

GetTransactionsByAddress indicates an expected call of GetTransactionsByAddress.

func (*MockconservativeStateMockRecorder) Validation added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) Validation(raw interface{}) *gomock.Call

Validation indicates an expected call of Validation.

type MockgenesisTimeAPI added in v1.0.0 

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

MockgenesisTimeAPI is a mock of genesisTimeAPI interface.

func NewMockgenesisTimeAPI added in v1.0.0 

func NewMockgenesisTimeAPI(ctrl *gomock.Controller) *MockgenesisTimeAPI

NewMockgenesisTimeAPI creates a new mock instance.

func (*MockgenesisTimeAPI) CurrentLayer added in v1.0.0 

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

CurrentLayer mocks base method.

func (*MockgenesisTimeAPI) EXPECT added in v1.0.0 

func (m *MockgenesisTimeAPI) EXPECT() *MockgenesisTimeAPIMockRecorder

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

func (*MockgenesisTimeAPI) GenesisTime added in v1.0.0 

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

GenesisTime mocks base method.

type MockgenesisTimeAPIMockRecorder added in v1.0.0 

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

MockgenesisTimeAPIMockRecorder is the mock recorder for MockgenesisTimeAPI.

func (*MockgenesisTimeAPIMockRecorder) CurrentLayer added in v1.0.0 

func (mr *MockgenesisTimeAPIMockRecorder) CurrentLayer() *gomock.Call

CurrentLayer indicates an expected call of CurrentLayer.

func (*MockgenesisTimeAPIMockRecorder) GenesisTime added in v1.0.0 

func (mr *MockgenesisTimeAPIMockRecorder) GenesisTime() *gomock.Call

GenesisTime indicates an expected call of GenesisTime.

type MockmeshAPI added in v1.0.0 

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

MockmeshAPI is a mock of meshAPI interface.

func NewMockmeshAPI added in v1.0.0 

func NewMockmeshAPI(ctrl *gomock.Controller) *MockmeshAPI

NewMockmeshAPI creates a new mock instance.

func (*MockmeshAPI) EXPECT added in v1.0.0 

func (m *MockmeshAPI) EXPECT() *MockmeshAPIMockRecorder

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

func (*MockmeshAPI) EpochAtxs added in v1.0.0 

func (m *MockmeshAPI) EpochAtxs(arg0 types.EpochID) ([]types.ATXID, error)

EpochAtxs mocks base method.

func (*MockmeshAPI) GetATXs added in v1.0.0 

func (m *MockmeshAPI) GetATXs(arg0 context.Context, arg1 []types.ATXID) (map[types.ATXID]*types.VerifiedActivationTx, []types.ATXID)

GetATXs mocks base method.

func (*MockmeshAPI) GetLayer added in v1.0.0 

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

GetLayer mocks base method.

func (*MockmeshAPI) GetRewards added in v1.0.0 

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

GetRewards mocks base method.

func (*MockmeshAPI) LatestLayer added in v1.0.0 

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

LatestLayer mocks base method.

func (*MockmeshAPI) LatestLayerInState added in v1.0.0 

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

LatestLayerInState mocks base method.

func (*MockmeshAPI) MeshHash added in v1.0.0 

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

MeshHash mocks base method.

func (*MockmeshAPI) ProcessedLayer added in v1.0.0 

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

ProcessedLayer mocks base method.

type MockmeshAPIMockRecorder added in v1.0.0 

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

MockmeshAPIMockRecorder is the mock recorder for MockmeshAPI.

func (*MockmeshAPIMockRecorder) EpochAtxs added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) EpochAtxs(arg0 interface{}) *gomock.Call

EpochAtxs indicates an expected call of EpochAtxs.

func (*MockmeshAPIMockRecorder) GetATXs added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) GetATXs(arg0, arg1 interface{}) *gomock.Call

GetATXs indicates an expected call of GetATXs.

func (*MockmeshAPIMockRecorder) GetLayer added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) GetLayer(arg0 interface{}) *gomock.Call

GetLayer indicates an expected call of GetLayer.

func (*MockmeshAPIMockRecorder) GetRewards added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) GetRewards(arg0 interface{}) *gomock.Call

GetRewards indicates an expected call of GetRewards.

func (*MockmeshAPIMockRecorder) LatestLayer added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) LatestLayer() *gomock.Call

LatestLayer indicates an expected call of LatestLayer.

func (*MockmeshAPIMockRecorder) LatestLayerInState added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) LatestLayerInState() *gomock.Call

LatestLayerInState indicates an expected call of LatestLayerInState.

func (*MockmeshAPIMockRecorder) MeshHash added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) MeshHash(arg0 interface{}) *gomock.Call

MeshHash indicates an expected call of MeshHash.

func (*MockmeshAPIMockRecorder) ProcessedLayer added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) ProcessedLayer() *gomock.Call

ProcessedLayer indicates an expected call of ProcessedLayer.

type MocknetworkIdentity added in v1.0.0 

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

MocknetworkIdentity is a mock of networkIdentity interface.

func NewMocknetworkIdentity added in v1.0.0 

func NewMocknetworkIdentity(ctrl *gomock.Controller) *MocknetworkIdentity

NewMocknetworkIdentity creates a new mock instance.

func (*MocknetworkIdentity) EXPECT added in v1.0.0 

func (m *MocknetworkIdentity) EXPECT() *MocknetworkIdentityMockRecorder

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

func (*MocknetworkIdentity) ID added in v1.0.0 

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

ID mocks base method.

type MocknetworkIdentityMockRecorder added in v1.0.0 

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

MocknetworkIdentityMockRecorder is the mock recorder for MocknetworkIdentity.

func (*MocknetworkIdentityMockRecorder) ID added in v1.0.0 

func (mr *MocknetworkIdentityMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

type Mockoracle added in v1.0.0 

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

Mockoracle is a mock of oracle interface.

func NewMockoracle added in v1.0.0 

func NewMockoracle(ctrl *gomock.Controller) *Mockoracle

NewMockoracle creates a new mock instance.

func (*Mockoracle) ActiveSet added in v1.0.0 

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

ActiveSet mocks base method.

func (*Mockoracle) EXPECT added in v1.0.0 

func (m *Mockoracle) EXPECT() *MockoracleMockRecorder

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

type MockoracleMockRecorder added in v1.0.0 

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

MockoracleMockRecorder is the mock recorder for Mockoracle.

func (*MockoracleMockRecorder) ActiveSet added in v1.0.0 

func (mr *MockoracleMockRecorder) ActiveSet(arg0, arg1 interface{}) *gomock.Call

ActiveSet indicates an expected call of ActiveSet.

type MockpeerCounter added in v1.0.0 

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

MockpeerCounter is a mock of peerCounter interface.

func NewMockpeerCounter added in v1.0.0 

func NewMockpeerCounter(ctrl *gomock.Controller) *MockpeerCounter

NewMockpeerCounter creates a new mock instance.

func (*MockpeerCounter) EXPECT added in v1.0.0 

func (m *MockpeerCounter) EXPECT() *MockpeerCounterMockRecorder

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

func (*MockpeerCounter) PeerCount added in v1.0.0 

func (m *MockpeerCounter) PeerCount() uint64

PeerCount mocks base method.

type MockpeerCounterMockRecorder added in v1.0.0 

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

MockpeerCounterMockRecorder is the mock recorder for MockpeerCounter.

func (*MockpeerCounterMockRecorder) PeerCount added in v1.0.0 

func (mr *MockpeerCounterMockRecorder) PeerCount() *gomock.Call

PeerCount indicates an expected call of PeerCount.

type MockpostSetupProvider added in v1.0.0 

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

MockpostSetupProvider is a mock of postSetupProvider interface.

func NewMockpostSetupProvider added in v1.0.0 

func NewMockpostSetupProvider(ctrl *gomock.Controller) *MockpostSetupProvider

NewMockpostSetupProvider creates a new mock instance.

func (*MockpostSetupProvider) Benchmark added in v1.0.0 

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

Benchmark mocks base method.

func (*MockpostSetupProvider) Config added in v1.0.0 

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

Config mocks base method.

func (*MockpostSetupProvider) EXPECT added in v1.0.0 

func (m *MockpostSetupProvider) EXPECT() *MockpostSetupProviderMockRecorder

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

func (*MockpostSetupProvider) Providers added in v1.0.0 

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

Providers mocks base method.

func (*MockpostSetupProvider) Status added in v1.0.0 

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

Status mocks base method.

type MockpostSetupProviderMockRecorder added in v1.0.0 

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

MockpostSetupProviderMockRecorder is the mock recorder for MockpostSetupProvider.

func (*MockpostSetupProviderMockRecorder) Benchmark added in v1.0.0 

func (mr *MockpostSetupProviderMockRecorder) Benchmark(p interface{}) *gomock.Call

Benchmark indicates an expected call of Benchmark.

func (*MockpostSetupProviderMockRecorder) Config added in v1.0.0 

func (mr *MockpostSetupProviderMockRecorder) Config() *gomock.Call

Config indicates an expected call of Config.

func (*MockpostSetupProviderMockRecorder) Providers added in v1.0.0 

func (mr *MockpostSetupProviderMockRecorder) Providers() *gomock.Call

Providers indicates an expected call of Providers.

func (*MockpostSetupProviderMockRecorder) Status added in v1.0.0 

func (mr *MockpostSetupProviderMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status.

type Mocksyncer added in v1.0.0 

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

Mocksyncer is a mock of syncer interface.

func NewMocksyncer added in v1.0.0 

func NewMocksyncer(ctrl *gomock.Controller) *Mocksyncer

NewMocksyncer creates a new mock instance.

func (*Mocksyncer) EXPECT added in v1.0.0 

func (m *Mocksyncer) EXPECT() *MocksyncerMockRecorder

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

func (*Mocksyncer) IsSynced added in v1.0.0 

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

IsSynced mocks base method.

type MocksyncerMockRecorder added in v1.0.0 

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

MocksyncerMockRecorder is the mock recorder for Mocksyncer.

func (*MocksyncerMockRecorder) IsSynced added in v1.0.0 

func (mr *MocksyncerMockRecorder) IsSynced(arg0 interface{}) *gomock.Call

IsSynced indicates an expected call of IsSynced.

type MocktxValidator added in v1.0.0 

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

MocktxValidator is a mock of txValidator interface.

func NewMocktxValidator added in v1.0.0 

func NewMocktxValidator(ctrl *gomock.Controller) *MocktxValidator

NewMocktxValidator creates a new mock instance.

func (*MocktxValidator) EXPECT added in v1.0.0 

func (m *MocktxValidator) EXPECT() *MocktxValidatorMockRecorder

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

func (*MocktxValidator) VerifyAndCacheTx added in v1.0.0 

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

VerifyAndCacheTx mocks base method.

type MocktxValidatorMockRecorder added in v1.0.0 

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

MocktxValidatorMockRecorder is the mock recorder for MocktxValidator.

func (*MocktxValidatorMockRecorder) VerifyAndCacheTx added in v1.0.0 

func (mr *MocktxValidatorMockRecorder) VerifyAndCacheTx(arg0, arg1 interface{}) *gomock.Call

VerifyAndCacheTx indicates an expected call of VerifyAndCacheTx.

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(
	appCtx context.Context,
	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, *empty.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) RegisterService 

func (s NodeService) RegisterService(server *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) Version 

func (s NodeService) Version(context.Context, *empty.Empty) (*pb.VersionResponse, error)

Version returns the version of the node software as a semver string.

type Server 

type Server struct {
	Listener   string
	GrpcServer *grpc.Server
}

Server is a very basic grpc server.

func New added in v1.0.0 

func New(listener string, opts ...grpc.ServerOption) *Server

New creates and returns a new Server with port and interface.

func (*Server) Close 

func (s *Server) Close() error

Close stops the server.

func (*Server) Start 

func (s *Server) Start() <-chan struct{}

Start starts the server.

type Service added in v1.0.0 

type Service = string
const (
	Admin       Service = "admin"
	Debug       Service = "debug"
	GlobalState Service = "global"
	Mesh        Service = "mesh"
	Transaction Service = "transaction"
	Activation  Service = "activation"
	Smesher     Service = "smesher"
	Node        Service = "node"
)

type ServiceAPI 

type ServiceAPI interface {
	RegisterService(*Server)
}

ServiceAPI allows individual grpc services to register the grpc server.

type SmesherService 

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

SmesherService exposes endpoints to manage smeshing.

func NewSmesherService 

func NewSmesherService(post postSetupProvider, smeshing activation.SmeshingProvider, streamInterval time.Duration, postOpts activation.PostSetupOpts) *SmesherService

NewSmesherService creates a new grpc service using config data.

func (SmesherService) Coinbase 

func (s SmesherService) Coinbase(context.Context, *empty.Empty) (*pb.CoinbaseResponse, error)

Coinbase returns the current coinbase setting of this node.

func (SmesherService) EstimatedRewards added in v0.1.16 

func (s SmesherService) EstimatedRewards(context.Context, *pb.EstimatedRewardsRequest) (*pb.EstimatedRewardsResponse, error)

EstimatedRewards returns estimated smeshing rewards over the next epoch.

func (SmesherService) IsSmeshing 

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

IsSmeshing reports whether the node is smeshing.

func (SmesherService) MinGas 

func (s SmesherService) MinGas(context.Context, *empty.Empty) (*pb.MinGasResponse, error)

MinGas returns the current mingas setting of this node.

func (SmesherService) PostConfig added in v1.0.0 

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

PostConfig returns the Post protocol config.

func (SmesherService) PostSetupProviders added in v1.0.0 

func (s SmesherService) PostSetupProviders(ctx context.Context, in *pb.PostSetupProvidersRequest) (*pb.PostSetupProvidersResponse, error)

PostSetupComputeProviders returns a list of available Post setup compute providers.

func (SmesherService) PostSetupStatus added in v1.0.0 

func (s SmesherService) PostSetupStatus(context.Context, *empty.Empty) (*pb.PostSetupStatusResponse, error)

PostSetupStatus returns post data status.

func (SmesherService) PostSetupStatusStream added in v1.0.0 

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

PostSetupStatusStream exposes a stream of status updates during post setup.

func (SmesherService) RegisterService 

func (s SmesherService) RegisterService(server *Server)

RegisterService registers this service with a grpc server instance.

func (SmesherService) SetCoinbase 

func (s SmesherService) SetCoinbase(_ context.Context, in *pb.SetCoinbaseRequest) (*pb.SetCoinbaseResponse, error)

SetCoinbase sets the current coinbase setting of this node.

func (SmesherService) SetMinGas 

func (s SmesherService) SetMinGas(context.Context, *pb.SetMinGasRequest) (*pb.SetMinGasResponse, error)

SetMinGas sets the mingas setting of this node.

func (SmesherService) SmesherID 

func (s SmesherService) SmesherID(context.Context, *empty.Empty) (*pb.SmesherIDResponse, error)

SmesherID returns the smesher ID of this node.

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

func (s SmesherService) UpdatePoetServers(ctx context.Context, req *pb.UpdatePoetServersRequest) (*pb.UpdatePoetServersResponse, error)

UpdatePoetServers update server that is used for generating PoETs.

type TransactionService 

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

TransactionService exposes transaction data, and a submit tx endpoint.

func NewTransactionService 

func NewTransactionService(
	db *sql.Database,
	publisher pubsub.Publisher,
	msh meshAPI,
	conState conservativeState,
	syncer syncer,
	txHandler txValidator,
) *TransactionService

NewTransactionService creates a new grpc service using config data.

func (TransactionService) ParseTransaction added in v1.0.0 

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

func (TransactionService) RegisterService 

func (s TransactionService) RegisterService(server *Server)

RegisterService registers this service with a grpc server instance.

func (TransactionService) StreamResults added in v1.0.0 

func (s TransactionService) StreamResults(in *pb.TransactionResultsRequest, stream pb.TransactionService_StreamResultsServer) error

StreamResults allows to query historical results and subscribe to live data using the same filter.

func (TransactionService) 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.