clusterpb

package
v0.0.0-...-ddc6f60 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 20, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package clusterpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var (
	NodeType_name = map[int32]string{
		0: "NODE_TYPE_UNSPECIFIED",
		1: "REDIS_SHARED_CORE_NANO",
		2: "REDIS_HIGHMEM_MEDIUM",
		3: "REDIS_HIGHMEM_XLARGE",
		4: "REDIS_STANDARD_SMALL",
	}
	NodeType_value = map[string]int32{
		"NODE_TYPE_UNSPECIFIED":  0,
		"REDIS_SHARED_CORE_NANO": 1,
		"REDIS_HIGHMEM_MEDIUM":   2,
		"REDIS_HIGHMEM_XLARGE":   3,
		"REDIS_STANDARD_SMALL":   4,
	}
)

Enum value maps for NodeType.

View Source 
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.

View Source 
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.

View Source 
var (
	ClusterPersistenceConfig_PersistenceMode_name = map[int32]string{
		0: "PERSISTENCE_MODE_UNSPECIFIED",
		1: "DISABLED",
		2: "RDB",
		3: "AOF",
	}
	ClusterPersistenceConfig_PersistenceMode_value = map[string]int32{
		"PERSISTENCE_MODE_UNSPECIFIED": 0,
		"DISABLED":                     1,
		"RDB":                          2,
		"AOF":                          3,
	}
)

Enum value maps for ClusterPersistenceConfig_PersistenceMode.

View Source 
var (
	ClusterPersistenceConfig_RDBConfig_SnapshotPeriod_name = map[int32]string{
		0: "SNAPSHOT_PERIOD_UNSPECIFIED",
		1: "ONE_HOUR",
		2: "SIX_HOURS",
		3: "TWELVE_HOURS",
		4: "TWENTY_FOUR_HOURS",
	}
	ClusterPersistenceConfig_RDBConfig_SnapshotPeriod_value = map[string]int32{
		"SNAPSHOT_PERIOD_UNSPECIFIED": 0,
		"ONE_HOUR":                    1,
		"SIX_HOURS":                   2,
		"TWELVE_HOURS":                3,
		"TWENTY_FOUR_HOURS":           4,
	}
)

Enum value maps for ClusterPersistenceConfig_RDBConfig_SnapshotPeriod.

View Source 
var (
	ClusterPersistenceConfig_AOFConfig_AppendFsync_name = map[int32]string{
		0: "APPEND_FSYNC_UNSPECIFIED",
		1: "NO",
		2: "EVERYSEC",
		3: "ALWAYS",
	}
	ClusterPersistenceConfig_AOFConfig_AppendFsync_value = map[string]int32{
		"APPEND_FSYNC_UNSPECIFIED": 0,
		"NO":                       1,
		"EVERYSEC":                 2,
		"ALWAYS":                   3,
	}
)

Enum value maps for ClusterPersistenceConfig_AOFConfig_AppendFsync.

View Source 
var (
	ZoneDistributionConfig_ZoneDistributionMode_name = map[int32]string{
		0: "ZONE_DISTRIBUTION_MODE_UNSPECIFIED",
		1: "MULTI_ZONE",
		2: "SINGLE_ZONE",
	}
	ZoneDistributionConfig_ZoneDistributionMode_value = map[string]int32{
		"ZONE_DISTRIBUTION_MODE_UNSPECIFIED": 0,
		"MULTI_ZONE":                         1,
		"SINGLE_ZONE":                        2,
	}
)

Enum value maps for ZoneDistributionConfig_ZoneDistributionMode.

View Source 
var CloudRedisCluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mockgcp.cloud.redis.cluster.v1.CloudRedisCluster",
	HandlerType: (*CloudRedisClusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListClusters",
			Handler:    _CloudRedisCluster_ListClusters_Handler,
		},
		{
			MethodName: "GetCluster",
			Handler:    _CloudRedisCluster_GetCluster_Handler,
		},
		{
			MethodName: "UpdateCluster",
			Handler:    _CloudRedisCluster_UpdateCluster_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _CloudRedisCluster_DeleteCluster_Handler,
		},
		{
			MethodName: "CreateCluster",
			Handler:    _CloudRedisCluster_CreateCluster_Handler,
		},
		{
			MethodName: "GetClusterCertificateAuthority",
			Handler:    _CloudRedisCluster_GetClusterCertificateAuthority_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mockgcp/cloud/redis/cluster/v1/cloud_redis_cluster.proto",
}

