Package cloud.google.com/go/managedkafka/apiv1/managedkafkapb (v0.3.1)

Version 0.3.1

• 0.4.0 (latest)
• 0.3.1
• 0.2.3
• 0.1.6

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Variables

Cluster_State_name, Cluster_State_value

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.

RebalanceConfig_Mode_name, RebalanceConfig_Mode_value

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.

File_google_cloud_managedkafka_v1_managed_kafka_proto

var File_google_cloud_managedkafka_v1_managed_kafka_proto protoreflect.FileDescriptor

File_google_cloud_managedkafka_v1_resources_proto

var File_google_cloud_managedkafka_v1_resources_proto protoreflect.FileDescriptor

Functions

func RegisterManagedKafkaServer

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

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

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

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

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

Cluster

type Cluster struct {
	PlatformConfig isCluster_PlatformConfig `protobuf_oneof:"platform_config"`

	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	CapacityConfig *CapacityConfig `protobuf:"bytes,5,opt,name=capacity_config,json=capacityConfig,proto3" json:"capacity_config,omitempty"`

	RebalanceConfig *RebalanceConfig `protobuf:"bytes,8,opt,name=rebalance_config,json=rebalanceConfig,proto3" json:"rebalance_config,omitempty"`

	State Cluster_State `protobuf:"varint,10,opt,name=state,proto3,enum=google.cloud.managedkafka.v1.Cluster_State" json:"state,omitempty"`

	SatisfiesPzi *bool `protobuf:"varint,11,opt,name=satisfies_pzi,json=satisfiesPzi,proto3,oneof" json:"satisfies_pzi,omitempty"`

	SatisfiesPzs *bool `protobuf:"varint,12,opt,name=satisfies_pzs,json=satisfiesPzs,proto3,oneof" json:"satisfies_pzs,omitempty"`

}

An Apache Kafka cluster deployed in a location.

func (*Cluster) Descriptor

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

func (x *Cluster) GetSatisfiesPzi() bool

func (*Cluster) GetSatisfiesPzs

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

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"`
}

Cluster_State

type Cluster_State int32

The state of the cluster.

Cluster_STATE_UNSPECIFIED, Cluster_CREATING, Cluster_ACTIVE, Cluster_DELETING

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

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

ConsumerGroup

type ConsumerGroup struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Topics map[string]*ConsumerTopicMetadata "" /* 153 byte string literal not displayed */

}

A Kafka consumer group in a given cluster.

func (*ConsumerGroup) Descriptor

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

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

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

ConsumerTopicMetadata

type ConsumerTopicMetadata struct {
	Partitions map[int32]*ConsumerPartitionMetadata "" /* 162 byte string literal not displayed */

}

Metadata for a consumer group corresponding to a specific topic.

func (*ConsumerTopicMetadata) Descriptor

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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.

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

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

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

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

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

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

RebalanceConfig_Mode

type RebalanceConfig_Mode int32

The partition rebalance mode for the cluster.

RebalanceConfig_MODE_UNSPECIFIED, RebalanceConfig_NO_REBALANCE, RebalanceConfig_AUTO_REBALANCE_ON_SCALE_UP

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

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

Topic

type Topic struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	PartitionCount int32 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`

	ReplicationFactor int32 `protobuf:"varint,3,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`

	Configs map[string]string "" /* 155 byte string literal not displayed */

}

A Kafka topic in a given cluster.

func (*Topic) Descriptor

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

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)

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

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

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

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

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

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