You are an expert in writing code in many different languages. Your goal is to perform code completion for the following code, keeping in mind the rest of the code and the file meta data.
    Metadata details:
    filename: readreplica_live_test.go
    path of file: ./repos/azure-sdk-for-go/sdk/resourcemanager/cosmosforpostgresql/armcosmosforpostgresql
    
    the code of the file until where you have to start completion: //go:build go1.18
// +build go1.18

// Copyright (c) Mic
    
func (testsuite *ReadReplicaTestSuite) TestClusters() {
	var clusterId string
	var err error
	// From step Clusters_Create
	fmt.Println("Call operation: Clusters_Create")
	clustersClient, err := armcosmosforpostgresql.NewClustersClient(testsuite.subscriptionId, testsuite.cred, testsuite.options)
	testsuite.Require().NoError(err)
	clustersClientCreateResponsePoller, err := clustersClient.BeginCreate(testsuite.ctx, testsuite.resourceGroupName, testsuite.clusterName, armcosmosforpostgresql.Cluster{
		Location: to.Ptr(testsuite.location),
		Tags:     map[string]*string{},
		Properties: &armcosmosforpostgresql.ClusterProperties{
			AdministratorLoginPassword:      to.Ptr(testsuite.adminPassword),
			CitusVersion:                    to.Ptr("11.1"),
			CoordinatorEnablePublicIPAccess: to.Ptr(true),
			CoordinatorServerEdition:        to.Ptr("GeneralPurpose"),
			CoordinatorStorageQuotaInMb:     to.Ptr[int32](524288),
			CoordinatorVCores:               to.Ptr[int32](4),
			EnableHa:                        to.Ptr(true),
			EnableShardsOnCoordinator:       to.Ptr(false),
			NodeCount:                       to.Ptr[int32](3),
			NodeEnablePublicIPAccess:        to.Ptr(false),
			NodeServerEdition:               to.Ptr("MemoryOptimized"),
			NodeStorageQuotaInMb:            to.Ptr[int32](524288),
			NodeVCores:                      to.Ptr[int32](8),
			PostgresqlVersion:               to.Ptr("15"),
			PreferredPrimaryZone:            to.Ptr("1"),
		},
	}, nil)
	testsuite.Require().NoError(err)
	var clustersClientCreateResponse *armcosmosforpostgresql.ClustersClientCreateResponse
	clustersClientCreateResponse, err = testutil.PollForTest(testsuite.ctx, clustersClientCreateResponsePoller)
	testsuite.Require().NoError(err)
	clusterId = *clustersClientCreateResponse.ID

	// The source cluster is not ready for restore yet
	if recording.GetRecordMode() == recording.RecordingMode {
		time.Sleep(5 * time.Minute)
	}

	// From step Clusters_CreateReplica
	fmt.Println("Call operation: Clusters_Create")
	clustersClientCreateResponsePoller, err = clustersClient.BeginCreate(testsuite.ctx, testsuite.resourceGroupName, testsuite.clusterReplicaName, armcosmosforpostgresql.Cluster{
		Location: to.Ptr(testsuite.location),
		Properties: &armcosmosforpostgresql.ClusterProperties{
			SourceLocation:   to.Ptr(testsuite.location),
			SourceResourceID: to.Ptr(clusterId),
		},
	}, nil)
	testsuite.Require().NoError(err)
	_, err = testutil.PollForTest(testsuite.ctx, clustersClientCreateResponsePoller)
	testsuite.Require().NoError(err)

	// From step Clusters_PromoteReadReplica
	fmt.Println("Call operation: Clusters_PromoteReadReplica")
	clustersClientPromoteReadReplicaResponsePoller, err := clustersClient.BeginPromoteReadReplica(testsuite.ctx, testsuite.resourceGroupName, testsuite.clusterReplicaName, nil)
	testsuite.Require().NoError(err)
	_, err = testutil.PollForTest(testsuite.ctx, clustersClientPromoteReadReplicaResponsePoller)
	testsuite.Require().NoError(err)
}