TxGossipArmeriaAdapter

org.sigilaris.node.jvm.transport.armeria.gossip.TxGossipArmeriaAdapter

Server-side Armeria/Tapir adapter for transaction gossip protocol endpoints.

Exposes session open, event stream polling, control batch, and disconnect endpoints with transport authentication.

Attributes

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

Members list

Value members

Concrete methods

def endpoints[F[_] : Async, A : ByteEncoder](runtime: TxGossipRuntime[F, A], transportAuth: StaticPeerTransportAuth): List[ServerEndpoint[Fs2Streams[F], F]]

Creates the list of Tapir server endpoints for the transaction gossip protocol.

Creates the list of Tapir server endpoints for the transaction gossip protocol.

Type parameters

A

the gossip artifact type

F

the effect type

Value parameters

runtime

transaction gossip runtime handling session and message logic

transportAuth

transport authentication for verifying peer requests

Attributes

Returns

list of server endpoints for session open, events, control, and disconnect

Source
TxGossipArmeriaAdapter.scala
def finiteEndpoints[F[_] : Async, A : ByteEncoder](runtime: TxGossipRuntime[F, A], transportAuth: StaticPeerTransportAuth): List[ServerEndpoint[Fs2Streams[F], F]]

Creates finite request/response endpoints that keep the generic server request-timeout guard.

Creates finite request/response endpoints that keep the generic server request-timeout guard.

Attributes

Source
TxGossipArmeriaAdapter.scala
def streamEndpoints[F[_] : Async, A : ByteEncoder](runtime: TxGossipRuntime[F, A], transportAuth: StaticPeerTransportAuth): List[ServerEndpoint[Fs2Streams[F], F]]

Creates long-lived streaming endpoints that should be mounted with a stream-scoped timeout policy.

Creates long-lived streaming endpoints that should be mounted with a stream-scoped timeout policy.

Attributes

Source
TxGossipArmeriaAdapter.scala