TxGossipPeerClient

org.sigilaris.node.jvm.transport.armeria.gossip.TxGossipPeerClient
See theTxGossipPeerClient companion trait

Attributes

Companion
trait
Source
TxGossipPeerClient.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply[F[_] : Async, A : ByteDecoder](baseUri: URI, transportAuth: StaticPeerTransportAuth, authenticatedPeer: PeerIdentity, backend: Backend[F], streamBackend: StreamBackend[F, Fs2Streams[F]], requestGate: Semaphore[F], streamGate: Semaphore[F], requestTimeout: Duration, streamRequestTimeout: Duration, streamIdleTimeout: Duration): TxGossipPeerClient[F, A]

Attributes

Source
TxGossipPeerClient.scala
def resource[F[_] : Async, A : ByteDecoder](baseUri: URI, transportAuth: StaticPeerTransportAuth, authenticatedPeer: PeerIdentity, requestTimeout: Duration, streamRequestTimeout: Duration, streamIdleTimeout: Duration, maxConcurrentRequests: Int): Resource[F, TxGossipPeerClient[F, A]]

Attributes

Source
TxGossipPeerClient.scala

Concrete fields

val DefaultRequestTimeout: Duration

Attributes

Source
TxGossipPeerClient.scala
val DefaultStreamIdleTimeout: Duration

Attributes

Source
TxGossipPeerClient.scala

Attributes

Source
TxGossipPeerClient.scala