com.exonum.binding.service

Class NodeProxy

java.lang.Object

com.exonum.binding.proxy.AbstractNativeProxy

com.exonum.binding.proxy.AbstractCloseableNativeProxy

com.exonum.binding.service.NodeProxy

All Implemented Interfaces:

CloseableNativeProxy, Node, java.lang.AutoCloseable

public final class NodeProxy
extends AbstractCloseableNativeProxy
implements Node

An Exonum node context. Allows to add transactions to Exonum network and get a snapshot of the database state.

Field Summary

Fields inherited from class com.exonum.binding.proxy.AbstractNativeProxy

nativeHandle

Constructor Summary

Constructors

Constructor and Description
NodeProxy(long nativeHandle, ViewFactory viewFactory) Creates a proxy of a node.

Method Summary

Modifier and Type	Method and Description
protected void	disposeInternal() Releases any resources owned by this proxy (e.g., the corresponding native object).
byte[]	getPublicKey() Returns the public key of this node.
void	submitTransaction(Transaction transaction) Submits a transaction into Exonum network.
<ResultT> ResultT	withSnapshot(java.util.function.Function<Snapshot,ResultT> snapshotFunction) Performs a given function with a snapshot of the current database state.

Methods inherited from class com.exonum.binding.proxy.AbstractCloseableNativeProxy

close, getNativeHandle

Methods inherited from class com.exonum.binding.proxy.AbstractNativeProxy

isValidHandle

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeProxy

public NodeProxy(long nativeHandle,
                 ViewFactory viewFactory)

Creates a proxy of a node. Native code owns the node, and, therefore, shall destroy the object.

Parameters:

nativeHandle - an implementation-specific reference to a native node

viewFactory - a factory to instantiate native database views

Method Detail

submitTransaction

public void submitTransaction(Transaction transaction)
                       throws InvalidTransactionException,
                              InternalServerError

Submits a transaction into Exonum network. This node does not execute the transaction immediately, but verifies it and, if it is valid, broadcasts it to all the nodes in the network. Then each node adds the transaction to a pool of unconfirmed transactions. The transaction is executed later asynchronously.

Specified by:

submitTransaction in interface Node

Parameters:

transaction - a transaction to send

Throws:

java.lang.IllegalStateException - if the node proxy is closed

InvalidTransactionException - if the transaction is not valid

InternalServerError - if this node failed to process the transaction

withSnapshot

public <ResultT> ResultT withSnapshot(java.util.function.Function<Snapshot,ResultT> snapshotFunction)

Performs a given function with a snapshot of the current database state.

Specified by:

withSnapshot in interface Node

Type Parameters:

ResultT - a type the function returns

Parameters:

snapshotFunction - a function to execute

Returns:

the result of applying the given function to the database state

Throws:

java.lang.IllegalStateException - if the node proxy is closed

getPublicKey

public byte[] getPublicKey()

Returns the public key of this node.

Specified by:

getPublicKey in interface Node

Throws:

java.lang.IllegalStateException - if the node proxy is closed

disposeInternal

protected void disposeInternal()

Description copied from class: AbstractCloseableNativeProxy

Releases any resources owned by this proxy (e.g., the corresponding native object).

This method is only called once from AbstractCloseableNativeProxy.close() for a valid proxy and shall not be called directly.

Specified by:

disposeInternal in class AbstractCloseableNativeProxy