Class CloudRedisClient (2.2.0)
Stay organized with collections
Save and categorize content based on your preferences.
- 2.81.0 (latest)
- 2.79.0
- 2.78.0
- 2.77.0
- 2.76.0
- 2.75.0
- 2.73.0
- 2.71.0
- 2.70.0
- 2.67.0
- 2.66.0
- 2.65.0
- 2.63.0
- 2.62.0
- 2.61.0
- 2.60.0
- 2.59.0
- 2.58.0
- 2.57.0
- 2.56.0
- 2.55.0
- 2.54.0
- 2.52.0
- 2.51.0
- 2.50.0
- 2.49.0
- 2.48.0
- 2.47.0
- 2.46.0
- 2.45.0
- 2.44.0
- 2.43.0
- 2.42.0
- 2.40.0
- 2.39.0
- 2.38.0
- 2.37.0
- 2.36.0
- 2.35.0
- 2.34.0
- 2.33.0
- 2.32.0
- 2.31.0
- 2.30.0
- 2.27.0
- 2.26.0
- 2.25.0
- 2.24.0
- 2.23.0
- 2.22.0
- 2.21.0
- 2.20.0
- 2.19.0
- 2.18.0
- 2.17.0
- 2.16.0
- 2.15.0
- 2.14.0
- 2.12.0
- 2.11.0
- 2.10.0
- 2.9.0
- 2.8.0
- 2.7.0
- 2.6.5
- 2.5.0
- 2.4.1
- 2.3.0
- 2.2.0
- 2.1.1
publicclass CloudRedisClientimplementsBackgroundResourceService Description: Configures and manages Cloud Memorystore for Redis instances
Google Cloud Memorystore for Redis v1
The redis.googleapis.com service implements the Google Cloud Memorystore for Redis API and
defines the following resource model for managing Redis instances:
- The service works with a collection of cloud projects, named:
/projects/* - Each project has a collection of available locations, named:
/locations/* - Each location has a collection of Redis instances, named:
/instances/* - As such, Redis instances are resources of the form:
/projects/{project_id}/locations/{location_id}/instances/{instance_id}
Note that location_id must be referring to a GCP region; for example:
projects/redpepper-1290/locations/us-central1/instances/my-redis
This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
InstanceNamename=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
Instanceresponse=cloudRedisClient.getInstance(name);
}
Note: close() needs to be called on the CloudRedisClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().
The surface of this class includes several types of Java methods for each of the API's methods:
- A "flattened" method. With this type of method, the fields of the request type have been converted into function parameters. It may be the case that not all fields are available as parameters, and not every API method will have a flattened method entry point.
- A "request object" method. This type of method only takes one parameter, a request object, which must be constructed before the call. Not every API method will have a request object method.
- A "callable" method. This type of method takes no parameters and returns an immutable API callable object, which can be used to initiate calls to the service.
See the individual methods for example code.
Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.
This class can be customized by passing in a custom instance of CloudRedisSettings to create(). For example:
To customize credentials:
CloudRedisSettingscloudRedisSettings=
CloudRedisSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
.build();
CloudRedisClientcloudRedisClient=CloudRedisClient.create(cloudRedisSettings);
To customize the endpoint:
CloudRedisSettingscloudRedisSettings=
CloudRedisSettings.newBuilder().setEndpoint(myEndpoint).build();
CloudRedisClientcloudRedisClient=CloudRedisClient.create(cloudRedisSettings);
Please refer to the GitHub repository's samples for more quickstart code snippets.
Implements
BackgroundResourceInherited Members
Static Methods
create()
publicstaticfinalCloudRedisClientcreate()Constructs an instance of CloudRedisClient with default settings.
create(CloudRedisSettings settings)
publicstaticfinalCloudRedisClientcreate(CloudRedisSettingssettings)Constructs an instance of CloudRedisClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.
create(CloudRedisStub stub)
publicstaticfinalCloudRedisClientcreate(CloudRedisStubstub)Constructs an instance of CloudRedisClient, using the given stub for making calls. This is for advanced usage - prefer using create(CloudRedisSettings).
Constructors
CloudRedisClient(CloudRedisSettings settings)
protectedCloudRedisClient(CloudRedisSettingssettings)Constructs an instance of CloudRedisClient, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.
CloudRedisClient(CloudRedisStub stub)
protectedCloudRedisClient(CloudRedisStubstub)Methods
awaitTermination(long duration, TimeUnit unit)
publicbooleanawaitTermination(longduration,TimeUnitunit)close()
publicfinalvoidclose()createInstanceAsync(CreateInstanceRequest request)
publicfinalOperationFuture<Instance,OperationMetadata>createInstanceAsync(CreateInstanceRequestrequest)Creates a Redis instance based on the specified tier and memory size.
By default, the instance is accessible from the project's default network.
The creation is executed asynchronously and callers may check the returned operation to track its progress. Once the operation is completed the Redis instance will be fully functional. Completed longrunning.Operation will contain the new instance object in the response field.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
CreateInstanceRequestrequest=
CreateInstanceRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setInstanceId("instanceId902024336")
.setInstance(Instance.newBuilder().build())
.build();
Instanceresponse=cloudRedisClient.createInstanceAsync(request).get();
}
createInstanceAsync(LocationName parent, String instanceId, Instance instance)
publicfinalOperationFuture<Instance,OperationMetadata>createInstanceAsync(LocationNameparent,StringinstanceId,Instanceinstance)Creates a Redis instance based on the specified tier and memory size.
By default, the instance is accessible from the project's default network.
The creation is executed asynchronously and callers may check the returned operation to track its progress. Once the operation is completed the Redis instance will be fully functional. Completed longrunning.Operation will contain the new instance object in the response field.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
LocationNameparent=LocationName.of("[PROJECT]","[LOCATION]");
StringinstanceId="instanceId902024336";
Instanceinstance=Instance.newBuilder().build();
Instanceresponse=cloudRedisClient.createInstanceAsync(parent,instanceId,instance).get();
}
LocationName Required. The resource name of the instance location using the form:
projects/{project_id}/locations/{location_id} where location_id refers to a GCP region.
String Required. The logical name of the Redis instance in the customer project with the following restrictions:
- Must contain only lowercase letters, numbers, and hyphens.
- Must start with a letter.
- Must be between 1-40 characters.
- Must end with a number or a letter.
- Must be unique within the customer project / location
createInstanceAsync(String parent, String instanceId, Instance instance)
publicfinalOperationFuture<Instance,OperationMetadata>createInstanceAsync(Stringparent,StringinstanceId,Instanceinstance)Creates a Redis instance based on the specified tier and memory size.
By default, the instance is accessible from the project's default network.
The creation is executed asynchronously and callers may check the returned operation to track its progress. Once the operation is completed the Redis instance will be fully functional. Completed longrunning.Operation will contain the new instance object in the response field.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringparent=LocationName.of("[PROJECT]","[LOCATION]").toString();
StringinstanceId="instanceId902024336";
Instanceinstance=Instance.newBuilder().build();
Instanceresponse=cloudRedisClient.createInstanceAsync(parent,instanceId,instance).get();
}
String Required. The resource name of the instance location using the form:
projects/{project_id}/locations/{location_id} where location_id refers to a GCP region.
String Required. The logical name of the Redis instance in the customer project with the following restrictions:
- Must contain only lowercase letters, numbers, and hyphens.
- Must start with a letter.
- Must be between 1-40 characters.
- Must end with a number or a letter.
- Must be unique within the customer project / location
createInstanceCallable()
publicfinalUnaryCallable<CreateInstanceRequest,Operation>createInstanceCallable()Creates a Redis instance based on the specified tier and memory size.
By default, the instance is accessible from the project's default network.
The creation is executed asynchronously and callers may check the returned operation to track its progress. Once the operation is completed the Redis instance will be fully functional. Completed longrunning.Operation will contain the new instance object in the response field.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
CreateInstanceRequestrequest=
CreateInstanceRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setInstanceId("instanceId902024336")
.setInstance(Instance.newBuilder().build())
.build();
ApiFuture<Operation>future=cloudRedisClient.createInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}
createInstanceOperationCallable()
publicfinalOperationCallable<CreateInstanceRequest,Instance,OperationMetadata>createInstanceOperationCallable()Creates a Redis instance based on the specified tier and memory size.
By default, the instance is accessible from the project's default network.
The creation is executed asynchronously and callers may check the returned operation to track its progress. Once the operation is completed the Redis instance will be fully functional. Completed longrunning.Operation will contain the new instance object in the response field.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
CreateInstanceRequestrequest=
CreateInstanceRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setInstanceId("instanceId902024336")
.setInstance(Instance.newBuilder().build())
.build();
OperationFuturedeleteInstanceAsync(DeleteInstanceRequest request)
publicfinalOperationFuture<Empty,OperationMetadata>deleteInstanceAsync(DeleteInstanceRequestrequest)Deletes a specific Redis instance. Instance stops serving and data is deleted.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
DeleteInstanceRequestrequest=
DeleteInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
cloudRedisClient.deleteInstanceAsync(request).get();
}
deleteInstanceAsync(InstanceName name)
publicfinalOperationFuture<Empty,OperationMetadata>deleteInstanceAsync(InstanceNamename)Deletes a specific Redis instance. Instance stops serving and data is deleted.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
InstanceNamename=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
cloudRedisClient.deleteInstanceAsync(name).get();
}
InstanceName Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
deleteInstanceAsync(String name)
publicfinalOperationFuture<Empty,OperationMetadata>deleteInstanceAsync(Stringname)Deletes a specific Redis instance. Instance stops serving and data is deleted.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringname=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
cloudRedisClient.deleteInstanceAsync(name).get();
}
String Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
deleteInstanceCallable()
publicfinalUnaryCallable<DeleteInstanceRequest,Operation>deleteInstanceCallable()Deletes a specific Redis instance. Instance stops serving and data is deleted.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
DeleteInstanceRequestrequest=
DeleteInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
ApiFuture<Operation>future=cloudRedisClient.deleteInstanceCallable().futureCall(request);
// Do something.
future.get();
}
deleteInstanceOperationCallable()
publicfinalOperationCallable<DeleteInstanceRequest,Empty,OperationMetadata>deleteInstanceOperationCallable()Deletes a specific Redis instance. Instance stops serving and data is deleted.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
DeleteInstanceRequestrequest=
DeleteInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
OperationFutureexportInstanceAsync(ExportInstanceRequest request)
publicfinalOperationFuture<Instance,OperationMetadata>exportInstanceAsync(ExportInstanceRequestrequest)Export Redis instance data into a Redis RDB format file in Cloud Storage.
Redis will continue serving during this operation.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ExportInstanceRequestrequest=
ExportInstanceRequest.newBuilder()
.setName("name3373707")
.setOutputConfig(OutputConfig.newBuilder().build())
.build();
Instanceresponse=cloudRedisClient.exportInstanceAsync(request).get();
}
exportInstanceAsync(String name, OutputConfig outputConfig)
publicfinalOperationFuture<Instance,OperationMetadata>exportInstanceAsync(Stringname,OutputConfigoutputConfig)Export Redis instance data into a Redis RDB format file in Cloud Storage.
Redis will continue serving during this operation.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringname="name3373707";
OutputConfigoutputConfig=OutputConfig.newBuilder().build();
Instanceresponse=cloudRedisClient.exportInstanceAsync(name,outputConfig).get();
}
String Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
exportInstanceCallable()
publicfinalUnaryCallable<ExportInstanceRequest,Operation>exportInstanceCallable()Export Redis instance data into a Redis RDB format file in Cloud Storage.
Redis will continue serving during this operation.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ExportInstanceRequestrequest=
ExportInstanceRequest.newBuilder()
.setName("name3373707")
.setOutputConfig(OutputConfig.newBuilder().build())
.build();
ApiFuture<Operation>future=cloudRedisClient.exportInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}
exportInstanceOperationCallable()
publicfinalOperationCallable<ExportInstanceRequest,Instance,OperationMetadata>exportInstanceOperationCallable()Export Redis instance data into a Redis RDB format file in Cloud Storage.
Redis will continue serving during this operation.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ExportInstanceRequestrequest=
ExportInstanceRequest.newBuilder()
.setName("name3373707")
.setOutputConfig(OutputConfig.newBuilder().build())
.build();
OperationFuturefailoverInstanceAsync(FailoverInstanceRequest request)
publicfinalOperationFuture<Instance,OperationMetadata>failoverInstanceAsync(FailoverInstanceRequestrequest)Initiates a failover of the primary node to current replica node for a specific STANDARD tier Cloud Memorystore for Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
FailoverInstanceRequestrequest=
FailoverInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
Instanceresponse=cloudRedisClient.failoverInstanceAsync(request).get();
}
FailoverInstanceRequest The request object containing all of the parameters for the API call.
failoverInstanceAsync(InstanceName name, FailoverInstanceRequest.DataProtectionMode dataProtectionMode)
publicfinalOperationFuture<Instance,OperationMetadata>failoverInstanceAsync(InstanceNamename,FailoverInstanceRequest.DataProtectionModedataProtectionMode)Initiates a failover of the primary node to current replica node for a specific STANDARD tier Cloud Memorystore for Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
InstanceNamename=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
FailoverInstanceRequest.DataProtectionModedataProtectionMode=
FailoverInstanceRequest.DataProtectionMode.forNumber(0);
Instanceresponse=cloudRedisClient.failoverInstanceAsync(name,dataProtectionMode).get();
}
InstanceName Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
FailoverInstanceRequest.DataProtectionMode Optional. Available data protection modes that the user can choose. If it's unspecified, data protection mode will be LIMITED_DATA_LOSS by default.
failoverInstanceAsync(String name, FailoverInstanceRequest.DataProtectionMode dataProtectionMode)
publicfinalOperationFuture<Instance,OperationMetadata>failoverInstanceAsync(Stringname,FailoverInstanceRequest.DataProtectionModedataProtectionMode)Initiates a failover of the primary node to current replica node for a specific STANDARD tier Cloud Memorystore for Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringname=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
FailoverInstanceRequest.DataProtectionModedataProtectionMode=
FailoverInstanceRequest.DataProtectionMode.forNumber(0);
Instanceresponse=cloudRedisClient.failoverInstanceAsync(name,dataProtectionMode).get();
}
String Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
FailoverInstanceRequest.DataProtectionMode Optional. Available data protection modes that the user can choose. If it's unspecified, data protection mode will be LIMITED_DATA_LOSS by default.
failoverInstanceCallable()
publicfinalUnaryCallable<FailoverInstanceRequest,Operation>failoverInstanceCallable()Initiates a failover of the primary node to current replica node for a specific STANDARD tier Cloud Memorystore for Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
FailoverInstanceRequestrequest=
FailoverInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
ApiFuture<Operation>future=cloudRedisClient.failoverInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}
failoverInstanceOperationCallable()
publicfinalOperationCallable<FailoverInstanceRequest,Instance,OperationMetadata>failoverInstanceOperationCallable()Initiates a failover of the primary node to current replica node for a specific STANDARD tier Cloud Memorystore for Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
FailoverInstanceRequestrequest=
FailoverInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
OperationFuturegetInstance(GetInstanceRequest request)
publicfinalInstancegetInstance(GetInstanceRequestrequest)Gets the details of a specific Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
GetInstanceRequestrequest=
GetInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
Instanceresponse=cloudRedisClient.getInstance(request);
}
getInstance(InstanceName name)
publicfinalInstancegetInstance(InstanceNamename)Gets the details of a specific Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
InstanceNamename=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
Instanceresponse=cloudRedisClient.getInstance(name);
}
InstanceName Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
getInstance(String name)
publicfinalInstancegetInstance(Stringname)Gets the details of a specific Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringname=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
Instanceresponse=cloudRedisClient.getInstance(name);
}
String Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
getInstanceCallable()
publicfinalUnaryCallable<GetInstanceRequest,Instance>getInstanceCallable()Gets the details of a specific Redis instance.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
GetInstanceRequestrequest=
GetInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.build();
ApiFuture<Instance>future=cloudRedisClient.getInstanceCallable().futureCall(request);
// Do something.
Instanceresponse=future.get();
}
getOperationsClient()
publicfinalOperationsClientgetOperationsClient()Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.
getSettings()
publicfinalCloudRedisSettingsgetSettings()getStub()
publicCloudRedisStubgetStub()importInstanceAsync(ImportInstanceRequest request)
publicfinalOperationFuture<Instance,OperationMetadata>importInstanceAsync(ImportInstanceRequestrequest)Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.
Redis may stop serving during this operation. Instance state will be IMPORTING for entire operation. When complete, the instance will contain only data from the imported file.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ImportInstanceRequestrequest=
ImportInstanceRequest.newBuilder()
.setName("name3373707")
.setInputConfig(InputConfig.newBuilder().build())
.build();
Instanceresponse=cloudRedisClient.importInstanceAsync(request).get();
}
importInstanceAsync(String name, InputConfig inputConfig)
publicfinalOperationFuture<Instance,OperationMetadata>importInstanceAsync(Stringname,InputConfiginputConfig)Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.
Redis may stop serving during this operation. Instance state will be IMPORTING for entire operation. When complete, the instance will contain only data from the imported file.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringname="name3373707";
InputConfiginputConfig=InputConfig.newBuilder().build();
Instanceresponse=cloudRedisClient.importInstanceAsync(name,inputConfig).get();
}
String Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
importInstanceCallable()
publicfinalUnaryCallable<ImportInstanceRequest,Operation>importInstanceCallable()Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.
Redis may stop serving during this operation. Instance state will be IMPORTING for entire operation. When complete, the instance will contain only data from the imported file.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ImportInstanceRequestrequest=
ImportInstanceRequest.newBuilder()
.setName("name3373707")
.setInputConfig(InputConfig.newBuilder().build())
.build();
ApiFuture<Operation>future=cloudRedisClient.importInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}
importInstanceOperationCallable()
publicfinalOperationCallable<ImportInstanceRequest,Instance,OperationMetadata>importInstanceOperationCallable()Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.
Redis may stop serving during this operation. Instance state will be IMPORTING for entire operation. When complete, the instance will contain only data from the imported file.
The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ImportInstanceRequestrequest=
ImportInstanceRequest.newBuilder()
.setName("name3373707")
.setInputConfig(InputConfig.newBuilder().build())
.build();
OperationFutureisShutdown()
publicbooleanisShutdown()isTerminated()
publicbooleanisTerminated()listInstances(ListInstancesRequest request)
publicfinalCloudRedisClient.ListInstancesPagedResponselistInstances(ListInstancesRequestrequest)Lists all Redis instances owned by a project in either the specified location (region) or all locations.
The location should have the following format:
projects/{project_id}/locations/{location_id}
If location_id is specified as - (wildcard), then all regions available to the project
are queried, and the results are aggregated.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ListInstancesRequestrequest=
ListInstancesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
for(Instanceelement:cloudRedisClient.listInstances(request).iterateAll()){
// doThingsWith(element);
}
}
listInstances(LocationName parent)
publicfinalCloudRedisClient.ListInstancesPagedResponselistInstances(LocationNameparent)Lists all Redis instances owned by a project in either the specified location (region) or all locations.
The location should have the following format:
projects/{project_id}/locations/{location_id}
If location_id is specified as - (wildcard), then all regions available to the project
are queried, and the results are aggregated.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
LocationNameparent=LocationName.of("[PROJECT]","[LOCATION]");
for(Instanceelement:cloudRedisClient.listInstances(parent).iterateAll()){
// doThingsWith(element);
}
}
LocationName Required. The resource name of the instance location using the form:
projects/{project_id}/locations/{location_id} where location_id refers to a GCP region.
listInstances(String parent)
publicfinalCloudRedisClient.ListInstancesPagedResponselistInstances(Stringparent)Lists all Redis instances owned by a project in either the specified location (region) or all locations.
The location should have the following format:
projects/{project_id}/locations/{location_id}
If location_id is specified as - (wildcard), then all regions available to the project
are queried, and the results are aggregated.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringparent=LocationName.of("[PROJECT]","[LOCATION]").toString();
for(Instanceelement:cloudRedisClient.listInstances(parent).iterateAll()){
// doThingsWith(element);
}
}
String Required. The resource name of the instance location using the form:
projects/{project_id}/locations/{location_id} where location_id refers to a GCP region.
listInstancesCallable()
publicfinalUnaryCallable<ListInstancesRequest,ListInstancesResponse>listInstancesCallable()Lists all Redis instances owned by a project in either the specified location (region) or all locations.
The location should have the following format:
projects/{project_id}/locations/{location_id}
If location_id is specified as - (wildcard), then all regions available to the project
are queried, and the results are aggregated.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ListInstancesRequestrequest=
ListInstancesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
while(true){
ListInstancesResponseresponse=cloudRedisClient.listInstancesCallable().call(request);
for(Instanceelement:response.getResponsesList()){
// doThingsWith(element);
}
StringnextPageToken=response.getNextPageToken();
if(!Strings.isNullOrEmpty(nextPageToken)){
request=request.toBuilder().setPageToken(nextPageToken).build();
}else{
break;
}
}
}
listInstancesPagedCallable()
publicfinalUnaryCallable<ListInstancesRequest,CloudRedisClient.ListInstancesPagedResponse>listInstancesPagedCallable()Lists all Redis instances owned by a project in either the specified location (region) or all locations.
The location should have the following format:
projects/{project_id}/locations/{location_id}
If location_id is specified as - (wildcard), then all regions available to the project
are queried, and the results are aggregated.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
ListInstancesRequestrequest=
ListInstancesRequest.newBuilder()
.setParent(LocationName.of("[PROJECT]","[LOCATION]").toString())
.setPageSize(883849137)
.setPageToken("pageToken873572522")
.build();
ApiFuture<Instance>future=
cloudRedisClient.listInstancesPagedCallable().futureCall(request);
// Do something.
for(Instanceelement:future.get().iterateAll()){
// doThingsWith(element);
}
}
shutdown()
publicvoidshutdown()shutdownNow()
publicvoidshutdownNow()updateInstanceAsync(UpdateInstanceRequest request)
publicfinalOperationFuture<Instance,OperationMetadata>updateInstanceAsync(UpdateInstanceRequestrequest)Updates the metadata and configuration of a specific Redis instance.
Completed longrunning.Operation will contain the new instance object in the response field. The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
UpdateInstanceRequestrequest=
UpdateInstanceRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setInstance(Instance.newBuilder().build())
.build();
Instanceresponse=cloudRedisClient.updateInstanceAsync(request).get();
}
updateInstanceAsync(FieldMask updateMask, Instance instance)
publicfinalOperationFuture<Instance,OperationMetadata>updateInstanceAsync(FieldMaskupdateMask,Instanceinstance)Updates the metadata and configuration of a specific Redis instance.
Completed longrunning.Operation will contain the new instance object in the response field. The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
FieldMaskupdateMask=FieldMask.newBuilder().build();
Instanceinstance=Instance.newBuilder().build();
Instanceresponse=cloudRedisClient.updateInstanceAsync(updateMask,instance).get();
}
FieldMask Required. Mask of fields to update. At least one path must be supplied in this field. The elements of the repeated paths field may only include these fields from Instance:
* displayName * labels * memorySizeGb * redisConfig *
replica_count
updateInstanceCallable()
publicfinalUnaryCallable<UpdateInstanceRequest,Operation>updateInstanceCallable()Updates the metadata and configuration of a specific Redis instance.
Completed longrunning.Operation will contain the new instance object in the response field. The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
UpdateInstanceRequestrequest=
UpdateInstanceRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setInstance(Instance.newBuilder().build())
.build();
ApiFuture<Operation>future=cloudRedisClient.updateInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}
updateInstanceOperationCallable()
publicfinalOperationCallable<UpdateInstanceRequest,Instance,OperationMetadata>updateInstanceOperationCallable()Updates the metadata and configuration of a specific Redis instance.
Completed longrunning.Operation will contain the new instance object in the response field. The returned operation is automatically deleted after a few hours, so there is no need to call DeleteOperation.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
UpdateInstanceRequestrequest=
UpdateInstanceRequest.newBuilder()
.setUpdateMask(FieldMask.newBuilder().build())
.setInstance(Instance.newBuilder().build())
.build();
OperationFutureupgradeInstanceAsync(InstanceName name, String redisVersion)
publicfinalOperationFuture<Instance,OperationMetadata>upgradeInstanceAsync(InstanceNamename,StringredisVersion)Upgrades Redis instance to the newer Redis version specified in the request.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
InstanceNamename=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]");
StringredisVersion="redisVersion-1972584739";
Instanceresponse=cloudRedisClient.upgradeInstanceAsync(name,redisVersion).get();
}
InstanceName Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
upgradeInstanceAsync(UpgradeInstanceRequest request)
publicfinalOperationFuture<Instance,OperationMetadata>upgradeInstanceAsync(UpgradeInstanceRequestrequest)Upgrades Redis instance to the newer Redis version specified in the request.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
UpgradeInstanceRequestrequest=
UpgradeInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setRedisVersion("redisVersion-1972584739")
.build();
Instanceresponse=cloudRedisClient.upgradeInstanceAsync(request).get();
}
UpgradeInstanceRequest The request object containing all of the parameters for the API call.
upgradeInstanceAsync(String name, String redisVersion)
publicfinalOperationFuture<Instance,OperationMetadata>upgradeInstanceAsync(Stringname,StringredisVersion)Upgrades Redis instance to the newer Redis version specified in the request.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
Stringname=InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString();
StringredisVersion="redisVersion-1972584739";
Instanceresponse=cloudRedisClient.upgradeInstanceAsync(name,redisVersion).get();
}
String Required. Redis instance resource name using the form:
projects/{project_id}/locations/{location_id}/instances/{instance_id} where location_id
refers to a GCP region.
upgradeInstanceCallable()
publicfinalUnaryCallable<UpgradeInstanceRequest,Operation>upgradeInstanceCallable()Upgrades Redis instance to the newer Redis version specified in the request.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
UpgradeInstanceRequestrequest=
UpgradeInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setRedisVersion("redisVersion-1972584739")
.build();
ApiFuture<Operation>future=cloudRedisClient.upgradeInstanceCallable().futureCall(request);
// Do something.
Operationresponse=future.get();
}
upgradeInstanceOperationCallable()
publicfinalOperationCallable<UpgradeInstanceRequest,Instance,OperationMetadata>upgradeInstanceOperationCallable()Upgrades Redis instance to the newer Redis version specified in the request.
Sample code:
try(CloudRedisClientcloudRedisClient=CloudRedisClient.create()){
UpgradeInstanceRequestrequest=
UpgradeInstanceRequest.newBuilder()
.setName(InstanceName.of("[PROJECT]","[LOCATION]","[INSTANCE]").toString())
.setRedisVersion("redisVersion-1972584739")
.build();
OperationFuture