plumtree
Module Contents
alltypes
Module Contents
class EphemeralPeerRepository : PeerRepository
interface MessageHashing
interface MessageListener
interface MessageSender
interface MessageValidator
interface Peer
interface PeerPruning
interface PeerRepository
class State
Module Contents
State(peerRepository: PeerRepository!, messageHashingFunction: MessageHashing!, messageSender: MessageSender!, messageListener: MessageListener!, messageValidator: MessageValidator!, peerPruningFunction: PeerPruning!)
State(peerRepository: PeerRepository!, messageHashingFunction: MessageHashing!, messageSender: MessageSender!, messageListener: MessageListener!, messageValidator: MessageValidator!, peerPruningFunction: PeerPruning!, graftDelay: Long, lazyQueueInterval: Long)
fun addPeer(peer: Peer!): Unit
fun receiveGossipMessage(peer: Peer!, attributes: String!, message: Bytes!, messageHash: Bytes!): Unit
fun receiveGraftMessage(peer: Peer!, messageHash: Bytes!): Unit
fun receiveIHaveMessage(peer: Peer!, messageHash: Bytes!): Unit
fun receivePruneMessage(peer: Peer!): Unit
fun removePeer(peer: Peer!): Unit
fun sendGossipMessage(attributes: String!, message: Bytes!): Bytes!
fun stop(): Unit
class VertxGossipServer
Module Contents
VertxGossipServer(vertx: Vertx!, networkInterface: String!, port: Int, messageHashing: MessageHashing!, peerRepository: PeerRepository!, payloadListener: MessageListener!, @Nullable payloadValidator: MessageValidator?, @Nullable peerPruningFunction: PeerPruning?, graftDelay: Int, lazyQueueInterval: Int)
fun connectTo(host: String!, port: Int): AsyncCompletion!
fun gossip(attributes: String!, message: Bytes!): Unit
fun start(): AsyncCompletion!
fun stop(): AsyncCompletion!
package org.apache.tuweni.plumtree
Module Contents
class EphemeralPeerRepository : PeerRepository
interface MessageHashing
interface MessageListener
interface MessageSender
interface MessageValidator
interface Peer
interface PeerPruning
interface PeerRepository
class State
Module Contents
State(peerRepository: PeerRepository!, messageHashingFunction: MessageHashing!, messageSender: MessageSender!, messageListener: MessageListener!, messageValidator: MessageValidator!, peerPruningFunction: PeerPruning!)
State(peerRepository: PeerRepository!, messageHashingFunction: MessageHashing!, messageSender: MessageSender!, messageListener: MessageListener!, messageValidator: MessageValidator!, peerPruningFunction: PeerPruning!, graftDelay: Long, lazyQueueInterval: Long)
fun addPeer(peer: Peer!): Unit
fun receiveGossipMessage(peer: Peer!, attributes: String!, message: Bytes!, messageHash: Bytes!): Unit
fun receiveGraftMessage(peer: Peer!, messageHash: Bytes!): Unit
fun receiveIHaveMessage(peer: Peer!, messageHash: Bytes!): Unit
fun receivePruneMessage(peer: Peer!): Unit
fun removePeer(peer: Peer!): Unit
fun sendGossipMessage(attributes: String!, message: Bytes!): Bytes!
fun stop(): Unit
package org.apache.tuweni.plumtree.vertx
Module Contents
class VertxGossipServer
Module Contents
VertxGossipServer(vertx: Vertx!, networkInterface: String!, port: Int, messageHashing: MessageHashing!, peerRepository: PeerRepository!, payloadListener: MessageListener!, @Nullable payloadValidator: MessageValidator?, @Nullable peerPruningFunction: PeerPruning?, graftDelay: Int, lazyQueueInterval: Int)
fun connectTo(host: String!, port: Int): AsyncCompletion!
fun gossip(attributes: String!, message: Bytes!): Unit
fun start(): AsyncCompletion!
fun stop(): AsyncCompletion!