Receive notifications with metadata change feeds

usingGoogle.Api.Gax.ResourceNames ;
usingGoogle.Cloud.Dataplex.V1 ;
usingGoogle.LongRunning ;
publicsealedpartialclassGeneratedCatalogServiceClientSnippets
{
/// <summary>Snippet for CreateMetadataFeed</summary>
/// <remarks>
/// This snippet has been automatically generated and should be regarded as a code template only.
/// It will require modifications to work:
/// - It may require correct/in-range values for request initialization.
/// - It may require specifying regional endpoints when creating the service client as shown in
/// https://cloud.google.com/dotnet/docs/reference/help/client-configuration#endpoint.
/// </remarks>
publicvoidCreateMetadataFeedRequestObject()
{
// Create client
CatalogServiceClient catalogServiceClient=CatalogServiceClient .Create ();
// Initialize request argument(s)
CreateMetadataFeedRequest request=newCreateMetadataFeedRequest
{
ParentAsLocationName=LocationName .FromProjectLocation ("[PROJECT]","[LOCATION]"),
MetadataFeed=newMetadataFeed (),
MetadataFeedId="",
ValidateOnly=false,
};
// Make the request
Operation<MetadataFeed,OperationMetadata>response=catalogServiceClient.CreateMetadataFeed (request);
// Poll until the returned long-running operation is complete
Operation<MetadataFeed,OperationMetadata>completedResponse=response.PollUntilCompleted();
// Retrieve the operation result
MetadataFeed result=completedResponse.Result;
// Or get the name of the operation
stringoperationName=response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<MetadataFeed,OperationMetadata>retrievedResponse=catalogServiceClient.PollOnceCreateMetadataFeed (operationName);
// Check if the retrieved long-running operation has completed
if(retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
MetadataFeed retrievedResult=retrievedResponse.Result;
}
}
}

//go:build examples
packagemain
import(
"context"
dataplex"cloud.google.com/go/dataplex/apiv1"
dataplexpb"cloud.google.com/go/dataplex/apiv1/dataplexpb"
)
funcmain(){
ctx:=context.Background()
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in:
// https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
c,err:=dataplex.NewCatalogClient (ctx)
iferr!=nil{
// TODO: Handle error.
}
deferc.Close()
req:=&dataplexpb.CreateMetadataFeedRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/dataplex/apiv1/dataplexpb#CreateMetadataFeedRequest.
}
op,err:=c.CreateMetadataFeed(ctx,req)
iferr!=nil{
// TODO: Handle error.
}
resp,err:=op.Wait(ctx)
iferr!=nil{
// TODO: Handle error.
}
// TODO: Use resp.
_=resp
}

importcom.google.cloud.dataplex.v1.CatalogServiceClient ;
importcom.google.cloud.dataplex.v1.CreateMetadataFeedRequest ;
importcom.google.cloud.dataplex.v1.LocationName ;
importcom.google.cloud.dataplex.v1.MetadataFeed ;
publicclass SyncCreateMetadataFeed{
publicstaticvoidmain(String[]args)throwsException{
syncCreateMetadataFeed();
}
publicstaticvoidsyncCreateMetadataFeed()throwsException{
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(CatalogServiceClient catalogServiceClient=CatalogServiceClient .create()){
CreateMetadataFeedRequest request=
CreateMetadataFeedRequest .newBuilder()
.setParent(LocationName .of("[PROJECT]","[LOCATION]").toString())
.setMetadataFeed(MetadataFeed .newBuilder().build())
.setMetadataFeedId ("metadataFeedId1633421160")
.setValidateOnly(true)
.build();
MetadataFeed response=catalogServiceClient.createMetadataFeedAsync (request).get();
}
}
}

/**
 * This snippet has been automatically generated and should be regarded as a code template only.
 * It will require modifications to work.
 * It may require correct/in-range values for request initialization.
 * TODO(developer): Uncomment these variables before running the sample.
 */
/**
 * Required. The resource name of the parent location, in the format
 * `projects/{project_id_or_number}/locations/{location_id}`
 */
// const parent = 'abc123'
/**
 * Required. The metadata job resource.
 */
// const metadataFeed = {}
/**
 * Optional. The metadata job ID. If not provided, a unique ID is generated
 * with the prefix `metadata-job-`.
 */
// const metadataFeedId = 'abc123'
/**
 * Optional. The service validates the request without performing any
 * mutations. The default is false.
 */
