rlpx
Module Contents
alltypes
Module Contents
class DefaultWireConnection : WireConnection
Module Contents
DefaultWireConnection(id: String!, nodeId: Bytes!, peerNodeId: Bytes!, writer: Consumer<RLPxMessage!>!, afterHandshakeListener: Consumer<HelloMessage!>!, disconnectHandler: Runnable!, subprotocols: LinkedHashMap<SubProtocol!, SubProtocolHandler!>!, p2pVersion: Int, clientId: String!, advertisedPort: Int, ready: CompletableAsyncResult<String!>!)
fun disconnect(reason: DisconnectReason!): Unit
fun handleConnectionStart(): Unit
fun id(): String!
fun messageReceived(message: RLPxMessage!): Unit
fun sendMessage(subProtocolIdentifier: SubProtocolIdentifier!, messageType: Int, message: Bytes!): Unit
fun sendPing(): AsyncCompletion!
fun supports(subProtocolIdentifier: SubProtocolIdentifier!): Boolean
fun toString(): String
class DisconnectReason
open class EthereumIESEncryptionEngine
Module Contents
EthereumIESEncryptionEngine(agree: BasicAgreement!, kdf: DerivationFunction!, mac: Mac!, commonMac: ByteArray!)
EthereumIESEncryptionEngine(agree: BasicAgreement!, kdf: DerivationFunction!, mac: Mac!, commonMac: ByteArray!, cipher: BufferedBlockCipher!)
open fun getCipher(): BufferedBlockCipher!
protected open fun getLengthTag(p2: ByteArray!): ByteArray!
open fun getMac(): Mac!
open fun init(forEncryption: Boolean, privParam: CipherParameters!, pubParam: CipherParameters!, params: CipherParameters!): Unit
open fun init(publicKey: AsymmetricKeyParameter!, params: CipherParameters!, ephemeralKeyPairGenerator: EphemeralKeyPairGenerator!): Unit
open fun init(privateKey: AsymmetricKeyParameter!, params: CipherParameters!, publicKeyParser: KeyParser!): Unit
open fun processBlock(in: ByteArray!, inOff: Int, inLen: Int): ByteArray!
interface HandshakeMessage
class HelloMessage : WireProtocolMessage
open class InvalidMACException : RuntimeException
open class MemoryWireConnectionsRepository : WireConnectionRepository
class RLPxConnection
class RLPxConnectionFactory
Module Contents
RLPxConnectionFactory()
static fun createConnection(initiator: Boolean, initiatorMessage: Bytes!, responderMessage: Bytes!, ourEphemeralPrivateKey: SecretKey!, peerEphemeralPublicKey: PublicKey!, initiatorNonce: Bytes32!, responderNonce: Bytes32!, ourPublicKey: PublicKey!, peerPublicKey: PublicKey!): RLPxConnection!
static fun createHandshake(keyPair: KeyPair!, remotePublicKey: PublicKey!, initAndResponse: Function<Bytes!, AsyncResult<Bytes!>!>!): AsyncResult<RLPxConnection!>!
static fun generateRandomBytes32(): Bytes32!
static fun init(keyPair: KeyPair!, remotePublicKey: PublicKey!, ephemeralKeyPair: KeyPair!, initiatorNonce: Bytes32!): Bytes!
static fun messageSize(msgBytes: Bytes!): Int
static fun readResponse(response: Bytes!, privateKey: SecretKey!): HandshakeMessage!
static fun respondToHandshake(initiatorMessageBytes: Bytes!, keyPair: KeyPair!, responseHandler: Consumer<Bytes!>!): RLPxConnection!
class RLPxMessage
interface RLPxService
interface SubProtocol
interface SubProtocolClient
interface SubProtocolHandler
interface SubProtocolIdentifier
class VertxRLPxService : RLPxService
Module Contents
VertxRLPxService(vertx: Vertx!, listenPort: Int, networkInterface: String!, advertisedPort: Int, identityKeyPair: KeyPair!, subProtocols: MutableList<SubProtocol!>!, clientId: String!)
VertxRLPxService(vertx: Vertx!, listenPort: Int, networkInterface: String!, advertisedPort: Int, identityKeyPair: KeyPair!, subProtocols: MutableList<SubProtocol!>!, clientId: String!, repository: WireConnectionRepository!)
fun actualPort(): Int
fun advertisedPort(): Int
fun broadcast(subProtocolIdentifier: SubProtocolIdentifier!, messageType: Int, message: Bytes!): Unit
fun connectTo(peerPublicKey: PublicKey!, peerAddress: InetSocketAddress!): AsyncResult<String!>!
fun disconnect(connectionId: String!, disconnectReason: DisconnectReason!): Unit
fun getClient(subProtocolIdentifier: SubProtocolIdentifier!): SubProtocolClient!
fun repository(): WireConnectionRepository!
fun send(subProtocolIdentifier: SubProtocolIdentifier!, messageType: Int, connectionId: String!, message: Bytes!): Unit
fun start(): AsyncCompletion!
fun stop(): AsyncCompletion!
interface WireConnection
interface WireConnectionRepository
package org.apache.tuweni.rlpx
Module Contents
open class EthereumIESEncryptionEngine
Module Contents
EthereumIESEncryptionEngine(agree: BasicAgreement!, kdf: DerivationFunction!, mac: Mac!, commonMac: ByteArray!)
EthereumIESEncryptionEngine(agree: BasicAgreement!, kdf: DerivationFunction!, mac: Mac!, commonMac: ByteArray!, cipher: BufferedBlockCipher!)
open fun getCipher(): BufferedBlockCipher!
protected open fun getLengthTag(p2: ByteArray!): ByteArray!
open fun getMac(): Mac!
open fun init(forEncryption: Boolean, privParam: CipherParameters!, pubParam: CipherParameters!, params: CipherParameters!): Unit
open fun init(publicKey: AsymmetricKeyParameter!, params: CipherParameters!, ephemeralKeyPairGenerator: EphemeralKeyPairGenerator!): Unit
open fun init(privateKey: AsymmetricKeyParameter!, params: CipherParameters!, publicKeyParser: KeyParser!): Unit
open fun processBlock(in: ByteArray!, inOff: Int, inLen: Int): ByteArray!
interface HandshakeMessage
open class InvalidMACException : RuntimeException
open class MemoryWireConnectionsRepository : WireConnectionRepository
class RLPxConnection
class RLPxConnectionFactory
Module Contents
RLPxConnectionFactory()
static fun createConnection(initiator: Boolean, initiatorMessage: Bytes!, responderMessage: Bytes!, ourEphemeralPrivateKey: SecretKey!, peerEphemeralPublicKey: PublicKey!, initiatorNonce: Bytes32!, responderNonce: Bytes32!, ourPublicKey: PublicKey!, peerPublicKey: PublicKey!): RLPxConnection!
static fun createHandshake(keyPair: KeyPair!, remotePublicKey: PublicKey!, initAndResponse: Function<Bytes!, AsyncResult<Bytes!>!>!): AsyncResult<RLPxConnection!>!
static fun generateRandomBytes32(): Bytes32!
static fun init(keyPair: KeyPair!, remotePublicKey: PublicKey!, ephemeralKeyPair: KeyPair!, initiatorNonce: Bytes32!): Bytes!
static fun messageSize(msgBytes: Bytes!): Int
static fun readResponse(response: Bytes!, privateKey: SecretKey!): HandshakeMessage!
static fun respondToHandshake(initiatorMessageBytes: Bytes!, keyPair: KeyPair!, responseHandler: Consumer<Bytes!>!): RLPxConnection!
class RLPxMessage
interface RLPxService
interface WireConnectionRepository
package org.apache.tuweni.rlpx.vertx
Module Contents
class VertxRLPxService : RLPxService
Module Contents
VertxRLPxService(vertx: Vertx!, listenPort: Int, networkInterface: String!, advertisedPort: Int, identityKeyPair: KeyPair!, subProtocols: MutableList<SubProtocol!>!, clientId: String!)
VertxRLPxService(vertx: Vertx!, listenPort: Int, networkInterface: String!, advertisedPort: Int, identityKeyPair: KeyPair!, subProtocols: MutableList<SubProtocol!>!, clientId: String!, repository: WireConnectionRepository!)
fun actualPort(): Int
fun advertisedPort(): Int
fun broadcast(subProtocolIdentifier: SubProtocolIdentifier!, messageType: Int, message: Bytes!): Unit
fun connectTo(peerPublicKey: PublicKey!, peerAddress: InetSocketAddress!): AsyncResult<String!>!
fun disconnect(connectionId: String!, disconnectReason: DisconnectReason!): Unit
fun getClient(subProtocolIdentifier: SubProtocolIdentifier!): SubProtocolClient!
fun repository(): WireConnectionRepository!
fun send(subProtocolIdentifier: SubProtocolIdentifier!, messageType: Int, connectionId: String!, message: Bytes!): Unit
fun start(): AsyncCompletion!
fun stop(): AsyncCompletion!
package org.apache.tuweni.rlpx.wire
Module Contents
class DefaultWireConnection : WireConnection
Module Contents
DefaultWireConnection(id: String!, nodeId: Bytes!, peerNodeId: Bytes!, writer: Consumer<RLPxMessage!>!, afterHandshakeListener: Consumer<HelloMessage!>!, disconnectHandler: Runnable!, subprotocols: LinkedHashMap<SubProtocol!, SubProtocolHandler!>!, p2pVersion: Int, clientId: String!, advertisedPort: Int, ready: CompletableAsyncResult<String!>!)
fun disconnect(reason: DisconnectReason!): Unit
fun handleConnectionStart(): Unit
fun id(): String!
fun messageReceived(message: RLPxMessage!): Unit
fun sendMessage(subProtocolIdentifier: SubProtocolIdentifier!, messageType: Int, message: Bytes!): Unit
fun sendPing(): AsyncCompletion!
fun supports(subProtocolIdentifier: SubProtocolIdentifier!): Boolean
fun toString(): String
class DisconnectReason
class HelloMessage : WireProtocolMessage
interface SubProtocol
interface SubProtocolClient
interface SubProtocolHandler
interface SubProtocolIdentifier
interface WireConnection