ouroboros-network-framework-0.1.0.0

Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Subscription.Client

Synopsis

data ClientSubscriptionParams a = ClientSubscriptionParams {
- cspAddress :: !LocalAddress
- cspConnectionAttemptDelay :: !(Maybe DiffTime)
- cspErrorPolicies :: !ErrorPolicies
}
clientSubscriptionWorker :: LocalSnocket -> Tracer IO (SubscriptionTrace LocalAddress) -> Tracer IO (WithAddr LocalAddress ErrorPolicyTrace) -> NetworkMutableState LocalAddress -> ClientSubscriptionParams a -> (LocalSocket -> IO a) -> IO Void

Documentation

data ClientSubscriptionParams a Source #

Constructors

ClientSubscriptionParams
Fields cspAddress :: !LocalAddress unix socket or named pipe address cspConnectionAttemptDelay :: !(Maybe DiffTime) delay between connection attempts cspErrorPolicies :: !ErrorPolicies error policies for subscription worker

clientSubscriptionWorker :: LocalSnocket -> Tracer IO (SubscriptionTrace LocalAddress) -> Tracer IO (WithAddr LocalAddress ErrorPolicyTrace) -> NetworkMutableState LocalAddress -> ClientSubscriptionParams a -> (LocalSocket -> IO a) -> IO Void Source #

Client subscription worker keeps subsribing to the LocalAddress using either unix socket or named pipe.