package clusterpb
import "cloud.google.com/go/redis/cluster/apiv1/clusterpb"
Index ¶
- Variables
- func RegisterCloudRedisClusterServer(s *grpc.Server, srv CloudRedisClusterServer)
- type AuthorizationMode
- func (AuthorizationMode) Descriptor() protoreflect.EnumDescriptor
- func (x AuthorizationMode) Enum() *AuthorizationMode
- func (AuthorizationMode) EnumDescriptor() ([]byte, []int)
- func (x AuthorizationMode) Number() protoreflect.EnumNumber
- func (x AuthorizationMode) String() string
- func (AuthorizationMode) Type() protoreflect.EnumType
- type CloudRedisClusterClient
- type CloudRedisClusterServer
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)
- func (x *Cluster) GetAuthorizationMode() AuthorizationMode
- func (x *Cluster) GetCreateTime() *timestamppb.Timestamp
- func (x *Cluster) GetDiscoveryEndpoints() []*DiscoveryEndpoint
- func (x *Cluster) GetName() string
- func (x *Cluster) GetPscConfigs() []*PscConfig
- func (x *Cluster) GetPscConnections() []*PscConnection
- func (x *Cluster) GetReplicaCount() int32
- func (x *Cluster) GetShardCount() int32
- func (x *Cluster) GetSizeGb() int32
- func (x *Cluster) GetState() Cluster_State
- func (x *Cluster) GetStateInfo() *Cluster_StateInfo
- func (x *Cluster) GetTransitEncryptionMode() TransitEncryptionMode
- func (x *Cluster) GetUid() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type Cluster_State
- func (Cluster_State) Descriptor() protoreflect.EnumDescriptor
- func (x Cluster_State) Enum() *Cluster_State
- func (Cluster_State) EnumDescriptor() ([]byte, []int)
- func (x Cluster_State) Number() protoreflect.EnumNumber
- func (x Cluster_State) String() string
- func (Cluster_State) Type() protoreflect.EnumType
- type Cluster_StateInfo
- func (*Cluster_StateInfo) Descriptor() ([]byte, []int)
- func (m *Cluster_StateInfo) GetInfo() isCluster_StateInfo_Info
- func (x *Cluster_StateInfo) GetUpdateInfo() *Cluster_StateInfo_UpdateInfo
- func (*Cluster_StateInfo) ProtoMessage()
- func (x *Cluster_StateInfo) ProtoReflect() protoreflect.Message
- func (x *Cluster_StateInfo) Reset()
- func (x *Cluster_StateInfo) String() string
- type Cluster_StateInfo_UpdateInfo
- func (*Cluster_StateInfo_UpdateInfo) Descriptor() ([]byte, []int)
- func (x *Cluster_StateInfo_UpdateInfo) GetTargetReplicaCount() int32
- func (x *Cluster_StateInfo_UpdateInfo) GetTargetShardCount() int32
- func (*Cluster_StateInfo_UpdateInfo) ProtoMessage()
- func (x *Cluster_StateInfo_UpdateInfo) ProtoReflect() protoreflect.Message
- func (x *Cluster_StateInfo_UpdateInfo) Reset()
- func (x *Cluster_StateInfo_UpdateInfo) String() string
- type Cluster_StateInfo_UpdateInfo_
- type CreateClusterRequest
- func (*CreateClusterRequest) Descriptor() ([]byte, []int)
- func (x *CreateClusterRequest) GetCluster() *Cluster
- func (x *CreateClusterRequest) GetClusterId() string
- func (x *CreateClusterRequest) GetParent() string
- func (x *CreateClusterRequest) GetRequestId() string
- func (*CreateClusterRequest) ProtoMessage()
- func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *CreateClusterRequest) Reset()
- func (x *CreateClusterRequest) String() string
- type DeleteClusterRequest
- func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
- func (x *DeleteClusterRequest) GetName() string
- func (x *DeleteClusterRequest) GetRequestId() string
- func (*DeleteClusterRequest) ProtoMessage()
- func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteClusterRequest) Reset()
- func (x *DeleteClusterRequest) String() string
- type DiscoveryEndpoint
- func (*DiscoveryEndpoint) Descriptor() ([]byte, []int)
- func (x *DiscoveryEndpoint) GetAddress() string
- func (x *DiscoveryEndpoint) GetPort() int32
- func (x *DiscoveryEndpoint) GetPscConfig() *PscConfig
- func (*DiscoveryEndpoint) ProtoMessage()
- func (x *DiscoveryEndpoint) ProtoReflect() protoreflect.Message
- func (x *DiscoveryEndpoint) Reset()
- func (x *DiscoveryEndpoint) String() string
- type GetClusterRequest
- func (*GetClusterRequest) Descriptor() ([]byte, []int)
- func (x *GetClusterRequest) GetName() string
- func (*GetClusterRequest) ProtoMessage()
- func (x *GetClusterRequest) ProtoReflect() protoreflect.Message
- func (x *GetClusterRequest) Reset()
- func (x *GetClusterRequest) String() string
- type ListClustersRequest
- func (*ListClustersRequest) Descriptor() ([]byte, []int)
- func (x *ListClustersRequest) GetPageSize() int32
- func (x *ListClustersRequest) GetPageToken() string
- func (x *ListClustersRequest) GetParent() string
- func (*ListClustersRequest) ProtoMessage()
- func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
- func (x *ListClustersRequest) Reset()
- func (x *ListClustersRequest) String() string
- type ListClustersResponse
- func (*ListClustersResponse) Descriptor() ([]byte, []int)
- func (x *ListClustersResponse) GetClusters() []*Cluster
- func (x *ListClustersResponse) GetNextPageToken() string
- func (x *ListClustersResponse) GetUnreachable() []string
- func (*ListClustersResponse) ProtoMessage()
- func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
- func (x *ListClustersResponse) Reset()
- func (x *ListClustersResponse) String() string
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)
- func (x *OperationMetadata) GetApiVersion() string
- func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetRequestedCancellation() bool
- func (x *OperationMetadata) GetStatusMessage() string
- func (x *OperationMetadata) GetTarget() string
- func (x *OperationMetadata) GetVerb() string
- func (*OperationMetadata) ProtoMessage()
- func (x *OperationMetadata) ProtoReflect() protoreflect.Message
- func (x *OperationMetadata) Reset()
- func (x *OperationMetadata) String() string
- type PscConfig
- func (*PscConfig) Descriptor() ([]byte, []int)
- func (x *PscConfig) GetNetwork() string
- func (*PscConfig) ProtoMessage()
- func (x *PscConfig) ProtoReflect() protoreflect.Message
- func (x *PscConfig) Reset()
- func (x *PscConfig) String() string
- type PscConnection
- func (*PscConnection) Descriptor() ([]byte, []int)
- func (x *PscConnection) GetAddress() string
- func (x *PscConnection) GetForwardingRule() string
- func (x *PscConnection) GetNetwork() string
- func (x *PscConnection) GetProjectId() string
- func (x *PscConnection) GetPscConnectionId() string
- func (*PscConnection) ProtoMessage()
- func (x *PscConnection) ProtoReflect() protoreflect.Message
- func (x *PscConnection) Reset()
- func (x *PscConnection) String() string
- type TransitEncryptionMode
- func (TransitEncryptionMode) Descriptor() protoreflect.EnumDescriptor
- func (x TransitEncryptionMode) Enum() *TransitEncryptionMode
- func (TransitEncryptionMode) EnumDescriptor() ([]byte, []int)
- func (x TransitEncryptionMode) Number() protoreflect.EnumNumber
- func (x TransitEncryptionMode) String() string
- func (TransitEncryptionMode) Type() protoreflect.EnumType
- type UnimplementedCloudRedisClusterServer
- func (*UnimplementedCloudRedisClusterServer) CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedCloudRedisClusterServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedCloudRedisClusterServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
- func (*UnimplementedCloudRedisClusterServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
- func (*UnimplementedCloudRedisClusterServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)
- type UpdateClusterRequest
- func (*UpdateClusterRequest) Descriptor() ([]byte, []int)
- func (x *UpdateClusterRequest) GetCluster() *Cluster
- func (x *UpdateClusterRequest) GetRequestId() string
- func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateClusterRequest) ProtoMessage()
- func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateClusterRequest) Reset()
- func (x *UpdateClusterRequest) String() string
Variables ¶
var ( AuthorizationMode_name = map[int32]string{ 0: "AUTH_MODE_UNSPECIFIED", 1: "AUTH_MODE_IAM_AUTH", 2: "AUTH_MODE_DISABLED", } AuthorizationMode_value = map[string]int32{ "AUTH_MODE_UNSPECIFIED": 0, "AUTH_MODE_IAM_AUTH": 1, "AUTH_MODE_DISABLED": 2, } )
Enum value maps for AuthorizationMode.
var ( TransitEncryptionMode_name = map[int32]string{ 0: "TRANSIT_ENCRYPTION_MODE_UNSPECIFIED", 1: "TRANSIT_ENCRYPTION_MODE_DISABLED", 2: "TRANSIT_ENCRYPTION_MODE_SERVER_AUTHENTICATION", } TransitEncryptionMode_value = map[string]int32{ "TRANSIT_ENCRYPTION_MODE_UNSPECIFIED": 0, "TRANSIT_ENCRYPTION_MODE_DISABLED": 1, "TRANSIT_ENCRYPTION_MODE_SERVER_AUTHENTICATION": 2, } )
Enum value maps for TransitEncryptionMode.
var ( Cluster_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "CREATING", 2: "ACTIVE", 3: "UPDATING", 4: "DELETING", } Cluster_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "CREATING": 1, "ACTIVE": 2, "UPDATING": 3, "DELETING": 4, } )
Enum value maps for Cluster_State.
var File_google_cloud_redis_cluster_v1_cloud_redis_cluster_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCloudRedisClusterServer ¶
func RegisterCloudRedisClusterServer(s *grpc.Server, srv CloudRedisClusterServer)
Types ¶
type AuthorizationMode ¶
type AuthorizationMode int32
Available authorization mode of a Redis cluster.
const ( // Not set. AuthorizationMode_AUTH_MODE_UNSPECIFIED AuthorizationMode = 0 // IAM basic authorization mode AuthorizationMode_AUTH_MODE_IAM_AUTH AuthorizationMode = 1 // Authorization disabled mode AuthorizationMode_AUTH_MODE_DISABLED AuthorizationMode = 2 )
func (AuthorizationMode) Descriptor ¶
func (AuthorizationMode) Descriptor() protoreflect.EnumDescriptor
func (AuthorizationMode) Enum ¶
func (x AuthorizationMode) Enum() *AuthorizationMode
func (AuthorizationMode) EnumDescriptor ¶
func (AuthorizationMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use AuthorizationMode.Descriptor instead.
func (AuthorizationMode) Number ¶
func (x AuthorizationMode) Number() protoreflect.EnumNumber
func (AuthorizationMode) String ¶
func (x AuthorizationMode) String() string
func (AuthorizationMode) Type ¶
func (AuthorizationMode) Type() protoreflect.EnumType
type CloudRedisClusterClient ¶
type CloudRedisClusterClient interface { // Lists all Redis clusters 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. ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) // Gets the details of a specific Redis cluster. GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) // Updates the metadata and configuration of a specific Redis cluster. // // Completed longrunning.Operation will contain the new cluster object // in the response field. The returned operation is automatically deleted // after a few hours, so there is no need to call DeleteOperation. UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Deletes a specific Redis cluster. Cluster stops serving and data is // deleted. DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Creates a Redis cluster based on the specified properties. // The creation is executed asynchronously and callers may check the returned // operation to track its progress. Once the operation is completed the Redis // cluster will be fully functional. The completed longrunning.Operation will // contain the new cluster object in the response field. // // The returned operation is automatically deleted after a few hours, so there // is no need to call DeleteOperation. CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) }
CloudRedisClusterClient is the client API for CloudRedisCluster service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCloudRedisClusterClient ¶
func NewCloudRedisClusterClient(cc grpc.ClientConnInterface) CloudRedisClusterClient
type CloudRedisClusterServer ¶
type CloudRedisClusterServer interface { // Lists all Redis clusters 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. ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error) // Gets the details of a specific Redis cluster. GetCluster(context.Context, *GetClusterRequest) (*Cluster, error) // Updates the metadata and configuration of a specific Redis cluster. // // Completed longrunning.Operation will contain the new cluster object // in the response field. The returned operation is automatically deleted // after a few hours, so there is no need to call DeleteOperation. UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error) // Deletes a specific Redis cluster. Cluster stops serving and data is // deleted. DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error) // Creates a Redis cluster based on the specified properties. // The creation is executed asynchronously and callers may check the returned // operation to track its progress. Once the operation is completed the Redis // cluster will be fully functional. The completed longrunning.Operation will // contain the new cluster object in the response field. // // The returned operation is automatically deleted after a few hours, so there // is no need to call DeleteOperation. CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error) }
CloudRedisClusterServer is the server API for CloudRedisCluster service.
type Cluster ¶
type Cluster struct { // Required. Unique name of the resource in this scope including project and // location using the form: // // `projects/{project_id}/locations/{location_id}/clusters/{cluster_id}` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. The timestamp associated with the cluster creation request. CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The current state of this cluster. // Can be CREATING, READY, UPDATING, DELETING and SUSPENDED State Cluster_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.redis.cluster.v1.Cluster_State" json:"state,omitempty"` // Output only. System assigned, unique identifier for the cluster. Uid string `protobuf:"bytes,5,opt,name=uid,proto3" json:"uid,omitempty"` // Optional. The number of replica nodes per shard. ReplicaCount *int32 `protobuf:"varint,8,opt,name=replica_count,json=replicaCount,proto3,oneof" json:"replica_count,omitempty"` // Optional. The authorization mode of the Redis cluster. // If not provided, auth feature is disabled for the cluster. AuthorizationMode AuthorizationMode `protobuf:"varint,11,opt,name=authorization_mode,json=authorizationMode,proto3,enum=google.cloud.redis.cluster.v1.AuthorizationMode" json:"authorization_mode,omitempty"` // Optional. The in-transit encryption for the Redis cluster. // If not provided, encryption is disabled for the cluster. TransitEncryptionMode TransitEncryptionMode `protobuf:"varint,12,opt,name=transit_encryption_mode,json=transitEncryptionMode,proto3,enum=google.cloud.redis.cluster.v1.TransitEncryptionMode" json:"transit_encryption_mode,omitempty"` // Output only. Redis memory size in GB for the entire cluster. SizeGb *int32 `protobuf:"varint,13,opt,name=size_gb,json=sizeGb,proto3,oneof" json:"size_gb,omitempty"` // Required. Number of shards for the Redis cluster. ShardCount *int32 `protobuf:"varint,14,opt,name=shard_count,json=shardCount,proto3,oneof" json:"shard_count,omitempty"` // Required. Each PscConfig configures the consumer network where IPs will // be designated to the cluster for client access through Private Service // Connect Automation. Currently, only one PscConfig is supported. PscConfigs []*PscConfig `protobuf:"bytes,15,rep,name=psc_configs,json=pscConfigs,proto3" json:"psc_configs,omitempty"` // Output only. Endpoints created on each given network, for Redis clients to // connect to the cluster. Currently only one discovery endpoint is supported. DiscoveryEndpoints []*DiscoveryEndpoint `protobuf:"bytes,16,rep,name=discovery_endpoints,json=discoveryEndpoints,proto3" json:"discovery_endpoints,omitempty"` // Output only. PSC connections for discovery of the cluster topology and // accessing the cluster. PscConnections []*PscConnection `protobuf:"bytes,17,rep,name=psc_connections,json=pscConnections,proto3" json:"psc_connections,omitempty"` // Output only. Additional information about the current state of the cluster. StateInfo *Cluster_StateInfo `protobuf:"bytes,18,opt,name=state_info,json=stateInfo,proto3" json:"state_info,omitempty"` // contains filtered or unexported fields }
A cluster instance.
func (*Cluster) Descriptor ¶
Deprecated: Use Cluster.ProtoReflect.Descriptor instead.
func (*Cluster) GetAuthorizationMode ¶
func (x *Cluster) GetAuthorizationMode() AuthorizationMode
func (*Cluster) GetCreateTime ¶
func (x *Cluster) GetCreateTime() *timestamppb.Timestamp
func (*Cluster) GetDiscoveryEndpoints ¶
func (x *Cluster) GetDiscoveryEndpoints() []*DiscoveryEndpoint
func (*Cluster) GetName ¶
func (*Cluster) GetPscConfigs ¶
func (*Cluster) GetPscConnections ¶
func (x *Cluster) GetPscConnections() []*PscConnection
func (*Cluster) GetReplicaCount ¶
func (*Cluster) GetShardCount ¶
func (*Cluster) GetSizeGb ¶
func (*Cluster) GetState ¶
func (x *Cluster) GetState() Cluster_State
func (*Cluster) GetStateInfo ¶
func (x *Cluster) GetStateInfo() *Cluster_StateInfo
func (*Cluster) GetTransitEncryptionMode ¶
func (x *Cluster) GetTransitEncryptionMode() TransitEncryptionMode
func (*Cluster) GetUid ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
func (*Cluster) Reset ¶
func (x *Cluster) Reset()
func (*Cluster) String ¶
type Cluster_State ¶
type Cluster_State int32
Represents the different states of a Redis cluster.
const ( // Not set. Cluster_STATE_UNSPECIFIED Cluster_State = 0 // Redis cluster is being created. Cluster_CREATING Cluster_State = 1 // Redis cluster has been created and is fully usable. Cluster_ACTIVE Cluster_State = 2 // Redis cluster configuration is being updated. Cluster_UPDATING Cluster_State = 3 // Redis cluster is being deleted. Cluster_DELETING Cluster_State = 4 )
func (Cluster_State) Descriptor ¶
func (Cluster_State) Descriptor() protoreflect.EnumDescriptor
func (Cluster_State) Enum ¶
func (x Cluster_State) Enum() *Cluster_State
func (Cluster_State) EnumDescriptor ¶
func (Cluster_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Cluster_State.Descriptor instead.
func (Cluster_State) Number ¶
func (x Cluster_State) Number() protoreflect.EnumNumber
func (Cluster_State) String ¶
func (x Cluster_State) String() string
func (Cluster_State) Type ¶
func (Cluster_State) Type() protoreflect.EnumType
type Cluster_StateInfo ¶
type Cluster_StateInfo struct { // Types that are assignable to Info: // // *Cluster_StateInfo_UpdateInfo_ Info isCluster_StateInfo_Info `protobuf_oneof:"info"` // contains filtered or unexported fields }
Represents additional information about the state of the cluster.
func (*Cluster_StateInfo) Descriptor ¶
func (*Cluster_StateInfo) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_StateInfo.ProtoReflect.Descriptor instead.
func (*Cluster_StateInfo) GetInfo ¶
func (m *Cluster_StateInfo) GetInfo() isCluster_StateInfo_Info
func (*Cluster_StateInfo) GetUpdateInfo ¶
func (x *Cluster_StateInfo) GetUpdateInfo() *Cluster_StateInfo_UpdateInfo
func (*Cluster_StateInfo) ProtoMessage ¶
func (*Cluster_StateInfo) ProtoMessage()
func (*Cluster_StateInfo) ProtoReflect ¶
func (x *Cluster_StateInfo) ProtoReflect() protoreflect.Message
func (*Cluster_StateInfo) Reset ¶
func (x *Cluster_StateInfo) Reset()
func (*Cluster_StateInfo) String ¶
func (x *Cluster_StateInfo) String() string
type Cluster_StateInfo_UpdateInfo ¶
type Cluster_StateInfo_UpdateInfo struct { // Target number of shards for redis cluster TargetShardCount *int32 `protobuf:"varint,1,opt,name=target_shard_count,json=targetShardCount,proto3,oneof" json:"target_shard_count,omitempty"` // Target number of replica nodes per shard. TargetReplicaCount *int32 `protobuf:"varint,2,opt,name=target_replica_count,json=targetReplicaCount,proto3,oneof" json:"target_replica_count,omitempty"` // contains filtered or unexported fields }
Represents information about an updating cluster.
func (*Cluster_StateInfo_UpdateInfo) Descriptor ¶
func (*Cluster_StateInfo_UpdateInfo) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_StateInfo_UpdateInfo.ProtoReflect.Descriptor instead.
func (*Cluster_StateInfo_UpdateInfo) GetTargetReplicaCount ¶
func (x *Cluster_StateInfo_UpdateInfo) GetTargetReplicaCount() int32
func (*Cluster_StateInfo_UpdateInfo) GetTargetShardCount ¶
func (x *Cluster_StateInfo_UpdateInfo) GetTargetShardCount() int32
func (*Cluster_StateInfo_UpdateInfo) ProtoMessage ¶
func (*Cluster_StateInfo_UpdateInfo) ProtoMessage()
func (*Cluster_StateInfo_UpdateInfo) ProtoReflect ¶
func (x *Cluster_StateInfo_UpdateInfo) ProtoReflect() protoreflect.Message
func (*Cluster_StateInfo_UpdateInfo) Reset ¶
func (x *Cluster_StateInfo_UpdateInfo) Reset()
func (*Cluster_StateInfo_UpdateInfo) String ¶
func (x *Cluster_StateInfo_UpdateInfo) String() string
type Cluster_StateInfo_UpdateInfo_ ¶
type Cluster_StateInfo_UpdateInfo_ struct { // Describes ongoing update on the cluster when cluster state is UPDATING. UpdateInfo *Cluster_StateInfo_UpdateInfo `protobuf:"bytes,1,opt,name=update_info,json=updateInfo,proto3,oneof"` }
type CreateClusterRequest ¶
type CreateClusterRequest struct { // Required. The resource name of the cluster location using the form: // // `projects/{project_id}/locations/{location_id}` // // where `location_id` refers to a GCP region. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Required. The logical name of the Redis cluster 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-63 characters. // * Must end with a number or a letter. // * Must be unique within the customer project / location ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Required. The cluster that is to be created. Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"` // Idempotent request UUID. RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request for [CreateCluster][CloudRedis.CreateCluster].
func (*CreateClusterRequest) Descriptor ¶
func (*CreateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.
func (*CreateClusterRequest) GetCluster ¶
func (x *CreateClusterRequest) GetCluster() *Cluster
func (*CreateClusterRequest) GetClusterId ¶
func (x *CreateClusterRequest) GetClusterId() string
func (*CreateClusterRequest) GetParent ¶
func (x *CreateClusterRequest) GetParent() string
func (*CreateClusterRequest) GetRequestId ¶
func (x *CreateClusterRequest) GetRequestId() string
func (*CreateClusterRequest) ProtoMessage ¶
func (*CreateClusterRequest) ProtoMessage()
func (*CreateClusterRequest) ProtoReflect ¶
func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
func (*CreateClusterRequest) Reset ¶
func (x *CreateClusterRequest) Reset()
func (*CreateClusterRequest) String ¶
func (x *CreateClusterRequest) String() string
type DeleteClusterRequest ¶
type DeleteClusterRequest struct { // Required. Redis cluster resource name using the form: // // `projects/{project_id}/locations/{location_id}/clusters/{cluster_id}` // // where `location_id` refers to a GCP region. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Idempotent request UUID. RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request for [DeleteCluster][CloudRedis.DeleteCluster].
func (*DeleteClusterRequest) Descriptor ¶
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.
func (*DeleteClusterRequest) GetName ¶
func (x *DeleteClusterRequest) GetName() string
func (*DeleteClusterRequest) GetRequestId ¶
func (x *DeleteClusterRequest) GetRequestId() string
func (*DeleteClusterRequest) ProtoMessage ¶
func (*DeleteClusterRequest) ProtoMessage()
func (*DeleteClusterRequest) ProtoReflect ¶
func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
func (*DeleteClusterRequest) Reset ¶
func (x *DeleteClusterRequest) Reset()
func (*DeleteClusterRequest) String ¶
func (x *DeleteClusterRequest) String() string
type DiscoveryEndpoint ¶
type DiscoveryEndpoint struct { // Output only. Address of the exposed Redis endpoint used by clients to // connect to the service. The address could be either IP or hostname. Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // Output only. The port number of the exposed Redis endpoint. Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // Output only. Customer configuration for where the endpoint is created and // accessed from. PscConfig *PscConfig `protobuf:"bytes,3,opt,name=psc_config,json=pscConfig,proto3" json:"psc_config,omitempty"` // contains filtered or unexported fields }
Endpoints on each network, for Redis clients to connect to the cluster.
func (*DiscoveryEndpoint) Descriptor ¶
func (*DiscoveryEndpoint) Descriptor() ([]byte, []int)
Deprecated: Use DiscoveryEndpoint.ProtoReflect.Descriptor instead.
func (*DiscoveryEndpoint) GetAddress ¶
func (x *DiscoveryEndpoint) GetAddress() string
func (*DiscoveryEndpoint) GetPort ¶
func (x *DiscoveryEndpoint) GetPort() int32
func (*DiscoveryEndpoint) GetPscConfig ¶
func (x *DiscoveryEndpoint) GetPscConfig() *PscConfig
func (*DiscoveryEndpoint) ProtoMessage ¶
func (*DiscoveryEndpoint) ProtoMessage()
func (*DiscoveryEndpoint) ProtoReflect ¶
func (x *DiscoveryEndpoint) ProtoReflect() protoreflect.Message
func (*DiscoveryEndpoint) Reset ¶
func (x *DiscoveryEndpoint) Reset()
func (*DiscoveryEndpoint) String ¶
func (x *DiscoveryEndpoint) String() string
type GetClusterRequest ¶
type GetClusterRequest struct { // Required. Redis cluster resource name using the form: // // `projects/{project_id}/locations/{location_id}/clusters/{cluster_id}` // // where `location_id` refers to a GCP region. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request for [GetCluster][CloudRedis.GetCluster].
func (*GetClusterRequest) Descriptor ¶
func (*GetClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.
func (*GetClusterRequest) GetName ¶
func (x *GetClusterRequest) GetName() string
func (*GetClusterRequest) ProtoMessage ¶
func (*GetClusterRequest) ProtoMessage()
func (*GetClusterRequest) ProtoReflect ¶
func (x *GetClusterRequest) ProtoReflect() protoreflect.Message
func (*GetClusterRequest) Reset ¶
func (x *GetClusterRequest) Reset()
func (*GetClusterRequest) String ¶
func (x *GetClusterRequest) String() string
type ListClustersRequest ¶
type ListClustersRequest struct { // Required. The resource name of the cluster location using the form: // // `projects/{project_id}/locations/{location_id}` // // where `location_id` refers to a GCP region. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The maximum number of items to return. // // If not specified, a default value of 1000 will be used by the service. // Regardless of the page_size value, the response may include a partial list // and a caller should only rely on response's // [`next_page_token`][google.cloud.redis.cluster.v1.ListClustersResponse.next_page_token] // to determine if there are more clusters left to be queried. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // The `next_page_token` value returned from a previous // [ListClusters][CloudRedis.ListClusters] request, if any. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
Request for [ListClusters][CloudRedis.ListClusters].
func (*ListClustersRequest) Descriptor ¶
func (*ListClustersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.
func (*ListClustersRequest) GetPageSize ¶
func (x *ListClustersRequest) GetPageSize() int32
func (*ListClustersRequest) GetPageToken ¶
func (x *ListClustersRequest) GetPageToken() string
func (*ListClustersRequest) GetParent ¶
func (x *ListClustersRequest) GetParent() string
func (*ListClustersRequest) ProtoMessage ¶
func (*ListClustersRequest) ProtoMessage()
func (*ListClustersRequest) ProtoReflect ¶
func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
func (*ListClustersRequest) Reset ¶
func (x *ListClustersRequest) Reset()
func (*ListClustersRequest) String ¶
func (x *ListClustersRequest) String() string
type ListClustersResponse ¶
type ListClustersResponse struct { // A list of Redis clusters in the project in the specified location, // or across all locations. // // If the `location_id` in the parent field of the request is "-", all regions // available to the project are queried, and the results aggregated. // If in such an aggregated query a location is unavailable, a placeholder // Redis entry is included in the response with the `name` field set to a // value of the form // `projects/{project_id}/locations/{location_id}/clusters/`- and the // `status` field set to ERROR and `status_message` field set to "location not // available for ListClusters". Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"` // Token to retrieve the next page of results, or empty if there are no more // results in the list. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Locations that could not be reached. Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"` // contains filtered or unexported fields }
Response for [ListClusters][CloudRedis.ListClusters].
func (*ListClustersResponse) Descriptor ¶
func (*ListClustersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.
func (*ListClustersResponse) GetClusters ¶
func (x *ListClustersResponse) GetClusters() []*Cluster
func (*ListClustersResponse) GetNextPageToken ¶
func (x *ListClustersResponse) GetNextPageToken() string
func (*ListClustersResponse) GetUnreachable ¶
func (x *ListClustersResponse) GetUnreachable() []string
func (*ListClustersResponse) ProtoMessage ¶
func (*ListClustersResponse) ProtoMessage()
func (*ListClustersResponse) ProtoReflect ¶
func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
func (*ListClustersResponse) Reset ¶
func (x *ListClustersResponse) Reset()
func (*ListClustersResponse) String ¶
func (x *ListClustersResponse) String() string
type OperationMetadata ¶
type OperationMetadata struct { // Output only. The time the operation was created. CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time the operation finished running. EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // Output only. Server-defined resource path for the target of the operation. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Output only. Name of the verb executed by the operation. Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"` // Output only. Human-readable status of the operation, if any. StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"` // Output only. Identifies whether the user has requested cancellation // of the operation. Operations that have successfully been cancelled // have [Operation.error][] value with a // [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to // `Code.CANCELLED`. RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"` // Output only. API version used to start the operation. ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"` // contains filtered or unexported fields }
Pre-defined metadata fields.
func (*OperationMetadata) Descriptor ¶
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion ¶
func (x *OperationMetadata) GetApiVersion() string
func (*OperationMetadata) GetCreateTime ¶
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (*OperationMetadata) GetEndTime ¶
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (*OperationMetadata) GetRequestedCancellation ¶
func (x *OperationMetadata) GetRequestedCancellation() bool
func (*OperationMetadata) GetStatusMessage ¶
func (x *OperationMetadata) GetStatusMessage() string
func (*OperationMetadata) GetTarget ¶
func (x *OperationMetadata) GetTarget() string
func (*OperationMetadata) GetVerb ¶
func (x *OperationMetadata) GetVerb() string
func (*OperationMetadata) ProtoMessage ¶
func (*OperationMetadata) ProtoMessage()
func (*OperationMetadata) ProtoReflect ¶
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (*OperationMetadata) Reset ¶
func (x *OperationMetadata) Reset()
func (*OperationMetadata) String ¶
func (x *OperationMetadata) String() string
type PscConfig ¶
type PscConfig struct { // Required. The network where the IP address of the discovery endpoint will // be reserved, in the form of // projects/{network_project}/global/networks/{network_id}. Network string `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"` // contains filtered or unexported fields }
func (*PscConfig) Descriptor ¶
Deprecated: Use PscConfig.ProtoReflect.Descriptor instead.
func (*PscConfig) GetNetwork ¶
func (*PscConfig) ProtoMessage ¶
func (*PscConfig) ProtoMessage()
func (*PscConfig) ProtoReflect ¶
func (x *PscConfig) ProtoReflect() protoreflect.Message
func (*PscConfig) Reset ¶
func (x *PscConfig) Reset()
func (*PscConfig) String ¶
type PscConnection ¶
type PscConnection struct { // Output only. The PSC connection id of the forwarding rule connected to the // service attachment. PscConnectionId string `protobuf:"bytes,1,opt,name=psc_connection_id,json=pscConnectionId,proto3" json:"psc_connection_id,omitempty"` // Output only. The IP allocated on the consumer network for the PSC // forwarding rule. Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // Output only. The URI of the consumer side forwarding rule. // Example: // projects/{projectNumOrId}/regions/us-east1/forwardingRules/{resourceId}. ForwardingRule string `protobuf:"bytes,3,opt,name=forwarding_rule,json=forwardingRule,proto3" json:"forwarding_rule,omitempty"` // Output only. The consumer project_id where the forwarding rule is created // from. ProjectId string `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // The consumer network where the IP address resides, in the form of // projects/{project_id}/global/networks/{network_id}. Network string `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"` // contains filtered or unexported fields }
Details of consumer resources in a PSC connection.
func (*PscConnection) Descriptor ¶
func (*PscConnection) Descriptor() ([]byte, []int)
Deprecated: Use PscConnection.ProtoReflect.Descriptor instead.
func (*PscConnection) GetAddress ¶
func (x *PscConnection) GetAddress() string
func (*PscConnection) GetForwardingRule ¶
func (x *PscConnection) GetForwardingRule() string
func (*PscConnection) GetNetwork ¶
func (x *PscConnection) GetNetwork() string
func (*PscConnection) GetProjectId ¶
func (x *PscConnection) GetProjectId() string
func (*PscConnection) GetPscConnectionId ¶
func (x *PscConnection) GetPscConnectionId() string
func (*PscConnection) ProtoMessage ¶
func (*PscConnection) ProtoMessage()
func (*PscConnection) ProtoReflect ¶
func (x *PscConnection) ProtoReflect() protoreflect.Message
func (*PscConnection) Reset ¶
func (x *PscConnection) Reset()
func (*PscConnection) String ¶
func (x *PscConnection) String() string
type TransitEncryptionMode ¶
type TransitEncryptionMode int32
Available mode of in-transit encryption.
const ( // In-transit encryption not set. TransitEncryptionMode_TRANSIT_ENCRYPTION_MODE_UNSPECIFIED TransitEncryptionMode = 0 // In-transit encryption disabled. TransitEncryptionMode_TRANSIT_ENCRYPTION_MODE_DISABLED TransitEncryptionMode = 1 // Use server managed encryption for in-transit encryption. TransitEncryptionMode_TRANSIT_ENCRYPTION_MODE_SERVER_AUTHENTICATION TransitEncryptionMode = 2 )
func (TransitEncryptionMode) Descriptor ¶
func (TransitEncryptionMode) Descriptor() protoreflect.EnumDescriptor
func (TransitEncryptionMode) Enum ¶
func (x TransitEncryptionMode) Enum() *TransitEncryptionMode
func (TransitEncryptionMode) EnumDescriptor ¶
func (TransitEncryptionMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransitEncryptionMode.Descriptor instead.
func (TransitEncryptionMode) Number ¶
func (x TransitEncryptionMode) Number() protoreflect.EnumNumber
func (TransitEncryptionMode) String ¶
func (x TransitEncryptionMode) String() string
func (TransitEncryptionMode) Type ¶
func (TransitEncryptionMode) Type() protoreflect.EnumType
type UnimplementedCloudRedisClusterServer ¶
type UnimplementedCloudRedisClusterServer struct { }
UnimplementedCloudRedisClusterServer can be embedded to have forward compatible implementations.
func (*UnimplementedCloudRedisClusterServer) CreateCluster ¶
func (*UnimplementedCloudRedisClusterServer) CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)
func (*UnimplementedCloudRedisClusterServer) DeleteCluster ¶
func (*UnimplementedCloudRedisClusterServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)
func (*UnimplementedCloudRedisClusterServer) GetCluster ¶
func (*UnimplementedCloudRedisClusterServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
func (*UnimplementedCloudRedisClusterServer) ListClusters ¶
func (*UnimplementedCloudRedisClusterServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
func (*UnimplementedCloudRedisClusterServer) UpdateCluster ¶
func (*UnimplementedCloudRedisClusterServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)
type UpdateClusterRequest ¶
type UpdateClusterRequest struct { // 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 [Cluster][google.cloud.redis.cluster.v1.Cluster]: // // - `size_gb` // - `replica_count` UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // Required. Update description. // Only fields specified in update_mask are updated. Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` // Idempotent request UUID. RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request for [UpdateCluster][CloudRedis.UpdateCluster].
func (*UpdateClusterRequest) Descriptor ¶
func (*UpdateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.
func (*UpdateClusterRequest) GetCluster ¶
func (x *UpdateClusterRequest) GetCluster() *Cluster
func (*UpdateClusterRequest) GetRequestId ¶
func (x *UpdateClusterRequest) GetRequestId() string
func (*UpdateClusterRequest) GetUpdateMask ¶
func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateClusterRequest) ProtoMessage ¶
func (*UpdateClusterRequest) ProtoMessage()
func (*UpdateClusterRequest) ProtoReflect ¶
func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
func (*UpdateClusterRequest) Reset ¶
func (x *UpdateClusterRequest) Reset()
func (*UpdateClusterRequest) String ¶
func (x *UpdateClusterRequest) String() string
Source Files ¶
cloud_redis_cluster.pb.go
- Version
- v1.14.3
- Published
- Mar 14, 2024
- Platform
- js/wasm
- Imports
- 14 packages
- Last checked
- 10 hours ago –
Tools for package owners.