managedkafkapb

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2025 License: Apache-2.0 Imports: 13 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Cluster_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "DELETING",
	}
	Cluster_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"ACTIVE":            2,
		"DELETING":          3,
	}
)

Enum value maps for Cluster_State.

View Source 
var (
	RebalanceConfig_Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "NO_REBALANCE",
		2: "AUTO_REBALANCE_ON_SCALE_UP",
	}
	RebalanceConfig_Mode_value = map[string]int32{
		"MODE_UNSPECIFIED":           0,
		"NO_REBALANCE":               1,
		"AUTO_REBALANCE_ON_SCALE_UP": 2,
	}
)

Enum value maps for RebalanceConfig_Mode.

View Source 
var File_google_cloud_managedkafka_v1_managed_kafka_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_managedkafka_v1_resources_proto protoreflect.FileDescriptor

Functions

func RegisterManagedKafkaServer 

func RegisterManagedKafkaServer(s *grpc.Server, srv ManagedKafkaServer)

Types

type AccessConfig 

type AccessConfig struct {

	// Required. Virtual Private Cloud (VPC) networks that must be granted direct
	// access to the Kafka cluster. Minimum of 1 network is required. Maximum 10
	// networks can be specified.
	NetworkConfigs []*NetworkConfig `protobuf:"bytes,1,rep,name=network_configs,json=networkConfigs,proto3" json:"network_configs,omitempty"`
	// contains filtered or unexported fields
}

The configuration of access to the Kafka cluster.

func (*AccessConfig) Descriptor deprecated 

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

Deprecated: Use AccessConfig.ProtoReflect.Descriptor instead.

func (*AccessConfig) GetNetworkConfigs 

func (x *AccessConfig) GetNetworkConfigs() []*NetworkConfig

func (*AccessConfig) ProtoMessage 

func (*AccessConfig) ProtoMessage()

func (*AccessConfig) ProtoReflect 

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

func (*AccessConfig) Reset 

func (x *AccessConfig) Reset()

func (*AccessConfig) String 

func (x *AccessConfig) String() string

type CapacityConfig 

type CapacityConfig struct {

	// Required. The number of vCPUs to provision for the cluster. Minimum: 3.
	VcpuCount int64 `protobuf:"varint,1,opt,name=vcpu_count,json=vcpuCount,proto3" json:"vcpu_count,omitempty"`
	// Required. The memory to provision for the cluster in bytes.
	// The CPU:memory ratio (vCPU:GiB) must be between 1:1 and 1:8.
	// Minimum: 3221225472 (3 GiB).
	MemoryBytes int64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	// contains filtered or unexported fields
}

A capacity configuration of a Kafka cluster.

func (*CapacityConfig) Descriptor deprecated 

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

Deprecated: Use CapacityConfig.ProtoReflect.Descriptor instead.

func (*CapacityConfig) GetMemoryBytes 

func (x *CapacityConfig) GetMemoryBytes() int64

func (*CapacityConfig) GetVcpuCount 

func (x *CapacityConfig) GetVcpuCount() int64

func (*CapacityConfig) ProtoMessage 

func (*CapacityConfig) ProtoMessage()

func (*CapacityConfig) ProtoReflect 

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

func (*CapacityConfig) Reset 

func (x *CapacityConfig) Reset()

func (*CapacityConfig) String 

func (x *CapacityConfig) String() string

type Cluster 

type Cluster struct {

	// Platform specific configuration properties for a Kafka cluster.
	//
	// Types that are assignable to PlatformConfig:
	//
	//	*Cluster_GcpConfig
	PlatformConfig isCluster_PlatformConfig `protobuf_oneof:"platform_config"`
	// Identifier. The name of the cluster. Structured like:
	// projects/{project_number}/locations/{location}/clusters/{cluster_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The time when the cluster was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the cluster was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Labels as key value pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Required. Capacity configuration for the Kafka cluster.
	CapacityConfig *CapacityConfig `protobuf:"bytes,5,opt,name=capacity_config,json=capacityConfig,proto3" json:"capacity_config,omitempty"`
	// Optional. Rebalance configuration for the Kafka cluster.
	RebalanceConfig *RebalanceConfig `protobuf:"bytes,8,opt,name=rebalance_config,json=rebalanceConfig,proto3" json:"rebalance_config,omitempty"`
	// Output only. The current state of the cluster.
	State Cluster_State `protobuf:"varint,10,opt,name=state,proto3,enum=google.cloud.managedkafka.v1.Cluster_State" json:"state,omitempty"`
	// Output only. Reserved for future use.
	SatisfiesPzi *bool `protobuf:"varint,11,opt,name=satisfies_pzi,json=satisfiesPzi,proto3,oneof" json:"satisfies_pzi,omitempty"`
	// Output only. Reserved for future use.
	SatisfiesPzs *bool `protobuf:"varint,12,opt,name=satisfies_pzs,json=satisfiesPzs,proto3,oneof" json:"satisfies_pzs,omitempty"`
	// contains filtered or unexported fields
}

