import("context""fmt""io""cloud.google.com/go/pubsublite")// seekSubscription initiates a seek operation for a subscription.funcseekSubscription(wio.Writer,projectID,region,zone,subIDstring,seekTargetpubsublite.SeekTarget,waitForOperationbool)error{// projectID := "my-project-id"// region := "us-central1"// zone := "us-central1-a"// subID := "my-subscription"// seekTarget := pubsublite.Beginning// waitForOperation := false// Possible values for seekTarget:// - pubsublite.Beginning: replays from the beginning of all retained//   messages.// - pubsublite.End: skips past all current published messages.// - pubsublite.PublishTime(<time>): delivers messages with publish time//   greater than or equal to the specified timestamp.// - pubsublite.EventTime(<time>): seeks to the first message with event//   time greater than or equal to the specified timestamp.// Waiting for the seek operation to complete is optional. It indicates when// subscribers for all partitions are receiving messages from the seek// target. If subscribers are offline, the operation will complete once they// are online.ctx:=context.Background()client,err:=pubsublite.NewAdminClient(ctx,region)iferr!=nil{returnfmt.Errorf("pubsublite.NewAdminClient: %w",err)}deferclient.Close()// Initiate an out-of-band seek for a subscription to the specified target.// If an operation is returned, the seek has been successfully registered// and will eventually propagate to subscribers.subPath:=fmt.Sprintf("projects/%s/locations/%s/subscriptions/%s",projectID,zone,subID)seekOp,err:=client.SeekSubscription(ctx,subPath,seekTarget)iferr!=nil{returnfmt.Errorf("client.SeekSubscription got err: %w",err)}fmt.Fprintf(w,"Seek operation initiated: %s\n",seekOp.Name())ifwaitForOperation{_,err=seekOp.Wait(ctx)iferr!=nil{returnfmt.Errorf("seekOp.Wait got err: %w",err)}metadata,err:=seekOp.Metadata()iferr!=nil{returnfmt.Errorf("seekOp.Metadata got err: %w",err)}fmt.Fprintf(w,"Seek operation completed with metadata: %v\n",metadata)}returnnil}

importcom.google.api.gax.longrunning.OperationFuture;importcom.google.cloud.pubsublite.AdminClient;importcom.google.cloud.pubsublite.AdminClientSettings;importcom.google.cloud.pubsublite.BacklogLocation;importcom.google.cloud.pubsublite.CloudRegion;importcom.google.cloud.pubsublite.CloudRegionOrZone;importcom.google.cloud.pubsublite.CloudZone;importcom.google.cloud.pubsublite.ProjectNumber;importcom.google.cloud.pubsublite.SeekTarget;importcom.google.cloud.pubsublite.SubscriptionName;importcom.google.cloud.pubsublite.SubscriptionPath;importcom.google.cloud.pubsublite.proto.OperationMetadata;importcom.google.cloud.pubsublite.proto.SeekSubscriptionResponse;publicclassSeekSubscriptionExample{publicstaticvoidmain(String...args)throwsException{// TODO(developer): Replace these variables before running the sample.StringcloudRegion="your-cloud-region";charzoneId='b';// Choose an existing subscription.StringsubscriptionId="your-subscription-id";longprojectNumber=Long.parseLong("123456789");// True if using a regional location. False if using a zonal location.// https://cloud.google.com/pubsub/lite/docs/topicsbooleanregional=false;// Choose a target location within the message backlog to seek a subscription to.// Possible values for SeekTarget:// - SeekTarget.of(BacklogLocation.BEGINNING): replays from the beginning of all retained//   messages.// - SeekTarget.of(BacklogLocation.END): skips past all current published messages.// - SeekTarget.ofPublishTime(<timestamp>): delivers messages with publish time greater than//   or equal to the specified timestamp.// - SeekTarget.ofEventTime(<timestamp>): seeks to the first message with event time greater//   than or equal to the specified timestamp.SeekTargettarget=SeekTarget.of(BacklogLocation.BEGINNING);// Optional: Wait for the seek operation to complete, which indicates when subscribers for all// partitions are receiving messages from the seek target. If subscribers are offline, the// operation will complete once they are online.booleanwaitForOperation=false;seekSubscriptionExample(cloudRegion,zoneId,projectNumber,subscriptionId,target,waitForOperation,regional);}publicstaticvoidseekSubscriptionExample(StringcloudRegion,charzoneId,longprojectNumber,StringsubscriptionId,SeekTargettarget,booleanwaitForOperation,booleanregional)throwsException{CloudRegionOrZonelocation;if(regional){location=CloudRegionOrZone.of(CloudRegion.of(cloudRegion));}else{location=CloudRegionOrZone.of(CloudZone.of(CloudRegion.of(cloudRegion),zoneId));}SubscriptionPathsubscriptionPath=SubscriptionPath.newBuilder().setLocation(location).setProject(ProjectNumber.of(projectNumber)).setName(SubscriptionName.of(subscriptionId)).build();AdminClientSettingsadminClientSettings=AdminClientSettings.newBuilder().setRegion(CloudRegion.of(cloudRegion)).build();try(AdminClientadminClient=AdminClient.create(adminClientSettings)){// Initiate an out-of-band seek for a subscription to the specified target. If an operation// is returned, the seek has been successfully registered and will eventually propagate to// subscribers.OperationFuture<SeekSubscriptionResponse,OperationMetadata>seekFuture=adminClient.seekSubscription(subscriptionPath,target);System.out.println("Seek operation "+seekFuture.getName()+" initiated successfully.");if(waitForOperation){System.out.println("Waiting for operation to complete...");seekFuture.get();System.out.println("Operation completed. Metadata:\n"+seekFuture.getMetadata().get());}}}}

fromgoogle.api_core.exceptionsimportNotFoundfromgoogle.cloud.pubsubliteimportAdminClientfromgoogle.cloud.pubsublite.typesimportCloudRegion,CloudZone,SubscriptionPath# TODO(developer):# project_number = 1122334455# cloud_region = "us-central1"# zone_id = "a"# subscription_id = "your-subscription-id"# seek_target = BacklogLocation.BEGINNING# wait_for_operation = False# regional = True# Possible values for seek_target:# - BacklogLocation.BEGINNING: replays from the beginning of all retained#   messages.# - BacklogLocation.END: skips past all current published messages.# - PublishTime(<datetime>): delivers messages with publish time greater#   than or equal to the specified timestamp.# - EventTime(<datetime>): seeks to the first message with event time#   greater than or equal to the specified timestamp.# Waiting for the seek operation to complete is optional. It indicates when# subscribers for all partitions are receiving messages from the seek# target. If subscribers are offline, the operation will complete once they# are online.ifregional:location=CloudRegion(cloud_region)else:location=CloudZone(CloudRegion(cloud_region),zone_id)subscription_path=SubscriptionPath(project_number,location,subscription_id)client=AdminClient(cloud_region)try:# Initiate an out-of-band seek for a subscription to the specified# target. If an operation is returned, the seek has been successfully# registered and will eventually propagate to subscribers.seek_operation=client.seek_subscription(subscription_path,seek_target)print(f"Seek operation:{seek_operation.operation.name}")exceptNotFound:print(f"{subscription_path} not found.")returnifwait_for_operation:print("Waiting for operation to complete...")seek_operation.result()print(f"Operation completed. Metadata:\n{seek_operation.metadata}")