CloudRedisCluster_ServiceDesc is the grpc.ServiceDesc for CloudRedisCluster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_mockgcp_cloud_redis_cluster_v1_cloud_redis_cluster_proto protoreflect.FileDescriptor

Functions

func RegisterCloudRedisClusterHandler 

func RegisterCloudRedisClusterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCloudRedisClusterHandler registers the http handlers for service CloudRedisCluster to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCloudRedisClusterHandlerClient 

func RegisterCloudRedisClusterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CloudRedisClusterClient) error

RegisterCloudRedisClusterHandlerClient registers the http handlers for service CloudRedisCluster to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CloudRedisClusterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CloudRedisClusterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CloudRedisClusterClient" to call the correct interceptors.

func RegisterCloudRedisClusterHandlerFromEndpoint 

func RegisterCloudRedisClusterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCloudRedisClusterHandlerFromEndpoint is same as RegisterCloudRedisClusterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCloudRedisClusterHandlerServer 

func RegisterCloudRedisClusterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CloudRedisClusterServer) error

RegisterCloudRedisClusterHandlerServer registers the http handlers for service CloudRedisCluster to "mux". UnaryRPC :call CloudRedisClusterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterCloudRedisClusterHandlerFromEndpoint instead.

func RegisterCloudRedisClusterServer 

func RegisterCloudRedisClusterServer(s grpc.ServiceRegistrar, 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 deprecated 

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 CertificateAuthority 

type CertificateAuthority struct {

	// server ca information
	//
	// Types that are assignable to ServerCa:
	//
	//	*CertificateAuthority_ManagedServerCa
	ServerCa isCertificateAuthority_ServerCa `protobuf_oneof:"server_ca"`
	// Identifier. Unique name of the resource in this scope including project,
	// location and cluster using the form:
	//
	//	`projects/{project}/locations/{location}/clusters/{cluster}/certificateAuthority`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Redis cluster certificate authority

func (*CertificateAuthority) Descriptor deprecated 

func (*CertificateAuthority) Descriptor() ([]byte, []int)

Deprecated: Use CertificateAuthority.ProtoReflect.Descriptor instead.

func (*CertificateAuthority) GetManagedServerCa 

func (x *CertificateAuthority) GetManagedServerCa() *CertificateAuthority_ManagedCertificateAuthority

func (*CertificateAuthority) GetName 

func (x *CertificateAuthority) GetName() string

func (*CertificateAuthority) GetServerCa 

func (m *CertificateAuthority) GetServerCa() isCertificateAuthority_ServerCa

func (*CertificateAuthority) ProtoMessage 

func (*CertificateAuthority) ProtoMessage()

func (*CertificateAuthority) ProtoReflect 

func (x *CertificateAuthority) ProtoReflect() protoreflect.Message

func (*CertificateAuthority) Reset 

func (x *CertificateAuthority) Reset()

func (*CertificateAuthority) String 

func (x *CertificateAuthority) String() string

type CertificateAuthority_ManagedCertificateAuthority 

type CertificateAuthority_ManagedCertificateAuthority struct {

	// The PEM encoded CA certificate chains for redis managed
	// server authentication
	CaCerts []*CertificateAuthority_ManagedCertificateAuthority_CertChain `protobuf:"bytes,1,rep,name=ca_certs,json=caCerts,proto3" json:"ca_certs,omitempty"`
	// contains filtered or unexported fields
}

func (*CertificateAuthority_ManagedCertificateAuthority) Descriptor deprecated 

func (*CertificateAuthority_ManagedCertificateAuthority) Descriptor() ([]byte, []int)

Deprecated: Use CertificateAuthority_ManagedCertificateAuthority.ProtoReflect.Descriptor instead.

func (*CertificateAuthority_ManagedCertificateAuthority) GetCaCerts 

func (x *CertificateAuthority_ManagedCertificateAuthority) GetCaCerts() []*CertificateAuthority_ManagedCertificateAuthority_CertChain

func (*CertificateAuthority_ManagedCertificateAuthority) ProtoMessage 

func (*CertificateAuthority_ManagedCertificateAuthority) ProtoMessage()

func (*CertificateAuthority_ManagedCertificateAuthority) ProtoReflect 

func (x *CertificateAuthority_ManagedCertificateAuthority) ProtoReflect() protoreflect.Message

func (*CertificateAuthority_ManagedCertificateAuthority) Reset 

func (x *CertificateAuthority_ManagedCertificateAuthority) Reset()

func (*CertificateAuthority_ManagedCertificateAuthority) String 

func (x *CertificateAuthority_ManagedCertificateAuthority) String() string

type CertificateAuthority_ManagedCertificateAuthority_CertChain 

type CertificateAuthority_ManagedCertificateAuthority_CertChain struct {

	// The certificates that form the CA chain, from leaf to root order.
	Certificates []string `protobuf:"bytes,1,rep,name=certificates,proto3" json:"certificates,omitempty"`
	// contains filtered or unexported fields
}

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) Descriptor deprecated 

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) Descriptor() ([]byte, []int)

