| Safe Haskell | Safe-Inferred |
|---|---|
| Language | Haskell2010 |
Test.Consensus.PeerSimulator.BlockFetch
Description
Functions that call to the BlockFetch API to start clients and servers
Documentation
Arguments
| ∷ (IOLike m, MonadTime m, MonadTimer m, HasHeader blk, HasHeader (Header blk), ShowProxy blk) | |
| ⇒ Tracer m (TraceEvent blk) | |
| → PeerId | |
| → BlockFetchTimeout | |
| → StateViewTracers blk m | |
| → FetchClientRegistry PeerId (Header blk) blk m | |
| → ControlMessageSTM m | |
| → Channel m (AnyMessage (BlockFetch blk (Point blk))) | Send and receive message via the given |
| → m () |
Arguments
| ∷ (IOLike m, ShowProxy blk) | |
| ⇒ Tracer m (TraceEvent blk) | |
| → PeerId | |
| → StateViewTracers blk m | |
| → BlockFetchServer blk (Point blk) m () | |
| → Channel m (AnyMessage (BlockFetch blk (Point blk))) | Send and receive message via the given |
| → m () |
startBlockFetchLogic ∷ ∀ m. IOLike m ⇒ ResourceRegistry m → Tracer m (TraceEvent TestBlock) → ChainDB m TestBlock → FetchClientRegistry PeerId (Header TestBlock) TestBlock m → STM m (Map PeerId (AnchoredFragment (Header TestBlock))) → m () Source #
startKeepAliveThread ∷ ∀ m peer blk. (Ord peer, IOLike m) ⇒ ResourceRegistry m → FetchClientRegistry peer (Header blk) blk m → peer → m () Source #