An Apache Kafka cluster deployed in a location.

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetCapacityConfig 

func (x *Cluster) GetCapacityConfig() *CapacityConfig

func (*Cluster) GetCreateTime 

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

func (*Cluster) GetGcpConfig 

func (x *Cluster) GetGcpConfig() *GcpConfig

func (*Cluster) GetLabels 

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

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetPlatformConfig 

func (m *Cluster) GetPlatformConfig() isCluster_PlatformConfig

func (*Cluster) GetRebalanceConfig 

func (x *Cluster) GetRebalanceConfig() *RebalanceConfig

func (*Cluster) GetSatisfiesPzi added in v0.3.0 

func (x *Cluster) GetSatisfiesPzi() bool

func (*Cluster) GetSatisfiesPzs added in v0.3.0 

func (x *Cluster) GetSatisfiesPzs() bool

func (*Cluster) GetState 

func (x *Cluster) GetState() Cluster_State

func (*Cluster) GetUpdateTime 

func (x *Cluster) GetUpdateTime() *timestamppb.Timestamp

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 Cluster_GcpConfig 

type Cluster_GcpConfig struct {
	// Required. Configuration properties for a Kafka cluster deployed to Google
	// Cloud Platform.
	GcpConfig *GcpConfig `protobuf:"bytes,9,opt,name=gcp_config,json=gcpConfig,proto3,oneof"`
}

type Cluster_State 

type Cluster_State int32

The state of the cluster. 

const (
	// A state was not specified.
	Cluster_STATE_UNSPECIFIED Cluster_State = 0
	// The cluster is being created.
	Cluster_CREATING Cluster_State = 1
	// The cluster is active.
	Cluster_ACTIVE Cluster_State = 2
	// The cluster is being deleted.
	Cluster_DELETING Cluster_State = 3
)

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 ConsumerGroup 

