grpcserver

package
v1.3.7 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2024 License: MIT Imports: 53 Imported by: 0

Documentation

Overview

Package config provides configuration for GRPC and HTTP api servers

Code generated by MockGen. DO NOT EDIT. Source: ./interface.go

Generated by this command: 

mockgen -typed -package=grpcserver -destination=./mocks.go -source=./interface.go

Package grpcserver is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewActivationService added in v1.0.0 

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

Types

type AdminService added in v1.0.0 

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

AdminService exposes endpoints for node administration.

func NewAdminService added in v1.0.0 

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

NewAdminService creates a new admin grpc service.

func (AdminService) CheckpointStream added in v1.0.0 

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

func (AdminService) EventsStream added in v1.0.0 

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

func (AdminService) PeerInfoStream added in v1.1.2 

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

func (AdminService) Recover added in v1.0.0 

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

func (AdminService) RegisterHandlerService added in v1.3.0 

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

func (AdminService) RegisterService added in v1.0.0 

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

RegisterService registers this service with a grpc server instance.

func (AdminService) String added in v1.3.0 

func (a AdminService) String() string

String returns the name of this service.

type Config added in v1.0.0 

type Config struct {
	PublicServices  []Service
	PublicListener  string `mapstructure:"grpc-public-listener"`
	PrivateServices []Service
	PrivateListener string `mapstructure:"grpc-private-listener"`
	TLSServices     []Service
	TLSListener     string `mapstructure:"grpc-tls-listener"`
	TLSCACert       string `mapstructure:"grpc-tls-ca-cert"`
	TLSCert         string `mapstructure:"grpc-tls-cert"`
	TLSKey          string `mapstructure:"grpc-tls-key"`
	GrpcSendMsgSize int    `mapstructure:"grpc-send-msg-size"`
	GrpcRecvMsgSize int    `mapstructure:"grpc-recv-msg-size"`
	JSONListener    string `mapstructure:"grpc-json-listener"`

	SmesherStreamInterval time.Duration
}

func DefaultConfig added in v1.0.0 

func DefaultConfig() Config

DefaultConfig defines the default configuration options for api.

func DefaultTestConfig added in v1.0.0 

func DefaultTestConfig() Config

DefaultTestConfig returns the default config for tests.

type DebugService added in v0.1.16 

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

DebugService exposes global state data, output from the STF.

func NewDebugService added in v0.1.16 

func NewDebugService(db *sql.Database, conState conservativeState, host networkInfo, oracle oracle) *DebugService

NewDebugService creates a new grpc service using config data.

func (DebugService) Accounts added in v0.1.16 

func (d DebugService) Accounts(ctx context.Context, in *pb.AccountsRequest) (*pb.AccountsResponse, error)

Accounts returns current counter and balance for all accounts.

func (DebugService) ActiveSet added in v1.0.0 

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

ActiveSet query provides hare active set for the specified epoch.

func (DebugService) NetworkInfo added in v1.0.0 

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

NetworkInfo query provides NetworkInfoResponse.

func (DebugService) ProposalsStream added in v1.0.0 

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

ProposalsStream streams all proposals confirmed by hare.

func (DebugService) RegisterHandlerService added in v1.3.0 

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

func (DebugService) RegisterService added in v0.1.16 

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

RegisterService registers this service with a grpc server instance.

func (DebugService) String added in v1.3.0 

func (d DebugService) String() string

String returns the name of this service.

type GlobalStateService 

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

GlobalStateService exposes global state data, output from the STF.

func NewGlobalStateService 

func NewGlobalStateService(msh meshAPI, conState conservativeState) *GlobalStateService

NewGlobalStateService creates a new grpc service using config data.

func (GlobalStateService) Account 

func (s GlobalStateService) Account(ctx context.Context, in *pb.AccountRequest) (*pb.AccountResponse, error)

Account returns current and projected counter and balance for one account.

func (GlobalStateService) AccountDataQuery 

func (s GlobalStateService) AccountDataQuery(
	ctx context.Context,
	in *pb.AccountDataQueryRequest,
) (*pb.AccountDataQueryResponse, error)

AccountDataQuery returns historical account data such as rewards and receipts.

func (GlobalStateService) AccountDataStream 

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

AccountDataStream exposes a stream of account-related data.