// const validateOnly = true
// Imports the Dataplex library
const{CatalogServiceClient}=require('@google-cloud/dataplex').v1;
// Instantiates a client
constdataplexClient=newCatalogServiceClient ();
asyncfunctioncallCreateMetadataFeed(){
// Construct request
constrequest={
parent,
metadataFeed,
};
// Run request
const[operation]=awaitdataplexClient.createMetadataFeed(request);
const[response]=awaitoperation.promise();
console.log(response);
}
callCreateMetadataFeed();

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
# client as shown in:
# https://googleapis.dev/python/google-api-core/latest/client_options.html
fromgoogle.cloudimport dataplex_v1
defsample_create_metadata_feed():
 # Create a client
 client = dataplex_v1 .CatalogServiceClient ()
 # Initialize request argument(s)
 metadata_feed = dataplex_v1 .MetadataFeed ()
 metadata_feed.pubsub_topic = "pubsub_topic_value"
 request = dataplex_v1 .CreateMetadataFeedRequest (
 parent="parent_value",
 metadata_feed=metadata_feed,
 )
 # Make the request
 operation = client.create_metadata_feed (request=request)
 print("Waiting for operation to complete...")
 response = operation.result()
 # Handle the response
 print(response)

usingGoogle.Cloud.Dataplex.V1 ;
publicsealedpartialclassGeneratedCatalogServiceClientSnippets
{
/// <summary>Snippet for GetMetadataFeed</summary>
/// <remarks>
/// This snippet has been automatically generated and should be regarded as a code template only.
/// It will require modifications to work:
/// - It may require correct/in-range values for request initialization.
/// - It may require specifying regional endpoints when creating the service client as shown in
/// https://cloud.google.com/dotnet/docs/reference/help/client-configuration#endpoint.
/// </remarks>
publicvoidGetMetadataFeedRequestObject()
{
// Create client
CatalogServiceClient catalogServiceClient=CatalogServiceClient .Create ();
// Initialize request argument(s)
GetMetadataFeedRequest request=newGetMetadataFeedRequest
{
MetadataFeedName=MetadataFeedName .FromProjectLocationMetadataFeed ("[PROJECT]","[LOCATION]","[METADATA_FEED]"),
};
// Make the request
MetadataFeed response=catalogServiceClient.GetMetadataFeed (request);
}
}

//go:build examples
packagemain
import(
"context"
dataplex"cloud.google.com/go/dataplex/apiv1"
dataplexpb"cloud.google.com/go/dataplex/apiv1/dataplexpb"
)
funcmain(){
ctx:=context.Background()
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in:
// https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
c,err:=dataplex.NewCatalogClient (ctx)
iferr!=nil{
// TODO: Handle error.
}
deferc.Close()
req:=&dataplexpb.GetMetadataFeedRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/dataplex/apiv1/dataplexpb#GetMetadataFeedRequest.
}
resp,err:=c.GetMetadataFeed(ctx,req)
iferr!=nil{
// TODO: Handle error.
}
// TODO: Use resp.
_=resp
}

importcom.google.cloud.dataplex.v1.CatalogServiceClient ;
importcom.google.cloud.dataplex.v1.GetMetadataFeedRequest ;
importcom.google.cloud.dataplex.v1.MetadataFeed ;
importcom.google.cloud.dataplex.v1.MetadataFeedName ;
publicclass SyncGetMetadataFeed{
publicstaticvoidmain(String[]args)throwsException{
syncGetMetadataFeed();
}
publicstaticvoidsyncGetMetadataFeed()throwsException{
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(CatalogServiceClient catalogServiceClient=CatalogServiceClient .create()){
GetMetadataFeedRequest request=
GetMetadataFeedRequest .newBuilder()
.setName(MetadataFeedName .of("[PROJECT]","[LOCATION]","[METADATA_FEED]").toString())
.build();
MetadataFeed response=catalogServiceClient.getMetadataFeed(request);
}
}
}

/**
 * This snippet has been automatically generated and should be regarded as a code template only.
 * It will require modifications to work.
 * It may require correct/in-range values for request initialization.
 * TODO(developer): Uncomment these variables before running the sample.
 */
/**
 * Required. The resource name of the metadata feed, in the format
 * `projects/{project_id_or_number}/locations/{location_id}/MetadataFeeds/{metadata_feed_id}`.
 */