Deprecated: Use CertificateAuthority_ManagedCertificateAuthority_CertChain.ProtoReflect.Descriptor instead.

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) GetCertificates 

func (x *CertificateAuthority_ManagedCertificateAuthority_CertChain) GetCertificates() []string

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) ProtoMessage 

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) ProtoMessage()

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) ProtoReflect 

func (x *CertificateAuthority_ManagedCertificateAuthority_CertChain) ProtoReflect() protoreflect.Message

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) Reset 

func (x *CertificateAuthority_ManagedCertificateAuthority_CertChain) Reset()

func (*CertificateAuthority_ManagedCertificateAuthority_CertChain) String 

func (x *CertificateAuthority_ManagedCertificateAuthority_CertChain) String() string

type CertificateAuthority_ManagedServerCa 

type CertificateAuthority_ManagedServerCa struct {
	ManagedServerCa *CertificateAuthority_ManagedCertificateAuthority `protobuf:"bytes,1,opt,name=managed_server_ca,json=managedServerCa,proto3,oneof"`
}

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)
	// Gets the details of certificate authority information for Redis cluster.
	GetClusterCertificateAuthority(ctx context.Context, in *GetClusterCertificateAuthorityRequest, opts ...grpc.CallOption) (*CertificateAuthority, error)
}

CloudRedisClusterClient is the client API for CloudRedisCluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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)
	// Gets the details of certificate authority information for Redis cluster.
	GetClusterCertificateAuthority(context.Context, *GetClusterCertificateAuthorityRequest) (*CertificateAuthority, error)
	// contains filtered or unexported methods
}

