Lines Matching refs:cbt
28 namespace cbt = google::cloud::bigtable; in CreateTable()
30 [](cbt::TableAdmin admin, std::string const& table_id) { in CreateTable()
33 cbt::TableConfig({{"fam", cbt::GcRule::MaxNumVersions(10)}, in CreateTable()
34 {"foo", cbt::GcRule::MaxAge(std::chrono::hours(72))}}, in CreateTable()
47 namespace cbt = google::cloud::bigtable; in ListTables()
49 [](cbt::TableAdmin admin) { in ListTables()
51 admin.ListTables(cbt::TableAdmin::NAME_ONLY); in ListTables()
65 namespace cbt = google::cloud::bigtable; in GetTable()
67 [](cbt::TableAdmin admin, std::string const& table_id) { in GetTable()
69 admin.GetTable(table_id, cbt::TableAdmin::FULL); in GetTable()
80 namespace cbt = google::cloud::bigtable; in CheckTableExists()
82 [](cbt::TableAdmin admin, std::string const& table_id) { in CheckTableExists()
84 admin.GetTable(table_id, cbt::TableAdmin::NAME_ONLY); in CheckTableExists()
102 namespace cbt = google::cloud::bigtable; in GetOrCreateTable()
104 [](cbt::TableAdmin admin, std::string const& table_id) { in GetOrCreateTable()
106 admin.GetTable(table_id, cbt::TableAdmin::FULL); in GetOrCreateTable()
112 cbt::TableConfig({{"fam", cbt::GcRule::MaxNumVersions(10)}}, {})); in GetOrCreateTable()
116 table = admin.GetTable(table_id, cbt::TableAdmin::FULL); in GetOrCreateTable()
128 namespace cbt = google::cloud::bigtable; in DeleteTable()
129 [](cbt::TableAdmin admin, std::string const& table_id) { in DeleteTable()
141 namespace cbt = google::cloud::bigtable; in ModifyTable()
143 [](cbt::TableAdmin admin, std::string const& table_id) { in ModifyTable()
147 {cbt::ColumnFamilyModification::Drop("foo"), in ModifyTable()
148 cbt::ColumnFamilyModification::Update( in ModifyTable()
149 "fam", cbt::GcRule::Union( in ModifyTable()
150 cbt::GcRule::MaxNumVersions(5), in ModifyTable()
151 cbt::GcRule::MaxAge(std::chrono::hours(24 * 7)))), in ModifyTable()
152 cbt::ColumnFamilyModification::Create( in ModifyTable()
153 "bar", cbt::GcRule::Intersection( in ModifyTable()
154 cbt::GcRule::MaxNumVersions(3), in ModifyTable()
155 cbt::GcRule::MaxAge(std::chrono::hours(72))))}); in ModifyTable()
167 namespace cbt = google::cloud::bigtable; in CreateMaxAgeFamily()
169 [](cbt::TableAdmin admin, std::string const& table_id, in CreateMaxAgeFamily()
174 {cbt::ColumnFamilyModification::Create( in CreateMaxAgeFamily()
175 family_name, cbt::GcRule::MaxAge(std::chrono::hours(5 * 24)))}); in CreateMaxAgeFamily()
187 namespace cbt = google::cloud::bigtable; in CreateMaxVersionsFamily()
189 [](cbt::TableAdmin admin, std::string const& table_id, in CreateMaxVersionsFamily()
193 table_id, {cbt::ColumnFamilyModification::Create( in CreateMaxVersionsFamily()
194 family_name, cbt::GcRule::MaxNumVersions(2))}); in CreateMaxVersionsFamily()
206 namespace cbt = google::cloud::bigtable; in CreateUnionFamily()
208 [](cbt::TableAdmin admin, std::string const& table_id, in CreateUnionFamily()
213 {cbt::ColumnFamilyModification::Create( in CreateUnionFamily()
215 cbt::GcRule::Union( in CreateUnionFamily()
216 cbt::GcRule::MaxNumVersions(1), in CreateUnionFamily()
217 cbt::GcRule::MaxAge(5 * std::chrono::hours(24))))}); in CreateUnionFamily()
229 namespace cbt = google::cloud::bigtable; in CreateIntersectionFamily()
231 [](cbt::TableAdmin admin, std::string const& table_id, in CreateIntersectionFamily()
236 {cbt::ColumnFamilyModification::Create( in CreateIntersectionFamily()
238 cbt::GcRule::Intersection( in CreateIntersectionFamily()
239 cbt::GcRule::MaxNumVersions(1), in CreateIntersectionFamily()
240 cbt::GcRule::MaxAge(5 * std::chrono::hours(24))))}); in CreateIntersectionFamily()
252 namespace cbt = google::cloud::bigtable; in CreateNestedFamily()
254 [](cbt::TableAdmin admin, std::string const& table_id, in CreateNestedFamily()
259 {cbt::ColumnFamilyModification::Create( in CreateNestedFamily()
261 cbt::GcRule::Union( in CreateNestedFamily()
262 cbt::GcRule::MaxNumVersions(10), in CreateNestedFamily()
263 cbt::GcRule::Intersection( in CreateNestedFamily()
264 cbt::GcRule::MaxNumVersions(1), in CreateNestedFamily()
265 cbt::GcRule::MaxAge(5 * std::chrono::hours(24)))))}); in CreateNestedFamily()
277 namespace cbt = google::cloud::bigtable; in GetFamilyMetadata()
279 [](cbt::TableAdmin admin, std::string const& table_id, in GetFamilyMetadata()
282 admin.GetTable(table_id, cbt::TableAdmin::FULL); in GetFamilyMetadata()
300 namespace cbt = google::cloud::bigtable; in GetOrCreateFamily()
302 [](cbt::TableAdmin admin, std::string const& table_id, in GetOrCreateFamily()
305 admin.GetTable(table_id, cbt::TableAdmin::FULL); in GetOrCreateFamily()
313 {cbt::ColumnFamilyModification::Create( in GetOrCreateFamily()
314 family_name, cbt::GcRule::MaxAge(std::chrono::hours(5 * 24)))}); in GetOrCreateFamily()
336 namespace cbt = google::cloud::bigtable; in DeleteColumnFamily()
338 [](cbt::TableAdmin admin, std::string const& table_id, in DeleteColumnFamily()
342 table_id, {cbt::ColumnFamilyModification::Drop(family_name)}); in DeleteColumnFamily()
354 namespace cbt = google::cloud::bigtable; in CheckFamilyExists()
356 [](cbt::TableAdmin admin, std::string const& table_id, in CheckFamilyExists()
359 admin.GetTable(table_id, cbt::TableAdmin::FULL); in CheckFamilyExists()
376 namespace cbt = google::cloud::bigtable; in ListColumnFamilies()
378 [](cbt::TableAdmin admin, std::string const& table_id) { in ListColumnFamilies()
380 admin.GetTable(table_id, cbt::TableAdmin::FULL); in ListColumnFamilies()
397 namespace cbt = google::cloud::bigtable; in UpdateGcRule()
399 [](cbt::TableAdmin admin, std::string const& table_id, in UpdateGcRule()
403 table_id, {cbt::ColumnFamilyModification::Update( in UpdateGcRule()
404 family_name, cbt::GcRule::MaxNumVersions(1))}); in UpdateGcRule()
417 namespace cbt = google::cloud::bigtable; in DropAllRows()
418 [](cbt::TableAdmin admin, std::string const& table_id) { in DropAllRows()
431 namespace cbt = google::cloud::bigtable; in DropRowsByPrefix()
432 [](cbt::TableAdmin admin, std::string const& table_id, in DropRowsByPrefix()
446 namespace cbt = google::cloud::bigtable; in WaitForConsistencyCheck()
449 [](cbt::TableAdmin admin, std::string const& table_id) { in WaitForConsistencyCheck()
455 future<StatusOr<cbt::Consistency>> consistent_future = in WaitForConsistencyCheck()
458 [&consistency_token](future<StatusOr<cbt::Consistency>> f) { in WaitForConsistencyCheck()
463 if (*is_consistent == cbt::Consistency::kConsistent) { in WaitForConsistencyCheck()
481 namespace cbt = google::cloud::bigtable; in CheckConsistency()
483 [](cbt::TableAdmin admin, std::string const& table_id, in CheckConsistency()
485 StatusOr<cbt::Consistency> result = in CheckConsistency()
488 if (*result == cbt::Consistency::kConsistent) { in CheckConsistency()
504 namespace cbt = google::cloud::bigtable; in GenerateConsistencyToken()
506 [](cbt::TableAdmin admin, std::string const& table_id) { in GenerateConsistencyToken()
517 namespace cbt = google::cloud::bigtable; in RunAll()
531 cbt::TableAdmin admin( in RunAll()
532 cbt::CreateDefaultAdminClient(project_id, cbt::ClientOptions{}), in RunAll()
551 table_id_1, cbt::TableConfig( in RunAll()
553 {"fam", cbt::GcRule::MaxNumVersions(10)}, in RunAll()
554 {"foo", cbt::GcRule::MaxNumVersions(3)}, in RunAll()