Package org.bdware.bdledger.api.grpc

Class Client

java.lang.Object

org.bdware.bdledger.api.grpc.Client

public class Client
extends Object

事务账本客户端

如有更灵活的需求可直接使用LedgerGrpc类。

See Also:

• 事务账本API

Constructor Summary

Constructors

Constructor	Description
Client(io.grpc.ManagedChannelBuilder<?> channelBuilder, String token)	用已有的Channel对象构造客户端来向BDLedger节点发请求。
Client(String host, int port)	构造客户端来向host:port BDLedger节点发请求。
Client(String host, int port, String token)	构造客户端，使用token作access token来向host:port BDLedger节点发请求。

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<NodeProto.ClientVersionResponse>	clientVersion()	查询BDLedger节点版本 （非阻塞）
NodeProto.ClientVersionResponse	clientVersionSync()	查询BDLedger节点版本 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.CountBlocksResponse>	countBlocks(String ledger)	返回账本中的区块数量 （非阻塞）
QueryProto.CountBlocksResponse	countBlocksSync(String ledger)	返回账本中的区块数量 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.CountTransactionsResponse>	countTransactions(String ledger)	返回账本中的事务数量 （非阻塞）
QueryProto.CountTransactionsResponse	countTransactionsSync(String ledger)	返回账本中的事务数量 （阻塞）
com.google.common.util.concurrent.ListenableFuture<LedgerProto.CreateLedgerResponse>	createLedger(String name)	创建账本 （非阻塞）
LedgerProto.CreateLedgerResponse	createLedgerSync(String name)	创建账本 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlockByHashResponse>	getBlockByHash(String ledger, String hash, boolean fullTransactions)	返回哈希所指定的区块 （非阻塞）
QueryProto.GetBlockByHashResponse	getBlockByHashSync(String ledger, String hash, boolean fullTransactions)	返回哈希所指定的区块 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse>	getBlocks(String ledger, long startUnixTime, long endUnixTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （非阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse>	getBlocks(String ledger, long startUnixTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （非阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse>	getBlocks(String ledger, ZonedDateTime startDateTime, ZonedDateTime endDateTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （非阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse>	getBlocks(String ledger, ZonedDateTime startDateTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （非阻塞）
QueryProto.GetBlocksResponse	getBlocksSync(String ledger, long startUnixTime, long endUnixTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （阻塞）
QueryProto.GetBlocksResponse	getBlocksSync(String ledger, long startUnixTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （阻塞）
QueryProto.GetBlocksResponse	getBlocksSync(String ledger, ZonedDateTime startDateTime, ZonedDateTime endDateTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （阻塞）
QueryProto.GetBlocksResponse	getBlocksSync(String ledger, ZonedDateTime startDateTime, QueryProto.IncludeTransactions includeTransactions)	返回时间范围内的区块 （阻塞）
com.google.common.util.concurrent.ListenableFuture<LedgerProto.GetLedgersResponse>	getLedgers()	返回账本列表 （非阻塞）
LedgerProto.GetLedgersResponse	getLedgersSync()	返回账本列表 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse>	getRecentBlocks(String ledger, int count, QueryProto.IncludeTransactions includeTransactions)	返回时间戳最新的若干区块 （非阻塞）
QueryProto.GetBlocksResponse	getRecentBlocksSync(String ledger, int count, QueryProto.IncludeTransactions includeTransactions)	返回时间戳最新的若干区块 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionByBlockHashAndIndexResponse>	getTransactionByBlockHashAndIndex(String ledger, String blockHash, int index)	返回区块的哈希与事务的index所指定的事务 （非阻塞）
QueryProto.GetTransactionByBlockHashAndIndexResponse	getTransactionByBlockHashAndIndexSync(String ledger, String blockHash, int index)	返回区块的哈希与事务的index所指定的事务 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionByHashResponse>	getTransactionByHash(String ledger, String hash)	返回哈希所指定的事务 （非阻塞）
QueryProto.GetTransactionByHashResponse	getTransactionByHashSync(String ledger, String hash)	返回哈希所指定的事务 （阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse>	getTransactions(String ledger, long startUnixTime)	返回时间范围内的事务 （非阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse>	getTransactions(String ledger, long startUnixTime, long endUnixTime)	返回时间范围内的事务 （非阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse>	getTransactions(String ledger, ZonedDateTime startDateTime)	返回时间范围内的事务 （非阻塞）
com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse>	getTransactions(String ledger, ZonedDateTime startDateTime, ZonedDateTime endDateTime)	返回时间范围内的事务 （非阻塞）
QueryProto.GetTransactionsResponse	getTransactionsSync(String ledger, long startUnixTime)	返回时间范围内的事务 （阻塞）
QueryProto.GetTransactionsResponse	getTransactionsSync(String ledger, long startUnixTime, long endUnixTime)	返回时间范围内的事务 （阻塞）
QueryProto.GetTransactionsResponse	getTransactionsSync(String ledger, ZonedDateTime startDateTime)	返回时间范围内的事务 （阻塞）
QueryProto.GetTransactionsResponse	getTransactionsSync(String ledger, ZonedDateTime startDateTime, ZonedDateTime endDateTime)	返回时间范围内的事务 （阻塞）
com.google.common.util.concurrent.ListenableFuture<LedgerProto.SendTransactionResponse>	sendTransaction(String ledger, CommonProto.TransactionType type, String from, long nonce, String to, byte[] data)	发送新事务 （非阻塞）
LedgerProto.SendTransactionResponse	sendTransactionSync(String ledger, CommonProto.TransactionType type, String from, long nonce, String to, byte[] data)	发送新事务 （阻塞）
void	shutdown()	关闭客户端的网络连接。

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Client

public Client(String host,
 int port)

构造客户端来向host:port BDLedger节点发请求。

Client

public Client(String host,
 int port,
 String token)

构造客户端，使用token作access token来向host:port BDLedger节点发请求。

Client

public Client(io.grpc.ManagedChannelBuilder<?> channelBuilder,
 String token)

用已有的Channel对象构造客户端来向BDLedger节点发请求。

Method Details

shutdown

public void shutdown()
              throws InterruptedException

关闭客户端的网络连接。

Throws:

InterruptedException

clientVersion

public com.google.common.util.concurrent.ListenableFuture<NodeProto.ClientVersionResponse> clientVersion()

查询BDLedger节点版本 （非阻塞）

clientVersionSync

public NodeProto.ClientVersionResponse clientVersionSync()

查询BDLedger节点版本 （阻塞）

createLedger

public com.google.common.util.concurrent.ListenableFuture<LedgerProto.CreateLedgerResponse> createLedger(String name)

创建账本 （非阻塞）

createLedgerSync

public LedgerProto.CreateLedgerResponse createLedgerSync(String name)

创建账本 （阻塞）

getLedgers

public com.google.common.util.concurrent.ListenableFuture<LedgerProto.GetLedgersResponse> getLedgers()

返回账本列表 （非阻塞）

getLedgersSync

public LedgerProto.GetLedgersResponse getLedgersSync()

返回账本列表 （阻塞）

sendTransaction

public com.google.common.util.concurrent.ListenableFuture<LedgerProto.SendTransactionResponse> sendTransaction(String ledger,
 CommonProto.TransactionType type,
 String from,
 long nonce,
 String to,
 byte[] data)

发送新事务 （非阻塞）

sendTransactionSync

public LedgerProto.SendTransactionResponse sendTransactionSync(String ledger,
 CommonProto.TransactionType type,
 String from,
 long nonce,
 String to,
 byte[] data)

发送新事务 （阻塞）

getBlockByHash

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlockByHashResponse> getBlockByHash(String ledger,
 String hash,
 boolean fullTransactions)

返回哈希所指定的区块 （非阻塞）

getBlockByHashSync

public QueryProto.GetBlockByHashResponse getBlockByHashSync(String ledger,
 String hash,
 boolean fullTransactions)

返回哈希所指定的区块 （阻塞）

getBlocks

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse> getBlocks(String ledger,
 ZonedDateTime startDateTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （非阻塞）

getBlocks

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse> getBlocks(String ledger,
 ZonedDateTime startDateTime,
 ZonedDateTime endDateTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （非阻塞）

getBlocksSync

public QueryProto.GetBlocksResponse getBlocksSync(String ledger,
 ZonedDateTime startDateTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （阻塞）

getBlocksSync

public QueryProto.GetBlocksResponse getBlocksSync(String ledger,
 ZonedDateTime startDateTime,
 ZonedDateTime endDateTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （阻塞）

getBlocks

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse> getBlocks(String ledger,
 long startUnixTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （非阻塞）

getBlocks

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse> getBlocks(String ledger,
 long startUnixTime,
 long endUnixTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （非阻塞）

getBlocksSync

public QueryProto.GetBlocksResponse getBlocksSync(String ledger,
 long startUnixTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （阻塞）

getBlocksSync

public QueryProto.GetBlocksResponse getBlocksSync(String ledger,
 long startUnixTime,
 long endUnixTime,
 QueryProto.IncludeTransactions includeTransactions)

返回时间范围内的区块 （阻塞）

countBlocks

public com.google.common.util.concurrent.ListenableFuture<QueryProto.CountBlocksResponse> countBlocks(String ledger)

返回账本中的区块数量 （非阻塞）

countBlocksSync

public QueryProto.CountBlocksResponse countBlocksSync(String ledger)

返回账本中的区块数量 （阻塞）

getRecentBlocks

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetBlocksResponse> getRecentBlocks(String ledger,
 int count,
 QueryProto.IncludeTransactions includeTransactions)

返回时间戳最新的若干区块 （非阻塞）

getRecentBlocksSync

public QueryProto.GetBlocksResponse getRecentBlocksSync(String ledger,
 int count,
 QueryProto.IncludeTransactions includeTransactions)

返回时间戳最新的若干区块 （阻塞）

getTransactionByHash

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionByHashResponse> getTransactionByHash(String ledger,
 String hash)

返回哈希所指定的事务 （非阻塞）

getTransactionByHashSync

public QueryProto.GetTransactionByHashResponse getTransactionByHashSync(String ledger,
 String hash)

返回哈希所指定的事务 （阻塞）

getTransactionByBlockHashAndIndex

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionByBlockHashAndIndexResponse> getTransactionByBlockHashAndIndex(String ledger,
 String blockHash,
 int index)

返回区块的哈希与事务的index所指定的事务 （非阻塞）

getTransactionByBlockHashAndIndexSync

public QueryProto.GetTransactionByBlockHashAndIndexResponse getTransactionByBlockHashAndIndexSync(String ledger,
 String blockHash,
 int index)

返回区块的哈希与事务的index所指定的事务 （阻塞）

getTransactions

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse> getTransactions(String ledger,
 ZonedDateTime startDateTime)

返回时间范围内的事务 （非阻塞）

getTransactions

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse> getTransactions(String ledger,
 ZonedDateTime startDateTime,
 ZonedDateTime endDateTime)

返回时间范围内的事务 （非阻塞）

getTransactionsSync

public QueryProto.GetTransactionsResponse getTransactionsSync(String ledger,
 ZonedDateTime startDateTime)

返回时间范围内的事务 （阻塞）

getTransactionsSync

public QueryProto.GetTransactionsResponse getTransactionsSync(String ledger,
 ZonedDateTime startDateTime,
 ZonedDateTime endDateTime)

返回时间范围内的事务 （阻塞）

getTransactions

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse> getTransactions(String ledger,
 long startUnixTime)

返回时间范围内的事务 （非阻塞）

getTransactions

public com.google.common.util.concurrent.ListenableFuture<QueryProto.GetTransactionsResponse> getTransactions(String ledger,
 long startUnixTime,
 long endUnixTime)

返回时间范围内的事务 （非阻塞）

getTransactionsSync

public QueryProto.GetTransactionsResponse getTransactionsSync(String ledger,
 long startUnixTime)

返回时间范围内的事务 （阻塞）

getTransactionsSync

public QueryProto.GetTransactionsResponse getTransactionsSync(String ledger,
 long startUnixTime,
 long endUnixTime)

返回时间范围内的事务 （阻塞）

countTransactions

public com.google.common.util.concurrent.ListenableFuture<QueryProto.CountTransactionsResponse> countTransactions(String ledger)

返回账本中的事务数量 （非阻塞）

countTransactionsSync

public QueryProto.CountTransactionsResponse countTransactionsSync(String ledger)

返回账本中的事务数量 （阻塞）