Erebos.Network.Protocol

Documentation

data TransportPacket a

Constructors

TransportPacket TransportHeader [a]

transportToObject :: PartialStorage -> TransportHeader -> PartialObject

data TransportHeader

Constructors

TransportHeader [TransportHeaderItem]

Instances

Show TransportHeader

Defined in Erebos.Network.Protocol

Methods

showsPrec :: Int -> TransportHeader -> ShowS

show :: TransportHeader -> String

showList :: [TransportHeader] -> ShowS

data TransportHeaderItem

Constructors

Acknowledged RefDigest

AcknowledgedSingle Integer

Rejected RefDigest

ProtocolVersion Text

Initiation RefDigest

CookieSet Cookie

CookieEcho Cookie

DataRequest RefDigest

DataResponse RefDigest

AnnounceSelf RefDigest

AnnounceUpdate RefDigest

TrChannelRequest RefDigest

TrChannelAccept RefDigest

ServiceType ServiceID

ServiceRef RefDigest

Instances

Show TransportHeaderItem

Defined in Erebos.Network.Protocol

Methods

showsPrec :: Int -> TransportHeaderItem -> ShowS

show :: TransportHeaderItem -> String

showList :: [TransportHeaderItem] -> ShowS

Eq TransportHeaderItem

Defined in Erebos.Network.Protocol

Methods

(==) :: TransportHeaderItem -> TransportHeaderItem -> Bool

(/=) :: TransportHeaderItem -> TransportHeaderItem -> Bool

data WaitingRef

Constructors

WaitingRef

Fields

• wrefStorage :: Storage
• wrefPartial :: PartialRef
• wrefAction :: Ref -> WaitingRefCallback
• wrefStatus :: TVar (Either [RefDigest] Ref)

type WaitingRefCallback = ExceptT String IO ()

wrDigest :: WaitingRef -> RefDigest

data ChannelState

Constructors

ChannelNone

ChannelCookieWait

ChannelCookieReceived Cookie

ChannelCookieConfirmed Cookie

ChannelOurRequest (Maybe Cookie) (Stored ChannelRequest)

ChannelPeerRequest (Maybe Cookie) WaitingRef

ChannelOurAccept (Maybe Cookie) (Stored ChannelAccept) Channel

ChannelEstablished Channel

data ControlRequest addr

Constructors

RequestConnection addr

SendAnnounce addr

UpdateSelfIdentity UnifiedIdentity

data ControlMessage addr

Constructors

NewConnection (Connection addr) (Maybe RefDigest)

ReceivedAnnounce addr RefDigest

erebosNetworkProtocol :: (Eq addr, Ord addr, Show addr) => UnifiedIdentity -> (String -> STM ()) -> SymFlow (addr, ByteString) -> Flow (ControlRequest addr) (ControlMessage addr) -> IO ()

data Connection addr

connAddress :: Connection addr -> addr

connData :: Connection addr -> Flow (Bool, TransportPacket PartialObject) (Bool, TransportPacket Ref, [TransportHeaderItem])

connGetChannel :: Connection addr -> STM ChannelState

connSetChannel :: Connection addr -> ChannelState -> STM ()

data Flow r w

type SymFlow a = Flow a a

newFlow :: STM (Flow a b, Flow b a)

newFlowIO :: IO (Flow a b, Flow b a)

readFlow :: Flow r w -> STM r

tryReadFlow :: Flow r w -> STM (Maybe r)

canReadFlow :: Flow r w -> STM Bool

writeFlow :: Flow r w -> w -> STM ()

writeFlowBulk :: Flow r w -> [w] -> STM ()

tryWriteFlow :: Flow r w -> w -> STM Bool

canWriteFlow :: Flow r w -> STM Bool

readFlowIO :: Flow r w -> IO r

writeFlowIO :: Flow r w -> w -> IO ()

mapFlow :: (r -> r') -> (w' -> w) -> Flow r w -> Flow r' w'