Skip to content

Commit

Permalink
feat: Publish Dataproc Metastore v1alpha API
Browse files Browse the repository at this point in the history 
PiperOrigin-RevId: 361084441

Source-Author: Google APIs <noreply@google.com>
Source-Date: Thu Mar 4 23:41:25 2021 -0800
Source-Repo: googleapis/googleapis
Source-Sha: 8f117308d5bb55816953a0d6ad1a7d27a69a7d3f
Source-Link: googleapis/googleapis@8f11730
  • Loading branch information
@yoshi-automation @jskeet
yoshi-automation authored and jskeet committed Mar 5, 2021
1 parent d31d172 commit 4019cd7
Show file tree
Hide file tree
Showing 7 changed files with 9,851 additions and 2,086 deletions.
1,013 changes: 1,013 additions & 0 deletions ...tore.V1Alpha/Google.Cloud.Metastore.V1Alpha.Snippets/DataprocMetastoreClientSnippets.g.cs
View file

Large diffs are not rendered by default.

192 changes: 186 additions & 6 deletions ...d.Metastore.V1Alpha/Google.Cloud.Metastore.V1Alpha.Tests/DataprocMetastoreClientTest.g.cs
View file
Expand Up @@ -56,7 +56,11 @@ public void GetServiceRequestObject()
State = Service.Types.State.Deleting,
StateMessage = "state_message46cf28c0",
ArtifactGcsUri = "artifact_gcs_uri4d2b3985",
Tier = Service.Types.Tier.Enterprise,
Tier = Service.Types.Tier.Developer,
MetadataIntegration = new MetadataIntegration(),
MaintenanceWindow = new MaintenanceWindow(),
Uid = "uida2d37198",
MetadataManagementActivity = new MetadataManagementActivity(),
};
mockGrpcClient.Setup(x => x.GetService(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -93,7 +97,11 @@ public void GetServiceRequestObject()
State = Service.Types.State.Deleting,
StateMessage = "state_message46cf28c0",
ArtifactGcsUri = "artifact_gcs_uri4d2b3985",
Tier = Service.Types.Tier.Enterprise,
Tier = Service.Types.Tier.Developer,
MetadataIntegration = new MetadataIntegration(),
MaintenanceWindow = new MaintenanceWindow(),
Uid = "uida2d37198",
MetadataManagementActivity = new MetadataManagementActivity(),
};
mockGrpcClient.Setup(x => x.GetServiceAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Service>(stt::Task.FromResult(expectedResponse), null, null, null, null));
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -132,7 +140,11 @@ public void GetService()
State = Service.Types.State.Deleting,
StateMessage = "state_message46cf28c0",
ArtifactGcsUri = "artifact_gcs_uri4d2b3985",
Tier = Service.Types.Tier.Enterprise,
Tier = Service.Types.Tier.Developer,
MetadataIntegration = new MetadataIntegration(),
MaintenanceWindow = new MaintenanceWindow(),
Uid = "uida2d37198",
MetadataManagementActivity = new MetadataManagementActivity(),
};
mockGrpcClient.Setup(x => x.GetService(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -169,7 +181,11 @@ public void GetService()
State = Service.Types.State.Deleting,
StateMessage = "state_message46cf28c0",
ArtifactGcsUri = "artifact_gcs_uri4d2b3985",
Tier = Service.Types.Tier.Enterprise,
Tier = Service.Types.Tier.Developer,
MetadataIntegration = new MetadataIntegration(),
MaintenanceWindow = new MaintenanceWindow(),
Uid = "uida2d37198",
MetadataManagementActivity = new MetadataManagementActivity(),
};
mockGrpcClient.Setup(x => x.GetServiceAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Service>(stt::Task.FromResult(expectedResponse), null, null, null, null));
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -208,7 +224,11 @@ public void GetServiceResourceNames()
State = Service.Types.State.Deleting,
StateMessage = "state_message46cf28c0",
ArtifactGcsUri = "artifact_gcs_uri4d2b3985",
Tier = Service.Types.Tier.Enterprise,
Tier = Service.Types.Tier.Developer,
MetadataIntegration = new MetadataIntegration(),
MaintenanceWindow = new MaintenanceWindow(),
Uid = "uida2d37198",
MetadataManagementActivity = new MetadataManagementActivity(),
};
mockGrpcClient.Setup(x => x.GetService(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -245,7 +265,11 @@ public void GetServiceResourceNames()
State = Service.Types.State.Deleting,
StateMessage = "state_message46cf28c0",
ArtifactGcsUri = "artifact_gcs_uri4d2b3985",
Tier = Service.Types.Tier.Enterprise,
Tier = Service.Types.Tier.Developer,
MetadataIntegration = new MetadataIntegration(),
MaintenanceWindow = new MaintenanceWindow(),
Uid = "uida2d37198",
MetadataManagementActivity = new MetadataManagementActivity(),
};
mockGrpcClient.Setup(x => x.GetServiceAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Service>(stt::Task.FromResult(expectedResponse), null, null, null, null));
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Expand Down Expand Up @@ -411,5 +435,161 @@ public void GetMetadataImportResourceNames()
xunit::Assert.Same(expectedResponse, responseCancellationToken);
mockGrpcClient.VerifyAll();
}