CloudRedisClusterServer is the server API for CloudRedisCluster service. All implementations must embed UnimplementedCloudRedisClusterServer for forward compatibility

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 *timestamp.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=mockgcp.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 `` /* 168-byte string literal not displayed */
	// Optional. The in-transit encryption for the Redis cluster.
	// If not provided, encryption  is disabled for the cluster.
	TransitEncryptionMode TransitEncryptionMode `` /* 186-byte string literal not displayed */
	// Output only. Redis memory size in GB for the entire cluster rounded up to
	// the next integer.
	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"`
	// Optional. The type of a redis node in the cluster. NodeType determines the
	// underlying machine-type of a redis node.
	NodeType NodeType `` /* 132-byte string literal not displayed */
	// Optional. Persistence config (RDB, AOF) for the cluster.
	PersistenceConfig *ClusterPersistenceConfig `protobuf:"bytes,20,opt,name=persistence_config,json=persistenceConfig,proto3" json:"persistence_config,omitempty"`
	// Optional. Key/Value pairs of customer overrides for mutable Redis Configs
	RedisConfigs map[string]string `` /* 186-byte string literal not displayed */
	// Output only. Precise value of redis memory size in GB for the entire
	// cluster.
	PreciseSizeGb *float64 `protobuf:"fixed64,22,opt,name=precise_size_gb,json=preciseSizeGb,proto3,oneof" json:"precise_size_gb,omitempty"`
	// Optional. This config will be used to determine how the customer wants us
	// to distribute cluster resources within the region.
	ZoneDistributionConfig *ZoneDistributionConfig `` /* 130-byte string literal not displayed */
	// Optional. The delete operation will fail when the value is set to true.
	DeletionProtectionEnabled *bool `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

A cluster instance.

func (*Cluster) Descriptor deprecated 

func (*Cluster) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetAuthorizationMode 

func (x *Cluster) GetAuthorizationMode() AuthorizationMode

func (*Cluster) GetCreateTime 

func (x *Cluster) GetCreateTime() *timestamp.Timestamp

func (*Cluster) GetDeletionProtectionEnabled 

func (x *Cluster) GetDeletionProtectionEnabled() bool

func (*Cluster) GetDiscoveryEndpoints 

func (x *Cluster) GetDiscoveryEndpoints() []*DiscoveryEndpoint

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetNodeType 

func (x *Cluster) GetNodeType() NodeType

func (*Cluster) GetPersistenceConfig 

func (x *Cluster) GetPersistenceConfig() *ClusterPersistenceConfig

func (*Cluster) GetPreciseSizeGb 

func (x *Cluster) GetPreciseSizeGb() float64

func (*Cluster) GetPscConfigs 

func (x *Cluster) GetPscConfigs() []*PscConfig

func (*Cluster) GetPscConnections 

func (x *Cluster) GetPscConnections() []*PscConnection

func (*Cluster) GetRedisConfigs 

func (x *Cluster) GetRedisConfigs() map[string]string

func (*Cluster) GetReplicaCount 

func (x *Cluster) GetReplicaCount() int32

func (*Cluster) GetShardCount 

func (x *Cluster) GetShardCount() int32

func (*Cluster) GetSizeGb 

func (x *Cluster) GetSizeGb() int32

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 (x *Cluster) GetUid() string

func (*Cluster) GetZoneDistributionConfig 

func (x *Cluster) GetZoneDistributionConfig() *ZoneDistributionConfig

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 

func (x *Cluster) String() string

type ClusterPersistenceConfig 

type ClusterPersistenceConfig struct {

	// Optional. The mode of persistence.
	Mode ClusterPersistenceConfig_PersistenceMode `` /* 139-byte string literal not displayed */
	// Optional. RDB configuration. This field will be ignored if mode is not RDB.
	RdbConfig *ClusterPersistenceConfig_RDBConfig `protobuf:"bytes,2,opt,name=rdb_config,json=rdbConfig,proto3" json:"rdb_config,omitempty"`
	// Optional. AOF configuration. This field will be ignored if mode is not AOF.
	AofConfig *ClusterPersistenceConfig_AOFConfig `protobuf:"bytes,3,opt,name=aof_config,json=aofConfig,proto3" json:"aof_config,omitempty"`
	// contains filtered or unexported fields
}

Configuration of the persistence functionality.

func (*ClusterPersistenceConfig) Descriptor deprecated 

func (*ClusterPersistenceConfig) Descriptor() ([]byte, []int)

Deprecated: Use ClusterPersistenceConfig.ProtoReflect.Descriptor instead.

func (*ClusterPersistenceConfig) GetAofConfig 

func (x *ClusterPersistenceConfig) GetAofConfig() *ClusterPersistenceConfig_AOFConfig

func (*ClusterPersistenceConfig) GetMode 

func (x *ClusterPersistenceConfig) GetMode() ClusterPersistenceConfig_PersistenceMode

func (*ClusterPersistenceConfig) GetRdbConfig 

func (x *ClusterPersistenceConfig) GetRdbConfig() *ClusterPersistenceConfig_RDBConfig

func (*ClusterPersistenceConfig) ProtoMessage 

func (*ClusterPersistenceConfig) ProtoMessage()

func (*ClusterPersistenceConfig) ProtoReflect 

func (x *ClusterPersistenceConfig) ProtoReflect() protoreflect.Message

func (*ClusterPersistenceConfig) Reset 

func (x *ClusterPersistenceConfig) Reset()

func (*ClusterPersistenceConfig) String 

func (x *ClusterPersistenceConfig) String() string

type ClusterPersistenceConfig_AOFConfig 

type ClusterPersistenceConfig_AOFConfig struct {

	// Optional. fsync configuration.
	AppendFsync ClusterPersistenceConfig_AOFConfig_AppendFsync `` /* 178-byte string literal not displayed */
	// contains filtered or unexported fields
}

Configuration of the AOF based persistence.

func (*ClusterPersistenceConfig_AOFConfig) Descriptor deprecated 

func (*ClusterPersistenceConfig_AOFConfig) Descriptor() ([]byte, []int)

Deprecated: Use ClusterPersistenceConfig_AOFConfig.ProtoReflect.Descriptor instead.

func (*ClusterPersistenceConfig_AOFConfig) GetAppendFsync 

func (x *ClusterPersistenceConfig_AOFConfig) GetAppendFsync() ClusterPersistenceConfig_AOFConfig_AppendFsync

func (*ClusterPersistenceConfig_AOFConfig) ProtoMessage 

func (*ClusterPersistenceConfig_AOFConfig) ProtoMessage()

func (*ClusterPersistenceConfig_AOFConfig) ProtoReflect 

func (x *ClusterPersistenceConfig_AOFConfig) ProtoReflect() protoreflect.Message

func (*ClusterPersistenceConfig_AOFConfig) Reset 

func (x *ClusterPersistenceConfig_AOFConfig) Reset()

func (*ClusterPersistenceConfig_AOFConfig) String 

func (x *ClusterPersistenceConfig_AOFConfig) String() string

type ClusterPersistenceConfig_AOFConfig_AppendFsync 

type ClusterPersistenceConfig_AOFConfig_AppendFsync int32

Available fsync modes. 

const (
	// Not set. Default: EVERYSEC
	ClusterPersistenceConfig_AOFConfig_APPEND_FSYNC_UNSPECIFIED ClusterPersistenceConfig_AOFConfig_AppendFsync = 0
	// Never fsync. Normally Linux will flush data every 30 seconds with this
	// configuration, but it's up to the kernel's exact tuning.
	ClusterPersistenceConfig_AOFConfig_NO ClusterPersistenceConfig_AOFConfig_AppendFsync = 1
	// fsync every second. Fast enough, and you may lose 1 second of data if
	// there is a disaster
	ClusterPersistenceConfig_AOFConfig_EVERYSEC ClusterPersistenceConfig_AOFConfig_AppendFsync = 2
	// fsync every time new commands are appended to the AOF. It has the best
	// data loss protection at the cost of performance
	ClusterPersistenceConfig_AOFConfig_ALWAYS ClusterPersistenceConfig_AOFConfig_AppendFsync = 3
)

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) Descriptor 

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) Descriptor() protoreflect.EnumDescriptor

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) Enum 

func (x ClusterPersistenceConfig_AOFConfig_AppendFsync) Enum() *ClusterPersistenceConfig_AOFConfig_AppendFsync

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) EnumDescriptor deprecated 

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClusterPersistenceConfig_AOFConfig_AppendFsync.Descriptor instead.

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) Number 

func (x ClusterPersistenceConfig_AOFConfig_AppendFsync) Number() protoreflect.EnumNumber

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) String 

func (x ClusterPersistenceConfig_AOFConfig_AppendFsync) String() string

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) Type 

func (ClusterPersistenceConfig_AOFConfig_AppendFsync) Type() protoreflect.EnumType

type ClusterPersistenceConfig_PersistenceMode 

type ClusterPersistenceConfig_PersistenceMode int32

Available persistence modes. 

const (
	// Not set.
	ClusterPersistenceConfig_PERSISTENCE_MODE_UNSPECIFIED ClusterPersistenceConfig_PersistenceMode = 0
	// Persistence is disabled, and any snapshot data is deleted.
	ClusterPersistenceConfig_DISABLED ClusterPersistenceConfig_PersistenceMode = 1
	// RDB based persistence is enabled.
	ClusterPersistenceConfig_RDB ClusterPersistenceConfig_PersistenceMode = 2
	// AOF based persistence is enabled.
	ClusterPersistenceConfig_AOF ClusterPersistenceConfig_PersistenceMode = 3
)

func (ClusterPersistenceConfig_PersistenceMode) Descriptor 

func (ClusterPersistenceConfig_PersistenceMode) Descriptor() protoreflect.EnumDescriptor

func (ClusterPersistenceConfig_PersistenceMode) Enum 

func (x ClusterPersistenceConfig_PersistenceMode) Enum() *ClusterPersistenceConfig_PersistenceMode

func (ClusterPersistenceConfig_PersistenceMode) EnumDescriptor deprecated 

func (ClusterPersistenceConfig_PersistenceMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClusterPersistenceConfig_PersistenceMode.Descriptor instead.

func (ClusterPersistenceConfig_PersistenceMode) Number 

func (x ClusterPersistenceConfig_PersistenceMode) Number() protoreflect.EnumNumber

func (ClusterPersistenceConfig_PersistenceMode) String 

func (x ClusterPersistenceConfig_PersistenceMode) String() string

func (ClusterPersistenceConfig_PersistenceMode) Type 

func (ClusterPersistenceConfig_PersistenceMode) Type() protoreflect.EnumType

type ClusterPersistenceConfig_RDBConfig 

type ClusterPersistenceConfig_RDBConfig struct {

	// Optional. Period between RDB snapshots.
	RdbSnapshotPeriod ClusterPersistenceConfig_RDBConfig_SnapshotPeriod `` /* 201-byte string literal not displayed */
	// Optional. The time that the first snapshot was/will be attempted, and to
	// which future snapshots will be aligned. If not provided, the current time
	// will be used.
	RdbSnapshotStartTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=rdb_snapshot_start_time,json=rdbSnapshotStartTime,proto3" json:"rdb_snapshot_start_time,omitempty"`
	// contains filtered or unexported fields
}

