2424namespace Google \Cloud \Samples \Bigtable ;
2525
2626// [START bigtable_create_cluster]
27- use Google \Cloud \Bigtable \Admin \V2 \BigtableInstanceAdminClient ;
27+ use Google \ApiCore \ApiException ;
28+ use Google \Cloud \Bigtable \Admin \V2 \Client \BigtableInstanceAdminClient ;
2829use Google \Cloud \Bigtable \Admin \V2 \Cluster ;
30+ use Google \Cloud \Bigtable \Admin \V2 \CreateClusterRequest ;
31+ use Google \Cloud \Bigtable \Admin \V2 \GetClusterRequest ;
32+ use Google \Cloud \Bigtable \Admin \V2 \GetInstanceRequest ;
33+ use Google \Cloud \Bigtable \Admin \V2 \ListClustersRequest ;
2934use Google \Cloud \Bigtable \Admin \V2 \StorageType ;
30- use Google \ApiCore \ApiException ;
3135
3236/**
3337 * Create a cluster in an existing Bigtable instance
@@ -50,7 +54,9 @@ function create_cluster(
5054
5155 printf ('Adding Cluster to Instance %s ' . PHP_EOL , $ instanceId );
5256 try {
53- $ instanceAdminClient ->getInstance ($ instanceName );
57+ $ getInstanceRequest = (new GetInstanceRequest ())
58+ ->setName ($ instanceName );
59+ $ instanceAdminClient ->getInstance ($ getInstanceRequest );
5460 } catch (ApiException $ e ) {
5561 if ($ e ->getStatus () === 'NOT_FOUND ' ) {
5662 printf ('Instance %s does not exists. ' . PHP_EOL , $ instanceId );
@@ -63,8 +69,10 @@ function create_cluster(
6369
6470 $ storage_type = StorageType::SSD ;
6571 $ serve_nodes = 3 ;
72+ $ listClustersRequest = (new ListClustersRequest ())
73+ ->setParent ($ instanceName );
6674
67- $ clustersBefore = $ instanceAdminClient ->listClusters ($ instanceName )->getClusters ();
75+ $ clustersBefore = $ instanceAdminClient ->listClusters ($ listClustersRequest )->getClusters ();
6876 $ clusters = $ clustersBefore ->getIterator ();
6977 foreach ($ clusters as $ cluster ) {
7078 print ($ cluster ->getName () . PHP_EOL );
@@ -80,11 +88,17 @@ function create_cluster(
8088 )
8189 );
8290 try {
83- $ instanceAdminClient ->getCluster ($ clusterName );
91+ $ getClusterRequest = (new GetClusterRequest ())
92+ ->setName ($ clusterName );
93+ $ instanceAdminClient ->getCluster ($ getClusterRequest );
8494 printf ('Cluster %s already exists, aborting... ' , $ clusterId );
8595 } catch (ApiException $ e ) {
8696 if ($ e ->getStatus () === 'NOT_FOUND ' ) {
87- $ operationResponse = $ instanceAdminClient ->createCluster ($ instanceName , $ clusterId , $ cluster );
97+ $ createClusterRequest = (new CreateClusterRequest ())
98+ ->setParent ($ instanceName )
99+ ->setClusterId ($ clusterId )
100+ ->setCluster ($ cluster );
101+ $ operationResponse = $ instanceAdminClient ->createCluster ($ createClusterRequest );
88102
89103 $ operationResponse ->pollUntilComplete ();
90104 if ($ operationResponse ->operationSucceeded ()) {
0 commit comments