// const name = 'abc123'
// Imports the Dataplex library
const{CatalogServiceClient}=require('@google-cloud/dataplex').v1;
// Instantiates a client
constdataplexClient=newCatalogServiceClient ();
asyncfunctioncallGetMetadataFeed(){
// Construct request
constrequest={
name,
};
// Run request
constresponse=awaitdataplexClient.getMetadataFeed(request);
console.log(response);
}
callGetMetadataFeed();

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
# client as shown in:
# https://googleapis.dev/python/google-api-core/latest/client_options.html
fromgoogle.cloudimport dataplex_v1
defsample_get_metadata_feed():
 # Create a client
 client = dataplex_v1 .CatalogServiceClient ()
 # Initialize request argument(s)
 request = dataplex_v1 .GetMetadataFeedRequest (
 name="name_value",
 )
 # Make the request
 response = client.get_metadata_feed (request=request)
 # Handle the response
 print(response)

usingGoogle.Api.Gax ;
usingGoogle.Api.Gax.ResourceNames ;
usingGoogle.Cloud.Dataplex.V1 ;
usingSystem;
publicsealedpartialclassGeneratedCatalogServiceClientSnippets
{
/// <summary>Snippet for ListMetadataFeeds</summary>
/// <remarks>
/// This snippet has been automatically generated and should be regarded as a code template only.
/// It will require modifications to work:
/// - It may require correct/in-range values for request initialization.
/// - It may require specifying regional endpoints when creating the service client as shown in
/// https://cloud.google.com/dotnet/docs/reference/help/client-configuration#endpoint.
/// </remarks>
publicvoidListMetadataFeedsRequestObject()
{
// Create client
CatalogServiceClient catalogServiceClient=CatalogServiceClient .Create ();
// Initialize request argument(s)
ListMetadataFeedsRequest request=newListMetadataFeedsRequest
{
ParentAsLocationName=LocationName .FromProjectLocation ("[PROJECT]","[LOCATION]"),
Filter="",
OrderBy="",
};
// Make the request
PagedEnumerable<ListMetadataFeedsResponse,MetadataFeed>response=catalogServiceClient.ListMetadataFeeds (request);
// Iterate over all response items, lazily performing RPCs as required
foreach(MetadataFeed iteminresponse)
{
// Do something with each item
Console.WriteLine(item);
}
// Or iterate over pages (of server-defined size), performing one RPC per page
foreach(ListMetadataFeedsResponse pageinresponse.AsRawResponses())
{
// Do something with each page of items
Console.WriteLine("A page of results:");
foreach(MetadataFeed iteminpage)
{
// Do something with each item
Console.WriteLine(item);
}
}
// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
intpageSize=10;
Page<MetadataFeed>singlePage=response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach(MetadataFeed iteminsinglePage)
{
// Do something with each item
Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
stringnextPageToken=singlePage.NextPageToken;
}
}

//go:build examples
packagemain
import(
"context"
dataplex"cloud.google.com/go/dataplex/apiv1"
dataplexpb"cloud.google.com/go/dataplex/apiv1/dataplexpb"
"google.golang.org/api/iterator"
)
funcmain(){
ctx:=context.Background()
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in:
// https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
c,err:=dataplex.NewCatalogClient (ctx)
iferr!=nil{
// TODO: Handle error.
}
deferc.Close()
req:=&dataplexpb.ListMetadataFeedsRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/dataplex/apiv1/dataplexpb#ListMetadataFeedsRequest.
}
it:=c.ListMetadataFeeds(ctx,req)
for{
resp,err:=it.Next()
iferr==iterator.Done{
break
}
iferr!=nil{
// TODO: Handle error.
}
// TODO: Use resp.
_=resp
// If you need to access the underlying RPC response,
// you can do so by casting the `Response` as below.
// Otherwise, remove this line. Only populated after
// first call to Next(). Not safe for concurrent access.
_=it.Response.(*dataplexpb.ListMetadataFeedsResponse)
}
}