Configuration of the RDB based persistence.

func (*ClusterPersistenceConfig_RDBConfig) Descriptor deprecated 

func (*ClusterPersistenceConfig_RDBConfig) Descriptor() ([]byte, []int)

Deprecated: Use ClusterPersistenceConfig_RDBConfig.ProtoReflect.Descriptor instead.

func (*ClusterPersistenceConfig_RDBConfig) GetRdbSnapshotPeriod 

func (x *ClusterPersistenceConfig_RDBConfig) GetRdbSnapshotPeriod() ClusterPersistenceConfig_RDBConfig_SnapshotPeriod

func (*ClusterPersistenceConfig_RDBConfig) GetRdbSnapshotStartTime 

func (x *ClusterPersistenceConfig_RDBConfig) GetRdbSnapshotStartTime() *timestamp.Timestamp

func (*ClusterPersistenceConfig_RDBConfig) ProtoMessage 

func (*ClusterPersistenceConfig_RDBConfig) ProtoMessage()

func (*ClusterPersistenceConfig_RDBConfig) ProtoReflect 

func (x *ClusterPersistenceConfig_RDBConfig) ProtoReflect() protoreflect.Message

func (*ClusterPersistenceConfig_RDBConfig) Reset 

func (x *ClusterPersistenceConfig_RDBConfig) Reset()

