Versions in this module Expand all Collapse all v0 v0.5.0 Mar 23, 2021 Changes in this version + func Asset(name string) ([]byte, error) + func AssetDir(name string) ([]string, error) + func AssetNames() []string + func ForwardTranslateASPreImage(f *from.ASPreImage) (*to.ASPreImage, error) + func ForwardTranslateAtomicSwap(f *from.AtomicSwap) (*to.AtomicSwap, error) + func ForwardTranslateBClaims(f *from.BClaims) (*to.BClaims, error) + func ForwardTranslateBlockHeader(f *from.BlockHeader) (*to.BlockHeader, error) + func ForwardTranslateByte(in []byte) (string, error) + func ForwardTranslateByteSlice(in [][]byte) ([]string, error) + func ForwardTranslateDSLinker(f *from.DSLinker) (*to.DSLinker, error) + func ForwardTranslateDSPreImage(f *from.DSPreImage) (*to.DSPreImage, error) + func ForwardTranslateDataStore(f *from.DataStore) (*to.DataStore, error) + func ForwardTranslateNHClaimsNHClaims(f *from.NHClaims) (*to.NHClaims, error) + func ForwardTranslateNRClaimsNRClaims(f *from.NRClaims) (*to.NRClaims, error) + func ForwardTranslateNextHeight(f *from.NextHeight) (*to.NextHeight, error) + func ForwardTranslateNextRound(f *from.NextRound) (*to.NextRound, error) + func ForwardTranslatePClaims(f *from.PClaims) (*to.PClaims, error) + func ForwardTranslatePreCommit(f *from.PreCommit) (*to.PreCommit, error) + func ForwardTranslatePreVote(f *from.PreVote) (*to.PreVote, error) + func ForwardTranslatePreVoteNil(f *from.PreVoteNil) (*to.PreVoteNil, error) + func ForwardTranslateProposal(f *from.Proposal) (*to.Proposal, error) + func ForwardTranslateRCert(f *from.RCert) (*to.RCert, error) + func ForwardTranslateRClaims(f *from.RClaims) (*to.RClaims, error) + func ForwardTranslateTXIn(f *from.TXIn) (*to.TXIn, error) + func ForwardTranslateTXInLinker(f *from.TXInLinker) (*to.TXInLinker, error) + func ForwardTranslateTXInPreImage(f *from.TXInPreImage) (*to.TXInPreImage, error) + func ForwardTranslateTXOut(f *from.TXOut) (*to.TXOut, error) + func ForwardTranslateTx(f *from.Tx) (*to.Tx, error) + func ForwardTranslateVSPreImage(f *from.VSPreImage) (*to.VSPreImage, error) + func ForwardTranslateValueStore(f *from.ValueStore) (*to.ValueStore, error) + func ReverseTranslateASPreImage(f *from.ASPreImage) (*to.ASPreImage, error) + func ReverseTranslateAtomicSwap(f *from.AtomicSwap) (*to.AtomicSwap, error) + func ReverseTranslateBClaims(f *from.BClaims) (*to.BClaims, error) + func ReverseTranslateBlockHeader(f *from.BlockHeader) (*to.BlockHeader, error) + func ReverseTranslateByte(in string) ([]byte, error) + func ReverseTranslateByteSlice(in []string) ([][]byte, error) + func ReverseTranslateDSLinker(f *from.DSLinker) (*to.DSLinker, error) + func ReverseTranslateDSPreImage(f *from.DSPreImage) (*to.DSPreImage, error) + func ReverseTranslateDataStore(f *from.DataStore) (*to.DataStore, error) + func ReverseTranslateNHClaims(f *from.NHClaims) (*to.NHClaims, error) + func ReverseTranslateNRClaims(f *from.NRClaims) (*to.NRClaims, error) + func ReverseTranslateNextHeight(f *from.NextHeight) (*to.NextHeight, error) + func ReverseTranslateNextRound(f *from.NextRound) (*to.NextRound, error) + func ReverseTranslatePClaims(f *from.PClaims) (*to.PClaims, error) + func ReverseTranslatePreCommit(f *from.PreCommit) (*to.PreCommit, error) + func ReverseTranslatePreVote(f *from.PreVote) (*to.PreVote, error) + func ReverseTranslatePreVoteNil(f *from.PreVoteNil) (*to.PreVoteNil, error) + func ReverseTranslateProposal(f *from.Proposal) (*to.Proposal, error) + func ReverseTranslateRCert(f *from.RCert) (*to.RCert, error) + func ReverseTranslateRClaims(f *from.RClaims) (*to.RClaims, error) + func ReverseTranslateTXIn(f *from.TXIn) (*to.TXIn, error) + func ReverseTranslateTXInLinker(f *from.TXInLinker) (*to.TXInLinker, error) + func ReverseTranslateTXInPreImage(f *from.TXInPreImage) (*to.TXInPreImage, error) + func ReverseTranslateTXOut(f *from.TXOut) (*to.TXOut, error) + func ReverseTranslateTx(f *from.Tx) (*to.Tx, error) + func ReverseTranslateVSPreImage(f *from.VSPreImage) (*to.VSPreImage, error) + func ReverseTranslateValueStore(f *from.ValueStore) (*to.ValueStore, error) + type Client struct + Address string + TimeOut time.Duration + func (lrpc *Client) Close() error + func (lrpc *Client) Connect(ctx context.Context) error + func (lrpc *Client) GetBlockHeader(ctx context.Context, height uint32) (*objs.BlockHeader, error) + func (lrpc *Client) GetBlockHeightForTx(ctx context.Context, txHash []byte) (uint32, error) + func (lrpc *Client) GetBlockNumber(ctx context.Context) (uint32, error) + func (lrpc *Client) GetData(ctx context.Context, curveSpec constants.CurveSpec, account []byte, ...) ([]byte, error) + func (lrpc *Client) GetEpochNumber(ctx context.Context) (uint32, error) + func (lrpc *Client) GetMinedTransaction(ctx context.Context, txHash []byte) (*aobjs.Tx, error) + func (lrpc *Client) GetPendingTransaction(ctx context.Context, txHash []byte) (*aobjs.Tx, error) + func (lrpc *Client) GetUTXO(ctx context.Context, utxoIDs [][]byte) (aobjs.Vout, error) + func (lrpc *Client) GetValueForOwner(ctx context.Context, curveSpec constants.CurveSpec, account []byte, ...) ([][]byte, *uint256.Uint256, error) + func (lrpc *Client) PaginateDataStoreUTXOByOwner(ctx context.Context, curveSpec constants.CurveSpec, account []byte, num uint8, ...) ([]*aobjs.PaginationResponse, error) + func (lrpc *Client) SendTransaction(ctx context.Context, tx *aobjs.Tx) ([]byte, error) + type Handler struct + func NewStateServerHandler(logger *logrus.Logger, addr string, service interfaces.StateServer) (*Handler, error) + func (rpch *Handler) Close() error + func (rpch *Handler) Serve() + type Handlers struct + AppHandler *application.Application + EthPubk []byte + GossipBus *gossip.Handlers + func (srpc *Handlers) HandleLocalStateGetBlockHeader(ctx context.Context, req *pb.BlockHeaderRequest) (*pb.BlockHeaderResponse, error) + func (srpc *Handlers) HandleLocalStateGetBlockNumber(ctx context.Context, req *pb.BlockNumberRequest) (*pb.BlockNumberResponse, error) + func (srpc *Handlers) HandleLocalStateGetChainID(ctx context.Context, req *pb.ChainIDRequest) (*pb.ChainIDResponse, error) + func (srpc *Handlers) HandleLocalStateGetData(ctx context.Context, req *pb.GetDataRequest) (*pb.GetDataResponse, error) + func (srpc *Handlers) HandleLocalStateGetEpochNumber(ctx context.Context, req *pb.EpochNumberRequest) (*pb.EpochNumberResponse, error) + func (srpc *Handlers) HandleLocalStateGetMinedTransaction(ctx context.Context, req *pb.MinedTransactionRequest) (*pb.MinedTransactionResponse, error) + func (srpc *Handlers) HandleLocalStateGetPendingTransaction(ctx context.Context, req *pb.PendingTransactionRequest) (*pb.PendingTransactionResponse, error) + func (srpc *Handlers) HandleLocalStateGetRoundStateForValidator(ctx context.Context, req *pb.RoundStateForValidatorRequest) (*pb.RoundStateForValidatorResponse, error) + func (srpc *Handlers) HandleLocalStateGetTxBlockNumber(ctx context.Context, req *pb.TxBlockNumberRequest) (*pb.TxBlockNumberResponse, error) + func (srpc *Handlers) HandleLocalStateGetUTXO(ctx context.Context, req *pb.UTXORequest) (*pb.UTXOResponse, error) + func (srpc *Handlers) HandleLocalStateGetValidatorSet(ctx context.Context, req *pb.ValidatorSetRequest) (*pb.ValidatorSetResponse, error) + func (srpc *Handlers) HandleLocalStateGetValueForOwner(ctx context.Context, req *pb.GetValueRequest) (*pb.GetValueResponse, error) + func (srpc *Handlers) HandleLocalStateIterateNameSpace(ctx context.Context, req *pb.IterateNameSpaceRequest) (*pb.IterateNameSpaceResponse, error) + func (srpc *Handlers) HandleLocalStateSendTransaction(ctx context.Context, req *pb.TransactionData) (*pb.TransactionDetails, error) + func (srpc *Handlers) Init(database *db.Database, app *application.Application, gh *gossip.Handlers, ...) error + func (srpc *Handlers) SafeMonitor() + func (srpc *Handlers) Start() + func (srpc *Handlers) Stop()
Go to main page