type ConsumerGroup struct {

	// Identifier. The name of the consumer group. The `consumer_group` segment is
	// used when connecting directly to the cluster. Structured like:
	// projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumer_group}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. Metadata for this consumer group for all topics it has metadata
	// for. The key of the map is a topic name, structured like:
	// projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}
	Topics map[string]*ConsumerTopicMetadata `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

A Kafka consumer group in a given cluster.

func (*ConsumerGroup) Descriptor deprecated 

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

Deprecated: Use ConsumerGroup.ProtoReflect.Descriptor instead.

func (*ConsumerGroup) GetName 

func (x *ConsumerGroup) GetName() string

func (*ConsumerGroup) GetTopics 

func (x *ConsumerGroup) GetTopics() map[string]*ConsumerTopicMetadata

func (*ConsumerGroup) ProtoMessage 

func (*ConsumerGroup) ProtoMessage()

func (*ConsumerGroup) ProtoReflect 

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

func (*ConsumerGroup) Reset 

func (x *ConsumerGroup) Reset()

func (*ConsumerGroup) String 

func (x *ConsumerGroup) String() string

type ConsumerPartitionMetadata 

type ConsumerPartitionMetadata struct {

	// Required. The current offset for this partition, or 0 if no offset has been
	// committed.
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// Optional. The associated metadata for this partition, or empty if it does
	// not exist.
	Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Metadata for a consumer group corresponding to a specific partition.

func (*ConsumerPartitionMetadata) Descriptor deprecated 

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

Deprecated: Use ConsumerPartitionMetadata.ProtoReflect.Descriptor instead.

func (*ConsumerPartitionMetadata) GetMetadata 

func (x *ConsumerPartitionMetadata) GetMetadata() string

func (*ConsumerPartitionMetadata) GetOffset 

func (x *ConsumerPartitionMetadata) GetOffset() int64

func (*ConsumerPartitionMetadata) ProtoMessage 

func (*ConsumerPartitionMetadata) ProtoMessage()

func (*ConsumerPartitionMetadata) ProtoReflect 

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

func (*ConsumerPartitionMetadata) Reset 

func (x *ConsumerPartitionMetadata) Reset()

func (*ConsumerPartitionMetadata) String 

func (x *ConsumerPartitionMetadata) String() string

type ConsumerTopicMetadata 

type ConsumerTopicMetadata struct {

	// Optional. Metadata for this consumer group and topic for all partition
	// indexes it has metadata for.
	Partitions map[int32]*ConsumerPartitionMetadata `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

Metadata for a consumer group corresponding to a specific topic.

func (*ConsumerTopicMetadata) Descriptor deprecated 

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

Deprecated: Use ConsumerTopicMetadata.ProtoReflect.Descriptor instead.

func (*ConsumerTopicMetadata) GetPartitions 

func (x *ConsumerTopicMetadata) GetPartitions() map[int32]*ConsumerPartitionMetadata

func (*ConsumerTopicMetadata) ProtoMessage 

func (*ConsumerTopicMetadata) ProtoMessage()

func (*ConsumerTopicMetadata) ProtoReflect 

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

func (*ConsumerTopicMetadata) Reset 

func (x *ConsumerTopicMetadata) Reset()

func (*ConsumerTopicMetadata) String 

func (x *ConsumerTopicMetadata) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {

	// Required. The parent region in which to create the cluster. Structured like
	// `projects/{project}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The ID to use for the cluster, which will become the final
	// component of the cluster's name. The ID must be 1-63 characters long, and
	// match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with
	// RFC 1035.
	//
	// This value is structured like: `my-cluster-id`.
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Required. Configuration of the cluster to create. Its `name` field is
	// ignored.
	Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID to avoid duplication of requests. If a request times out or
	// fails, retrying with the same ID allows the server to recognize the
	// previous attempt. For at least 60 minutes, the server ignores duplicate
	// requests bearing the same ID.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID
	// within 60 minutes of the last request, the server checks if an original
	// operation with the same request ID was received. If so, the server ignores
	// the second request.
	//
	// The request ID must be a valid UUID. A zero UUID is not supported
	// (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request for 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 CreateTopicRequest 

type CreateTopicRequest struct {

	// Required. The parent cluster in which to create the topic.
	// Structured like
	// `projects/{project}/locations/{location}/clusters/{cluster}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The ID to use for the topic, which will become the final
	// component of the topic's name.
	//
	// This value is structured like: `my-topic-name`.
	TopicId string `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	// Required. Configuration of the topic to create. Its `name` field is
	// ignored.
	Topic *Topic `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateTopic.

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetParent 

func (x *CreateTopicRequest) GetParent() string

func (*CreateTopicRequest) GetTopic 

func (x *CreateTopicRequest) GetTopic() *Topic

func (*CreateTopicRequest) GetTopicId 

func (x *CreateTopicRequest) GetTopicId() string

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

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

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {

	// Required. The name of the cluster to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID to avoid duplication of requests. If a request times out or
	// fails, retrying with the same ID allows the server to recognize the
	// previous attempt. For at least 60 minutes, the server ignores duplicate
	// requests bearing the same ID.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID
	// within 60 minutes of the last request, the server checks if an original
	// operation with the same request ID was received. If so, the server ignores
	// the second request.
	//
	// The request ID must be a valid UUID. A zero UUID is not supported
	// (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request for 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 DeleteConsumerGroupRequest 

type DeleteConsumerGroupRequest struct {

	// Required. The name of the consumer group to delete.
	// `projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumerGroup}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteConsumerGroup.

func (*DeleteConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteConsumerGroupRequest) GetName 

func (x *DeleteConsumerGroupRequest) GetName() string

func (*DeleteConsumerGroupRequest) ProtoMessage 

func (*DeleteConsumerGroupRequest) ProtoMessage()

func (*DeleteConsumerGroupRequest) ProtoReflect 

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

func (*DeleteConsumerGroupRequest) Reset 

func (x *DeleteConsumerGroupRequest) Reset()

func (*DeleteConsumerGroupRequest) String 

func (x *DeleteConsumerGroupRequest) String() string

type DeleteTopicRequest 

type DeleteTopicRequest struct {

	// Required. The name of the topic to delete.
	// `projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteTopic.

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetName 

func (x *DeleteTopicRequest) GetName() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect 

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

func (*DeleteTopicRequest) Reset 

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

type GcpConfig 

type GcpConfig struct {

	// Required. Access configuration for the Kafka cluster.
	AccessConfig *AccessConfig `protobuf:"bytes,3,opt,name=access_config,json=accessConfig,proto3" json:"access_config,omitempty"`
	// Optional. Immutable. The Cloud KMS Key name to use for encryption. The key
	// must be located in the same region as the cluster and cannot be changed.
	// Structured like:
	// projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{crypto_key}.
	KmsKey string `protobuf:"bytes,2,opt,name=kms_key,json=kmsKey,proto3" json:"kms_key,omitempty"`
	// contains filtered or unexported fields
}

Configuration properties for a Kafka cluster deployed to Google Cloud Platform.

func (*GcpConfig) Descriptor deprecated 

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

Deprecated: Use GcpConfig.ProtoReflect.Descriptor instead.

func (*GcpConfig) GetAccessConfig 

func (x *GcpConfig) GetAccessConfig() *AccessConfig

func (*GcpConfig) GetKmsKey 

func (x *GcpConfig) GetKmsKey() string

func (*GcpConfig) ProtoMessage 

func (*GcpConfig) ProtoMessage()

func (*GcpConfig) ProtoReflect 

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

func (*GcpConfig) Reset 

func (x *GcpConfig) Reset()

func (*GcpConfig) String 

func (x *GcpConfig) String() string

type GetClusterRequest 

type GetClusterRequest struct {

	// Required. The name of the cluster whose configuration to return.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for 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 GetConsumerGroupRequest 

type GetConsumerGroupRequest struct {

	// Required. The name of the consumer group whose configuration to return.
	// `projects/{project}/locations/{location}/clusters/{cluster}/consumerGroups/{consumerGroup}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetConsumerGroup.

func (*GetConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use GetConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*GetConsumerGroupRequest) GetName 

func (x *GetConsumerGroupRequest) GetName() string

func (*GetConsumerGroupRequest) ProtoMessage 

func (*GetConsumerGroupRequest) ProtoMessage()

func (*GetConsumerGroupRequest) ProtoReflect 

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

func (*GetConsumerGroupRequest) Reset 

func (x *GetConsumerGroupRequest) Reset()

func (*GetConsumerGroupRequest) String 

func (x *GetConsumerGroupRequest) String() string

type GetTopicRequest 

type GetTopicRequest struct {

	// Required. The name of the topic whose configuration to return. Structured
	// like:
	// projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetTopic.

func (*GetTopicRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicRequest.ProtoReflect.Descriptor instead.

func (*GetTopicRequest) GetName 

func (x *GetTopicRequest) GetName() string

func (*GetTopicRequest) ProtoMessage 

func (*GetTopicRequest) ProtoMessage()

func (*GetTopicRequest) ProtoReflect 

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

func (*GetTopicRequest) Reset 

func (x *GetTopicRequest) Reset()

func (*GetTopicRequest) String 

func (x *GetTopicRequest) String() string

type ListClustersRequest 

type ListClustersRequest struct {

	// Required. The parent location whose clusters are to be listed. Structured
	// like `projects/{project}/locations/{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of clusters to return. The service may return
	// fewer than this value. If unspecified, server will pick an appropriate
	// default.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from a previous `ListClusters` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListClusters` must match
	// the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. Filter expression for the result.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Optional. Order by fields for the result.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Request for ListClusters.

func (*ListClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetFilter 

func (x *ListClustersRequest) GetFilter() string

func (*ListClustersRequest) GetOrderBy 

func (x *ListClustersRequest) GetOrderBy() string

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 {

	// The list of Clusters in the requested parent.
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	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.

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 ListConsumerGroupsRequest 

type ListConsumerGroupsRequest struct {

	// Required. The parent cluster whose consumer groups are to be listed.
	// Structured like
	// `projects/{project}/locations/{location}/clusters/{cluster}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of consumer groups to return. The service may
	// return fewer than this value. If unset or zero, all consumer groups for the
	// parent is returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from a previous `ListConsumerGroups` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListConsumerGroups` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListConsumerGroups.

func (*ListConsumerGroupsRequest) Descriptor deprecated 

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

Deprecated: Use ListConsumerGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListConsumerGroupsRequest) GetPageSize 

func (x *ListConsumerGroupsRequest) GetPageSize() int32

func (*ListConsumerGroupsRequest) GetPageToken 

func (x *ListConsumerGroupsRequest) GetPageToken() string

func (*ListConsumerGroupsRequest) GetParent 

func (x *ListConsumerGroupsRequest) GetParent() string

func (*ListConsumerGroupsRequest) ProtoMessage 

func (*ListConsumerGroupsRequest) ProtoMessage()

func (*ListConsumerGroupsRequest) ProtoReflect 

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

func (*ListConsumerGroupsRequest) Reset 

func (x *ListConsumerGroupsRequest) Reset()

func (*ListConsumerGroupsRequest) String 

func (x *ListConsumerGroupsRequest) String() string

type ListConsumerGroupsResponse 

type ListConsumerGroupsResponse struct {

	// The list of consumer group in the requested parent. The order of the
	// consumer groups is unspecified.
	ConsumerGroups []*ConsumerGroup `protobuf:"bytes,1,rep,name=consumer_groups,json=consumerGroups,proto3" json:"consumer_groups,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListConsumerGroups.

func (*ListConsumerGroupsResponse) Descriptor deprecated 

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

Deprecated: Use ListConsumerGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListConsumerGroupsResponse) GetConsumerGroups 

func (x *ListConsumerGroupsResponse) GetConsumerGroups() []*ConsumerGroup

func (*ListConsumerGroupsResponse) GetNextPageToken 

func (x *ListConsumerGroupsResponse) GetNextPageToken() string

func (*ListConsumerGroupsResponse) ProtoMessage 

func (*ListConsumerGroupsResponse) ProtoMessage()

func (*ListConsumerGroupsResponse) ProtoReflect 

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

func (*ListConsumerGroupsResponse) Reset 

func (x *ListConsumerGroupsResponse) Reset()

func (*ListConsumerGroupsResponse) String 

func (x *ListConsumerGroupsResponse) String() string

type ListTopicsRequest 

type ListTopicsRequest struct {

	// Required. The parent cluster whose topics are to be listed. Structured like
	// `projects/{project}/locations/{location}/clusters/{cluster}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of topics to return. The service may return
	// fewer than this value. If unset or zero, all topics for the parent is
	// returned.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from a previous `ListTopics` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListTopics` must match
	// the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for ListTopics.

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) GetPageSize 

func (x *ListTopicsRequest) GetPageSize() int32

func (*ListTopicsRequest) GetPageToken 

func (x *ListTopicsRequest) GetPageToken() string

func (*ListTopicsRequest) GetParent 

func (x *ListTopicsRequest) GetParent() string

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect 

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

func (*ListTopicsRequest) Reset 

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {

	// The list of topics in the requested parent. The order of the topics is
	// unspecified.
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for ListTopics.

func (*ListTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetNextPageToken 

func (x *ListTopicsResponse) GetNextPageToken() string

func (*ListTopicsResponse) GetTopics 

func (x *ListTopicsResponse) GetTopics() []*Topic

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

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

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type ManagedKafkaClient 

type ManagedKafkaClient interface {
	// Lists the clusters in a given project and location.
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// Returns the properties of a single cluster.
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	// Creates a new cluster in a given project and location.
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates the properties of a single cluster.
	UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Deletes a single cluster.
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Lists the topics in a given cluster.
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	// Returns the properties of a single topic.
	GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Creates a new topic in a given project and location.
	CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Updates the properties of a single topic.
	UpdateTopic(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Deletes a single topic.
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Lists the consumer groups in a given cluster.
	ListConsumerGroups(ctx context.Context, in *ListConsumerGroupsRequest, opts ...grpc.CallOption) (*ListConsumerGroupsResponse, error)
	// Returns the properties of a single consumer group.
	GetConsumerGroup(ctx context.Context, in *GetConsumerGroupRequest, opts ...grpc.CallOption) (*ConsumerGroup, error)
	// Updates the properties of a single consumer group.
	UpdateConsumerGroup(ctx context.Context, in *UpdateConsumerGroupRequest, opts ...grpc.CallOption) (*ConsumerGroup, error)
	// Deletes a single consumer group.
	DeleteConsumerGroup(ctx context.Context, in *DeleteConsumerGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ManagedKafkaClient is the client API for ManagedKafka service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewManagedKafkaClient 

func NewManagedKafkaClient(cc grpc.ClientConnInterface) ManagedKafkaClient

type ManagedKafkaServer 

type ManagedKafkaServer interface {
	// Lists the clusters in a given project and location.
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// Returns the properties of a single cluster.
	GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
	// Creates a new cluster in a given project and location.
	CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)
	// Updates the properties of a single cluster.
	UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)
	// Deletes a single cluster.
	DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)
	// Lists the topics in a given cluster.
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	// Returns the properties of a single topic.
	GetTopic(context.Context, *GetTopicRequest) (*Topic, error)
	// Creates a new topic in a given project and location.
	CreateTopic(context.Context, *CreateTopicRequest) (*Topic, error)
	// Updates the properties of a single topic.
	UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error)
	// Deletes a single topic.
	DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)
	// Lists the consumer groups in a given cluster.
	ListConsumerGroups(context.Context, *ListConsumerGroupsRequest) (*ListConsumerGroupsResponse, error)
	// Returns the properties of a single consumer group.
	GetConsumerGroup(context.Context, *GetConsumerGroupRequest) (*ConsumerGroup, error)
	// Updates the properties of a single consumer group.
	UpdateConsumerGroup(context.Context, *UpdateConsumerGroupRequest) (*ConsumerGroup, error)
	// Deletes a single consumer group.
	DeleteConsumerGroup(context.Context, *DeleteConsumerGroupRequest) (*emptypb.Empty, error)
}

ManagedKafkaServer is the server API for ManagedKafka service.

type NetworkConfig 

type NetworkConfig struct {

	// Required. Name of the VPC subnet in which to create Private Service Connect
	// (PSC) endpoints for the Kafka brokers and bootstrap address. Structured
	// like: projects/{project}/regions/{region}/subnetworks/{subnet_id}
	//
	// The subnet must be located in the same region as the Kafka cluster. The
	// project may differ. Multiple subnets from the same parent network must not
	// be specified.
	//
	// The CIDR range of the subnet must be within the IPv4 address ranges for
	// private networks, as specified in RFC 1918.
	Subnet string `protobuf:"bytes,2,opt,name=subnet,proto3" json:"subnet,omitempty"`
	// contains filtered or unexported fields
}

The configuration of a Virtual Private Cloud (VPC) network that can access the Kafka cluster.

func (*NetworkConfig) Descriptor deprecated 

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

Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.

func (*NetworkConfig) GetSubnet 

func (x *NetworkConfig) GetSubnet() string

func (*NetworkConfig) ProtoMessage 

func (*NetworkConfig) ProtoMessage()

func (*NetworkConfig) ProtoReflect 

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

func (*NetworkConfig) Reset 

func (x *NetworkConfig) Reset()

func (*NetworkConfig) String 

func (x *NetworkConfig) 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 been cancelled successfully
	// 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
}

Represents the metadata of the long-running operation.

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() *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 RebalanceConfig 

type RebalanceConfig struct {

	// Optional. The rebalance behavior for the cluster.
	// When not specified, defaults to `NO_REBALANCE`.
	Mode RebalanceConfig_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=google.cloud.managedkafka.v1.RebalanceConfig_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

Defines rebalancing behavior of a Kafka cluster.

func (*RebalanceConfig) Descriptor deprecated 

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

Deprecated: Use RebalanceConfig.ProtoReflect.Descriptor instead.

func (*RebalanceConfig) GetMode 

func (x *RebalanceConfig) GetMode() RebalanceConfig_Mode

func (*RebalanceConfig) ProtoMessage 

func (*RebalanceConfig) ProtoMessage()

func (*RebalanceConfig) ProtoReflect 

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

func (*RebalanceConfig) Reset 

func (x *RebalanceConfig) Reset()

func (*RebalanceConfig) String 

func (x *RebalanceConfig) String() string

type RebalanceConfig_Mode 

type RebalanceConfig_Mode int32

The partition rebalance mode for the cluster. 

const (
	// A mode was not specified. Do not use.
	RebalanceConfig_MODE_UNSPECIFIED RebalanceConfig_Mode = 0
	// Do not rebalance automatically.
	RebalanceConfig_NO_REBALANCE RebalanceConfig_Mode = 1
	// Automatically rebalance topic partitions among brokers when the
	// cluster is scaled up.
	RebalanceConfig_AUTO_REBALANCE_ON_SCALE_UP RebalanceConfig_Mode = 2
)

func (RebalanceConfig_Mode) Descriptor 

func (RebalanceConfig_Mode) Descriptor() protoreflect.EnumDescriptor

func (RebalanceConfig_Mode) Enum 

func (x RebalanceConfig_Mode) Enum() *RebalanceConfig_Mode

func (RebalanceConfig_Mode) EnumDescriptor deprecated 

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

Deprecated: Use RebalanceConfig_Mode.Descriptor instead.

func (RebalanceConfig_Mode) Number 

func (x RebalanceConfig_Mode) Number() protoreflect.EnumNumber

func (RebalanceConfig_Mode) String 

func (x RebalanceConfig_Mode) String() string

func (RebalanceConfig_Mode) Type 

func (RebalanceConfig_Mode) Type() protoreflect.EnumType

type Topic 

type Topic struct {

	// Identifier. The name of the topic. The `topic` segment is used when
	// connecting directly to the cluster. Structured like:
	// projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The number of partitions this topic has. The partition count can
	// only be increased, not decreased. Please note that if partitions are
	// increased for a topic that has a key, the partitioning logic or the
	// ordering of the messages will be affected.
	PartitionCount int32 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// Required. Immutable. The number of replicas of each partition. A
	// replication factor of 3 is recommended for high availability.
	ReplicationFactor int32 `protobuf:"varint,3,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	// Optional. Configurations for the topic that are overridden from the cluster
	// defaults. The key of the map is a Kafka topic property name, for example:
	// `cleanup.policy`, `compression.type`.
	Configs map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

A Kafka topic in a given cluster.

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetConfigs 

func (x *Topic) GetConfigs() map[string]string

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitionCount 

func (x *Topic) GetPartitionCount() int32

func (*Topic) GetReplicationFactor 

func (x *Topic) GetReplicationFactor() int32

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

type UnimplementedManagedKafkaServer 

type UnimplementedManagedKafkaServer struct {
}

UnimplementedManagedKafkaServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagedKafkaServer) CreateCluster 

func (*UnimplementedManagedKafkaServer) CreateCluster(context.Context, *CreateClusterRequest) (*longrunningpb.Operation, error)

func (*UnimplementedManagedKafkaServer) CreateTopic 

func (*UnimplementedManagedKafkaServer) CreateTopic(context.Context, *CreateTopicRequest) (*Topic, error)

func (*UnimplementedManagedKafkaServer) DeleteCluster 

func (*UnimplementedManagedKafkaServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunningpb.Operation, error)

func (*UnimplementedManagedKafkaServer) DeleteConsumerGroup 

func (*UnimplementedManagedKafkaServer) DeleteConsumerGroup(context.Context, *DeleteConsumerGroupRequest) (*emptypb.Empty, error)

func (*UnimplementedManagedKafkaServer) DeleteTopic 

func (*UnimplementedManagedKafkaServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)

func (*UnimplementedManagedKafkaServer) GetCluster 

func (*UnimplementedManagedKafkaServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)

func (*UnimplementedManagedKafkaServer) GetConsumerGroup 

func (*UnimplementedManagedKafkaServer) GetConsumerGroup(context.Context, *GetConsumerGroupRequest) (*ConsumerGroup, error)

func (*UnimplementedManagedKafkaServer) GetTopic 

func (*UnimplementedManagedKafkaServer) GetTopic(context.Context, *GetTopicRequest) (*Topic, error)

func (*UnimplementedManagedKafkaServer) ListClusters 

func (*UnimplementedManagedKafkaServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

func (*UnimplementedManagedKafkaServer) ListConsumerGroups 

func (*UnimplementedManagedKafkaServer) ListConsumerGroups(context.Context, *ListConsumerGroupsRequest) (*ListConsumerGroupsResponse, error)

func (*UnimplementedManagedKafkaServer) ListTopics 

func (*UnimplementedManagedKafkaServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

func (*UnimplementedManagedKafkaServer) UpdateCluster 

func (*UnimplementedManagedKafkaServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunningpb.Operation, error)

func (*UnimplementedManagedKafkaServer) UpdateConsumerGroup 

func (*UnimplementedManagedKafkaServer) UpdateConsumerGroup(context.Context, *UpdateConsumerGroupRequest) (*ConsumerGroup, error)

func (*UnimplementedManagedKafkaServer) UpdateTopic 

func (*UnimplementedManagedKafkaServer) UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error)

type UpdateClusterRequest 

type UpdateClusterRequest struct {

	// Required. Field mask is used to specify the fields to be overwritten in the
	// cluster resource by the update. The fields specified in the update_mask are
	// relative to the resource, not the full request. A field will be overwritten
	// if it is in the mask. The mask is required and a value of * will update all
	// fields.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. The cluster to update. Its `name` field must be populated.
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID to avoid duplication of requests. If a request times out or
	// fails, retrying with the same ID allows the server to recognize the
	// previous attempt. For at least 60 minutes, the server ignores duplicate
	// requests bearing the same ID.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID
	// within 60 minutes of the last request, the server checks if an original
	// operation with the same request ID was received. If so, the server ignores
	// the second request.
	//
	// The request ID must be a valid UUID. A zero UUID is not supported
	// (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request for 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() *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

type UpdateConsumerGroupRequest 

type UpdateConsumerGroupRequest struct {

	// Required. Field mask is used to specify the fields to be overwritten in the
	// ConsumerGroup resource by the update.
	// The fields specified in the update_mask are relative to the resource, not
	// the full request. A field will be overwritten if it is in the mask. The
	// mask is required and a value of * will update all fields.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. The consumer group to update. Its `name` field must be populated.
	ConsumerGroup *ConsumerGroup `protobuf:"bytes,2,opt,name=consumer_group,json=consumerGroup,proto3" json:"consumer_group,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateConsumerGroup.

func (*UpdateConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*UpdateConsumerGroupRequest) GetConsumerGroup 

func (x *UpdateConsumerGroupRequest) GetConsumerGroup() *ConsumerGroup

func (*UpdateConsumerGroupRequest) GetUpdateMask 

func (x *UpdateConsumerGroupRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateConsumerGroupRequest) ProtoMessage 

func (*UpdateConsumerGroupRequest) ProtoMessage()

func (*UpdateConsumerGroupRequest) ProtoReflect 

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

func (*UpdateConsumerGroupRequest) Reset 

func (x *UpdateConsumerGroupRequest) Reset()

func (*UpdateConsumerGroupRequest) String 

func (x *UpdateConsumerGroupRequest) String() string

type UpdateTopicRequest 

type UpdateTopicRequest struct {

	// Required. Field mask is used to specify the fields to be overwritten in the
	// Topic resource by the update. The fields specified in the update_mask are
	// relative to the resource, not the full request. A field will be overwritten
	// if it is in the mask. The mask is required and a value of * will update all
	// fields.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. The topic to update. Its `name` field must be populated.
	Topic *Topic `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateTopic.

func (*UpdateTopicRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTopicRequest.ProtoReflect.Descriptor instead.

func (*UpdateTopicRequest) GetTopic 

func (x *UpdateTopicRequest) GetTopic() *Topic

func (*UpdateTopicRequest) GetUpdateMask 

func (x *UpdateTopicRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateTopicRequest) ProtoMessage 

func (*UpdateTopicRequest) ProtoMessage()

func (*UpdateTopicRequest) ProtoReflect 

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

func (*UpdateTopicRequest) Reset 

func (x *UpdateTopicRequest) Reset()

func (*UpdateTopicRequest) String 

func (x *UpdateTopicRequest) String() string

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.