ouroboros-network-framework-0.6.0.1: Ouroboros network framework

Safe Haskell	Safe-Inferred
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.