func (GlobalStateService) AppEventStream 

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

AppEventStream exposes a stream of emitted app events.

func (GlobalStateService) GlobalStateHash 

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

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

func (GlobalStateService) GlobalStateStream 

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

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

func (GlobalStateService) RegisterHandlerService added in v1.3.0 

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

func (GlobalStateService) RegisterService 

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

RegisterService registers this service with a grpc server instance.

func (GlobalStateService) SmesherDataQuery 

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

SmesherDataQuery returns historical info on smesher rewards.

func (GlobalStateService) SmesherRewardStream 

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

SmesherRewardStream exposes a stream of smesher rewards.

func (GlobalStateService) String added in v1.3.0 

func (s GlobalStateService) String() string

String returns the name of the service.

type JSONHTTPServer 

type JSONHTTPServer struct {

	// BoundAddress contains the address that the server bound to, useful if
	// the server uses a dynamic port. It is set during startup and can be
	// safely accessed after Start has completed (I.E. the returned channel has
	// been waited on)
	BoundAddress string
	// contains filtered or unexported fields
}

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

func NewJSONHTTPServer 

func NewJSONHTTPServer(listener string, lg *zap.Logger) *JSONHTTPServer

NewJSONHTTPServer creates a new json http server.

func (*JSONHTTPServer) Shutdown added in v1.0.0 

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

Shutdown stops the server.

func (*JSONHTTPServer) StartService 

func (s *JSONHTTPServer) StartService(
	ctx context.Context,
	services ...ServiceAPI,
) error

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

type MeshService 

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

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

func NewMeshService 

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

NewMeshService creates a new service using config data.

func (MeshService) AccountMeshDataQuery 

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

AccountMeshDataQuery returns account data.

func (MeshService) AccountMeshDataStream 

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

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

func (MeshService) CurrentEpoch 

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

CurrentEpoch returns the current epoch number.

func (MeshService) CurrentLayer 

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

CurrentLayer returns the current layer number.

func (MeshService) EpochNumLayers 

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

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

func (MeshService) EpochStream added in v1.0.0 

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

func (MeshService) GenesisID added in v1.0.0 

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

GenesisID returns the network ID.

func (MeshService) GenesisTime 

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

GenesisTime returns the network genesis time as UNIX time.

func (MeshService) LayerDuration 

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

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

func (MeshService) LayerStream 

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

LayerStream exposes a stream of all mesh data per layer.

func (MeshService) LayersQuery 

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

LayersQuery returns all mesh data, layer by layer.

func (MeshService) MalfeasanceQuery added in v1.1.0 

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

func (MeshService) MalfeasanceStream added in v1.1.0 

func (s MeshService) MalfeasanceStream(
	req *pb.MalfeasanceStreamRequest,
	stream pb.MeshService_MalfeasanceStreamServer,
) error

func (MeshService) MaxTransactionsPerSecond 

func (s MeshService) MaxTransactionsPerSecond(
	context.Context,
	*pb.MaxTransactionsPerSecondRequest,
) (*pb.MaxTransactionsPerSecondResponse, error)

MaxTransactionsPerSecond returns the max number of tx per sec (a network parameter).

func (MeshService) RegisterHandlerService added in v1.3.0 

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

func (MeshService) RegisterService 

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

RegisterService registers this service with a grpc server instance.

func (MeshService) String added in v1.3.0 

func (s MeshService) String() string

String returns the name of this service.

type MockatxProvider added in v1.0.0 

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

MockatxProvider is a mock of atxProvider interface.

func NewMockatxProvider added in v1.0.0 

func NewMockatxProvider(ctrl *gomock.Controller) *MockatxProvider

NewMockatxProvider creates a new mock instance.

func (*MockatxProvider) EXPECT added in v1.0.0 

func (m *MockatxProvider) EXPECT() *MockatxProviderMockRecorder

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

func (*MockatxProvider) GetFullAtx added in v1.0.0 

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

GetFullAtx mocks base method.

func (*MockatxProvider) GetMalfeasanceProof added in v1.1.0 

func (m *MockatxProvider) GetMalfeasanceProof(id types.NodeID) (*types.MalfeasanceProof, error)

GetMalfeasanceProof mocks base method.

func (*MockatxProvider) MaxHeightAtx added in v1.0.0 

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

