@Test void getCurrentVersionShouldReturnCurrentVersion() { when(schemaVersionDAO.getCurrentSchemaVersion()).thenReturn(Mono.just(Optional.of(CURRENT_VERSION))); assertThat(testee.getCurrentVersion()).contains(CURRENT_VERSION); }
public Optional<SchemaVersion> getCurrentVersion() { return schemaVersionDAO.getCurrentSchemaVersion().block(); }
CassandraMigrationService { public Optional<SchemaVersion> getCurrentVersion() { return schemaVersionDAO.getCurrentSchemaVersion().block(); } }
CassandraMigrationService { public Optional<SchemaVersion> getCurrentVersion() { return schemaVersionDAO.getCurrentSchemaVersion().block(); } @Inject  CassandraMigrationService(CassandraSchemaVersionDAO schemaVersionDAO, CassandraSchemaTransitions transitions,
                                     MigrationTask.Factory factory, @Named(LATEST_VERSION) SchemaVersion latestVersion); }
CassandraMigrationService { public Optional<SchemaVersion> getCurrentVersion() { return schemaVersionDAO.getCurrentSchemaVersion().block(); } @Inject  CassandraMigrationService(CassandraSchemaVersionDAO schemaVersionDAO, CassandraSchemaTransitions transitions,
                                     MigrationTask.Factory factory, @Named(LATEST_VERSION) SchemaVersion latestVersion); Optional<SchemaVersion> getCurrentVersion(); Optional<SchemaVersion> getLatestVersion(); Task upgradeToVersion(SchemaVersion target); Task upgradeToLastVersion(); }
CassandraMigrationService { public Optional<SchemaVersion> getCurrentVersion() { return schemaVersionDAO.getCurrentSchemaVersion().block(); } @Inject  CassandraMigrationService(CassandraSchemaVersionDAO schemaVersionDAO, CassandraSchemaTransitions transitions,
                                     MigrationTask.Factory factory, @Named(LATEST_VERSION) SchemaVersion latestVersion); Optional<SchemaVersion> getCurrentVersion(); Optional<SchemaVersion> getLatestVersion(); Task upgradeToVersion(SchemaVersion target); Task upgradeToLastVersion(); static final String LATEST_VERSION; }