Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Subscription.Dns

Contents

Traces

Synopsis

data DnsSubscriptionTarget = DnsSubscriptionTarget {
- dstDomain :: ! Domain
- dstPort :: ! PortNumber
- dstValency :: ! Int
}
data Resolver m = Resolver {
- lookupA :: Domain -> m ( Either DNSError [ SockAddr ])
- lookupAAAA :: Domain -> m ( Either DNSError [ SockAddr ])
}
type DnsSubscriptionParams a = SubscriptionParams a DnsSubscriptionTarget
dnsSubscriptionWorker' :: Snocket IO Socket SockAddr -> Tracer IO ( WithDomainName ( SubscriptionTrace SockAddr )) -> Tracer IO ( WithDomainName DnsTrace ) -> Tracer IO ( WithAddr SockAddr ErrorPolicyTrace ) -> NetworkMutableState SockAddr -> IO b -> (b -> ( Resolver IO -> IO ( SubscriptionTarget IO SockAddr )) -> IO ( SubscriptionTarget IO SockAddr )) -> DnsSubscriptionParams a -> Main IO ( PeerStates IO SockAddr ) x -> ( Socket -> IO a) -> IO x
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
dnsResolve :: forall a m s. ( MonadAsync m, MonadCatch m, MonadTime m, MonadTimer m) => Tracer m DnsTrace -> m a -> (a -> ( Resolver m -> m ( SubscriptionTarget m SockAddr )) -> m ( SubscriptionTarget m SockAddr )) -> StrictTVar m s -> BeforeConnect m s SockAddr -> DnsSubscriptionTarget -> m ( SubscriptionTarget m SockAddr )
resolutionDelay :: DiffTime
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 DnsTrace
- = DnsTraceLookupException SomeException
- | DnsTraceLookupAError DNSError
- | DnsTraceLookupAAAAError DNSError
- | DnsTraceLookupIPv6First
- | DnsTraceLookupIPv4First
- | DnsTraceLookupAResult [ SockAddr ]
- | DnsTraceLookupAAAAResult [ SockAddr ]
data ErrorPolicyTrace
- = ErrorPolicySuspendPeer ( Maybe (ConnectionOrApplicationExceptionTrace SomeException )) DiffTime DiffTime
- | ErrorPolicySuspendConsumer ( Maybe (ConnectionOrApplicationExceptionTrace SomeException )) DiffTime
- | ErrorPolicyLocalNodeError (ConnectionOrApplicationExceptionTrace SomeException )
- | ErrorPolicyResumePeer
- | ErrorPolicyKeepSuspended
- | ErrorPolicyResumeConsumer
- | ErrorPolicyResumeProducer
- | ErrorPolicyUnhandledApplicationException SomeException
- | ErrorPolicyUnhandledConnectionException SomeException
- | ErrorPolicyAcceptException IOException
data WithDomainName a = WithDomainName {
- wdnDomain :: Domain
- wdnEvent :: a
}
data WithAddr addr a = WithAddr {
- wiaAddr :: addr
- wiaEvent :: a
}

Documentation

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

data Resolver m Source #

Constructors

Resolver
Fields lookupA :: Domain -> m ( Either DNSError [ SockAddr ]) lookupAAAA :: Domain -> m ( Either DNSError [ SockAddr ])

type DnsSubscriptionParams a = SubscriptionParams a DnsSubscriptionTarget Source #

dnsSubscriptionWorker' :: Snocket IO Socket SockAddr -> Tracer IO ( WithDomainName ( SubscriptionTrace SockAddr )) -> Tracer IO ( WithDomainName DnsTrace ) -> Tracer IO ( WithAddr SockAddr ErrorPolicyTrace ) -> NetworkMutableState SockAddr -> IO b -> (b -> ( Resolver IO -> IO ( SubscriptionTarget IO SockAddr )) -> IO ( SubscriptionTarget IO SockAddr )) -> DnsSubscriptionParams a -> Main IO ( PeerStates IO SockAddr ) x -> ( Socket -> IO a) -> IO x Source #

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 #

dnsResolve :: forall a m s. ( MonadAsync m, MonadCatch m, MonadTime m, MonadTimer m) => Tracer m DnsTrace -> m a -> (a -> ( Resolver m -> m ( SubscriptionTarget m SockAddr )) -> m ( SubscriptionTarget m SockAddr )) -> StrictTVar m s -> BeforeConnect m s SockAddr -> DnsSubscriptionTarget -> m ( SubscriptionTarget m SockAddr ) Source #

resolutionDelay :: DiffTime Source #

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

Traces

data SubscriptionTrace addr Source #

Constructors

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

Instances

Instances details

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

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 Source # show :: DnsTrace -> String Source # showList :: [ DnsTrace ] -> ShowS Source #

data ErrorPolicyTrace Source #

Trace data for error policies

Constructors

ErrorPolicySuspendPeer ( Maybe (ConnectionOrApplicationExceptionTrace SomeException )) DiffTime DiffTime	suspending peer with a given exception until
ErrorPolicySuspendConsumer ( Maybe (ConnectionOrApplicationExceptionTrace SomeException )) DiffTime	suspending consumer until
ErrorPolicyLocalNodeError (ConnectionOrApplicationExceptionTrace SomeException )	caught a local exception
ErrorPolicyResumePeer	resume a peer (both consumer and producer)
ErrorPolicyKeepSuspended	consumer was suspended until producer will resume
ErrorPolicyResumeConsumer	resume consumer
ErrorPolicyResumeProducer	resume producer
ErrorPolicyUnhandledApplicationException SomeException	an application throwed an exception, which was not handled by any `ErrorPolicy` .
ErrorPolicyUnhandledConnectionException SomeException	`connect` throwed an exception, which was not handled by any `ErrorPolicy` .
ErrorPolicyAcceptException IOException	`accept` throwed an exception

Instances

Instances details

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

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 Source # show :: WithDomainName a -> String Source # showList :: [ WithDomainName a] -> ShowS Source #

data WithAddr addr a Source #

Constructors

WithAddr
Fields wiaAddr :: addr wiaEvent :: a

Instances

Instances details

( Show addr, Show a) => Show ( WithAddr addr a) Source #
Instance details Defined in Ouroboros.Network.ErrorPolicy Methods showsPrec :: Int -> WithAddr addr a -> ShowS Source # show :: WithAddr addr a -> String Source # showList :: [ WithAddr addr a] -> ShowS Source #