MaxHeightAtx mocks base method.

type MockatxProviderMockRecorder added in v1.0.0 

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

MockatxProviderMockRecorder is the mock recorder for MockatxProvider.

func (*MockatxProviderMockRecorder) GetFullAtx added in v1.0.0 

func (mr *MockatxProviderMockRecorder) GetFullAtx(id any) *atxProviderGetFullAtxCall

GetFullAtx indicates an expected call of GetFullAtx.

func (*MockatxProviderMockRecorder) GetMalfeasanceProof added in v1.1.0 

func (mr *MockatxProviderMockRecorder) GetMalfeasanceProof(id any) *atxProviderGetMalfeasanceProofCall

GetMalfeasanceProof indicates an expected call of GetMalfeasanceProof.

func (*MockatxProviderMockRecorder) MaxHeightAtx added in v1.0.0 

func (mr *MockatxProviderMockRecorder) MaxHeightAtx() *atxProviderMaxHeightAtxCall

MaxHeightAtx indicates an expected call of MaxHeightAtx.

type MockconservativeState added in v1.0.0 

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

MockconservativeState is a mock of conservativeState interface.

func NewMockconservativeState added in v1.0.0 

func NewMockconservativeState(ctrl *gomock.Controller) *MockconservativeState

NewMockconservativeState creates a new mock instance.

func (*MockconservativeState) EXPECT added in v1.0.0 

func (m *MockconservativeState) EXPECT() *MockconservativeStateMockRecorder

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

func (*MockconservativeState) GetAllAccounts added in v1.0.0 

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

GetAllAccounts mocks base method.

func (*MockconservativeState) GetBalance added in v1.0.0 

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

GetBalance mocks base method.

func (*MockconservativeState) GetLayerStateRoot added in v1.0.0 

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() *conservativeStateGetAllAccountsCall

GetAllAccounts indicates an expected call of GetAllAccounts.

func (*MockconservativeStateMockRecorder) GetBalance added in v1.0.0 

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

GetBalance indicates an expected call of GetBalance.

func (*MockconservativeStateMockRecorder) GetLayerStateRoot added in v1.0.0 

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

GetLayerStateRoot indicates an expected call of GetLayerStateRoot.

func (*MockconservativeStateMockRecorder) GetMeshTransaction added in v1.0.0 

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

GetMeshTransaction indicates an expected call of GetMeshTransaction.

func (*MockconservativeStateMockRecorder) GetMeshTransactions added in v1.0.0 

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

GetMeshTransactions indicates an expected call of GetMeshTransactions.

func (*MockconservativeStateMockRecorder) GetNonce added in v1.0.0 

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

GetNonce indicates an expected call of GetNonce.

func (*MockconservativeStateMockRecorder) GetProjection added in v1.0.0 

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

GetProjection indicates an expected call of GetProjection.

func (*MockconservativeStateMockRecorder) GetStateRoot added in v1.0.0 

func (mr *MockconservativeStateMockRecorder) GetStateRoot() *conservativeStateGetStateRootCall

GetStateRoot indicates an expected call of GetStateRoot.

func (*MockconservativeStateMockRecorder) GetTransactionsByAddress added in v1.0.0 

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

GetTransactionsByAddress indicates an expected call of GetTransactionsByAddress.

func (*MockconservativeStateMockRecorder) Validation added in v1.0.0 

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

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() *genesisTimeAPICurrentLayerCall

CurrentLayer indicates an expected call of CurrentLayer.

func (*MockgenesisTimeAPIMockRecorder) GenesisTime added in v1.0.0 

func (mr *MockgenesisTimeAPIMockRecorder) GenesisTime() *genesisTimeAPIGenesisTimeCall

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) 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) GetLayerVerified added in v1.3.3 

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

GetLayerVerified mocks base method.

func (*MockmeshAPI) GetRewardsByCoinbase added in v1.3.0 

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

GetRewardsByCoinbase mocks base method.

func (*MockmeshAPI) GetRewardsBySmesherId added in v1.3.0 

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

GetRewardsBySmesherId mocks base method.

func (*MockmeshAPI) LatestLayer added in v1.0.0 

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

LatestLayer mocks base method.

func (*MockmeshAPI) LatestLayerInState added in v1.0.0 

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

LatestLayerInState mocks base method.

