grpc

Documentation

Index

• type Account
• type ChainBrokerService
  • func NewChainBrokerService(api api.CoreAPI, config *repo.Config) (*ChainBrokerService, error)
  • func (cbs *ChainBrokerService) GetAccountBalance(ctx context.Context, req *pb.Address) (*pb.Response, error)
  • func (cbs *ChainBrokerService) GetBlock(ctx context.Context, req *pb.GetBlockRequest) (*pb.Block, error)
  • func (cbs *ChainBrokerService) GetBlocks(ctx context.Context, req *pb.GetBlocksRequest) (*pb.GetBlocksResponse, error)
  • func (cbs *ChainBrokerService) GetChainMeta(ctx context.Context, req *pb.Request) (*pb.ChainMeta, error)
  • func (cbs *ChainBrokerService) GetChainStatus(ctx context.Context, req *pb.Request) (*pb.Response, error)
  • func (cbs *ChainBrokerService) GetMerkleWrapper(req *pb.GetMerkleWrapperRequest, server pb.ChainBroker_GetMerkleWrapperServer) error
  • func (cbs *ChainBrokerService) GetNetworkMeta(ctx context.Context, req *pb.Request) (*pb.Response, error)
  • func (cbs *ChainBrokerService) GetReceipt(ctx context.Context, req *pb.TransactionHashMsg) (*pb.Receipt, error)
  • func (cbs *ChainBrokerService) GetTransaction(ctx context.Context, req *pb.TransactionHashMsg) (*pb.GetTransactionResponse, error)
  • func (cbs *ChainBrokerService) SendTransaction(ctx context.Context, tx *pb.SendTransactionRequest) (*pb.TransactionHashMsg, error)
  • func (cbs *ChainBrokerService) Start() error
  • func (cbs *ChainBrokerService) Stop() error
  • func (cbs *ChainBrokerService) Subscribe(req *pb.SubscriptionRequest, server pb.ChainBroker_SubscribeServer) error
  • func (cbs *ChainBrokerService) SyncMerkleWrapper(req *pb.SyncMerkleWrapperRequest, ...) error
• type InterchainStatus

Types

type Account

type Account struct {
	Type          string     `json:"type"`
	Balance       uint64     `json:"balance"`
	ContractCount uint64     `json:"contract_count"`
	CodeHash      types.Hash `json:"code_hash"`
}

type ChainBrokerService

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

func NewChainBrokerService

func NewChainBrokerService(api api.CoreAPI, config *repo.Config) (*ChainBrokerService, error)

func (*ChainBrokerService) GetAccountBalance

func (cbs *ChainBrokerService) GetAccountBalance(ctx context.Context, req *pb.Address) (*pb.Response, error)

func (*ChainBrokerService) GetBlock

func (cbs *ChainBrokerService) GetBlock(ctx context.Context, req *pb.GetBlockRequest) (*pb.Block, error)

func (*ChainBrokerService) GetBlocks

func (cbs *ChainBrokerService) GetBlocks(ctx context.Context, req *pb.GetBlocksRequest) (*pb.GetBlocksResponse, error)

func (*ChainBrokerService) GetChainMeta

func (cbs *ChainBrokerService) GetChainMeta(ctx context.Context, req *pb.Request) (*pb.ChainMeta, error)

func (*ChainBrokerService) GetChainStatus

func (cbs *ChainBrokerService) GetChainStatus(ctx context.Context, req *pb.Request) (*pb.Response, error)

func (*ChainBrokerService) GetMerkleWrapper

func (cbs *ChainBrokerService) GetMerkleWrapper(req *pb.GetMerkleWrapperRequest, server pb.ChainBroker_GetMerkleWrapperServer) error

func (*ChainBrokerService) GetNetworkMeta

func (cbs *ChainBrokerService) GetNetworkMeta(ctx context.Context, req *pb.Request) (*pb.Response, error)

func (*ChainBrokerService) GetReceipt

func (cbs *ChainBrokerService) GetReceipt(ctx context.Context, req *pb.TransactionHashMsg) (*pb.Receipt, error)

func (*ChainBrokerService) GetTransaction

func (cbs *ChainBrokerService) GetTransaction(ctx context.Context, req *pb.TransactionHashMsg) (*pb.GetTransactionResponse, error)

func (*ChainBrokerService) SendTransaction

func (cbs *ChainBrokerService) SendTransaction(ctx context.Context, tx *pb.SendTransactionRequest) (*pb.TransactionHashMsg, error)

SendTransaction handles transaction sent by the client. If the transaction is valid, it will return the transaction hash.

func (*ChainBrokerService) Start

func (cbs *ChainBrokerService) Start() error

func (*ChainBrokerService) Stop

func (cbs *ChainBrokerService) Stop() error

func (*ChainBrokerService) Subscribe

func (cbs *ChainBrokerService) Subscribe(req *pb.SubscriptionRequest, server pb.ChainBroker_SubscribeServer) error

Subscribe implements the interface for client to Subscribe the certain type of event arose in bitxhub. This request will establish a websocket conn with client.

func (*ChainBrokerService) SyncMerkleWrapper

func (cbs *ChainBrokerService) SyncMerkleWrapper(req *pb.SyncMerkleWrapperRequest, server pb.ChainBroker_SyncMerkleWrapperServer) error

type InterchainStatus

type InterchainStatus struct {
	From string `json:"from"`
	To   string `json:"to"`
	Hash string `json:"hash"`
}