Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Subscription

Contents

IP Subscription Worker
DNS Subscription Worker
Constants
Errors
Tracing

Description

Public interface of Subscription workers.

Synopsis

ipSubscriptionWorker :: forall a. Snocket IO Socket SockAddr -> Tracer IO (WithIPList (SubscriptionTrace SockAddr)) -> Tracer IO (WithAddr SockAddr ErrorPolicyTrace) -> NetworkMutableState SockAddr -> IPSubscriptionParams a -> (Socket -> IO a) -> IO Void
data IPSubscriptionTarget = IPSubscriptionTarget {
- ispIps :: ![SockAddr]
- ispValency :: !Int
}
dnsSubscriptionWorker :: Snocket IO Socket SockAddr -> Tracer IO (WithDomainName (SubscriptionTrace SockAddr)) -> Tracer IO (WithDomainName DnsTrace) -> Tracer IO (WithAddr SockAddr ErrorPolicyTrace) -> NetworkMutableState SockAddr -> DnsSubscriptionParams a -> (Socket -> IO a) -> IO Void
data DnsSubscriptionTarget = DnsSubscriptionTarget {
- dstDomain :: !Domain
- dstPort :: !PortNumber
- dstValency :: !Int
}
data ConnectResult
defaultConnectionAttemptDelay :: DiffTime
minConnectionAttemptDelay :: DiffTime
maxConnectionAttemptDelay :: DiffTime
ipRetryDelay :: DiffTime
resolutionDelay :: DiffTime
data SubscriberError = SubscriberError {
- seType :: !SubscriberErrorType
- seMessage :: !String
- seStack :: !CallStack
}
data SubscriptionTrace addr
- = SubscriptionTraceConnectStart addr
- | SubscriptionTraceConnectEnd addr ConnectResult
- | forall e.Exception e => SubscriptionTraceSocketAllocationException addr e
- | forall e.Exception e => SubscriptionTraceConnectException addr e
- | forall e.Exception e => SubscriptionTraceApplicationException addr e
- | SubscriptionTraceTryConnectToPeer addr
- | SubscriptionTraceSkippingPeer addr
- | SubscriptionTraceSubscriptionRunning
- | SubscriptionTraceSubscriptionWaiting Int
- | SubscriptionTraceSubscriptionFailed
- | SubscriptionTraceSubscriptionWaitingNewConnection DiffTime
- | SubscriptionTraceStart Int
- | SubscriptionTraceRestart DiffTime Int Int
- | SubscriptionTraceConnectionExist addr
- | SubscriptionTraceUnsupportedRemoteAddr addr
- | SubscriptionTraceMissingLocalAddress
- | SubscriptionTraceAllocateSocket addr
- | SubscriptionTraceCloseSocket addr
data WithIPList a = WithIPList {
- wilSrc :: !(LocalAddresses SockAddr)
- wilDsts :: ![SockAddr]
- wilEvent :: !a
}
data DnsTrace
- = DnsTraceLookupException SomeException
- | DnsTraceLookupAError DNSError
- | DnsTraceLookupAAAAError DNSError
- | DnsTraceLookupIPv6First
- | DnsTraceLookupIPv4First
- | DnsTraceLookupAResult [SockAddr]
- | DnsTraceLookupAAAAResult [SockAddr]
data WithDomainName a = WithDomainName {
- wdnDomain :: !Domain
- wdnEvent :: !a
}

IP Subscription Worker

ipSubscriptionWorker :: forall a. Snocket IO Socket SockAddr -> Tracer IO (WithIPList (SubscriptionTrace SockAddr)) -> Tracer IO (WithAddr SockAddr ErrorPolicyTrace) -> NetworkMutableState SockAddr -> IPSubscriptionParams a -> (Socket -> IO a) -> IO Void Source #

Spawns a subscription worker which will attempt to keep the specified number of connections (Valency) active towards the list of IP addresses given in IPSubscriptionTarget.

data IPSubscriptionTarget Source #

Constructors

IPSubscriptionTarget
Fields ispIps :: ![SockAddr] List of destinations to possibly connect to ispValency :: !Int Number of parallel connections to keep actice.

Instances

Instances details

Eq IPSubscriptionTarget Source #
Instance details Defined in Ouroboros.Network.Subscription.Ip Methods (==) :: IPSubscriptionTarget -> IPSubscriptionTarget -> Bool # (/=) :: IPSubscriptionTarget -> IPSubscriptionTarget -> Bool #
Show IPSubscriptionTarget Source #
Instance details Defined in Ouroboros.Network.Subscription.Ip Methods showsPrec :: Int -> IPSubscriptionTarget -> ShowS # show :: IPSubscriptionTarget -> String # showList :: [IPSubscriptionTarget] -> ShowS #

DNS Subscription Worker

dnsSubscriptionWorker :: Snocket IO Socket SockAddr -> Tracer IO (WithDomainName (SubscriptionTrace SockAddr)) -> Tracer IO (WithDomainName DnsTrace) -> Tracer IO (WithAddr SockAddr ErrorPolicyTrace) -> NetworkMutableState SockAddr -> DnsSubscriptionParams a -> (Socket -> IO a) -> IO Void Source #

data DnsSubscriptionTarget Source #

Constructors

DnsSubscriptionTarget
Fields dstDomain :: !Domain dstPort :: !PortNumber dstValency :: !Int

Instances

Instances details

Eq DnsSubscriptionTarget Source #
Instance details Defined in Ouroboros.Network.Subscription.Dns Methods (==) :: DnsSubscriptionTarget -> DnsSubscriptionTarget -> Bool # (/=) :: DnsSubscriptionTarget -> DnsSubscriptionTarget -> Bool #
Show DnsSubscriptionTarget Source #
Instance details Defined in Ouroboros.Network.Subscription.Dns Methods showsPrec :: Int -> DnsSubscriptionTarget -> ShowS # show :: DnsSubscriptionTarget -> String # showList :: [DnsSubscriptionTarget] -> ShowS #

