GossipArtifactSource

org.sigilaris.node.gossip.GossipArtifactSource
trait GossipArtifactSource[F[_], A]

Source of gossip artifacts for a producer to read from.

Type parameters

A

the artifact payload type

F

the effect type

Attributes

Source
Contracts.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def readAfter(chainId: ChainId, topic: GossipTopic, cursor: Option[CursorToken]): F[Either[CanonicalRejection, Vector[AvailableGossipEvent[A]]]]

Reads available events after the given cursor position.

Reads available events after the given cursor position.

Value parameters

chainId

the chain to read from

cursor

optional cursor; None starts from the beginning

topic

the gossip topic

Attributes

Returns

events after the cursor, or a rejection on error

Source
Contracts.scala
def readByIds(chainId: ChainId, topic: GossipTopic, ids: Vector[StableArtifactId]): F[Vector[AvailableGossipEvent[A]]]

Reads events by their stable artifact identifiers.

Reads events by their stable artifact identifiers.

Value parameters

chainId

the chain to read from

ids

the artifact identifiers to look up

topic

the gossip topic

Attributes

Returns

the matching available events

Source
Contracts.scala