importcom.google.cloud.dataplex.v1.CatalogServiceClient ;
importcom.google.cloud.dataplex.v1.ListMetadataFeedsRequest ;
importcom.google.cloud.dataplex.v1.LocationName ;
importcom.google.cloud.dataplex.v1.MetadataFeed ;
publicclass SyncListMetadataFeeds{
publicstaticvoidmain(String[]args)throwsException{
syncListMetadataFeeds();
}
publicstaticvoidsyncListMetadataFeeds()throwsException{
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(CatalogServiceClient catalogServiceClient=CatalogServiceClient .create()){
ListMetadataFeedsRequest request=
ListMetadataFeedsRequest .newBuilder()
.setParent(LocationName .of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.setFilter("filter-1274492040")
.setOrderBy("orderBy-1207110587")
.build();
for(MetadataFeed element:catalogServiceClient.listMetadataFeeds(request).iterateAll()){
// doThingsWith(element);
}
}
}
}

/**
 * This snippet has been automatically generated and should be regarded as a code template only.
 * It will require modifications to work.
 * It may require correct/in-range values for request initialization.
 * TODO(developer): Uncomment these variables before running the sample.
 */
/**
 * Required. The resource name of the parent location, in the format
 * `projects/{project_id_or_number}/locations/{location_id}`
 */
// const parent = 'abc123'
/**
 * Optional. The maximum number of metadata feeds to return. The service
 * might return fewer feeds than this value. If unspecified, at most 10 feeds
 * are returned. The maximum value is 1,000.
 */
// const pageSize = 1234
/**
 * Optional. The page token received from a previous `ListMetadataFeeds` call.
 * Provide this token to retrieve the subsequent page of results. When
 * paginating, all other parameters that are provided to the
 * `ListMetadataFeeds` request must match the call that provided the
 * page token.
 */
// const pageToken = 'abc123'
/**
 * Optional. Filter request. Filters are case-sensitive.
 * The service supports the following formats:
 * * `labels.key1 = "value1"`
 * * `labels:key1`
 * * `name = "value"`
 * You can combine filters with `AND`, `OR`, and `NOT` operators.
 */
// const filter = 'abc123'
/**
 * Optional. The field to sort the results by, either `name` or `create_time`.
 * If not specified, the ordering is undefined.
 */
// const orderBy = 'abc123'
// Imports the Dataplex library
const{CatalogServiceClient}=require('@google-cloud/dataplex').v1;
// Instantiates a client
constdataplexClient=newCatalogServiceClient ();
asyncfunctioncallListMetadataFeeds(){
// Construct request
constrequest={
parent,
};
// Run request
constiterable=dataplexClient.listMetadataFeedsAsync (request);
forawait(constresponseofiterable){
console.log(response);
}
}
callListMetadataFeeds();

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
# client as shown in:
# https://googleapis.dev/python/google-api-core/latest/client_options.html
fromgoogle.cloudimport dataplex_v1
defsample_list_metadata_feeds():
 # Create a client
 client = dataplex_v1 .CatalogServiceClient ()
 # Initialize request argument(s)
 request = dataplex_v1 .ListMetadataFeedsRequest (
 parent="parent_value",
 )
 # Make the request
 page_result = client.list_metadata_feeds (request=request)
 # Handle the response
 for response in page_result:
 print(response)

usingGoogle.Cloud.Dataplex.V1 ;
usingGoogle.LongRunning ;
usingGoogle.Protobuf.WellKnownTypes ;
publicsealedpartialclassGeneratedCatalogServiceClientSnippets
{
/// <summary>Snippet for UpdateMetadataFeed</summary>
/// <remarks>
/// This snippet has been automatically generated and should be regarded as a code template only.
/// It will require modifications to work:
/// - It may require correct/in-range values for request initialization.
/// - It may require specifying regional endpoints when creating the service client as shown in
/// https://cloud.google.com/dotnet/docs/reference/help/client-configuration#endpoint.
/// </remarks>
publicvoidUpdateMetadataFeedRequestObject()
{
// Create client
CatalogServiceClient catalogServiceClient=CatalogServiceClient .Create ();
// Initialize request argument(s)
UpdateMetadataFeedRequest request=newUpdateMetadataFeedRequest
{
MetadataFeed=newMetadataFeed (),
UpdateMask=newFieldMask (),
ValidateOnly=false,
};
// Make the request
Operation<MetadataFeed,OperationMetadata>response=catalogServiceClient.UpdateMetadataFeed (request);
// Poll until the returned long-running operation is complete
Operation<MetadataFeed,OperationMetadata>completedResponse=response.PollUntilCompleted();
// Retrieve the operation result
MetadataFeed result=completedResponse.Result;
// Or get the name of the operation
stringoperationName=response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<MetadataFeed,OperationMetadata>retrievedResponse=catalogServiceClient.PollOnceUpdateMetadataFeed (operationName);
// Check if the retrieved long-running operation has completed
if(retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
MetadataFeed retrievedResult=retrievedResponse.Result;
}
}
}

//go:build examples
packagemain
import(
"context"
dataplex"cloud.google.com/go/dataplex/apiv1"
dataplexpb"cloud.google.com/go/dataplex/apiv1/dataplexpb"
)
funcmain(){
ctx:=context.Background()
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in:
// https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
c,err:=dataplex.NewCatalogClient (ctx)
iferr!=nil{
// TODO: Handle error.
}
deferc.Close()
req:=&dataplexpb.UpdateMetadataFeedRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/dataplex/apiv1/dataplexpb#UpdateMetadataFeedRequest.
}
op,err:=c.UpdateMetadataFeed(ctx,req)
iferr!=nil{
// TODO: Handle error.
}
resp,err:=op.Wait(ctx)
iferr!=nil{
// TODO: Handle error.
}
// TODO: Use resp.
_=resp
}

