@@ -198,47 +198,6 @@ TEST(CloudFileSystemTest, ConfigureGcsProvider) {
198198 CloudStorageProviderImpl::kGcs ());
199199#endif
200200}
201-
202- /* kinesis
203- // Test is disabled until we have a mock provider and authentication issues are
204- // resolved
205- TEST(CloudFileSystemTest, DISABLED_ConfigureKinesisController) {
206- std::unique_ptr<CloudFileSystem> cfs;
207-
208- ConfigOptions config_options;
209- Status s = CloudFileSystem::CreateFromString(
210- config_options, "provider=mock; controller=kinesis", &cfs);
211- ASSERT_NOK(s);
212- ASSERT_EQ(cfs, nullptr);
213-
214- #ifdef USE_AWS
215- ASSERT_OK(CloudFileSystem::CreateFromString(
216- config_options, "id=aws; controller=kinesis; TEST=dbcloud:/test", &cfs));
217- ASSERT_STREQ(cfs->Name(), "aws");
218- ASSERT_NE(cfs->GetLogController(), nullptr);
219- ASSERT_STREQ(cfs->GetLogController()->Name(),
220- CloudLogControllerImpl::kKinesis());
221- #endif
222- }
223-
224- TEST(CloudFileSystemTest, ConfigureKafkaController) {
225- std::unique_ptr<CloudFileSystem> cfs;
226-
227- ConfigOptions config_options;
228- Status s = CloudFileSystem::CreateFromString(
229- config_options, "provider=mock; controller=kafka", &cfs);
230- #ifdef USE_KAFKA
231- ASSERT_OK(s);
232- ASSERT_NE(cfs, nullptr);
233- ASSERT_NE(cfs->GetLogController(), nullptr);
234- ASSERT_STREQ(cfs->GetLogController()->Name(),
235- CloudLogControllerImpl::kKafka());
236- #else
237- ASSERT_NOK(s);
238- ASSERT_EQ(cfs, nullptr);
239- #endif
240- }
241- */
242201} // namespace ROCKSDB_NAMESPACE
243202
244203
0 commit comments