Documentation ¶
Index ¶
- Constants
- type Client
- func (c *Client) Api() IApi
- func (c *Client) CloseMonitor()
- func (c *Client) GetBalance(accountId types.AccountId) (balance *big.Int, err error)
- func (c *Client) GetBlock(param interface{}) (types.Block, error)
- func (c *Client) GetBlockByHash(blockHash types.CryptoHash) (types.Block, error)
- func (c *Client) GetBlockByHeight(height int64) (types.Block, error)
- func (c *Client) GetBmcLinkStatus(destination, source chain.BTPAddress) (*chain.BMCLinkStatus, error)
- func (c *Client) GetChainStatus() (types.ChainStatus, error)
- func (c *Client) GetLatestBlockHash() (types.CryptoHash, error)
- func (c *Client) GetLatestBlockHeight() (int64, error)
- func (c *Client) GetNonce(publicKey types.PublicKey, accountId string) (int64, error)
- func (c *Client) GetReceipts(block *types.Block, accountId string) ([]*chain.Receipt, error)
- func (c *Client) GetTransactionResult(transactionId types.CryptoHash, senderId types.AccountId) (types.TransactionResult, error)
- func (c *Client) IsMonitorClosed() bool
- func (c *Client) Logger() log.Logger
- func (c *Client) MonitorBlockHeight(offset int64) rxgo.Observable
- func (c *Client) MonitorBlocks(height uint64, source string, concurrency uint, ...) error
- func (c *Client) SendTransaction(payload string) (*types.CryptoHash, error)
- type IApi
- type IClient
- type Receiver
- type ReceiverConfig
- type RelayTransaction
- type Sender
- type SenderConfig
- type Wallet
Constants ¶
View Source
const BmcContractMessageStateKey = "bWVzc2FnZQ=="
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) CloseMonitor ¶
func (c *Client) CloseMonitor()
func (*Client) GetBalance ¶
func (*Client) GetBlockByHash ¶
func (*Client) GetBlockByHeight ¶
func (*Client) GetBmcLinkStatus ¶
func (c *Client) GetBmcLinkStatus(destination, source chain.BTPAddress) (*chain.BMCLinkStatus, error)
func (*Client) GetChainStatus ¶
func (c *Client) GetChainStatus() (types.ChainStatus, error)
func (*Client) GetLatestBlockHash ¶
func (c *Client) GetLatestBlockHash() (types.CryptoHash, error)
func (*Client) GetLatestBlockHeight ¶
func (*Client) GetReceipts ¶
func (*Client) GetTransactionResult ¶
func (c *Client) GetTransactionResult(transactionId types.CryptoHash, senderId types.AccountId) (types.TransactionResult, error)
func (*Client) IsMonitorClosed ¶
func (*Client) MonitorBlockHeight ¶
func (*Client) MonitorBlocks ¶
func (*Client) SendTransaction ¶
func (c *Client) SendTransaction(payload string) (*types.CryptoHash, error)
type IApi ¶
type IApi interface { Block(param interface{}) (response types.Block, err error) BroadcastTxCommit(param interface{}) (response types.TransactionResult, err error) BroadcastTxAsync(param interface{}) (response types.CryptoHash, err error) CallFunction(param interface{}) (response types.CallFunctionResponse, err error) Changes(param interface{}) (response types.ContractStateChange, err error) Chunk(param interface{}) (response types.ChunkHeader, err error) LightClientProof(param interface{}) (response types.ReceiptProof, err error) Status(param interface{}) (response types.ChainStatus, err error) Transaction(param interface{}) (response types.TransactionResult, err error) ViewAccessKey(param interface{}) (response types.AccessKeyResponse, err error) ViewAccount(param interface{}) (response types.Account, err error) }
type IClient ¶
type IClient interface { Api() IApi CloseMonitor() GetBalance(types.AccountId) (*big.Int, error) GetBlockByHash(types.CryptoHash) (types.Block, error) GetBlockByHeight(int64) (types.Block, error) GetBmcLinkStatus(destination, source chain.BTPAddress) (*chain.BMCLinkStatus, error) GetLatestBlockHash() (types.CryptoHash, error) GetNonce(publicKey types.PublicKey, accountId string) (int64, error) GetTransactionResult(types.CryptoHash, types.AccountId) (types.TransactionResult, error) GetReceipts(block *types.Block, accountId string) ([]*chain.Receipt, error) Logger() log.Logger MonitorBlocks(height uint64, source string, concurrency uint, callback func(rxgo.Observable) error, subClient func() IClient) error SendTransaction(payload string) (*types.CryptoHash, error) GetLatestBlockHeight() (int64, error) MonitorBlockHeight(offset int64) rxgo.Observable IsMonitorClosed() bool }
type Receiver ¶
type Receiver struct {
// contains filtered or unexported fields
}
func NewReceiver ¶
func (*Receiver) ReceiveBlocks ¶
func (*Receiver) StopReceivingBlocks ¶
func (r *Receiver) StopReceivingBlocks()
type ReceiverConfig ¶
type ReceiverConfig struct {
// contains filtered or unexported fields
}
type RelayTransaction ¶
type RelayTransaction struct { Transaction types.Transaction // contains filtered or unexported fields }
func NewRelayTransaction ¶
func NewRelayTransaction(context context.Context, wallet *wallet.NearWallet, destination string, client IClient, actions []types.Action) *RelayTransaction
func (*RelayTransaction) ID ¶
func (relayTx *RelayTransaction) ID() interface{}
type Sender ¶
type Sender struct {
// contains filtered or unexported fields
}
type SenderConfig ¶
type SenderConfig struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.