importcom.google.cloud.dataplex.v1.CatalogServiceClient ;
importcom.google.cloud.dataplex.v1.MetadataFeed ;
importcom.google.cloud.dataplex.v1.UpdateMetadataFeedRequest ;
importcom.google.protobuf.FieldMask ;
publicclass SyncUpdateMetadataFeed{
publicstaticvoidmain(String[]args)throwsException{
syncUpdateMetadataFeed();
}
publicstaticvoidsyncUpdateMetadataFeed()throwsException{
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(CatalogServiceClient catalogServiceClient=CatalogServiceClient .create()){
UpdateMetadataFeedRequest request=
UpdateMetadataFeedRequest .newBuilder()
.setMetadataFeed(MetadataFeed .newBuilder().build())
.setUpdateMask(FieldMask .newBuilder().build())
.setValidateOnly(true)
.build();
MetadataFeed response=catalogServiceClient.updateMetadataFeedAsync (request).get();
}
}
}

/**
 * This snippet has been automatically generated and should be regarded as a code template only.
 * It will require modifications to work.
 * It may require correct/in-range values for request initialization.
 * TODO(developer): Uncomment these variables before running the sample.
 */
/**
 * Required. Update description.
 * Only fields specified in `update_mask` are updated.
 */
// const metadataFeed = {}
/**
 * Optional. Mask of fields to update.
 */
// const updateMask = {}
/**
 * Optional. Only validate the request, but do not perform mutations.
 * The default is false.
 */
// const validateOnly = true
// Imports the Dataplex library
const{CatalogServiceClient}=require('@google-cloud/dataplex').v1;
// Instantiates a client
constdataplexClient=newCatalogServiceClient ();
asyncfunctioncallUpdateMetadataFeed(){
// Construct request
constrequest={
metadataFeed,
};
// Run request
const[operation]=awaitdataplexClient.updateMetadataFeed(request);
const[response]=awaitoperation.promise();
console.log(response);
}
callUpdateMetadataFeed();

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
# client as shown in:
# https://googleapis.dev/python/google-api-core/latest/client_options.html
fromgoogle.cloudimport dataplex_v1
defsample_update_metadata_feed():
 # Create a client
 client = dataplex_v1 .CatalogServiceClient ()
 # Initialize request argument(s)
 metadata_feed = dataplex_v1 .MetadataFeed ()
 metadata_feed.pubsub_topic = "pubsub_topic_value"
 request = dataplex_v1 .UpdateMetadataFeedRequest (
 metadata_feed=metadata_feed,
 )
 # Make the request
 operation = client.update_metadata_feed (request=request)
 print("Waiting for operation to complete...")
 response = operation.result()
 # Handle the response
 print(response)