func (*MockmeshAPI) MeshHash added in v1.0.0 

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

MeshHash mocks base method.

func (*MockmeshAPI) ProcessedLayer added in v1.0.0 

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

ProcessedLayer mocks base method.

type MockmeshAPIMockRecorder added in v1.0.0 

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

MockmeshAPIMockRecorder is the mock recorder for MockmeshAPI.

func (*MockmeshAPIMockRecorder) GetATXs added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) GetATXs(arg0, arg1 any) *meshAPIGetATXsCall

GetATXs indicates an expected call of GetATXs.

func (*MockmeshAPIMockRecorder) GetLayer added in v1.0.0 

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

GetLayer indicates an expected call of GetLayer.

func (*MockmeshAPIMockRecorder) GetLayerVerified added in v1.3.3 

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

GetLayerVerified indicates an expected call of GetLayerVerified.

func (*MockmeshAPIMockRecorder) GetRewardsByCoinbase added in v1.3.0 

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

GetRewardsByCoinbase indicates an expected call of GetRewardsByCoinbase.

func (*MockmeshAPIMockRecorder) GetRewardsBySmesherId added in v1.3.0 

func (mr *MockmeshAPIMockRecorder) GetRewardsBySmesherId(id any) *meshAPIGetRewardsBySmesherIdCall

GetRewardsBySmesherId indicates an expected call of GetRewardsBySmesherId.

func (*MockmeshAPIMockRecorder) LatestLayer added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) LatestLayer() *meshAPILatestLayerCall

LatestLayer indicates an expected call of LatestLayer.

func (*MockmeshAPIMockRecorder) LatestLayerInState added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) LatestLayerInState() *meshAPILatestLayerInStateCall

LatestLayerInState indicates an expected call of LatestLayerInState.

func (*MockmeshAPIMockRecorder) MeshHash added in v1.0.0 

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

MeshHash indicates an expected call of MeshHash.

func (*MockmeshAPIMockRecorder) ProcessedLayer added in v1.0.0 

func (mr *MockmeshAPIMockRecorder) ProcessedLayer() *meshAPIProcessedLayerCall

ProcessedLayer indicates an expected call of ProcessedLayer.

type MocknetworkInfo added in v1.3.0 

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

MocknetworkInfo is a mock of networkInfo interface.

func NewMocknetworkInfo added in v1.3.0 

func NewMocknetworkInfo(ctrl *gomock.Controller) *MocknetworkInfo

NewMocknetworkInfo creates a new mock instance.

func (*MocknetworkInfo) DHTServerEnabled added in v1.3.0 

func (m *MocknetworkInfo) DHTServerEnabled() bool

DHTServerEnabled mocks base method.

func (*MocknetworkInfo) EXPECT added in v1.3.0 

func (m *MocknetworkInfo) EXPECT() *MocknetworkInfoMockRecorder

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

func (*MocknetworkInfo) ID added in v1.3.0 

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

ID mocks base method.

func (*MocknetworkInfo) KnownAddresses added in v1.3.0 

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

KnownAddresses mocks base method.

func (*MocknetworkInfo) ListenAddresses added in v1.3.0 

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

ListenAddresses mocks base method.

func (*MocknetworkInfo) NATDeviceType added in v1.3.0 

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

NATDeviceType mocks base method.

func (*MocknetworkInfo) Reachability added in v1.3.0 

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

Reachability mocks base method.

type MocknetworkInfoMockRecorder added in v1.3.0 

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

MocknetworkInfoMockRecorder is the mock recorder for MocknetworkInfo.

func (*MocknetworkInfoMockRecorder) DHTServerEnabled added in v1.3.0 

func (mr *MocknetworkInfoMockRecorder) DHTServerEnabled() *networkInfoDHTServerEnabledCall

DHTServerEnabled indicates an expected call of DHTServerEnabled.

func (*MocknetworkInfoMockRecorder) ID added in v1.3.0 

func (mr *MocknetworkInfoMockRecorder) ID() *networkInfoIDCall

ID indicates an expected call of ID.

func (*MocknetworkInfoMockRecorder) KnownAddresses added in v1.3.0 

func (mr *MocknetworkInfoMockRecorder) KnownAddresses() *networkInfoKnownAddressesCall

KnownAddresses indicates an expected call of KnownAddresses.