func (*ClusterPersistenceConfig_RDBConfig) String 

func (x *ClusterPersistenceConfig_RDBConfig) String() string

type ClusterPersistenceConfig_RDBConfig_SnapshotPeriod 

type ClusterPersistenceConfig_RDBConfig_SnapshotPeriod int32

Available snapshot periods. 

const (
	// Not set.
	ClusterPersistenceConfig_RDBConfig_SNAPSHOT_PERIOD_UNSPECIFIED ClusterPersistenceConfig_RDBConfig_SnapshotPeriod = 0
	// One hour.
	ClusterPersistenceConfig_RDBConfig_ONE_HOUR ClusterPersistenceConfig_RDBConfig_SnapshotPeriod = 1
	// Six hours.
	ClusterPersistenceConfig_RDBConfig_SIX_HOURS ClusterPersistenceConfig_RDBConfig_SnapshotPeriod = 2
	// Twelve hours.
	ClusterPersistenceConfig_RDBConfig_TWELVE_HOURS ClusterPersistenceConfig_RDBConfig_SnapshotPeriod = 3
	// Twenty four hours.
	ClusterPersistenceConfig_RDBConfig_TWENTY_FOUR_HOURS ClusterPersistenceConfig_RDBConfig_SnapshotPeriod = 4
)

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Descriptor 

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Descriptor() protoreflect.EnumDescriptor

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Enum 

