TxGossipTapirEndpoints

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

Shared Tapir endpoint definitions for the transaction gossip peer protocol.

Attributes

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

Members list

Value members

Concrete methods

def controlPath(sessionId: String): String

Attributes

Source
TxGossipTapirEndpoints.scala
def disconnectPath(sessionId: String): String

Attributes

Source
TxGossipTapirEndpoints.scala
def eventStreamOpen[F[_]]: Endpoint[Unit, (String, Option[String], Option[String], String), String, Stream[F, Byte], Fs2Streams[F]]

Attributes

Source
TxGossipTapirEndpoints.scala
def eventStreamOpenPath(sessionId: String): String

Attributes

Source
TxGossipTapirEndpoints.scala
def eventStreamPath(sessionId: String): String

Attributes

Source
TxGossipTapirEndpoints.scala

Concrete fields

val SessionOpenPath: String

Attributes

Source
TxGossipTapirEndpoints.scala
val all: List[AnyEndpoint]

Attributes

Source
TxGossipTapirEndpoints.scala
val control: Endpoint[Unit, (String, Option[String], Option[String], String), String, String, Any]

Attributes

Source
TxGossipTapirEndpoints.scala
val disconnect: Endpoint[Unit, (String, Option[String], Option[String]), String, String, Any]

Attributes

Source
TxGossipTapirEndpoints.scala
val eventStream: Endpoint[Unit, (String, Option[String], Option[String], String), Unit, Array[Byte], Any]

Attributes

Source
TxGossipTapirEndpoints.scala
val sessionOpen: Endpoint[Unit, (Option[String], Option[String], String), String, String, Any]

Attributes

Source
TxGossipTapirEndpoints.scala