usingGoogle.Cloud.Dataplex.V1 ;
usingGoogle.LongRunning ;
usingGoogle.Protobuf.WellKnownTypes ;
publicsealedpartialclassGeneratedCatalogServiceClientSnippets
{
/// <summary>Snippet for DeleteMetadataFeed</summary>
/// <remarks>
/// This snippet has been automatically generated and should be regarded as a code template only.
/// It will require modifications to work:
/// - It may require correct/in-range values for request initialization.
/// - It may require specifying regional endpoints when creating the service client as shown in
/// https://cloud.google.com/dotnet/docs/reference/help/client-configuration#endpoint.
/// </remarks>
publicvoidDeleteMetadataFeedRequestObject()
{
// Create client
CatalogServiceClient catalogServiceClient=CatalogServiceClient .Create ();
// Initialize request argument(s)
DeleteMetadataFeedRequest request=newDeleteMetadataFeedRequest
{
MetadataFeedName=MetadataFeedName .FromProjectLocationMetadataFeed ("[PROJECT]","[LOCATION]","[METADATA_FEED]"),
};
// Make the request
Operation<Empty,OperationMetadata>response=catalogServiceClient.DeleteMetadataFeed (request);
// Poll until the returned long-running operation is complete
Operation<Empty,OperationMetadata>completedResponse=response.PollUntilCompleted();
// Retrieve the operation result
Empty result=completedResponse.Result;
// Or get the name of the operation
stringoperationName=response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty,OperationMetadata>retrievedResponse=catalogServiceClient.PollOnceDeleteMetadataFeed (operationName);
// Check if the retrieved long-running operation has completed
if(retrievedResponse.IsCompleted)
{
// If it has completed, then access the result
Empty retrievedResult=retrievedResponse.Result;
}
}
}

//go:build examples
packagemain
import(
"context"
dataplex"cloud.google.com/go/dataplex/apiv1"
dataplexpb"cloud.google.com/go/dataplex/apiv1/dataplexpb"
)
funcmain(){
ctx:=context.Background()
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in:
// https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
c,err:=dataplex.NewCatalogClient (ctx)
iferr!=nil{
// TODO: Handle error.
}
deferc.Close()
req:=&dataplexpb.DeleteMetadataFeedRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/dataplex/apiv1/dataplexpb#DeleteMetadataFeedRequest.
}
op,err:=c.DeleteMetadataFeed(ctx,req)
iferr!=nil{
// TODO: Handle error.
}
err=op.Wait(ctx)
iferr!=nil{
// TODO: Handle error.
}
}

importcom.google.cloud.dataplex.v1.CatalogServiceClient ;
importcom.google.cloud.dataplex.v1.DeleteMetadataFeedRequest ;
importcom.google.cloud.dataplex.v1.MetadataFeedName ;
importcom.google.protobuf.Empty ;
publicclass SyncDeleteMetadataFeed{
publicstaticvoidmain(String[]args)throwsException{
syncDeleteMetadataFeed();
}
publicstaticvoidsyncDeleteMetadataFeed()throwsException{
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in
// https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
try(CatalogServiceClient catalogServiceClient=CatalogServiceClient .create()){
DeleteMetadataFeedRequest request=
DeleteMetadataFeedRequest .newBuilder()
.setName(MetadataFeedName .of("[PROJECT]","[LOCATION]","[METADATA_FEED]").toString())
.build();
catalogServiceClient.deleteMetadataFeedAsync (request).get();
}
}
}

/**
 * This snippet has been automatically generated and should be regarded as a code template only.
 * It will require modifications to work.
 * It may require correct/in-range values for request initialization.
 * TODO(developer): Uncomment these variables before running the sample.
 */
/**
 * Required. The resource name of the metadata feed, in the format
 * `projects/{project_id_or_number}/locations/{location_id}/MetadataFeeds/{metadata_feed_id}`.
 */
// const name = 'abc123'
// Imports the Dataplex library
const{CatalogServiceClient}=require('@google-cloud/dataplex').v1;
// Instantiates a client
constdataplexClient=newCatalogServiceClient ();
asyncfunctioncallDeleteMetadataFeed(){
// Construct request
constrequest={
name,
};
// Run request
const[operation]=awaitdataplexClient.deleteMetadataFeed(request);
const[response]=awaitoperation.promise();
console.log(response);
}
callDeleteMetadataFeed();

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
# client as shown in:
# https://googleapis.dev/python/google-api-core/latest/client_options.html
fromgoogle.cloudimport dataplex_v1
defsample_delete_metadata_feed():
 # Create a client
 client = dataplex_v1 .CatalogServiceClient ()
 # Initialize request argument(s)
 request = dataplex_v1 .DeleteMetadataFeedRequest (
 name="name_value",
 )
 # Make the request
 operation = client.delete_metadata_feed (request=request)
 print("Waiting for operation to complete...")
 response = operation.result()
 # Handle the response
 print(response)