@Test public void canWriteEmptyBatch() { assertThatCode(() -> stateLog.writeBatchOfRounds(ImmutableList.of())).doesNotThrowAnyException(); }
@Override public void writeBatchOfRounds(Iterable<PaxosRound<V>> rounds) { execute(dao -> dao.writeBatchOfRounds(namespace, useCase, rounds)); }
SqlitePaxosStateLog implements PaxosStateLog<V> { @Override public void writeBatchOfRounds(Iterable<PaxosRound<V>> rounds) { execute(dao -> dao.writeBatchOfRounds(namespace, useCase, rounds)); } }
SqlitePaxosStateLog implements PaxosStateLog<V> { @Override public void writeBatchOfRounds(Iterable<PaxosRound<V>> rounds) { execute(dao -> dao.writeBatchOfRounds(namespace, useCase, rounds)); } private  SqlitePaxosStateLog(NamespaceAndUseCase namespaceAndUseCase, Jdbi jdbi); }
SqlitePaxosStateLog implements PaxosStateLog<V> { @Override public void writeBatchOfRounds(Iterable<PaxosRound<V>> rounds) { execute(dao -> dao.writeBatchOfRounds(namespace, useCase, rounds)); } private  SqlitePaxosStateLog(NamespaceAndUseCase namespaceAndUseCase, Jdbi jdbi); static PaxosStateLog<V> create(
            NamespaceAndUseCase namespaceAndUseCase,
            DataSource dataSource); @Override void writeRound(long seq, V round); @Override void writeBatchOfRounds(Iterable<PaxosRound<V>> rounds); @Override byte[] readRound(long seq); @Override long getLeastLogEntry(); @Override long getGreatestLogEntry(); @Override void truncate(long toDeleteInclusive); }
SqlitePaxosStateLog implements PaxosStateLog<V> { @Override public void writeBatchOfRounds(Iterable<PaxosRound<V>> rounds) { execute(dao -> dao.writeBatchOfRounds(namespace, useCase, rounds)); } private  SqlitePaxosStateLog(NamespaceAndUseCase namespaceAndUseCase, Jdbi jdbi); static PaxosStateLog<V> create(
            NamespaceAndUseCase namespaceAndUseCase,
            DataSource dataSource); @Override void writeRound(long seq, V round); @Override void writeBatchOfRounds(Iterable<PaxosRound<V>> rounds); @Override byte[] readRound(long seq); @Override long getLeastLogEntry(); @Override long getGreatestLogEntry(); @Override void truncate(long toDeleteInclusive);  }