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

Version latest

• 0.8.1 (latest)
• 0.8.0
• 0.7.0
• 0.6.0
• 0.5.2
• 0.4.2
• 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.

Constants

ManagedKafkaConnect_ListConnectClusters_FullMethodName, ManagedKafkaConnect_GetConnectCluster_FullMethodName, ManagedKafkaConnect_CreateConnectCluster_FullMethodName, ManagedKafkaConnect_UpdateConnectCluster_FullMethodName, ManagedKafkaConnect_DeleteConnectCluster_FullMethodName, ManagedKafkaConnect_ListConnectors_FullMethodName, ManagedKafkaConnect_GetConnector_FullMethodName, ManagedKafkaConnect_CreateConnector_FullMethodName, ManagedKafkaConnect_UpdateConnector_FullMethodName, ManagedKafkaConnect_DeleteConnector_FullMethodName, ManagedKafkaConnect_PauseConnector_FullMethodName, ManagedKafkaConnect_ResumeConnector_FullMethodName, ManagedKafkaConnect_RestartConnector_FullMethodName, ManagedKafkaConnect_StopConnector_FullMethodName

const (
	ManagedKafkaConnect_ListConnectClusters_FullMethodName  = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/ListConnectClusters"
	ManagedKafkaConnect_GetConnectCluster_FullMethodName    = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/GetConnectCluster"
	ManagedKafkaConnect_CreateConnectCluster_FullMethodName = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/CreateConnectCluster"
	ManagedKafkaConnect_UpdateConnectCluster_FullMethodName = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/UpdateConnectCluster"
	ManagedKafkaConnect_DeleteConnectCluster_FullMethodName = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/DeleteConnectCluster"
	ManagedKafkaConnect_ListConnectors_FullMethodName       = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/ListConnectors"
	ManagedKafkaConnect_GetConnector_FullMethodName         = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/GetConnector"
	ManagedKafkaConnect_CreateConnector_FullMethodName      = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/CreateConnector"
	ManagedKafkaConnect_UpdateConnector_FullMethodName      = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/UpdateConnector"
	ManagedKafkaConnect_DeleteConnector_FullMethodName      = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/DeleteConnector"
	ManagedKafkaConnect_PauseConnector_FullMethodName       = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/PauseConnector"
	ManagedKafkaConnect_ResumeConnector_FullMethodName      = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/ResumeConnector"
	ManagedKafkaConnect_RestartConnector_FullMethodName     = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/RestartConnector"
	ManagedKafkaConnect_StopConnector_FullMethodName        = "/google.cloud.managedkafka.v1.ManagedKafkaConnect/StopConnector"
)

ManagedKafka_ListClusters_FullMethodName, ManagedKafka_GetCluster_FullMethodName, ManagedKafka_CreateCluster_FullMethodName, ManagedKafka_UpdateCluster_FullMethodName, ManagedKafka_DeleteCluster_FullMethodName, ManagedKafka_ListTopics_FullMethodName, ManagedKafka_GetTopic_FullMethodName, ManagedKafka_CreateTopic_FullMethodName, ManagedKafka_UpdateTopic_FullMethodName, ManagedKafka_DeleteTopic_FullMethodName, ManagedKafka_ListConsumerGroups_FullMethodName, ManagedKafka_GetConsumerGroup_FullMethodName, ManagedKafka_UpdateConsumerGroup_FullMethodName, ManagedKafka_DeleteConsumerGroup_FullMethodName, ManagedKafka_ListAcls_FullMethodName, ManagedKafka_GetAcl_FullMethodName, ManagedKafka_CreateAcl_FullMethodName, ManagedKafka_UpdateAcl_FullMethodName, ManagedKafka_DeleteAcl_FullMethodName, ManagedKafka_AddAclEntry_FullMethodName, ManagedKafka_RemoveAclEntry_FullMethodName

const (
	ManagedKafka_ListClusters_FullMethodName        = "/google.cloud.managedkafka.v1.ManagedKafka/ListClusters"
	ManagedKafka_GetCluster_FullMethodName          = "/google.cloud.managedkafka.v1.ManagedKafka/GetCluster"
	ManagedKafka_CreateCluster_FullMethodName       = "/google.cloud.managedkafka.v1.ManagedKafka/CreateCluster"
	ManagedKafka_UpdateCluster_FullMethodName       = "/google.cloud.managedkafka.v1.ManagedKafka/UpdateCluster"
	ManagedKafka_DeleteCluster_FullMethodName       = "/google.cloud.managedkafka.v1.ManagedKafka/DeleteCluster"
	ManagedKafka_ListTopics_FullMethodName          = "/google.cloud.managedkafka.v1.ManagedKafka/ListTopics"
	ManagedKafka_GetTopic_FullMethodName            = "/google.cloud.managedkafka.v1.ManagedKafka/GetTopic"
	ManagedKafka_CreateTopic_FullMethodName         = "/google.cloud.managedkafka.v1.ManagedKafka/CreateTopic"
	ManagedKafka_UpdateTopic_FullMethodName         = "/google.cloud.managedkafka.v1.ManagedKafka/UpdateTopic"
	ManagedKafka_DeleteTopic_FullMethodName         = "/google.cloud.managedkafka.v1.ManagedKafka/DeleteTopic"
	ManagedKafka_ListConsumerGroups_FullMethodName  = "/google.cloud.managedkafka.v1.ManagedKafka/ListConsumerGroups"
	ManagedKafka_GetConsumerGroup_FullMethodName    = "/google.cloud.managedkafka.v1.ManagedKafka/GetConsumerGroup"
	ManagedKafka_UpdateConsumerGroup_FullMethodName = "/google.cloud.managedkafka.v1.ManagedKafka/UpdateConsumerGroup"
	ManagedKafka_DeleteConsumerGroup_FullMethodName = "/google.cloud.managedkafka.v1.ManagedKafka/DeleteConsumerGroup"
	ManagedKafka_ListAcls_FullMethodName            = "/google.cloud.managedkafka.v1.ManagedKafka/ListAcls"
	ManagedKafka_GetAcl_FullMethodName              = "/google.cloud.managedkafka.v1.ManagedKafka/GetAcl"
	ManagedKafka_CreateAcl_FullMethodName           = "/google.cloud.managedkafka.v1.ManagedKafka/CreateAcl"
	ManagedKafka_UpdateAcl_FullMethodName           = "/google.cloud.managedkafka.v1.ManagedKafka/UpdateAcl"
	ManagedKafka_DeleteAcl_FullMethodName           = "/google.cloud.managedkafka.v1.ManagedKafka/DeleteAcl"
	ManagedKafka_AddAclEntry_FullMethodName         = "/google.cloud.managedkafka.v1.ManagedKafka/AddAclEntry"
	ManagedKafka_RemoveAclEntry_FullMethodName      = "/google.cloud.managedkafka.v1.ManagedKafka/RemoveAclEntry"
)

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.

ConnectCluster_State_name, ConnectCluster_State_value

var (
	ConnectCluster_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "DELETING",
	}
	ConnectCluster_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"ACTIVE":            2,
		"DELETING":          3,
	}
)

Enum value maps for ConnectCluster_State.

Connector_State_name, Connector_State_value

var (
	Connector_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "UNASSIGNED",
		2: "RUNNING",
		3: "PAUSED",
		4: "FAILED",
		5: "RESTARTING",
		6: "STOPPED",
	}
	Connector_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"UNASSIGNED":        1,
		"RUNNING":           2,
		"PAUSED":            3,
		"FAILED":            4,
		"RESTARTING":        5,
		"STOPPED":           6,
	}
)

Enum value maps for Connector_State.

File_google_cloud_managedkafka_v1_managed_kafka_connect_proto

var File_google_cloud_managedkafka_v1_managed_kafka_connect_proto protoreflect.FileDescriptor

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

ManagedKafkaConnect_ServiceDesc

var ManagedKafkaConnect_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.managedkafka.v1.ManagedKafkaConnect",
	HandlerType: (*ManagedKafkaConnectServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListConnectClusters",
			Handler:    _ManagedKafkaConnect_ListConnectClusters_Handler,
		},
		{
			MethodName: "GetConnectCluster",
			Handler:    _ManagedKafkaConnect_GetConnectCluster_Handler,
		},
		{
			MethodName: "CreateConnectCluster",
			Handler:    _ManagedKafkaConnect_CreateConnectCluster_Handler,
		},
		{
			MethodName: "UpdateConnectCluster",
			Handler:    _ManagedKafkaConnect_UpdateConnectCluster_Handler,
		},
		{
			MethodName: "DeleteConnectCluster",
			Handler:    _ManagedKafkaConnect_DeleteConnectCluster_Handler,
		},
		{
			MethodName: "ListConnectors",
			Handler:    _ManagedKafkaConnect_ListConnectors_Handler,
		},
		{
			MethodName: "GetConnector",
			Handler:    _ManagedKafkaConnect_GetConnector_Handler,
		},
		{
			MethodName: "CreateConnector",
			Handler:    _ManagedKafkaConnect_CreateConnector_Handler,
		},
		{
			MethodName: "UpdateConnector",
			Handler:    _ManagedKafkaConnect_UpdateConnector_Handler,
		},
		{
			MethodName: "DeleteConnector",
			Handler:    _ManagedKafkaConnect_DeleteConnector_Handler,
		},
		{
			MethodName: "PauseConnector",
			Handler:    _ManagedKafkaConnect_PauseConnector_Handler,
		},
		{
			MethodName: "ResumeConnector",
			Handler:    _ManagedKafkaConnect_ResumeConnector_Handler,
		},
		{
			MethodName: "RestartConnector",
			Handler:    _ManagedKafkaConnect_RestartConnector_Handler,
		},
		{
			MethodName: "StopConnector",
			Handler:    _ManagedKafkaConnect_StopConnector_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/managedkafka/v1/managed_kafka_connect.proto",
}

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