[xunit::FactAttribute]
public void GetBackupRequestObject()
{
moq::Mock<DataprocMetastore.DataprocMetastoreClient> mockGrpcClient = new moq::Mock<DataprocMetastore.DataprocMetastoreClient>(moq::MockBehavior.Strict);
mockGrpcClient.Setup(x => x.CreateOperationsClient()).Returns(new moq::Mock<lro::Operations.OperationsClient>().Object);
GetBackupRequest request = new GetBackupRequest
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
};
Backup expectedResponse = new Backup
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
CreateTime = new wkt::Timestamp(),
EndTime = new wkt::Timestamp(),
State = Backup.Types.State.Active,
ServiceRevision = new Service(),
Description = "description2cf9da67",
};
mockGrpcClient.Setup(x => x.GetBackup(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Backup response = client.GetBackup(request);
xunit::Assert.Same(expectedResponse, response);
mockGrpcClient.VerifyAll();
}

[xunit::FactAttribute]
public async stt::Task GetBackupRequestObjectAsync()
{
moq::Mock<DataprocMetastore.DataprocMetastoreClient> mockGrpcClient = new moq::Mock<DataprocMetastore.DataprocMetastoreClient>(moq::MockBehavior.Strict);
mockGrpcClient.Setup(x => x.CreateOperationsClient()).Returns(new moq::Mock<lro::Operations.OperationsClient>().Object);
GetBackupRequest request = new GetBackupRequest
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
};
Backup expectedResponse = new Backup
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
CreateTime = new wkt::Timestamp(),
EndTime = new wkt::Timestamp(),
State = Backup.Types.State.Active,
ServiceRevision = new Service(),
Description = "description2cf9da67",
};
mockGrpcClient.Setup(x => x.GetBackupAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Backup>(stt::Task.FromResult(expectedResponse), null, null, null, null));
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Backup responseCallSettings = await client.GetBackupAsync(request, gaxgrpc::CallSettings.FromCancellationToken(st::CancellationToken.None));
xunit::Assert.Same(expectedResponse, responseCallSettings);
Backup responseCancellationToken = await client.GetBackupAsync(request, st::CancellationToken.None);
xunit::Assert.Same(expectedResponse, responseCancellationToken);
mockGrpcClient.VerifyAll();
}