func (*MocknetworkInfoMockRecorder) ListenAddresses added in v1.3.0 

func (mr *MocknetworkInfoMockRecorder) ListenAddresses() *networkInfoListenAddressesCall

ListenAddresses indicates an expected call of ListenAddresses.

func (*MocknetworkInfoMockRecorder) NATDeviceType added in v1.3.0 

func (mr *MocknetworkInfoMockRecorder) NATDeviceType() *networkInfoNATDeviceTypeCall

NATDeviceType indicates an expected call of NATDeviceType.

func (*MocknetworkInfoMockRecorder) Reachability added in v1.3.0 

func (mr *MocknetworkInfoMockRecorder) Reachability() *networkInfoReachabilityCall

Reachability indicates an expected call of Reachability.

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 any) *oracleActiveSetCall

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() *peerCounterPeerCountCall

PeerCount indicates an expected call of PeerCount.

type Mockpeers added in v1.1.2 

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

Mockpeers is a mock of peers interface.

func NewMockpeers added in v1.1.2 

func NewMockpeers(ctrl *gomock.Controller) *Mockpeers

NewMockpeers creates a new mock instance.

func (*Mockpeers) ConnectedPeerInfo added in v1.1.2 

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

ConnectedPeerInfo mocks base method.

func (*Mockpeers) EXPECT added in v1.1.2 

func (m *Mockpeers) EXPECT() *MockpeersMockRecorder

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

func (*Mockpeers) GetPeers added in v1.1.2 

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

GetPeers mocks base method.

type MockpeersMockRecorder added in v1.1.2 

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

MockpeersMockRecorder is the mock recorder for Mockpeers.

func (*MockpeersMockRecorder) ConnectedPeerInfo added in v1.1.2 

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

ConnectedPeerInfo indicates an expected call of ConnectedPeerInfo.

func (*MockpeersMockRecorder) GetPeers added in v1.1.2 

func (mr *MockpeersMockRecorder) GetPeers() *peersGetPeersCall

GetPeers indicates an expected call of GetPeers.

type MockpostSupervisor added in v1.3.0 

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

MockpostSupervisor is a mock of postSupervisor interface.

func NewMockpostSupervisor added in v1.3.0 

func NewMockpostSupervisor(ctrl *gomock.Controller) *MockpostSupervisor

NewMockpostSupervisor creates a new mock instance.

func (*MockpostSupervisor) Benchmark added in v1.3.0 

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

Benchmark mocks base method.

func (*MockpostSupervisor) Config added in v1.3.0 

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

Config mocks base method.

func (*MockpostSupervisor) EXPECT added in v1.3.0 

func (m *MockpostSupervisor) EXPECT() *MockpostSupervisorMockRecorder

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

func (*MockpostSupervisor) Providers added in v1.3.0 

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

Providers mocks base method.

func (*MockpostSupervisor) Start added in v1.3.0 

func (m *MockpostSupervisor) Start(opts activation.PostSetupOpts) error

Start mocks base method.

func (*MockpostSupervisor) Status added in v1.3.0 

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

Status mocks base method.

func (*MockpostSupervisor) Stop added in v1.3.0 

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

Stop mocks base method.

type MockpostSupervisorMockRecorder added in v1.3.0 

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

MockpostSupervisorMockRecorder is the mock recorder for MockpostSupervisor.

func (*MockpostSupervisorMockRecorder) Benchmark added in v1.3.0 

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

Benchmark indicates an expected call of Benchmark.

func (*MockpostSupervisorMockRecorder) Config added in v1.3.0 

func (mr *MockpostSupervisorMockRecorder) Config() *postSupervisorConfigCall

Config indicates an expected call of Config.

func (*MockpostSupervisorMockRecorder) Providers added in v1.3.0 

func (mr *MockpostSupervisorMockRecorder) Providers() *postSupervisorProvidersCall

Providers indicates an expected call of Providers.

func (*MockpostSupervisorMockRecorder) Start added in v1.3.0 

func (mr *MockpostSupervisorMockRecorder) Start(opts any) *postSupervisorStartCall

Start indicates an expected call of Start.

func (*MockpostSupervisorMockRecorder) Status added in v1.3.0 

func (mr *MockpostSupervisorMockRecorder) Status() *postSupervisorStatusCall