ManagedKafka_ServiceDesc

var ManagedKafka_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.managedkafka.v1.ManagedKafka",
	HandlerType: (*ManagedKafkaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListClusters",
			Handler:    _ManagedKafka_ListClusters_Handler,
		},
		{
			MethodName: "GetCluster",
			Handler:    _ManagedKafka_GetCluster_Handler,
		},
		{
			MethodName: "CreateCluster",
			Handler:    _ManagedKafka_CreateCluster_Handler,
		},
		{
			MethodName: "UpdateCluster",
			Handler:    _ManagedKafka_UpdateCluster_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _ManagedKafka_DeleteCluster_Handler,
		},
		{
			MethodName: "ListTopics",
			Handler:    _ManagedKafka_ListTopics_Handler,
		},
		{
			MethodName: "GetTopic",
			Handler:    _ManagedKafka_GetTopic_Handler,
		},
		{
			MethodName: "CreateTopic",
			Handler:    _ManagedKafka_CreateTopic_Handler,
		},
		{
			MethodName: "UpdateTopic",
			Handler:    _ManagedKafka_UpdateTopic_Handler,
		},
		{
			MethodName: "DeleteTopic",
			Handler:    _ManagedKafka_DeleteTopic_Handler,
		},
		{
			MethodName: "ListConsumerGroups",
			Handler:    _ManagedKafka_ListConsumerGroups_Handler,
		},
		{
			MethodName: "GetConsumerGroup",
			Handler:    _ManagedKafka_GetConsumerGroup_Handler,
		},
		{
			MethodName: "UpdateConsumerGroup",
			Handler:    _ManagedKafka_UpdateConsumerGroup_Handler,
		},
		{
			MethodName: "DeleteConsumerGroup",
			Handler:    _ManagedKafka_DeleteConsumerGroup_Handler,
		},
		{
			MethodName: "ListAcls",
			Handler:    _ManagedKafka_ListAcls_Handler,
		},
		{
			MethodName: "GetAcl",
			Handler:    _ManagedKafka_GetAcl_Handler,
		},
		{
			MethodName: "CreateAcl",
			Handler:    _ManagedKafka_CreateAcl_Handler,
		},
		{
			MethodName: "UpdateAcl",
			Handler:    _ManagedKafka_UpdateAcl_Handler,
		},
		{
			MethodName: "DeleteAcl",
			Handler:    _ManagedKafka_DeleteAcl_Handler,
		},
		{
			MethodName: "AddAclEntry",
			Handler:    _ManagedKafka_AddAclEntry_Handler,
		},
		{
			MethodName: "RemoveAclEntry",
			Handler:    _ManagedKafka_RemoveAclEntry_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/managedkafka/v1/managed_kafka.proto",
}

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

Functions

func RegisterManagedKafkaConnectServer

func RegisterManagedKafkaConnectServer(s grpc.ServiceRegistrar, srv ManagedKafkaConnectServer)

func RegisterManagedKafkaServer

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

Acl

type Acl struct {

	// Identifier. The name for the acl. Represents a single Resource Pattern.
	// Structured like:
	// projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}
	//
	// The structure of `acl_id` defines the Resource Pattern (resource_type,
	// resource_name, pattern_type) of the acl. `acl_id` is structured like one of
	// the following:
	//
	// For acls on the cluster:
	//
	//	`cluster`
	//
	// For acls on a single resource within the cluster:
	//
	//	`topic/{resource_name}`
	//	`consumerGroup/{resource_name}`
	//	`transactionalId/{resource_name}`
	//
	// For acls on all resources that match a prefix:
	//
	//	`topicPrefixed/{resource_name}`
	//	`consumerGroupPrefixed/{resource_name}`
	//	`transactionalIdPrefixed/{resource_name}`
	//
	// For acls on all resources of a given type (i.e. the wildcard literal "*"):
	//
	//	`allTopics` (represents `topic/*`)
	//	`allConsumerGroups` (represents `consumerGroup/*`)
	//	`allTransactionalIds` (represents `transactionalId/*`)
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The ACL entries that apply to the resource pattern. The maximum
	// number of allowed entries 100.
	AclEntries []*AclEntry `protobuf:"bytes,2,rep,name=acl_entries,json=aclEntries,proto3" json:"acl_entries,omitempty"`
	// Optional. `etag` is used for concurrency control. An `etag` is returned in
	// the response to `GetAcl` and `CreateAcl`. Callers are required to put that
	// etag in the request to `UpdateAcl` to ensure that their change will be
	// applied to the same version of the acl that exists in the Kafka Cluster.
	//
	// A terminal 'T' character in the etag indicates that the AclEntries were
	// truncated; more entries for the Acl exist on the Kafka Cluster, but can't
	// be returned in the Acl due to repeated field limits.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// Output only. The ACL resource type derived from the name. One of: CLUSTER,
	// TOPIC, GROUP, TRANSACTIONAL_ID.
	ResourceType string `protobuf:"bytes,4,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	// Output only. The ACL resource name derived from the name. For cluster
	// resource_type, this is always "kafka-cluster". Can be the wildcard literal
	// "*".
	ResourceName string `protobuf:"bytes,5,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	// Output only. The ACL pattern type derived from the name. One of: LITERAL,
	// PREFIXED.
	PatternType string `protobuf:"bytes,6,opt,name=pattern_type,json=patternType,proto3" json:"pattern_type,omitempty"`
	// contains filtered or unexported fields
}

Represents the set of ACLs for a given Kafka Resource Pattern, which consists of resource_type, resource_name and pattern_type.

func (*Acl) Descriptor

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

Deprecated: Use Acl.ProtoReflect.Descriptor instead.

func (*Acl) GetAclEntries

func (x *Acl) GetAclEntries() []*AclEntry

func (*Acl) GetEtag

func (x *Acl) GetEtag() string

func (*Acl) GetName

func (x *Acl) GetName() string

func (*Acl) GetPatternType

func (x *Acl) GetPatternType() string

func (*Acl) GetResourceName

func (x *Acl) GetResourceName() string

func (*Acl) GetResourceType

func (x *Acl) GetResourceType() string

func (*Acl) ProtoMessage

func (*Acl) ProtoMessage()

func (*Acl) ProtoReflect

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

func (*Acl) Reset

func (x *Acl) Reset()

func (*Acl) String

func (x *Acl) String() string

AclEntry

type AclEntry struct {

	// Required. The principal. Specified as Google Cloud account, with the Kafka
	// StandardAuthorizer prefix "User:". For example:
	// "User:[e-mail]".
	// Can be the wildcard "User:*" to refer to all users.
	Principal string `protobuf:"bytes,4,opt,name=principal,proto3" json:"principal,omitempty"`
	// Required. The permission type. Accepted values are (case insensitive):
	// ALLOW, DENY.
	PermissionType string `protobuf:"bytes,5,opt,name=permission_type,json=permissionType,proto3" json:"permission_type,omitempty"`
	// Required. The operation type. Allowed values are (case insensitive): ALL,
	// READ, WRITE, CREATE, DELETE, ALTER, DESCRIBE, CLUSTER_ACTION,
	// DESCRIBE_CONFIGS, ALTER_CONFIGS, and IDEMPOTENT_WRITE. See
	// https://kafka.apache.org/documentation/#operations_resources_and_protocols
	// for valid combinations of resource_type and operation for different Kafka
	// API requests.
	Operation string `protobuf:"bytes,6,opt,name=operation,proto3" json:"operation,omitempty"`
	// Required. The host. Must be set to "*" for Managed Service for Apache
	// Kafka.
	Host string `protobuf:"bytes,7,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

Represents the access granted for a given Resource Pattern in an ACL.

func (*AclEntry) Descriptor

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

Deprecated: Use AclEntry.ProtoReflect.Descriptor instead.

func (*AclEntry) GetHost

func (x *AclEntry) GetHost() string

func (*AclEntry) GetOperation

func (x *AclEntry) GetOperation() string

func (*AclEntry) GetPermissionType

func (x *AclEntry) GetPermissionType() string

func (*AclEntry) GetPrincipal

func (x *AclEntry) GetPrincipal() string

func (*AclEntry) ProtoMessage

func (*AclEntry) ProtoMessage()

func (*AclEntry) ProtoReflect

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

func (*AclEntry) Reset

func (x *AclEntry) Reset()

func (*AclEntry) String

func (x *AclEntry) String() string

AddAclEntryRequest

type AddAclEntryRequest struct {

	// Required. The name of the acl to add the acl entry to.
	// Structured like:
	// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`.
	//
	// The structure of `acl_id` defines the Resource Pattern (resource_type,
	// resource_name, pattern_type) of the acl. See `Acl.name` for
	// details.
	Acl string `protobuf:"bytes,1,opt,name=acl,proto3" json:"acl,omitempty"`
	// Required. The acl entry to add.
	AclEntry *AclEntry `protobuf:"bytes,2,opt,name=acl_entry,json=aclEntry,proto3" json:"acl_entry,omitempty"`
	// contains filtered or unexported fields
}

Request for AddAclEntry.

func (*AddAclEntryRequest) Descriptor

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

Deprecated: Use AddAclEntryRequest.ProtoReflect.Descriptor instead.

func (*AddAclEntryRequest) GetAcl

func (x *AddAclEntryRequest) GetAcl() string

func (*AddAclEntryRequest) GetAclEntry

func (x *AddAclEntryRequest) GetAclEntry() *AclEntry

func (*AddAclEntryRequest) ProtoMessage

func (*AddAclEntryRequest) ProtoMessage()

func (*AddAclEntryRequest) ProtoReflect

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