func (x ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Enum() *ClusterPersistenceConfig_RDBConfig_SnapshotPeriod

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) EnumDescriptor deprecated 

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClusterPersistenceConfig_RDBConfig_SnapshotPeriod.Descriptor instead.

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Number 

func (x ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Number() protoreflect.EnumNumber

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) String 

func (x ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) String() string

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Type 

func (ClusterPersistenceConfig_RDBConfig_SnapshotPeriod) Type() protoreflect.EnumType

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 deprecated 

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 deprecated 

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 deprecated 

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 deprecated 

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 deprecated 

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 deprecated 

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 GetClusterCertificateAuthorityRequest 

type GetClusterCertificateAuthorityRequest struct {

	// Required. Redis cluster certificate authority resource name using the form:
	//
	//	`projects/{project_id}/locations/{location_id}/clusters/{cluster_id}/certificateAuthority`
	//
	// 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 GetClusterCertificateAuthorityRequest[CloudRedis.GetClusterCertificateAuthorityRequest].

func (*GetClusterCertificateAuthorityRequest) Descriptor deprecated 

func (*GetClusterCertificateAuthorityRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetClusterCertificateAuthorityRequest.ProtoReflect.Descriptor instead.

func (*GetClusterCertificateAuthorityRequest) GetName 

func (x *GetClusterCertificateAuthorityRequest) GetName() string

func (*GetClusterCertificateAuthorityRequest) ProtoMessage 

func (*GetClusterCertificateAuthorityRequest) ProtoMessage()

func (*GetClusterCertificateAuthorityRequest) ProtoReflect 

func (x *GetClusterCertificateAuthorityRequest) ProtoReflect() protoreflect.Message

func (*GetClusterCertificateAuthorityRequest) Reset 

func (x *GetClusterCertificateAuthorityRequest) Reset()

func (*GetClusterCertificateAuthorityRequest) String 

func (x *GetClusterCertificateAuthorityRequest) 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 deprecated 

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`][mockgcp.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 deprecated 

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 deprecated 

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 NodeType 

type NodeType int32

NodeType of a redis cluster node, 

const (
	NodeType_NODE_TYPE_UNSPECIFIED NodeType = 0
	// Redis shared core nano node_type.
	NodeType_REDIS_SHARED_CORE_NANO NodeType = 1
	// Redis highmem medium node_type.
	NodeType_REDIS_HIGHMEM_MEDIUM NodeType = 2
	// Redis highmem xlarge node_type.
	NodeType_REDIS_HIGHMEM_XLARGE NodeType = 3
	// Redis standard small node_type.
	NodeType_REDIS_STANDARD_SMALL NodeType = 4
)

func (NodeType) Descriptor 

func (NodeType) Descriptor() protoreflect.EnumDescriptor

func (NodeType) Enum 

func (x NodeType) Enum() *NodeType

func (NodeType) EnumDescriptor deprecated 

func (NodeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NodeType.Descriptor instead.

func (NodeType) Number 

func (x NodeType) Number() protoreflect.EnumNumber

func (NodeType) String 

func (x NodeType) String() string

func (NodeType) Type 

func (NodeType) Type() protoreflect.EnumType

type OperationMetadata 

type OperationMetadata struct {

	// Output only. The time the operation was created.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamp.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 deprecated 

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() *timestamp.Timestamp

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamp.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 

func (*PscConfig) Descriptor() ([]byte, []int)

Deprecated: Use PscConfig.ProtoReflect.Descriptor instead.

func (*PscConfig) GetNetwork 

func (x *PscConfig) GetNetwork() string

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 

func (x *PscConfig) String() 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 deprecated 

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 deprecated 

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 must 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) GetClusterCertificateAuthority 

func (UnimplementedCloudRedisClusterServer) GetClusterCertificateAuthority(context.Context, *GetClusterCertificateAuthorityRequest) (*CertificateAuthority, 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 UnsafeCloudRedisClusterServer 

type UnsafeCloudRedisClusterServer interface {
	// contains filtered or unexported methods
}

UnsafeCloudRedisClusterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CloudRedisClusterServer will result in compilation errors.

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][mockgcp.cloud.redis.cluster.v1.Cluster]:
	//
	//   - `size_gb`
	//   - `replica_count`
	UpdateMask *field_mask.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 deprecated 

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() *field_mask.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

type ZoneDistributionConfig 

type ZoneDistributionConfig struct {

	// Optional. The mode of zone distribution. Defaults to MULTI_ZONE, when not
	// specified.
	Mode ZoneDistributionConfig_ZoneDistributionMode `` /* 142-byte string literal not displayed */
	// Optional. When SINGLE ZONE distribution is selected, zone field would be
	// used to allocate all resources in that zone. This is not applicable to
	// MULTI_ZONE, and would be ignored for MULTI_ZONE clusters.
	Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	// contains filtered or unexported fields
}

Zone distribution config for allocation of cluster resources.

func (*ZoneDistributionConfig) Descriptor deprecated 

func (*ZoneDistributionConfig) Descriptor() ([]byte, []int)

Deprecated: Use ZoneDistributionConfig.ProtoReflect.Descriptor instead.

func (*ZoneDistributionConfig) GetMode 

func (x *ZoneDistributionConfig) GetMode() ZoneDistributionConfig_ZoneDistributionMode

func (*ZoneDistributionConfig) GetZone 

func (x *ZoneDistributionConfig) GetZone() string

func (*ZoneDistributionConfig) ProtoMessage 

func (*ZoneDistributionConfig) ProtoMessage()

func (*ZoneDistributionConfig) ProtoReflect 

func (x *ZoneDistributionConfig) ProtoReflect() protoreflect.Message

func (*ZoneDistributionConfig) Reset 

func (x *ZoneDistributionConfig) Reset()

func (*ZoneDistributionConfig) String 

func (x *ZoneDistributionConfig) String() string

type ZoneDistributionConfig_ZoneDistributionMode 

type ZoneDistributionConfig_ZoneDistributionMode int32

Defines various modes of zone distribution. Currently supports two modes, can be expanded in future to support more types of distribution modes. design doc: go/same-zone-cluster 

const (
	// Not Set. Default: MULTI_ZONE
	ZoneDistributionConfig_ZONE_DISTRIBUTION_MODE_UNSPECIFIED ZoneDistributionConfig_ZoneDistributionMode = 0
	// Distribute all resources across 3 zones picked at random, within the
	// region.
	ZoneDistributionConfig_MULTI_ZONE ZoneDistributionConfig_ZoneDistributionMode = 1
	// Distribute all resources in a single zone. The zone field must be
	// specified, when this mode is selected.
	ZoneDistributionConfig_SINGLE_ZONE ZoneDistributionConfig_ZoneDistributionMode = 2
)

func (ZoneDistributionConfig_ZoneDistributionMode) Descriptor 

func (ZoneDistributionConfig_ZoneDistributionMode) Descriptor() protoreflect.EnumDescriptor

func (ZoneDistributionConfig_ZoneDistributionMode) Enum 

func (x ZoneDistributionConfig_ZoneDistributionMode) Enum() *ZoneDistributionConfig_ZoneDistributionMode

func (ZoneDistributionConfig_ZoneDistributionMode) EnumDescriptor deprecated 

func (ZoneDistributionConfig_ZoneDistributionMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ZoneDistributionConfig_ZoneDistributionMode.Descriptor instead.

func (ZoneDistributionConfig_ZoneDistributionMode) Number 

func (x ZoneDistributionConfig_ZoneDistributionMode) Number() protoreflect.EnumNumber

func (ZoneDistributionConfig_ZoneDistributionMode) String 

func (x ZoneDistributionConfig_ZoneDistributionMode) String() string

func (ZoneDistributionConfig_ZoneDistributionMode) Type 

func (ZoneDistributionConfig_ZoneDistributionMode) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.