[xunit::FactAttribute]
public void GetBackup()
{
moq::Mock<DataprocMetastore.DataprocMetastoreClient> mockGrpcClient = new moq::Mock<DataprocMetastore.DataprocMetastoreClient>(moq::MockBehavior.Strict);
mockGrpcClient.Setup(x => x.CreateOperationsClient()).Returns(new moq::Mock<lro::Operations.OperationsClient>().Object);
GetBackupRequest request = new GetBackupRequest
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
};
Backup expectedResponse = new Backup
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
CreateTime = new wkt::Timestamp(),
EndTime = new wkt::Timestamp(),
State = Backup.Types.State.Active,
ServiceRevision = new Service(),
Description = "description2cf9da67",
};
mockGrpcClient.Setup(x => x.GetBackup(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Backup response = client.GetBackup(request.Name);
xunit::Assert.Same(expectedResponse, response);
mockGrpcClient.VerifyAll();
}

[xunit::FactAttribute]
public async stt::Task GetBackupAsync()
{
moq::Mock<DataprocMetastore.DataprocMetastoreClient> mockGrpcClient = new moq::Mock<DataprocMetastore.DataprocMetastoreClient>(moq::MockBehavior.Strict);
mockGrpcClient.Setup(x => x.CreateOperationsClient()).Returns(new moq::Mock<lro::Operations.OperationsClient>().Object);
GetBackupRequest request = new GetBackupRequest
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
};
Backup expectedResponse = new Backup
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
CreateTime = new wkt::Timestamp(),
EndTime = new wkt::Timestamp(),
State = Backup.Types.State.Active,
ServiceRevision = new Service(),
Description = "description2cf9da67",
};
mockGrpcClient.Setup(x => x.GetBackupAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Backup>(stt::Task.FromResult(expectedResponse), null, null, null, null));
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Backup responseCallSettings = await client.GetBackupAsync(request.Name, gaxgrpc::CallSettings.FromCancellationToken(st::CancellationToken.None));
xunit::Assert.Same(expectedResponse, responseCallSettings);
Backup responseCancellationToken = await client.GetBackupAsync(request.Name, st::CancellationToken.None);
xunit::Assert.Same(expectedResponse, responseCancellationToken);
mockGrpcClient.VerifyAll();
}

[xunit::FactAttribute]
public void GetBackupResourceNames()
{
moq::Mock<DataprocMetastore.DataprocMetastoreClient> mockGrpcClient = new moq::Mock<DataprocMetastore.DataprocMetastoreClient>(moq::MockBehavior.Strict);
mockGrpcClient.Setup(x => x.CreateOperationsClient()).Returns(new moq::Mock<lro::Operations.OperationsClient>().Object);
GetBackupRequest request = new GetBackupRequest
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
};
Backup expectedResponse = new Backup
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
CreateTime = new wkt::Timestamp(),
EndTime = new wkt::Timestamp(),
State = Backup.Types.State.Active,
ServiceRevision = new Service(),
Description = "description2cf9da67",
};
mockGrpcClient.Setup(x => x.GetBackup(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Backup response = client.GetBackup(request.BackupName);
xunit::Assert.Same(expectedResponse, response);
mockGrpcClient.VerifyAll();
}

[xunit::FactAttribute]
public async stt::Task GetBackupResourceNamesAsync()
{
moq::Mock<DataprocMetastore.DataprocMetastoreClient> mockGrpcClient = new moq::Mock<DataprocMetastore.DataprocMetastoreClient>(moq::MockBehavior.Strict);
mockGrpcClient.Setup(x => x.CreateOperationsClient()).Returns(new moq::Mock<lro::Operations.OperationsClient>().Object);
GetBackupRequest request = new GetBackupRequest
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
};
Backup expectedResponse = new Backup
{
BackupName = BackupName.FromProjectLocationServiceBackup("[PROJECT]", "[LOCATION]", "[SERVICE]", "[BACKUP]"),
CreateTime = new wkt::Timestamp(),
EndTime = new wkt::Timestamp(),
State = Backup.Types.State.Active,
ServiceRevision = new Service(),
Description = "description2cf9da67",
};
mockGrpcClient.Setup(x => x.GetBackupAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Backup>(stt::Task.FromResult(expectedResponse), null, null, null, null));
DataprocMetastoreClient client = new DataprocMetastoreClientImpl(mockGrpcClient.Object, null);
Backup responseCallSettings = await client.GetBackupAsync(request.BackupName, gaxgrpc::CallSettings.FromCancellationToken(st::CancellationToken.None));
xunit::Assert.Same(expectedResponse, responseCallSettings);
Backup responseCancellationToken = await client.GetBackupAsync(request.BackupName, st::CancellationToken.None);
xunit::Assert.Same(expectedResponse, responseCancellationToken);
mockGrpcClient.VerifyAll();
}
}
}

0 comments on commit 4019cd7

Please sign in to comment.