Documentation

coordinatorWorker :: (MonadIO m, Ord (Point b)) => Text -> Trace IO (IndexerEvent (Point b)) -> (a -> IO (Maybe b)) -> [Worker b (Point b)] -> m (WorkerIndexer IO a b (WithTrace IO Coordinator)) #

standardCoordinator :: Ord (Point event) => Trace IO (IndexerEvent (Point event)) -> [Worker event (Point event)] -> IO (WithTrace IO Coordinator event) #

syncStatsCoordinator :: Ord (Point event) => Trace IO (IndexerEvent (Point event)) -> MarconiTrace IO -> [Worker event (Point event)] -> IO (WithSyncStats (WithTrace IO Coordinator) event) #