Status indicates an expected call of Status.

func (*MockpostSupervisorMockRecorder) Stop added in v1.3.0 

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

Stop indicates an expected call of Stop.

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 any) *syncerIsSyncedCall

IsSynced indicates an expected call of IsSynced.

type MocktxValidator added in v1.0.0 

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

MocktxValidator is a mock of txValidator interface.

func NewMocktxValidator added in v1.0.0 

func NewMocktxValidator(ctrl *gomock.Controller) *MocktxValidator

NewMocktxValidator creates a new mock instance.

func (*MocktxValidator) EXPECT added in v1.0.0 

func (m *MocktxValidator) EXPECT() *MocktxValidatorMockRecorder

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

func (*MocktxValidator) VerifyAndCacheTx added in v1.0.0 

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

VerifyAndCacheTx mocks base method.

type MocktxValidatorMockRecorder added in v1.0.0 

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

MocktxValidatorMockRecorder is the mock recorder for MocktxValidator.

func (*MocktxValidatorMockRecorder) VerifyAndCacheTx added in v1.0.0 

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

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(
	peers peerCounter,
	msh meshAPI,
	genTime genesisTimeAPI,
	syncer syncer,
	appVersion string,
	appCommit string,
) *NodeService

NewNodeService creates a new grpc service using config data.

func (NodeService) Build 

func (s NodeService) Build(context.Context, *emptypb.Empty) (*pb.BuildResponse, error)

Build returns the build of the node software.

func (NodeService) Echo 

func (s NodeService) Echo(_ context.Context, in *pb.EchoRequest) (*pb.EchoResponse, error)

Echo returns the response for an echo api request. It's used for E2E tests.

func (NodeService) ErrorStream 

func (s NodeService) ErrorStream(_ *pb.ErrorStreamRequest, stream pb.NodeService_ErrorStreamServer) error

ErrorStream exposes a stream of node errors.

func (NodeService) NodeInfo added in v1.0.0 

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

func (NodeService) RegisterHandlerService added in v1.3.0 

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

func (NodeService) RegisterService 

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

RegisterService registers this service with a grpc server instance.

func (NodeService) Status 

func (s NodeService) Status(ctx context.Context, _ *pb.StatusRequest) (*pb.StatusResponse, error)

Status returns a status object providing information about the connected peers, sync status, current and verified layer.

func (NodeService) StatusStream 

func (s NodeService) StatusStream(_ *pb.StatusStreamRequest, stream pb.NodeService_StatusStreamServer) error

StatusStream exposes a stream of node status updates.

func (NodeService) String added in v1.3.0 

func (s NodeService) String() string

String returns the name of this service.

func (NodeService) Version 

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

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

type PostService added in v1.3.0 

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

PostService is a grpc server that PoST nodes can connect to in order to register. The bidirectional stream established between the node and the PoST node can be used to send challenges and receive proofs.

func NewPostService added in v1.3.0 

func NewPostService(log *zap.Logger) *PostService

NewPostService creates a new grpc service using config data.

func (*PostService) Client added in v1.3.0 

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

func (*PostService) Register added in v1.3.0 

func (s *PostService) Register(stream pb.PostService_RegisterServer) error

Register is called by the PoST service to connect with the node. It creates a bidirectional stream that is kept open until either side closes it. The other functions on this service are called by services of the node to send requests to the PoST node and receive responses.

func (*PostService) RegisterHandlerService added in v1.3.0 

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

func (*PostService) RegisterService added in v1.3.0 

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

RegisterService registers this service with a grpc server instance.

func (*PostService) String added in v1.3.0 

func (s *PostService) String() string

String returns the name of this service.

type Server 

type Server struct {

	// BoundAddress contains the address that the server bound to, useful if
	// the server uses a dynamic port. It is set during startup and can be
	// safely accessed after Start has completed (I.E. the returned channel has
	// been waited on)
	BoundAddress string
	GrpcServer   *grpc.Server
	// contains filtered or unexported fields
}

Server is a very basic grpc server.

func New added in v1.0.0 

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

New creates and returns a new Server listening on the given address. The server is configured with the given logger and config. Additional grpc options can be passed.

func NewPrivate added in v1.3.0 

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

NewPrivate creates new Server listening on the PrivateListener address with the given logger and config. Services passed in the svc slice are registered with the server.