func (*AddAclEntryRequest) Reset

func (x *AddAclEntryRequest) Reset()

func (*AddAclEntryRequest) String

func (x *AddAclEntryRequest) String() string

AddAclEntryResponse

type AddAclEntryResponse struct {

	// The updated acl.
	Acl *Acl `protobuf:"bytes,1,opt,name=acl,proto3" json:"acl,omitempty"`
	// Whether the acl was created as a result of adding the acl entry.
	AclCreated bool `protobuf:"varint,2,opt,name=acl_created,json=aclCreated,proto3" json:"acl_created,omitempty"`
	// contains filtered or unexported fields
}

Response for AddAclEntry.

func (*AddAclEntryResponse) Descriptor

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

Deprecated: Use AddAclEntryResponse.ProtoReflect.Descriptor instead.

func (*AddAclEntryResponse) GetAcl

func (x *AddAclEntryResponse) GetAcl() *Acl

func (*AddAclEntryResponse) GetAclCreated

func (x *AddAclEntryResponse) GetAclCreated() bool

func (*AddAclEntryResponse) ProtoMessage

func (*AddAclEntryResponse) ProtoMessage()

func (*AddAclEntryResponse) ProtoReflect

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

func (*AddAclEntryResponse) Reset

func (x *AddAclEntryResponse) Reset()

func (*AddAclEntryResponse) String

func (x *AddAclEntryResponse) 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 {

	// 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 `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// 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"`
	// Optional. TLS configuration for the Kafka cluster.
	TlsConfig *TlsConfig `protobuf:"bytes,13,opt,name=tls_config,json=tlsConfig,proto3" json:"tls_config,omitempty"`
	// contains filtered or unexported fields
}

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) GetTlsConfig

func (x *Cluster) GetTlsConfig() *TlsConfig

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

ConnectAccessConfig