data ConnectResult Source #

GADT which classifies connection result.

Constructors

ConnectSuccess	Successful connection.
ConnectSuccessLast	Successfully connection, reached the valency target. Other ongoing connection attempts will be killed.
ConnectValencyExceeded	Someone else manged to create the final connection to a target before us.

Instances

Instances details

Eq ConnectResult Source #
Instance details Defined in Ouroboros.Network.Subscription.Worker Methods (==) :: ConnectResult -> ConnectResult -> Bool # (/=) :: ConnectResult -> ConnectResult -> Bool #
Ord ConnectResult Source #
Instance details Defined in Ouroboros.Network.Subscription.Worker Methods compare :: ConnectResult -> ConnectResult -> Ordering # (<) :: ConnectResult -> ConnectResult -> Bool # (<=) :: ConnectResult -> ConnectResult -> Bool # (>) :: ConnectResult -> ConnectResult -> Bool # (>=) :: ConnectResult -> ConnectResult -> Bool # max :: ConnectResult -> ConnectResult -> ConnectResult # min :: ConnectResult -> ConnectResult -> ConnectResult #
Show ConnectResult Source #
Instance details Defined in Ouroboros.Network.Subscription.Worker Methods showsPrec :: Int -> ConnectResult -> ShowS # show :: ConnectResult -> String # showList :: [ConnectResult] -> ShowS #

Constants

defaultConnectionAttemptDelay :: DiffTime Source #

Time to wait between connection attempts when we don't have any DeltaQ info.

minConnectionAttemptDelay :: DiffTime Source #

Minimum time to wait between connection attempts.

maxConnectionAttemptDelay :: DiffTime Source #

Maximum time to wait between connection attempts.

ipRetryDelay :: DiffTime Source #

Minimum time to wait between ip reconnects

resolutionDelay :: DiffTime Source #

Time to wait for an AAAA response after receiving an A response.

Errors

data SubscriberError Source #

Constructors

SubscriberError
Fields seType :: !SubscriberErrorType seMessage :: !String seStack :: !CallStack

Instances

Instances details

Show SubscriberError Source #
Instance details Defined in Ouroboros.Network.Subscription.Worker Methods showsPrec :: Int -> SubscriberError -> ShowS # show :: SubscriberError -> String # showList :: [SubscriberError] -> ShowS #
Exception SubscriberError Source #
Instance details Defined in Ouroboros.Network.Subscription.Worker Methods toException :: SubscriberError -> SomeException # fromException :: SomeException -> Maybe SubscriberError # displayException :: SubscriberError -> String #

Tracing

data SubscriptionTrace addr Source #

Instances

Instances details

Show addr => Show (SubscriptionTrace addr) Source #
Instance details Defined in Ouroboros.Network.Subscription.Worker Methods showsPrec :: Int -> SubscriptionTrace addr -> ShowS # show :: SubscriptionTrace addr -> String # showList :: [SubscriptionTrace addr] -> ShowS #

data WithIPList a Source #

Constructors

WithIPList
Fields wilSrc :: !(LocalAddresses SockAddr) wilDsts :: ![SockAddr] wilEvent :: !a

Instances

Instances details

Show a => Show (WithIPList a) Source #
Instance details Defined in Ouroboros.Network.Subscription.Ip Methods showsPrec :: Int -> WithIPList a -> ShowS # show :: WithIPList a -> String # showList :: [WithIPList a] -> ShowS #

data DnsTrace Source #

Constructors

DnsTraceLookupException SomeException
DnsTraceLookupAError DNSError
DnsTraceLookupAAAAError DNSError
DnsTraceLookupIPv6First
DnsTraceLookupIPv4First
DnsTraceLookupAResult [SockAddr]
DnsTraceLookupAAAAResult [SockAddr]

Instances

Instances details

Show DnsTrace Source #
Instance details Defined in Ouroboros.Network.Subscription.Dns Methods showsPrec :: Int -> DnsTrace -> ShowS # show :: DnsTrace -> String # showList :: [DnsTrace] -> ShowS #

data WithDomainName a Source #

Constructors

WithDomainName
Fields wdnDomain :: !Domain wdnEvent :: !a

Instances

Instances details

Show a => Show (WithDomainName a) Source #
Instance details Defined in Ouroboros.Network.Subscription.Dns Methods showsPrec :: Int -> WithDomainName a -> ShowS # show :: WithDomainName a -> String # showList :: [WithDomainName a] -> ShowS #

SubscriptionTraceConnectStart addr
SubscriptionTraceConnectEnd addr ConnectResult
forall e.Exception e => SubscriptionTraceSocketAllocationException addr e
forall e.Exception e => SubscriptionTraceConnectException addr e
forall e.Exception e => SubscriptionTraceApplicationException addr e
SubscriptionTraceTryConnectToPeer addr
SubscriptionTraceSkippingPeer addr
SubscriptionTraceSubscriptionRunning
SubscriptionTraceSubscriptionWaiting Int
SubscriptionTraceSubscriptionFailed
SubscriptionTraceSubscriptionWaitingNewConnection DiffTime
SubscriptionTraceStart Int
SubscriptionTraceRestart DiffTime Int Int
SubscriptionTraceConnectionExist addr
SubscriptionTraceUnsupportedRemoteAddr addr
SubscriptionTraceMissingLocalAddress
SubscriptionTraceAllocateSocket addr
SubscriptionTraceCloseSocket addr