func NewPublic added in v1.3.0 

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

NewPublic creates a new Server listening on the PublicListener address with the given logger and config. Services passed in the svc slice are registered with the server.

func NewTLS added in v1.3.0 

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

NewTLS creates a new Server listening on the TLSListener address with the given logger and config. Services passed in the svc slice are registered with the server.

func (*Server) Close 

func (s *Server) Close() error

Close stops the server.

func (*Server) Start 

func (s *Server) Start() error

Start starts the server.

type Service added in v1.0.0 

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

type ServiceAPI 

type ServiceAPI interface {
	RegisterService(*grpc.Server)
	RegisterHandlerService(*runtime.ServeMux) error
	String() string
}

ServiceAPI allows individual grpc services to register the grpc server.

type SmesherService 

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

SmesherService exposes endpoints to manage smeshing.

func NewSmesherService 

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

NewSmesherService creates a new grpc service using config data.

func (SmesherService) Coinbase 

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

Coinbase returns the current coinbase setting of this node.

func (SmesherService) EstimatedRewards added in v0.1.16 

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

EstimatedRewards returns estimated smeshing rewards over the next epoch.

func (SmesherService) IsSmeshing 

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

IsSmeshing reports whether the node is smeshing.

func (SmesherService) MinGas 

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

MinGas returns the current mingas setting of this node.

func (SmesherService) PostConfig added in v1.0.0 

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

PostConfig returns the Post protocol config.

func (SmesherService) PostSetupProviders added in v1.0.0 

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

PostSetupComputeProviders returns a list of available Post setup compute providers.

func (SmesherService) PostSetupStatus added in v1.0.0 

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

PostSetupStatus returns post data status.

func (SmesherService) PostSetupStatusStream added in v1.0.0 

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

PostSetupStatusStream exposes a stream of status updates during post setup.

func (SmesherService) RegisterHandlerService added in v1.3.0 

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

func (SmesherService) RegisterService 

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

RegisterService registers this service with a grpc server instance.

func (SmesherService) SetCoinbase 

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

SetCoinbase sets the current coinbase setting of this node.

func (SmesherService) SetMinGas 

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

SetMinGas sets the mingas setting of this node.

func (SmesherService) SmesherID 

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

SmesherID returns the smesher ID of this node.

func (SmesherService) StartSmeshing 

func (s SmesherService) StartSmeshing(
	ctx context.Context,
	in *pb.StartSmeshingRequest,
) (*pb.StartSmeshingResponse, error)

StartSmeshing requests that the node begin smeshing.

func (SmesherService) StopSmeshing 

func (s SmesherService) StopSmeshing(
	ctx context.Context,
	in *pb.StopSmeshingRequest,
) (*pb.StopSmeshingResponse, error)

StopSmeshing requests that the node stop smeshing.

func (SmesherService) String added in v1.3.0 

func (s SmesherService) String() string

String returns the name of this service.

type TransactionService 

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

TransactionService exposes transaction data, and a submit tx endpoint.

func NewTransactionService 

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

NewTransactionService creates a new grpc service using config data.

func (TransactionService) ParseTransaction added in v1.0.0 

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

func (TransactionService) RegisterHandlerService added in v1.3.0 

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

func (TransactionService) RegisterService 

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

RegisterService registers this service with a grpc server instance.

func (TransactionService) StreamResults added in v1.0.0 

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

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

func (TransactionService) String added in v1.3.0 

func (s TransactionService) String() string

String returns the name of this service.

func (TransactionService) SubmitTransaction 

func (s TransactionService) SubmitTransaction(
	ctx context.Context,
	in *pb.SubmitTransactionRequest,
) (*pb.SubmitTransactionResponse, error)

SubmitTransaction allows a new tx to be submitted.

func (TransactionService) TransactionsState 

func (s TransactionService) TransactionsState(
	_ context.Context,
	in *pb.TransactionsStateRequest,
) (*pb.TransactionsStateResponse, error)

TransactionsState returns current tx data for one or more txs.

func (TransactionService) TransactionsStateStream 

func (s TransactionService) TransactionsStateStream(
	in *pb.TransactionsStateStreamRequest,
	stream pb.TransactionService_TransactionsStateStreamServer,
) error

TransactionsStateStream exposes a stream of tx data.

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.