type ConnectAccessConfig struct {

	// Required.
	// Virtual Private Cloud (VPC) networks that must be granted direct access to
	// the Kafka Connect cluster. Minimum of 1 network is required. Maximum 10
	// networks can be specified.
	NetworkConfigs []*ConnectNetworkConfig `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 Connect cluster.

func (*ConnectAccessConfig) Descriptor

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

Deprecated: Use ConnectAccessConfig.ProtoReflect.Descriptor instead.

func (*ConnectAccessConfig) GetNetworkConfigs

func (x *ConnectAccessConfig) GetNetworkConfigs() []*ConnectNetworkConfig

func (*ConnectAccessConfig) ProtoMessage

func (*ConnectAccessConfig) ProtoMessage()

func (*ConnectAccessConfig) ProtoReflect

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

func (*ConnectAccessConfig) Reset

func (x *ConnectAccessConfig) Reset()

func (*ConnectAccessConfig) String

func (x *ConnectAccessConfig) String() string

ConnectCluster

type ConnectCluster struct {

	// Platform specific configuration properties for a Kafka Connect cluster.
	//
	// Types that are assignable to PlatformConfig:
	//
	//	*ConnectCluster_GcpConfig
	PlatformConfig isConnectCluster_PlatformConfig `protobuf_oneof:"platform_config"`
	// Identifier. The name of the Kafka Connect cluster. Structured like:
	// projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Immutable. The name of the Kafka cluster this Kafka Connect
	// cluster is attached to. Structured like:
	// projects/{project}/locations/{location}/clusters/{cluster}
	KafkaCluster string `protobuf:"bytes,2,opt,name=kafka_cluster,json=kafkaCluster,proto3" json:"kafka_cluster,omitempty"`
	// Output only. The time when the cluster was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,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,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Labels as key value pairs.
	Labels map[string]string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Required. Capacity configuration for the Kafka Connect cluster.
	CapacityConfig *CapacityConfig `protobuf:"bytes,6,opt,name=capacity_config,json=capacityConfig,proto3" json:"capacity_config,omitempty"`
	// Output only. The current state of the cluster.
	State ConnectCluster_State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.managedkafka.v1.ConnectCluster_State" json:"state,omitempty"`
	// Optional. Configurations for the worker that are overridden from the
	// defaults. The key of the map is a Kafka Connect worker property name, for
	// example: `exactly.once.source.support`.
	Config map[string]string `protobuf:"bytes,9,rep,name=config,proto3" json:"config,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

An Apache Kafka Connect cluster deployed in a location.

func (*ConnectCluster) Descriptor

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

Deprecated: Use ConnectCluster.ProtoReflect.Descriptor instead.

func (*ConnectCluster) GetCapacityConfig

func (x *ConnectCluster) GetCapacityConfig() *CapacityConfig

func (*ConnectCluster) GetConfig

func (x *ConnectCluster) GetConfig() map[string]string

func (*ConnectCluster) GetCreateTime

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

func (*ConnectCluster) GetGcpConfig

func (x *ConnectCluster) GetGcpConfig() *ConnectGcpConfig

func (*ConnectCluster) GetKafkaCluster

func (x *ConnectCluster) GetKafkaCluster() string

func (*ConnectCluster) GetLabels

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

func (*ConnectCluster) GetName

func (x *ConnectCluster) GetName() string

func (*ConnectCluster) GetPlatformConfig

func (m *ConnectCluster) GetPlatformConfig() isConnectCluster_PlatformConfig

func (*ConnectCluster) GetState

func (x *ConnectCluster) GetState() ConnectCluster_State

func (*ConnectCluster) GetUpdateTime

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

func (*ConnectCluster) ProtoMessage

func (*ConnectCluster) ProtoMessage()

func (*ConnectCluster) ProtoReflect

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

func (*ConnectCluster) Reset

func (x *ConnectCluster) Reset()

func (*ConnectCluster) String

func (x *ConnectCluster) String() string

ConnectCluster_GcpConfig

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

ConnectCluster_State

type ConnectCluster_State int32

The state of the cluster.

ConnectCluster_STATE_UNSPECIFIED, ConnectCluster_CREATING, ConnectCluster_ACTIVE, ConnectCluster_DELETING

const (
	// A state was not specified.
	ConnectCluster_STATE_UNSPECIFIED ConnectCluster_State = 0
	// The cluster is being created.
	ConnectCluster_CREATING ConnectCluster_State = 1
	// The cluster is active.
	ConnectCluster_ACTIVE ConnectCluster_State = 2
	// The cluster is being deleted.
	ConnectCluster_DELETING ConnectCluster_State = 3
)

func (ConnectCluster_State) Descriptor

func (ConnectCluster_State) Descriptor() protoreflect.EnumDescriptor

func (ConnectCluster_State) Enum

func (x ConnectCluster_State) Enum() *ConnectCluster_State

func (ConnectCluster_State) EnumDescriptor

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

Deprecated: Use ConnectCluster_State.Descriptor instead.

func (ConnectCluster_State) Number

func (x ConnectCluster_State) Number() protoreflect.EnumNumber

func (ConnectCluster_State) String

func (x ConnectCluster_State) String() string

func (ConnectCluster_State) Type

func (ConnectCluster_State) Type() protoreflect.EnumType

ConnectGcpConfig

type ConnectGcpConfig struct {

	// Required. Access configuration for the Kafka Connect cluster.
	AccessConfig *ConnectAccessConfig `protobuf:"bytes,1,opt,name=access_config,json=accessConfig,proto3" json:"access_config,omitempty"`
	// Optional. Secrets to load into workers. Exact SecretVersions from Secret
	// Manager must be provided -- aliases are not supported. Up to 32 secrets may
	// be loaded into one cluster. Format:
	// projects/

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

func (*ConnectGcpConfig) Descriptor

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

Deprecated: Use ConnectGcpConfig.ProtoReflect.Descriptor instead.

func (*ConnectGcpConfig) GetAccessConfig

func (x *ConnectGcpConfig) GetAccessConfig() *ConnectAccessConfig

func (*ConnectGcpConfig) GetSecretPaths

func (x *ConnectGcpConfig) GetSecretPaths() []string

func (*ConnectGcpConfig) ProtoMessage

func (*ConnectGcpConfig) ProtoMessage()

func (*ConnectGcpConfig) ProtoReflect

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

func (*ConnectGcpConfig) Reset

func (x *ConnectGcpConfig) Reset()

func (*ConnectGcpConfig) String

func (x *ConnectGcpConfig) String() string

ConnectNetworkConfig

type ConnectNetworkConfig struct {

	// Required. VPC subnet to make available to the Kafka Connect cluster.
	// Structured like:
	// projects/{project}/regions/{region}/subnetworks/{subnet_id}
	//
	// It is used to create a Private Service Connect (PSC) interface for the
	// Kafka Connect workers. It must be located in the same region as the
	// Kafka Connect cluster.
	//
	// The CIDR range of the subnet must be within the IPv4 address ranges for
	// private networks, as specified in RFC 1918. The primary subnet CIDR range
	// must have a minimum size of /22 (1024 addresses).
	PrimarySubnet string `protobuf:"bytes,3,opt,name=primary_subnet,json=primarySubnet,proto3" json:"primary_subnet,omitempty"`
	// Optional. Additional subnets may be specified. They may be in another
	// region, but must be in the same VPC network. The Connect workers can
	// communicate with network endpoints in either the primary or additional
	// subnets.
	AdditionalSubnets []string `protobuf:"bytes,4,rep,name=additional_subnets,json=additionalSubnets,proto3" json:"additional_subnets,omitempty"`
	// Optional. Additional DNS domain names from the subnet's network to be made
	// visible to the Connect Cluster. When using MirrorMaker2, it's necessary to
	// add the bootstrap address's dns domain name of the target cluster to make
	// it visible to the connector. For example:
	// my-kafka-cluster.us-central1.managedkafka.my-project.cloud.goog
	DnsDomainNames []string `protobuf:"bytes,2,rep,name=dns_domain_names,json=dnsDomainNames,proto3" json:"dns_domain_names,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ConnectNetworkConfig) Descriptor

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

Deprecated: Use ConnectNetworkConfig.ProtoReflect.Descriptor instead.

func (*ConnectNetworkConfig) GetAdditionalSubnets

func (x *ConnectNetworkConfig) GetAdditionalSubnets() []string

func (*ConnectNetworkConfig) GetDnsDomainNames

func (x *ConnectNetworkConfig) GetDnsDomainNames() []string

func (*ConnectNetworkConfig) GetPrimarySubnet

func (x *ConnectNetworkConfig) GetPrimarySubnet() string

func (*ConnectNetworkConfig) ProtoMessage

func (*ConnectNetworkConfig) ProtoMessage()

func (*ConnectNetworkConfig) ProtoReflect

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

func (*ConnectNetworkConfig) Reset

func (x *ConnectNetworkConfig) Reset()

func (*ConnectNetworkConfig) String

func (x *ConnectNetworkConfig) String() string

Connector

type Connector struct {

	// A policy that specifies how to restart the failed connectors/tasks in a
	// Cluster resource. If not set, the failed connectors/tasks won't be
	// restarted.
	//
	// Types that are assignable to RestartPolicy:
	//
	//	*Connector_TaskRestartPolicy
	RestartPolicy isConnector_RestartPolicy `protobuf_oneof:"restart_policy"`
	// Identifier. The name of the connector.
	// Structured like:
	// projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. Connector config as keys/values.
	// The keys of the map are connector property names, for example:
	// `connector.class`, `tasks.max`, `key.converter`.
	Configs map[string]string `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Output only. The current state of the connector.
	State Connector_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.managedkafka.v1.Connector_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

A Kafka Connect connector in a given ConnectCluster.

func (*Connector) Descriptor

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

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetConfigs

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

func (*Connector) GetName

func (x *Connector) GetName() string

func (*Connector) GetRestartPolicy

func (m *Connector) GetRestartPolicy() isConnector_RestartPolicy

func (*Connector) GetState

func (x *Connector) GetState() Connector_State

func (*Connector) GetTaskRestartPolicy

func (x *Connector) GetTaskRestartPolicy() *TaskRetryPolicy

func (*Connector) ProtoMessage

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect

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

func (*Connector) Reset

func (x *Connector) Reset()

func (*Connector) String

func (x *Connector) String() string

Connector_State

type Connector_State int32

The state of the connector.

Connector_STATE_UNSPECIFIED, Connector_UNASSIGNED, Connector_RUNNING, Connector_PAUSED, Connector_FAILED, Connector_RESTARTING, Connector_STOPPED

const (
	// A state was not specified.
	Connector_STATE_UNSPECIFIED Connector_State = 0
	// The connector is not assigned to any tasks, usually transient.
	Connector_UNASSIGNED Connector_State = 1
	// The connector is running.
	Connector_RUNNING Connector_State = 2
	// The connector has been paused.
	Connector_PAUSED Connector_State = 3
	// The connector has failed. See logs for why.
	Connector_FAILED Connector_State = 4
	// The connector is restarting.
	Connector_RESTARTING Connector_State = 5
	// The connector has been stopped.
	Connector_STOPPED Connector_State = 6
)

func (Connector_State) Descriptor

func (Connector_State) Descriptor() protoreflect.EnumDescriptor

func (Connector_State) Enum

func (x Connector_State) Enum() *Connector_State

func (Connector_State) EnumDescriptor

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

Deprecated: Use Connector_State.Descriptor instead.

func (Connector_State) Number

func (x Connector_State) Number() protoreflect.EnumNumber

func (Connector_State) String

func (x Connector_State) String() string

func (Connector_State) Type

func (Connector_State) Type() protoreflect.EnumType

Connector_TaskRestartPolicy

type Connector_TaskRestartPolicy struct {
	// Optional. Restarts the individual tasks of a Connector.
	TaskRestartPolicy *TaskRetryPolicy `protobuf:"bytes,4,opt,name=task_restart_policy,json=taskRestartPolicy,proto3,oneof"`
}

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 `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

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 {

	// Optional. Metadata for this consumer group and topic for all partition
	// indexes it has metadata for.
	Partitions map[int32]*ConsumerPartitionMetadata `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

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

CreateAclRequest

type CreateAclRequest struct {

	// Required. The parent cluster in which to create the acl.
	// 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 acl, which will become the final component
	// of the acl's name. The structure of `acl_id` defines the Resource Pattern
	// (resource_type, resource_name, pattern_type) of the acl. `acl_id` is
	// structured like one of the following:
	//
	// For acls on the cluster:
	//
	//	`cluster`
	//
	// For acls on a single resource within the cluster:
	//
	//	`topic/{resource_name}`
	//	`consumerGroup/{resource_name}`
	//	`transactionalId/{resource_name}`
	//
	// For acls on all resources that match a prefix:
	//
	//	`topicPrefixed/{resource_name}`
	//	`consumerGroupPrefixed/{resource_name}`
	//	`transactionalIdPrefixed/{resource_name}`
	//
	// For acls on all resources of a given type (i.e. the wildcard literal "*"):
	//
	//	`allTopics` (represents `topic/*`)
	//	`allConsumerGroups` (represents `consumerGroup/*`)
	//	`allTransactionalIds` (represents `transactionalId/*`)
	AclId string `protobuf:"bytes,2,opt,name=acl_id,json=aclId,proto3" json:"acl_id,omitempty"`
	// Required. Configuration of the acl to create. Its `name` field is ignored.
	Acl *Acl `protobuf:"bytes,3,opt,name=acl,proto3" json:"acl,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateAcl.

func (*CreateAclRequest) Descriptor

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

Deprecated: Use CreateAclRequest.ProtoReflect.Descriptor instead.

func (*CreateAclRequest) GetAcl

func (x *CreateAclRequest) GetAcl() *Acl

func (*CreateAclRequest) GetAclId

func (x *CreateAclRequest) GetAclId() string

func (*CreateAclRequest) GetParent

func (x *CreateAclRequest) GetParent() string

func (*CreateAclRequest) ProtoMessage

func (*CreateAclRequest) ProtoMessage()

func (*CreateAclRequest) ProtoReflect

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

func (*CreateAclRequest) Reset

func (x *CreateAclRequest) Reset()

func (*CreateAclRequest) String

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

CreateConnectClusterRequest

type CreateConnectClusterRequest struct {

	// Required. The parent project/location in which to create the Kafka Connect
	// 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 Connect 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`.
	ConnectClusterId string `protobuf:"bytes,2,opt,name=connect_cluster_id,json=connectClusterId,proto3" json:"connect_cluster_id,omitempty"`
	// Required. Configuration of the Kafka Connect cluster to create. Its `name`
	// field is ignored.
	ConnectCluster *ConnectCluster `protobuf:"bytes,3,opt,name=connect_cluster,json=connectCluster,proto3" json:"connect_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 CreateConnectCluster.

func (*CreateConnectClusterRequest) Descriptor

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

Deprecated: Use CreateConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectClusterRequest) GetConnectCluster

func (x *CreateConnectClusterRequest) GetConnectCluster() *ConnectCluster

func (*CreateConnectClusterRequest) GetConnectClusterId

func (x *CreateConnectClusterRequest) GetConnectClusterId() string

func (*CreateConnectClusterRequest) GetParent

func (x *CreateConnectClusterRequest) GetParent() string

func (*CreateConnectClusterRequest) GetRequestId

func (x *CreateConnectClusterRequest) GetRequestId() string

func (*CreateConnectClusterRequest) ProtoMessage

func (*CreateConnectClusterRequest) ProtoMessage()

func (*CreateConnectClusterRequest) ProtoReflect

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

func (*CreateConnectClusterRequest) Reset

func (x *CreateConnectClusterRequest) Reset()

func (*CreateConnectClusterRequest) String

func (x *CreateConnectClusterRequest) String() string

CreateConnectorRequest

type CreateConnectorRequest struct {

	// Required. The parent Connect cluster in which to create the connector.
	// Structured like
	// `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The ID to use for the connector, which will become the final
	// component of the connector'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-connector-id`.
	ConnectorId string `protobuf:"bytes,2,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// Required. The connector to create.
	Connector *Connector `protobuf:"bytes,3,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateConnector.

func (*CreateConnectorRequest) Descriptor

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

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetConnector

func (x *CreateConnectorRequest) GetConnector() *Connector

func (*CreateConnectorRequest) GetConnectorId

func (x *CreateConnectorRequest) GetConnectorId() string

func (*CreateConnectorRequest) GetParent

func (x *CreateConnectorRequest) GetParent() string

func (*CreateConnectorRequest) ProtoMessage

func (*CreateConnectorRequest) ProtoMessage()

func (*CreateConnectorRequest) ProtoReflect

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

func (*CreateConnectorRequest) Reset

func (x *CreateConnectorRequest) Reset()

func (*CreateConnectorRequest) String

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

DeleteAclRequest

type DeleteAclRequest struct {

	// Required. The name of the acl to delete.
	// Structured like:
	// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`.
	//
	// The structure of `acl_id` defines the Resource Pattern (resource_type,
	// resource_name, pattern_type) of the acl. See `Acl.name` for details.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteAcl.

func (*DeleteAclRequest) Descriptor

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

Deprecated: Use DeleteAclRequest.ProtoReflect.Descriptor instead.

func (*DeleteAclRequest) GetName

func (x *DeleteAclRequest) GetName() string

func (*DeleteAclRequest) ProtoMessage

func (*DeleteAclRequest) ProtoMessage()

func (*DeleteAclRequest) ProtoReflect

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

func (*DeleteAclRequest) Reset

func (x *DeleteAclRequest) Reset()

func (*DeleteAclRequest) String

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

DeleteConnectClusterRequest

type DeleteConnectClusterRequest struct {

	// Required. The name of the Kafka Connect cluster to delete.
	// Structured like
	// `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`.
	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 DeleteConnectCluster.

func (*DeleteConnectClusterRequest) Descriptor

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

Deprecated: Use DeleteConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectClusterRequest) GetName

func (x *DeleteConnectClusterRequest) GetName() string

func (*DeleteConnectClusterRequest) GetRequestId

func (x *DeleteConnectClusterRequest) GetRequestId() string

func (*DeleteConnectClusterRequest) ProtoMessage

func (*DeleteConnectClusterRequest) ProtoMessage()

func (*DeleteConnectClusterRequest) ProtoReflect

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

func (*DeleteConnectClusterRequest) Reset

func (x *DeleteConnectClusterRequest) Reset()

func (*DeleteConnectClusterRequest) String

func (x *DeleteConnectClusterRequest) String() string

DeleteConnectorRequest

type DeleteConnectorRequest struct {

	// Required. The name of the connector to delete.
	// Structured like:
	// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteConnector.

func (*DeleteConnectorRequest) Descriptor

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

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetName

func (x *DeleteConnectorRequest) GetName() string

func (*DeleteConnectorRequest) ProtoMessage

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect

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

func (*DeleteConnectorRequest) Reset

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) String

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

GetAclRequest

type GetAclRequest struct {

	// Required. The name of the acl to return.
	// Structured like:
	// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`.
	//
	// The structure of `acl_id` defines the Resource Pattern (resource_type,
	// resource_name, pattern_type) of the acl. See `Acl.name` for
	// details.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetAcl.

func (*GetAclRequest) Descriptor

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

Deprecated: Use GetAclRequest.ProtoReflect.Descriptor instead.

func (*GetAclRequest) GetName

func (x *GetAclRequest) GetName() string

func (*GetAclRequest) ProtoMessage

func (*GetAclRequest) ProtoMessage()

func (*GetAclRequest) ProtoReflect

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

func (*GetAclRequest) Reset

func (x *GetAclRequest) Reset()

func (*GetAclRequest) String

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

GetConnectClusterRequest

type GetConnectClusterRequest struct {

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

Request for GetConnectCluster.

func (*GetConnectClusterRequest) Descriptor

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

Deprecated: Use GetConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*GetConnectClusterRequest) GetName

func (x *GetConnectClusterRequest) GetName() string

func (*GetConnectClusterRequest) ProtoMessage

func (*GetConnectClusterRequest) ProtoMessage()

func (*GetConnectClusterRequest) ProtoReflect

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

func (*GetConnectClusterRequest) Reset

func (x *GetConnectClusterRequest) Reset()

func (*GetConnectClusterRequest) String

func (x *GetConnectClusterRequest) String() string

GetConnectorRequest

type GetConnectorRequest struct {

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

Request for GetConnector.

func (*GetConnectorRequest) Descriptor

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

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetName

func (x *GetConnectorRequest) GetName() string

func (*GetConnectorRequest) ProtoMessage

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect

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

func (*GetConnectorRequest) Reset

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) String

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

ListAclsRequest

type ListAclsRequest struct {

	// Required. The parent cluster whose acls 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 acls to return. The service may return
	// fewer than this value. If unset or zero, all acls 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 `ListAcls` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListAcls` 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 ListAcls.

func (*ListAclsRequest) Descriptor

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

Deprecated: Use ListAclsRequest.ProtoReflect.Descriptor instead.

func (*ListAclsRequest) GetPageSize

func (x *ListAclsRequest) GetPageSize() int32

func (*ListAclsRequest) GetPageToken

func (x *ListAclsRequest) GetPageToken() string

func (*ListAclsRequest) GetParent

func (x *ListAclsRequest) GetParent() string

func (*ListAclsRequest) ProtoMessage

func (*ListAclsRequest) ProtoMessage()

func (*ListAclsRequest) ProtoReflect

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

func (*ListAclsRequest) Reset

func (x *ListAclsRequest) Reset()

func (*ListAclsRequest) String

func (x *ListAclsRequest) String() string

ListAclsResponse

type ListAclsResponse struct {

	// The list of acls in the requested parent. The order of the acls is
	// unspecified.
	Acls []*Acl `protobuf:"bytes,1,rep,name=acls,proto3" json:"acls,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 ListAcls.

func (*ListAclsResponse) Descriptor

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

Deprecated: Use ListAclsResponse.ProtoReflect.Descriptor instead.

func (*ListAclsResponse) GetAcls

func (x *ListAclsResponse) GetAcls() []*Acl

func (*ListAclsResponse) GetNextPageToken

func (x *ListAclsResponse) GetNextPageToken() string

func (*ListAclsResponse) ProtoMessage

func (*ListAclsResponse) ProtoMessage()

func (*ListAclsResponse) ProtoReflect

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

func (*ListAclsResponse) Reset

func (x *ListAclsResponse) Reset()

func (*ListAclsResponse) String

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

ListConnectClustersRequest

type ListConnectClustersRequest struct {

	// Required. The parent project/location whose Connect 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 Connect 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 `ListConnectClusters`
	// call. Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListConnectClusters`
	// 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 ListConnectClusters.

func (*ListConnectClustersRequest) Descriptor

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

Deprecated: Use ListConnectClustersRequest.ProtoReflect.Descriptor instead.

func (*ListConnectClustersRequest) GetFilter

func (x *ListConnectClustersRequest) GetFilter() string

func (*ListConnectClustersRequest) GetOrderBy

func (x *ListConnectClustersRequest) GetOrderBy() string

func (*ListConnectClustersRequest) GetPageSize

func (x *ListConnectClustersRequest) GetPageSize() int32

func (*ListConnectClustersRequest) GetPageToken

func (x *ListConnectClustersRequest) GetPageToken() string

func (*ListConnectClustersRequest) GetParent

func (x *ListConnectClustersRequest) GetParent() string

func (*ListConnectClustersRequest) ProtoMessage

func (*ListConnectClustersRequest) ProtoMessage()

func (*ListConnectClustersRequest) ProtoReflect

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

func (*ListConnectClustersRequest) Reset

func (x *ListConnectClustersRequest) Reset()

func (*ListConnectClustersRequest) String

func (x *ListConnectClustersRequest) String() string

ListConnectClustersResponse

type ListConnectClustersResponse struct {

	// The list of Connect clusters in the requested parent.
	ConnectClusters []*ConnectCluster `protobuf:"bytes,1,rep,name=connect_clusters,json=connectClusters,proto3" json:"connect_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 ListConnectClusters.

func (*ListConnectClustersResponse) Descriptor

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

Deprecated: Use ListConnectClustersResponse.ProtoReflect.Descriptor instead.

func (*ListConnectClustersResponse) GetConnectClusters

func (x *ListConnectClustersResponse) GetConnectClusters() []*ConnectCluster

func (*ListConnectClustersResponse) GetNextPageToken

func (x *ListConnectClustersResponse) GetNextPageToken() string

func (*ListConnectClustersResponse) GetUnreachable

func (x *ListConnectClustersResponse) GetUnreachable() []string

func (*ListConnectClustersResponse) ProtoMessage

func (*ListConnectClustersResponse) ProtoMessage()

func (*ListConnectClustersResponse) ProtoReflect

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

func (*ListConnectClustersResponse) Reset

func (x *ListConnectClustersResponse) Reset()

func (*ListConnectClustersResponse) String

func (x *ListConnectClustersResponse) String() string

ListConnectorsRequest

type ListConnectorsRequest struct {

	// Required. The parent Connect cluster whose connectors are to be listed.
	// Structured like
	// `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of connectors 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 `ListConnectors` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListConnectors`
	// 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 ListConnectors.

func (*ListConnectorsRequest) Descriptor

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

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) GetPageSize

func (x *ListConnectorsRequest) GetPageSize() int32

func (*ListConnectorsRequest) GetPageToken

func (x *ListConnectorsRequest) GetPageToken() string

func (*ListConnectorsRequest) GetParent

func (x *ListConnectorsRequest) GetParent() string

func (*ListConnectorsRequest) ProtoMessage

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect

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

func (*ListConnectorsRequest) Reset

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) String

func (x *ListConnectorsRequest) String() string

ListConnectorsResponse

type ListConnectorsResponse struct {

	// The list of connectors in the requested parent.
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,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 ListConnectors.

func (*ListConnectorsResponse) Descriptor

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

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors

func (x *ListConnectorsResponse) GetConnectors() []*Connector

func (*ListConnectorsResponse) GetNextPageToken

func (x *ListConnectorsResponse) GetNextPageToken() string

func (*ListConnectorsResponse) ProtoMessage

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect

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

func (*ListConnectorsResponse) Reset

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String

func (x *ListConnectorsResponse) 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)
	// Lists the acls in a given cluster.
	ListAcls(ctx context.Context, in *ListAclsRequest, opts ...grpc.CallOption) (*ListAclsResponse, error)
	// Returns the properties of a single acl.
	GetAcl(ctx context.Context, in *GetAclRequest, opts ...grpc.CallOption) (*Acl, error)
	// Creates a new acl in the given project, location, and cluster.
	CreateAcl(ctx context.Context, in *CreateAclRequest, opts ...grpc.CallOption) (*Acl, error)
	// Updates the properties of a single acl.
	UpdateAcl(ctx context.Context, in *UpdateAclRequest, opts ...grpc.CallOption) (*Acl, error)
	// Deletes an acl.
	DeleteAcl(ctx context.Context, in *DeleteAclRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Incremental update: Adds an acl entry to an acl. Creates the acl if it does
	// not exist yet.
	AddAclEntry(ctx context.Context, in *AddAclEntryRequest, opts ...grpc.CallOption) (*AddAclEntryResponse, error)
	// Incremental update: Removes an acl entry from an acl. Deletes the acl if
	// its acl entries become empty (i.e. if the removed entry was the last one in
	// the acl).
	RemoveAclEntry(ctx context.Context, in *RemoveAclEntryRequest, opts ...grpc.CallOption) (*RemoveAclEntryResponse, error)
}

ManagedKafkaClient is the client API for ManagedKafka service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewManagedKafkaClient

func NewManagedKafkaClient(cc grpc.ClientConnInterface) ManagedKafkaClient

ManagedKafkaConnectClient

type ManagedKafkaConnectClient interface {
	// Lists the Kafka Connect clusters in a given project and location.
	ListConnectClusters(ctx context.Context, in *ListConnectClustersRequest, opts ...grpc.CallOption) (*ListConnectClustersResponse, error)
	// Returns the properties of a single Kafka Connect cluster.
	GetConnectCluster(ctx context.Context, in *GetConnectClusterRequest, opts ...grpc.CallOption) (*ConnectCluster, error)
	// Creates a new Kafka Connect cluster in a given project and location.
	CreateConnectCluster(ctx context.Context, in *CreateConnectClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates the properties of a single Kafka Connect cluster.
	UpdateConnectCluster(ctx context.Context, in *UpdateConnectClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Deletes a single Connect cluster.
	DeleteConnectCluster(ctx context.Context, in *DeleteConnectClusterRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Lists the connectors in a given Connect cluster.
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	// Returns the properties of a single connector.
	GetConnector(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	// Creates a new connector in a given Connect cluster.
	CreateConnector(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	// Updates the properties of a connector.
	UpdateConnector(ctx context.Context, in *UpdateConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	// Deletes a connector.
	DeleteConnector(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Pauses the connector and its tasks.
	PauseConnector(ctx context.Context, in *PauseConnectorRequest, opts ...grpc.CallOption) (*PauseConnectorResponse, error)
	// Resumes the connector and its tasks.
	ResumeConnector(ctx context.Context, in *ResumeConnectorRequest, opts ...grpc.CallOption) (*ResumeConnectorResponse, error)
	// Restarts the connector.
	RestartConnector(ctx context.Context, in *RestartConnectorRequest, opts ...grpc.CallOption) (*RestartConnectorResponse, error)
	// Stops the connector.
	StopConnector(ctx context.Context, in *StopConnectorRequest, opts ...grpc.CallOption) (*StopConnectorResponse, error)
}

ManagedKafkaConnectClient is the client API for ManagedKafkaConnect service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewManagedKafkaConnectClient

func NewManagedKafkaConnectClient(cc grpc.ClientConnInterface) ManagedKafkaConnectClient

ManagedKafkaConnectServer

type ManagedKafkaConnectServer interface {
	// Lists the Kafka Connect clusters in a given project and location.
	ListConnectClusters(context.Context, *ListConnectClustersRequest) (*ListConnectClustersResponse, error)
	// Returns the properties of a single Kafka Connect cluster.
	GetConnectCluster(context.Context, *GetConnectClusterRequest) (*ConnectCluster, error)
	// Creates a new Kafka Connect cluster in a given project and location.
	CreateConnectCluster(context.Context, *CreateConnectClusterRequest) (*longrunningpb.Operation, error)
	// Updates the properties of a single Kafka Connect cluster.
	UpdateConnectCluster(context.Context, *UpdateConnectClusterRequest) (*longrunningpb.Operation, error)
	// Deletes a single Connect cluster.
	DeleteConnectCluster(context.Context, *DeleteConnectClusterRequest) (*longrunningpb.Operation, error)
	// Lists the connectors in a given Connect cluster.
	ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	// Returns the properties of a single connector.
	GetConnector(context.Context, *GetConnectorRequest) (*Connector, error)
	// Creates a new connector in a given Connect cluster.
	CreateConnector(context.Context, *CreateConnectorRequest) (*Connector, error)
	// Updates the properties of a connector.
	UpdateConnector(context.Context, *UpdateConnectorRequest) (*Connector, error)
	// Deletes a connector.
	DeleteConnector(context.Context, *DeleteConnectorRequest) (*emptypb.Empty, error)
	// Pauses the connector and its tasks.
	PauseConnector(context.Context, *PauseConnectorRequest) (*PauseConnectorResponse, error)
	// Resumes the connector and its tasks.
	ResumeConnector(context.Context, *ResumeConnectorRequest) (*ResumeConnectorResponse, error)
	// Restarts the connector.
	RestartConnector(context.Context, *RestartConnectorRequest) (*RestartConnectorResponse, error)
	// Stops the connector.
	StopConnector(context.Context, *StopConnectorRequest) (*StopConnectorResponse, error)
}

ManagedKafkaConnectServer is the server API for ManagedKafkaConnect service. All implementations should embed UnimplementedManagedKafkaConnectServer for forward compatibility

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)
	// Lists the acls in a given cluster.
	ListAcls(context.Context, *ListAclsRequest) (*ListAclsResponse, error)
	// Returns the properties of a single acl.
	GetAcl(context.Context, *GetAclRequest) (*Acl, error)
	// Creates a new acl in the given project, location, and cluster.
	CreateAcl(context.Context, *CreateAclRequest) (*Acl, error)
	// Updates the properties of a single acl.
	UpdateAcl(context.Context, *UpdateAclRequest) (*Acl, error)
	// Deletes an acl.
	DeleteAcl(context.Context, *DeleteAclRequest) (*emptypb.Empty, error)
	// Incremental update: Adds an acl entry to an acl. Creates the acl if it does
	// not exist yet.
	AddAclEntry(context.Context, *AddAclEntryRequest) (*AddAclEntryResponse, error)
	// Incremental update: Removes an acl entry from an acl. Deletes the acl if
	// its acl entries become empty (i.e. if the removed entry was the last one in
	// the acl).
	RemoveAclEntry(context.Context, *RemoveAclEntryRequest) (*RemoveAclEntryResponse, error)
}

ManagedKafkaServer is the server API for ManagedKafka service. All implementations should embed UnimplementedManagedKafkaServer for forward compatibility

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

PauseConnectorRequest

type PauseConnectorRequest struct {

	// Required. The name of the connector to pause.
	// Structured like:
	// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for PauseConnector.

func (*PauseConnectorRequest) Descriptor

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

Deprecated: Use PauseConnectorRequest.ProtoReflect.Descriptor instead.

func (*PauseConnectorRequest) GetName

func (x *PauseConnectorRequest) GetName() string

func (*PauseConnectorRequest) ProtoMessage

func (*PauseConnectorRequest) ProtoMessage()

func (*PauseConnectorRequest) ProtoReflect

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

func (*PauseConnectorRequest) Reset

func (x *PauseConnectorRequest) Reset()

func (*PauseConnectorRequest) String

func (x *PauseConnectorRequest) String() string

PauseConnectorResponse

type PauseConnectorResponse struct {
	// contains filtered or unexported fields
}

Response for PauseConnector.

func (*PauseConnectorResponse) Descriptor

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

Deprecated: Use PauseConnectorResponse.ProtoReflect.Descriptor instead.

func (*PauseConnectorResponse) ProtoMessage

func (*PauseConnectorResponse) ProtoMessage()

func (*PauseConnectorResponse) ProtoReflect

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

func (*PauseConnectorResponse) Reset

func (x *PauseConnectorResponse) Reset()

func (*PauseConnectorResponse) String

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

RemoveAclEntryRequest

type RemoveAclEntryRequest struct {

	// Required. The name of the acl to remove the acl entry from.
	// Structured like:
	// `projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`.
	//
	// The structure of `acl_id` defines the Resource Pattern (resource_type,
	// resource_name, pattern_type) of the acl. See `Acl.name` for
	// details.
	Acl string `protobuf:"bytes,1,opt,name=acl,proto3" json:"acl,omitempty"`
	// Required. The acl entry to remove.
	AclEntry *AclEntry `protobuf:"bytes,2,opt,name=acl_entry,json=aclEntry,proto3" json:"acl_entry,omitempty"`
	// contains filtered or unexported fields
}

Request for RemoveAclEntry.

func (*RemoveAclEntryRequest) Descriptor

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

Deprecated: Use RemoveAclEntryRequest.ProtoReflect.Descriptor instead.

func (*RemoveAclEntryRequest) GetAcl

func (x *RemoveAclEntryRequest) GetAcl() string

func (*RemoveAclEntryRequest) GetAclEntry

func (x *RemoveAclEntryRequest) GetAclEntry() *AclEntry

func (*RemoveAclEntryRequest) ProtoMessage

func (*RemoveAclEntryRequest) ProtoMessage()

func (*RemoveAclEntryRequest) ProtoReflect

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

func (*RemoveAclEntryRequest) Reset

func (x *RemoveAclEntryRequest) Reset()

func (*RemoveAclEntryRequest) String

func (x *RemoveAclEntryRequest) String() string

RemoveAclEntryResponse

type RemoveAclEntryResponse struct {

	// The result of removing the acl entry, depending on whether the acl was
	// deleted as a result of removing the acl entry.
	//
	// Types that are assignable to Result:
	//
	//	*RemoveAclEntryResponse_Acl
	//	*RemoveAclEntryResponse_AclDeleted
	Result isRemoveAclEntryResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

Response for RemoveAclEntry.

func (*RemoveAclEntryResponse) Descriptor

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

Deprecated: Use RemoveAclEntryResponse.ProtoReflect.Descriptor instead.

func (*RemoveAclEntryResponse) GetAcl

func (x *RemoveAclEntryResponse) GetAcl() *Acl

func (*RemoveAclEntryResponse) GetAclDeleted

func (x *RemoveAclEntryResponse) GetAclDeleted() bool

func (*RemoveAclEntryResponse) GetResult

func (m *RemoveAclEntryResponse) GetResult() isRemoveAclEntryResponse_Result

func (*RemoveAclEntryResponse) ProtoMessage

func (*RemoveAclEntryResponse) ProtoMessage()

func (*RemoveAclEntryResponse) ProtoReflect

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

func (*RemoveAclEntryResponse) Reset

func (x *RemoveAclEntryResponse) Reset()

func (*RemoveAclEntryResponse) String

func (x *RemoveAclEntryResponse) String() string

RemoveAclEntryResponse_Acl

type RemoveAclEntryResponse_Acl struct {
	// The updated acl. Returned if the removed acl entry was not the last entry
	// in the acl.
	Acl *Acl `protobuf:"bytes,1,opt,name=acl,proto3,oneof"`
}

RemoveAclEntryResponse_AclDeleted

type RemoveAclEntryResponse_AclDeleted struct {
	// Returned with value true if the removed acl entry was the last entry in
	// the acl, resulting in acl deletion.
	AclDeleted bool `protobuf:"varint,2,opt,name=acl_deleted,json=aclDeleted,proto3,oneof"`
}

RestartConnectorRequest

type RestartConnectorRequest struct {

	// Required. The name of the connector to restart.
	// Structured like:
	// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for RestartConnector.

func (*RestartConnectorRequest) Descriptor

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

Deprecated: Use RestartConnectorRequest.ProtoReflect.Descriptor instead.

func (*RestartConnectorRequest) GetName

func (x *RestartConnectorRequest) GetName() string

func (*RestartConnectorRequest) ProtoMessage

func (*RestartConnectorRequest) ProtoMessage()

func (*RestartConnectorRequest) ProtoReflect

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

func (*RestartConnectorRequest) Reset

func (x *RestartConnectorRequest) Reset()

func (*RestartConnectorRequest) String

func (x *RestartConnectorRequest) String() string

RestartConnectorResponse

type RestartConnectorResponse struct {
	// contains filtered or unexported fields
}

Response for RestartConnector.

func (*RestartConnectorResponse) Descriptor

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

Deprecated: Use RestartConnectorResponse.ProtoReflect.Descriptor instead.

func (*RestartConnectorResponse) ProtoMessage

func (*RestartConnectorResponse) ProtoMessage()

func (*RestartConnectorResponse) ProtoReflect

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

func (*RestartConnectorResponse) Reset

func (x *RestartConnectorResponse) Reset()

func (*RestartConnectorResponse) String

func (x *RestartConnectorResponse) String() string

ResumeConnectorRequest

type ResumeConnectorRequest struct {

	// Required. The name of the connector to pause.
	// Structured like:
	// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for ResumeConnector.

func (*ResumeConnectorRequest) Descriptor

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

Deprecated: Use ResumeConnectorRequest.ProtoReflect.Descriptor instead.

func (*ResumeConnectorRequest) GetName

func (x *ResumeConnectorRequest) GetName() string

func (*ResumeConnectorRequest) ProtoMessage

func (*ResumeConnectorRequest) ProtoMessage()

func (*ResumeConnectorRequest) ProtoReflect

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

func (*ResumeConnectorRequest) Reset

func (x *ResumeConnectorRequest) Reset()

func (*ResumeConnectorRequest) String

func (x *ResumeConnectorRequest) String() string

ResumeConnectorResponse

type ResumeConnectorResponse struct {
	// contains filtered or unexported fields
}

Response for ResumeConnector.

func (*ResumeConnectorResponse) Descriptor

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

Deprecated: Use ResumeConnectorResponse.ProtoReflect.Descriptor instead.

func (*ResumeConnectorResponse) ProtoMessage

func (*ResumeConnectorResponse) ProtoMessage()

func (*ResumeConnectorResponse) ProtoReflect

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

func (*ResumeConnectorResponse) Reset

func (x *ResumeConnectorResponse) Reset()

func (*ResumeConnectorResponse) String

func (x *ResumeConnectorResponse) String() string

StopConnectorRequest

type StopConnectorRequest struct {

	// Required. The name of the connector to stop.
	// Structured like:
	// projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for StopConnector.

func (*StopConnectorRequest) Descriptor

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

Deprecated: Use StopConnectorRequest.ProtoReflect.Descriptor instead.

func (*StopConnectorRequest) GetName

func (x *StopConnectorRequest) GetName() string

func (*StopConnectorRequest) ProtoMessage

func (*StopConnectorRequest) ProtoMessage()

func (*StopConnectorRequest) ProtoReflect

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

func (*StopConnectorRequest) Reset

func (x *StopConnectorRequest) Reset()

func (*StopConnectorRequest) String

func (x *StopConnectorRequest) String() string

StopConnectorResponse

type StopConnectorResponse struct {
	// contains filtered or unexported fields
}

Response for StopConnector.

func (*StopConnectorResponse) Descriptor

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

Deprecated: Use StopConnectorResponse.ProtoReflect.Descriptor instead.

func (*StopConnectorResponse) ProtoMessage

func (*StopConnectorResponse) ProtoMessage()

func (*StopConnectorResponse) ProtoReflect

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

func (*StopConnectorResponse) Reset

func (x *StopConnectorResponse) Reset()

func (*StopConnectorResponse) String

func (x *StopConnectorResponse) String() string

TaskRetryPolicy

type TaskRetryPolicy struct {

	// Optional. The minimum amount of time to wait before retrying a failed task.
	// This sets a lower bound for the backoff delay.
	MinimumBackoff *durationpb.Duration `protobuf:"bytes,1,opt,name=minimum_backoff,json=minimumBackoff,proto3" json:"minimum_backoff,omitempty"`
	// Optional. The maximum amount of time to wait before retrying a failed task.
	// This sets an upper bound for the backoff delay.
	MaximumBackoff *durationpb.Duration `protobuf:"bytes,2,opt,name=maximum_backoff,json=maximumBackoff,proto3" json:"maximum_backoff,omitempty"`
	// contains filtered or unexported fields
}

Task Retry Policy is implemented on a best-effort basis. Retry delay will be exponential based on provided minimum and maximum backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. Note that the delay between consecutive task restarts may not always precisely match the configured settings. This can happen when the ConnectCluster is in rebalancing state or if the ConnectCluster is unresponsive etc. The default values for minimum and maximum backoffs are 60 seconds and 30 minutes respectively.

func (*TaskRetryPolicy) Descriptor

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

Deprecated: Use TaskRetryPolicy.ProtoReflect.Descriptor instead.

func (*TaskRetryPolicy) GetMaximumBackoff

func (x *TaskRetryPolicy) GetMaximumBackoff() *durationpb.Duration

func (*TaskRetryPolicy) GetMinimumBackoff

func (x *TaskRetryPolicy) GetMinimumBackoff() *durationpb.Duration

func (*TaskRetryPolicy) ProtoMessage

func (*TaskRetryPolicy) ProtoMessage()

func (*TaskRetryPolicy) ProtoReflect

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

func (*TaskRetryPolicy) Reset

func (x *TaskRetryPolicy) Reset()

func (*TaskRetryPolicy) String

func (x *TaskRetryPolicy) String() string

TlsConfig

type TlsConfig struct {

	// Optional. The configuration of the broker truststore. If specified, clients
	// can use mTLS for authentication.
	TrustConfig *TrustConfig `protobuf:"bytes,1,opt,name=trust_config,json=trustConfig,proto3" json:"trust_config,omitempty"`
	// Optional. A list of rules for mapping from SSL principal names to
	// short names. These are applied in order by Kafka.
	// Refer to the Apache Kafka documentation for `ssl.principal.mapping.rules`
	// for the precise formatting details and syntax.
	// Example: "RULE:^CN=(.*?),OU=ServiceUsers.*$/$[e-mail]/,DEFAULT"
	//
	// This is a static Kafka broker configuration. Setting or modifying this
	// field will trigger a rolling restart of the Kafka brokers to apply
	// the change. An empty string means no rules are applied (Kafka default).
	SslPrincipalMappingRules string `protobuf:"bytes,2,opt,name=ssl_principal_mapping_rules,json=sslPrincipalMappingRules,proto3" json:"ssl_principal_mapping_rules,omitempty"`
	// contains filtered or unexported fields
}

The TLS configuration for the Kafka cluster.

func (*TlsConfig) Descriptor

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

Deprecated: Use TlsConfig.ProtoReflect.Descriptor instead.

func (*TlsConfig) GetSslPrincipalMappingRules

func (x *TlsConfig) GetSslPrincipalMappingRules() string

func (*TlsConfig) GetTrustConfig

func (x *TlsConfig) GetTrustConfig() *TrustConfig

func (*TlsConfig) ProtoMessage

func (*TlsConfig) ProtoMessage()

func (*TlsConfig) ProtoReflect

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

func (*TlsConfig) Reset

func (x *TlsConfig) Reset()

func (*TlsConfig) String

func (x *TlsConfig) String() string

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 `protobuf:"bytes,4,rep,name=configs,proto3" json:"configs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

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

TrustConfig

type TrustConfig struct {

	// Optional. Configuration for the Google Certificate Authority Service.
	// Maximum 10.
	CasConfigs []*TrustConfig_CertificateAuthorityServiceConfig `protobuf:"bytes,1,rep,name=cas_configs,json=casConfigs,proto3" json:"cas_configs,omitempty"`
	// contains filtered or unexported fields
}

Sources of CA certificates to install in the broker's truststore.

func (*TrustConfig) Descriptor

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

Deprecated: Use TrustConfig.ProtoReflect.Descriptor instead.

func (*TrustConfig) GetCasConfigs

func (x *TrustConfig) GetCasConfigs() []*TrustConfig_CertificateAuthorityServiceConfig

func (*TrustConfig) ProtoMessage

func (*TrustConfig) ProtoMessage()

func (*TrustConfig) ProtoReflect

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

func (*TrustConfig) Reset

func (x *TrustConfig) Reset()

func (*TrustConfig) String

func (x *TrustConfig) String() string

TrustConfig_CertificateAuthorityServiceConfig

type TrustConfig_CertificateAuthorityServiceConfig struct {

	// Required. The name of the CA pool to pull CA certificates from.
	// Structured like:
	// projects/{project}/locations/{location}/caPools/{ca_pool}.
	// The CA pool does not need to be in the same project or location as the
	// Kafka cluster.
	CaPool string `protobuf:"bytes,1,opt,name=ca_pool,json=caPool,proto3" json:"ca_pool,omitempty"`
	// contains filtered or unexported fields
}

A configuration for the Google Certificate Authority Service.

func (*TrustConfig_CertificateAuthorityServiceConfig) Descriptor

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

Deprecated: Use TrustConfig_CertificateAuthorityServiceConfig.ProtoReflect.Descriptor instead.

func (*TrustConfig_CertificateAuthorityServiceConfig) GetCaPool

func (x *TrustConfig_CertificateAuthorityServiceConfig) GetCaPool() string

func (*TrustConfig_CertificateAuthorityServiceConfig) ProtoMessage

func (*TrustConfig_CertificateAuthorityServiceConfig) ProtoMessage()

func (*TrustConfig_CertificateAuthorityServiceConfig) ProtoReflect

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

func (*TrustConfig_CertificateAuthorityServiceConfig) Reset

func (x *TrustConfig_CertificateAuthorityServiceConfig) Reset()

func (*TrustConfig_CertificateAuthorityServiceConfig) String

func (x *TrustConfig_CertificateAuthorityServiceConfig) String() string

UnimplementedManagedKafkaConnectServer

type UnimplementedManagedKafkaConnectServer struct {
}

UnimplementedManagedKafkaConnectServer should be embedded to have forward compatible implementations.

func (UnimplementedManagedKafkaConnectServer) CreateConnectCluster

func (UnimplementedManagedKafkaConnectServer) CreateConnectCluster(context.Context, *CreateConnectClusterRequest) (*longrunningpb.Operation, error)

func (UnimplementedManagedKafkaConnectServer) CreateConnector

func (UnimplementedManagedKafkaConnectServer) CreateConnector(context.Context, *CreateConnectorRequest) (*Connector, error)

func (UnimplementedManagedKafkaConnectServer) DeleteConnectCluster

func (UnimplementedManagedKafkaConnectServer) DeleteConnectCluster(context.Context, *DeleteConnectClusterRequest) (*longrunningpb.Operation, error)

func (UnimplementedManagedKafkaConnectServer) DeleteConnector

func (UnimplementedManagedKafkaConnectServer) DeleteConnector(context.Context, *DeleteConnectorRequest) (*emptypb.Empty, error)

func (UnimplementedManagedKafkaConnectServer) GetConnectCluster

func (UnimplementedManagedKafkaConnectServer) GetConnectCluster(context.Context, *GetConnectClusterRequest) (*ConnectCluster, error)

func (UnimplementedManagedKafkaConnectServer) GetConnector

func (UnimplementedManagedKafkaConnectServer) GetConnector(context.Context, *GetConnectorRequest) (*Connector, error)

func (UnimplementedManagedKafkaConnectServer) ListConnectClusters

func (UnimplementedManagedKafkaConnectServer) ListConnectClusters(context.Context, *ListConnectClustersRequest) (*ListConnectClustersResponse, error)

func (UnimplementedManagedKafkaConnectServer) ListConnectors

func (UnimplementedManagedKafkaConnectServer) ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

func (UnimplementedManagedKafkaConnectServer) PauseConnector

func (UnimplementedManagedKafkaConnectServer) PauseConnector(context.Context, *PauseConnectorRequest) (*PauseConnectorResponse, error)

func (UnimplementedManagedKafkaConnectServer) RestartConnector

func (UnimplementedManagedKafkaConnectServer) RestartConnector(context.Context, *RestartConnectorRequest) (*RestartConnectorResponse, error)

func (UnimplementedManagedKafkaConnectServer) ResumeConnector

func (UnimplementedManagedKafkaConnectServer) ResumeConnector(context.Context, *ResumeConnectorRequest) (*ResumeConnectorResponse, error)

func (UnimplementedManagedKafkaConnectServer) StopConnector

func (UnimplementedManagedKafkaConnectServer) StopConnector(context.Context, *StopConnectorRequest) (*StopConnectorResponse, error)

func (UnimplementedManagedKafkaConnectServer) UpdateConnectCluster

func (UnimplementedManagedKafkaConnectServer) UpdateConnectCluster(context.Context, *UpdateConnectClusterRequest) (*longrunningpb.Operation, error)

func (UnimplementedManagedKafkaConnectServer) UpdateConnector

func (UnimplementedManagedKafkaConnectServer) UpdateConnector(context.Context, *UpdateConnectorRequest) (*Connector, error)

UnimplementedManagedKafkaServer

type UnimplementedManagedKafkaServer struct {
}

UnimplementedManagedKafkaServer should be embedded to have forward compatible implementations.

func (UnimplementedManagedKafkaServer) AddAclEntry

func (UnimplementedManagedKafkaServer) AddAclEntry(context.Context, *AddAclEntryRequest) (*AddAclEntryResponse, error)

func (UnimplementedManagedKafkaServer) CreateAcl

func (UnimplementedManagedKafkaServer) CreateAcl(context.Context, *CreateAclRequest) (*Acl, error)

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) DeleteAcl

func (UnimplementedManagedKafkaServer) DeleteAcl(context.Context, *DeleteAclRequest) (*emptypb.Empty, 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) GetAcl

func (UnimplementedManagedKafkaServer) GetAcl(context.Context, *GetAclRequest) (*Acl, 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) ListAcls

func (UnimplementedManagedKafkaServer) ListAcls(context.Context, *ListAclsRequest) (*ListAclsResponse, 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) RemoveAclEntry

func (UnimplementedManagedKafkaServer) RemoveAclEntry(context.Context, *RemoveAclEntryRequest) (*RemoveAclEntryResponse, error)

func (UnimplementedManagedKafkaServer) UpdateAcl

func (UnimplementedManagedKafkaServer) UpdateAcl(context.Context, *UpdateAclRequest) (*Acl, 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)

UnsafeManagedKafkaConnectServer

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

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

UnsafeManagedKafkaServer

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

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

UpdateAclRequest

type UpdateAclRequest struct {

	// Required. The updated acl. Its `name` and `etag` fields must be populated.
	// `acl_entries` must not be empty in the updated acl; to remove all acl
	// entries for an acl, use DeleteAcl.
	Acl *Acl `protobuf:"bytes,1,opt,name=acl,proto3" json:"acl,omitempty"`
	// Optional. Field mask is used to specify the fields to be overwritten in the
	// Acl 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.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateAcl.

func (*UpdateAclRequest) Descriptor

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

Deprecated: Use UpdateAclRequest.ProtoReflect.Descriptor instead.

func (*UpdateAclRequest) GetAcl

func (x *UpdateAclRequest) GetAcl() *Acl

func (*UpdateAclRequest) GetUpdateMask

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

func (*UpdateAclRequest) ProtoMessage

func (*UpdateAclRequest) ProtoMessage()

func (*UpdateAclRequest) ProtoReflect

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

func (*UpdateAclRequest) Reset

func (x *UpdateAclRequest) Reset()

func (*UpdateAclRequest) String

func (x *UpdateAclRequest) String() string

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

UpdateConnectClusterRequest

type UpdateConnectClusterRequest 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 Kafka Connect cluster to update. Its `name` field must be
	// populated.
	ConnectCluster *ConnectCluster `protobuf:"bytes,2,opt,name=connect_cluster,json=connectCluster,proto3" json:"connect_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 UpdateConnectCluster.

func (*UpdateConnectClusterRequest) Descriptor

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

Deprecated: Use UpdateConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectClusterRequest) GetConnectCluster

func (x *UpdateConnectClusterRequest) GetConnectCluster() *ConnectCluster

func (*UpdateConnectClusterRequest) GetRequestId

func (x *UpdateConnectClusterRequest) GetRequestId() string

func (*UpdateConnectClusterRequest) GetUpdateMask

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

func (*UpdateConnectClusterRequest) ProtoMessage

func (*UpdateConnectClusterRequest) ProtoMessage()

func (*UpdateConnectClusterRequest) ProtoReflect

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

func (*UpdateConnectClusterRequest) Reset

func (x *UpdateConnectClusterRequest) Reset()

func (*UpdateConnectClusterRequest) String

func (x *UpdateConnectClusterRequest) String() string

UpdateConnectorRequest

type UpdateConnectorRequest 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 connector to update. Its `name` field must be populated.
	Connector *Connector `protobuf:"bytes,2,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateConnector.

func (*UpdateConnectorRequest) Descriptor

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

Deprecated: Use UpdateConnectorRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectorRequest) GetConnector

func (x *UpdateConnectorRequest) GetConnector() *Connector

func (*UpdateConnectorRequest) GetUpdateMask

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

func (*UpdateConnectorRequest) ProtoMessage

func (*UpdateConnectorRequest) ProtoMessage()

func (*UpdateConnectorRequest) ProtoReflect

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

func (*UpdateConnectorRequest) Reset

func (x *UpdateConnectorRequest) Reset()

func (*UpdateConnectorRequest) String

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