managedkafkapb

package
v0.8.1 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2025 License: Apache-2.0 Imports: 14 Imported by: 6

Documentation

Index

Constants

View Source 
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"
)
View Source 
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

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

Enum value maps for Cluster_State.

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

Enum value maps for RebalanceConfig_Mode.

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

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

View Source 
var File_google_cloud_managedkafka_v1_managed_kafka_connect_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_managedkafka_v1_managed_kafka_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_managedkafka_v1_resources_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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 added in v0.5.0 

func RegisterManagedKafkaConnectServer(s grpc.ServiceRegistrar, srv ManagedKafkaConnectServer)

func RegisterManagedKafkaServer 

func RegisterManagedKafkaServer(s grpc.ServiceRegistrar, srv ManagedKafkaServer)

Types

type AccessConfig 

type AccessConfig struct {

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

The configuration of access to the Kafka cluster.

func (*AccessConfig) Descriptor deprecated 

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

Deprecated: Use AccessConfig.ProtoReflect.Descriptor instead.

func (*AccessConfig) GetNetworkConfigs 

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

func (*AccessConfig) ProtoMessage 

func (*AccessConfig) ProtoMessage()

func (*AccessConfig) ProtoReflect 

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

func (*AccessConfig) Reset 

func (x *AccessConfig) Reset()

func (*AccessConfig) String 

func (x *AccessConfig) String() string

type Acl added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use Acl.ProtoReflect.Descriptor instead.

func (*Acl) GetAclEntries added in v0.6.0 

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

func (*Acl) GetEtag added in v0.6.0 

func (x *Acl) GetEtag() string

func (*Acl) GetName added in v0.6.0 

func (x *Acl) GetName() string

func (*Acl) GetPatternType added in v0.6.0 

func (x *Acl) GetPatternType() string

func (*Acl) GetResourceName added in v0.6.0 

func (x *Acl) GetResourceName() string

func (*Acl) GetResourceType added in v0.6.0 

func (x *Acl) GetResourceType() string

func (*Acl) ProtoMessage added in v0.6.0 

func (*Acl) ProtoMessage()

func (*Acl) ProtoReflect added in v0.6.0 

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

func (*Acl) Reset added in v0.6.0 

func (x *Acl) Reset()

func (*Acl) String added in v0.6.0 

func (x *Acl) String() string

type AclEntry added in v0.6.0 

type AclEntry struct {

	// Required. The principal. Specified as Google Cloud account, with the Kafka
	// StandardAuthorizer prefix "User:". For example:
	// "User:test-kafka-client@test-project.iam.gserviceaccount.com".
	// 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 deprecated added in v0.6.0 

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

Deprecated: Use AclEntry.ProtoReflect.Descriptor instead.

func (*AclEntry) GetHost added in v0.6.0 

func (x *AclEntry) GetHost() string

func (*AclEntry) GetOperation added in v0.6.0 

func (x *AclEntry) GetOperation() string

func (*AclEntry) GetPermissionType added in v0.6.0 

func (x *AclEntry) GetPermissionType() string

func (*AclEntry) GetPrincipal added in v0.6.0 

func (x *AclEntry) GetPrincipal() string

func (*AclEntry) ProtoMessage added in v0.6.0 

func (*AclEntry) ProtoMessage()

func (*AclEntry) ProtoReflect added in v0.6.0 

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

func (*AclEntry) Reset added in v0.6.0 

func (x *AclEntry) Reset()

func (*AclEntry) String added in v0.6.0 

func (x *AclEntry) String() string

type AddAclEntryRequest added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use AddAclEntryRequest.ProtoReflect.Descriptor instead.

func (*AddAclEntryRequest) GetAcl added in v0.6.0 

func (x *AddAclEntryRequest) GetAcl() string

func (*AddAclEntryRequest) GetAclEntry added in v0.6.0 

func (x *AddAclEntryRequest) GetAclEntry() *AclEntry

func (*AddAclEntryRequest) ProtoMessage added in v0.6.0 

func (*AddAclEntryRequest) ProtoMessage()

func (*AddAclEntryRequest) ProtoReflect added in v0.6.0 

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

func (*AddAclEntryRequest) Reset added in v0.6.0 

func (x *AddAclEntryRequest) Reset()

func (*AddAclEntryRequest) String added in v0.6.0 

func (x *AddAclEntryRequest) String() string

type AddAclEntryResponse added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use AddAclEntryResponse.ProtoReflect.Descriptor instead.

func (*AddAclEntryResponse) GetAcl added in v0.6.0 

func (x *AddAclEntryResponse) GetAcl() *Acl

func (*AddAclEntryResponse) GetAclCreated added in v0.6.0 

func (x *AddAclEntryResponse) GetAclCreated() bool

func (*AddAclEntryResponse) ProtoMessage added in v0.6.0 

func (*AddAclEntryResponse) ProtoMessage()

func (*AddAclEntryResponse) ProtoReflect added in v0.6.0 

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

func (*AddAclEntryResponse) Reset added in v0.6.0 

func (x *AddAclEntryResponse) Reset()

func (*AddAclEntryResponse) String added in v0.6.0 

func (x *AddAclEntryResponse) String() string

type CapacityConfig 

type CapacityConfig struct {

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

A capacity configuration of a Kafka cluster.

func (*CapacityConfig) Descriptor deprecated 

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

Deprecated: Use CapacityConfig.ProtoReflect.Descriptor instead.

func (*CapacityConfig) GetMemoryBytes 

func (x *CapacityConfig) GetMemoryBytes() int64

func (*CapacityConfig) GetVcpuCount 

func (x *CapacityConfig) GetVcpuCount() int64

func (*CapacityConfig) ProtoMessage 

func (*CapacityConfig) ProtoMessage()

func (*CapacityConfig) ProtoReflect 

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

func (*CapacityConfig) Reset 

func (x *CapacityConfig) Reset()

func (*CapacityConfig) String 

func (x *CapacityConfig) String() string

type Cluster 

type Cluster struct {

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

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetCapacityConfig 

func (x *Cluster) GetCapacityConfig() *CapacityConfig

func (*Cluster) GetCreateTime 

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

func (*Cluster) GetGcpConfig 

func (x *Cluster) GetGcpConfig() *GcpConfig

func (*Cluster) GetLabels 

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

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetPlatformConfig 

func (m *Cluster) GetPlatformConfig() isCluster_PlatformConfig

func (*Cluster) GetRebalanceConfig 

func (x *Cluster) GetRebalanceConfig() *RebalanceConfig

func (*Cluster) GetSatisfiesPzi added in v0.3.0 

func (x *Cluster) GetSatisfiesPzi() bool

func (*Cluster) GetSatisfiesPzs added in v0.3.0 

func (x *Cluster) GetSatisfiesPzs() bool

func (*Cluster) GetState 

func (x *Cluster) GetState() Cluster_State

func (*Cluster) GetTlsConfig added in v0.7.0 

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

type Cluster_GcpConfig 

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

type Cluster_State 

type Cluster_State int32

The state of the cluster. 

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

func (Cluster_State) Descriptor 

func (Cluster_State) Descriptor() protoreflect.EnumDescriptor

func (Cluster_State) Enum 

func (x Cluster_State) Enum() *Cluster_State

func (Cluster_State) EnumDescriptor deprecated 

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

Deprecated: Use Cluster_State.Descriptor instead.

func (Cluster_State) Number 

func (x Cluster_State) Number() protoreflect.EnumNumber

func (Cluster_State) String 

func (x Cluster_State) String() string

func (Cluster_State) Type 

func (Cluster_State) Type() protoreflect.EnumType

type ConnectAccessConfig added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use ConnectAccessConfig.ProtoReflect.Descriptor instead.

func (*ConnectAccessConfig) GetNetworkConfigs added in v0.5.0 

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

func (*ConnectAccessConfig) ProtoMessage added in v0.5.0 

func (*ConnectAccessConfig) ProtoMessage()

func (*ConnectAccessConfig) ProtoReflect added in v0.5.0 

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

func (*ConnectAccessConfig) Reset added in v0.5.0 

func (x *ConnectAccessConfig) Reset()

func (*ConnectAccessConfig) String added in v0.5.0 

func (x *ConnectAccessConfig) String() string

type ConnectCluster added in v0.5.0 

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 `` /* 153-byte string literal not displayed */
	// 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 `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

An Apache Kafka Connect cluster deployed in a location.

func (*ConnectCluster) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use ConnectCluster.ProtoReflect.Descriptor instead.

func (*ConnectCluster) GetCapacityConfig added in v0.5.0 

func (x *ConnectCluster) GetCapacityConfig() *CapacityConfig

func (*ConnectCluster) GetConfig added in v0.5.0 

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

func (*ConnectCluster) GetCreateTime added in v0.5.0 

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

func (*ConnectCluster) GetGcpConfig added in v0.5.0 

func (x *ConnectCluster) GetGcpConfig() *ConnectGcpConfig

func (*ConnectCluster) GetKafkaCluster added in v0.5.0 

func (x *ConnectCluster) GetKafkaCluster() string

func (*ConnectCluster) GetLabels added in v0.5.0 

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

func (*ConnectCluster) GetName added in v0.5.0 

func (x *ConnectCluster) GetName() string

func (*ConnectCluster) GetPlatformConfig added in v0.5.0 

func (m *ConnectCluster) GetPlatformConfig() isConnectCluster_PlatformConfig

func (*ConnectCluster) GetState added in v0.5.0 

func (x *ConnectCluster) GetState() ConnectCluster_State

func (*ConnectCluster) GetUpdateTime added in v0.5.0 

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

func (*ConnectCluster) ProtoMessage added in v0.5.0 

func (*ConnectCluster) ProtoMessage()

func (*ConnectCluster) ProtoReflect added in v0.5.0 

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

func (*ConnectCluster) Reset added in v0.5.0 

func (x *ConnectCluster) Reset()

func (*ConnectCluster) String added in v0.5.0 

func (x *ConnectCluster) String() string

type ConnectCluster_GcpConfig added in v0.5.0 

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

type ConnectCluster_State added in v0.5.0 

type ConnectCluster_State int32

The state of the cluster. 

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 added in v0.5.0 

func (ConnectCluster_State) Descriptor() protoreflect.EnumDescriptor

func (ConnectCluster_State) Enum added in v0.5.0 

func (x ConnectCluster_State) Enum() *ConnectCluster_State

func (ConnectCluster_State) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use ConnectCluster_State.Descriptor instead.

func (ConnectCluster_State) Number added in v0.5.0 

func (x ConnectCluster_State) Number() protoreflect.EnumNumber

func (ConnectCluster_State) String added in v0.5.0 

func (x ConnectCluster_State) String() string

func (ConnectCluster_State) Type added in v0.5.0 

func (ConnectCluster_State) Type() protoreflect.EnumType

type ConnectGcpConfig added in v0.5.0 

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/<project-id>/secrets/<secret-name>/versions/<version-id>
	SecretPaths []string `protobuf:"bytes,2,rep,name=secret_paths,json=secretPaths,proto3" json:"secret_paths,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ConnectGcpConfig) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use ConnectGcpConfig.ProtoReflect.Descriptor instead.

func (*ConnectGcpConfig) GetAccessConfig added in v0.5.0 

func (x *ConnectGcpConfig) GetAccessConfig() *ConnectAccessConfig

func (*ConnectGcpConfig) GetSecretPaths added in v0.5.0 

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

func (*ConnectGcpConfig) ProtoMessage added in v0.5.0 

func (*ConnectGcpConfig) ProtoMessage()

func (*ConnectGcpConfig) ProtoReflect added in v0.5.0 

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

func (*ConnectGcpConfig) Reset added in v0.5.0 

func (x *ConnectGcpConfig) Reset()

func (*ConnectGcpConfig) String added in v0.5.0 

func (x *ConnectGcpConfig) String() string

type ConnectNetworkConfig added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use ConnectNetworkConfig.ProtoReflect.Descriptor instead.

func (*ConnectNetworkConfig) GetAdditionalSubnets added in v0.5.0 

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

func (*ConnectNetworkConfig) GetDnsDomainNames added in v0.5.0 

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

func (*ConnectNetworkConfig) GetPrimarySubnet added in v0.5.0 

func (x *ConnectNetworkConfig) GetPrimarySubnet() string

func (*ConnectNetworkConfig) ProtoMessage added in v0.5.0 

func (*ConnectNetworkConfig) ProtoMessage()

func (*ConnectNetworkConfig) ProtoReflect added in v0.5.0 

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

func (*ConnectNetworkConfig) Reset added in v0.5.0 

func (x *ConnectNetworkConfig) Reset()

func (*ConnectNetworkConfig) String added in v0.5.0 

func (x *ConnectNetworkConfig) String() string

type Connector added in v0.5.0 

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 `` /* 155-byte string literal not displayed */
	// 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 deprecated added in v0.5.0 

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

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetConfigs added in v0.5.0 

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

func (*Connector) GetName added in v0.5.0 

func (x *Connector) GetName() string

func (*Connector) GetRestartPolicy added in v0.5.0 

func (m *Connector) GetRestartPolicy() isConnector_RestartPolicy

func (*Connector) GetState added in v0.5.0 

func (x *Connector) GetState() Connector_State

func (*Connector) GetTaskRestartPolicy added in v0.5.0 

func (x *Connector) GetTaskRestartPolicy() *TaskRetryPolicy

func (*Connector) ProtoMessage added in v0.5.0 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect added in v0.5.0 

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

func (*Connector) Reset added in v0.5.0 

func (x *Connector) Reset()

func (*Connector) String added in v0.5.0 

func (x *Connector) String() string

type Connector_State added in v0.5.0 

type Connector_State int32

The state of the connector. 

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 added in v0.5.0 

func (Connector_State) Descriptor() protoreflect.EnumDescriptor

func (Connector_State) Enum added in v0.5.0 

func (x Connector_State) Enum() *Connector_State

func (Connector_State) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use Connector_State.Descriptor instead.

func (Connector_State) Number added in v0.5.0 

func (x Connector_State) Number() protoreflect.EnumNumber

func (Connector_State) String added in v0.5.0 

func (x Connector_State) String() string

func (Connector_State) Type added in v0.5.0 

func (Connector_State) Type() protoreflect.EnumType

type Connector_TaskRestartPolicy added in v0.5.0 

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

type ConsumerGroup 

type ConsumerGroup struct {

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

A Kafka consumer group in a given cluster.

func (*ConsumerGroup) Descriptor deprecated 

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

Deprecated: Use ConsumerGroup.ProtoReflect.Descriptor instead.

func (*ConsumerGroup) GetName 

func (x *ConsumerGroup) GetName() string

func (*ConsumerGroup) GetTopics 

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

func (*ConsumerGroup) ProtoMessage 

func (*ConsumerGroup) ProtoMessage()

func (*ConsumerGroup) ProtoReflect 

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

func (*ConsumerGroup) Reset 

func (x *ConsumerGroup) Reset()

func (*ConsumerGroup) String 

func (x *ConsumerGroup) String() string

type ConsumerPartitionMetadata 

type ConsumerPartitionMetadata struct {

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

Metadata for a consumer group corresponding to a specific partition.

func (*ConsumerPartitionMetadata) Descriptor deprecated 

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

Deprecated: Use ConsumerPartitionMetadata.ProtoReflect.Descriptor instead.

func (*ConsumerPartitionMetadata) GetMetadata 

func (x *ConsumerPartitionMetadata) GetMetadata() string

func (*ConsumerPartitionMetadata) GetOffset 

func (x *ConsumerPartitionMetadata) GetOffset() int64

func (*ConsumerPartitionMetadata) ProtoMessage 

func (*ConsumerPartitionMetadata) ProtoMessage()

func (*ConsumerPartitionMetadata) ProtoReflect 

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

func (*ConsumerPartitionMetadata) Reset 

func (x *ConsumerPartitionMetadata) Reset()

func (*ConsumerPartitionMetadata) String 

func (x *ConsumerPartitionMetadata) String() string

type ConsumerTopicMetadata 

type ConsumerTopicMetadata struct {

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

Metadata for a consumer group corresponding to a specific topic.

func (*ConsumerTopicMetadata) Descriptor deprecated 

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

Deprecated: Use ConsumerTopicMetadata.ProtoReflect.Descriptor instead.

func (*ConsumerTopicMetadata) GetPartitions 

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

func (*ConsumerTopicMetadata) ProtoMessage 

func (*ConsumerTopicMetadata) ProtoMessage()

func (*ConsumerTopicMetadata) ProtoReflect 

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

func (*ConsumerTopicMetadata) Reset 

func (x *ConsumerTopicMetadata) Reset()

func (*ConsumerTopicMetadata) String 

func (x *ConsumerTopicMetadata) String() string

type CreateAclRequest added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use CreateAclRequest.ProtoReflect.Descriptor instead.

func (*CreateAclRequest) GetAcl added in v0.6.0 

func (x *CreateAclRequest) GetAcl() *Acl

func (*CreateAclRequest) GetAclId added in v0.6.0 

func (x *CreateAclRequest) GetAclId() string

func (*CreateAclRequest) GetParent added in v0.6.0 

func (x *CreateAclRequest) GetParent() string

func (*CreateAclRequest) ProtoMessage added in v0.6.0 

func (*CreateAclRequest) ProtoMessage()

func (*CreateAclRequest) ProtoReflect added in v0.6.0 

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

func (*CreateAclRequest) Reset added in v0.6.0 

func (x *CreateAclRequest) Reset()

func (*CreateAclRequest) String added in v0.6.0 

func (x *CreateAclRequest) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {

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

Request for CreateCluster.

func (*CreateClusterRequest) Descriptor deprecated 

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetCluster 

func (x *CreateClusterRequest) GetCluster() *Cluster

func (*CreateClusterRequest) GetClusterId 

func (x *CreateClusterRequest) GetClusterId() string

func (*CreateClusterRequest) GetParent 

func (x *CreateClusterRequest) GetParent() string

func (*CreateClusterRequest) GetRequestId 

func (x *CreateClusterRequest) GetRequestId() string

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

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

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type CreateConnectClusterRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use CreateConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectClusterRequest) GetConnectCluster added in v0.5.0 

func (x *CreateConnectClusterRequest) GetConnectCluster() *ConnectCluster

func (*CreateConnectClusterRequest) GetConnectClusterId added in v0.5.0 

func (x *CreateConnectClusterRequest) GetConnectClusterId() string

func (*CreateConnectClusterRequest) GetParent added in v0.5.0 

func (x *CreateConnectClusterRequest) GetParent() string

func (*CreateConnectClusterRequest) GetRequestId added in v0.5.0 

func (x *CreateConnectClusterRequest) GetRequestId() string

func (*CreateConnectClusterRequest) ProtoMessage added in v0.5.0 

func (*CreateConnectClusterRequest) ProtoMessage()

func (*CreateConnectClusterRequest) ProtoReflect added in v0.5.0 

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

func (*CreateConnectClusterRequest) Reset added in v0.5.0 

func (x *CreateConnectClusterRequest) Reset()

func (*CreateConnectClusterRequest) String added in v0.5.0 

func (x *CreateConnectClusterRequest) String() string

type CreateConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetConnector added in v0.5.0 

func (x *CreateConnectorRequest) GetConnector() *Connector

func (*CreateConnectorRequest) GetConnectorId added in v0.5.0 

func (x *CreateConnectorRequest) GetConnectorId() string

func (*CreateConnectorRequest) GetParent added in v0.5.0 

func (x *CreateConnectorRequest) GetParent() string

func (*CreateConnectorRequest) ProtoMessage added in v0.5.0 

func (*CreateConnectorRequest) ProtoMessage()

func (*CreateConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*CreateConnectorRequest) Reset added in v0.5.0 

func (x *CreateConnectorRequest) Reset()

func (*CreateConnectorRequest) String added in v0.5.0 

func (x *CreateConnectorRequest) String() string

type CreateTopicRequest 

type CreateTopicRequest struct {

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

Request for CreateTopic.

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetParent 

func (x *CreateTopicRequest) GetParent() string

func (*CreateTopicRequest) GetTopic 

func (x *CreateTopicRequest) GetTopic() *Topic

func (*CreateTopicRequest) GetTopicId 

func (x *CreateTopicRequest) GetTopicId() string

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

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

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

type DeleteAclRequest added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use DeleteAclRequest.ProtoReflect.Descriptor instead.

func (*DeleteAclRequest) GetName added in v0.6.0 

func (x *DeleteAclRequest) GetName() string

func (*DeleteAclRequest) ProtoMessage added in v0.6.0 

func (*DeleteAclRequest) ProtoMessage()

func (*DeleteAclRequest) ProtoReflect added in v0.6.0 

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

func (*DeleteAclRequest) Reset added in v0.6.0 

func (x *DeleteAclRequest) Reset()

func (*DeleteAclRequest) String added in v0.6.0 

func (x *DeleteAclRequest) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {

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

Request for DeleteCluster.

func (*DeleteClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetName 

func (x *DeleteClusterRequest) GetName() string

func (*DeleteClusterRequest) GetRequestId 

func (x *DeleteClusterRequest) GetRequestId() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect 

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

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteConnectClusterRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use DeleteConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectClusterRequest) GetName added in v0.5.0 

func (x *DeleteConnectClusterRequest) GetName() string

func (*DeleteConnectClusterRequest) GetRequestId added in v0.5.0 

func (x *DeleteConnectClusterRequest) GetRequestId() string

func (*DeleteConnectClusterRequest) ProtoMessage added in v0.5.0 

func (*DeleteConnectClusterRequest) ProtoMessage()

func (*DeleteConnectClusterRequest) ProtoReflect added in v0.5.0 

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

func (*DeleteConnectClusterRequest) Reset added in v0.5.0 

func (x *DeleteConnectClusterRequest) Reset()

func (*DeleteConnectClusterRequest) String added in v0.5.0 

func (x *DeleteConnectClusterRequest) String() string

type DeleteConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetName added in v0.5.0 

func (x *DeleteConnectorRequest) GetName() string

func (*DeleteConnectorRequest) ProtoMessage added in v0.5.0 

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*DeleteConnectorRequest) Reset added in v0.5.0 

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) String added in v0.5.0 

func (x *DeleteConnectorRequest) String() string

type DeleteConsumerGroupRequest 

type DeleteConsumerGroupRequest struct {

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

Request for DeleteConsumerGroup.

func (*DeleteConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteConsumerGroupRequest) GetName 

func (x *DeleteConsumerGroupRequest) GetName() string

func (*DeleteConsumerGroupRequest) ProtoMessage 

func (*DeleteConsumerGroupRequest) ProtoMessage()

func (*DeleteConsumerGroupRequest) ProtoReflect 

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

func (*DeleteConsumerGroupRequest) Reset 

func (x *DeleteConsumerGroupRequest) Reset()

func (*DeleteConsumerGroupRequest) String 

func (x *DeleteConsumerGroupRequest) String() string

type DeleteTopicRequest 

type DeleteTopicRequest struct {

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

Request for DeleteTopic.

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetName 

func (x *DeleteTopicRequest) GetName() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect 

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

func (*DeleteTopicRequest) Reset 

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

type GcpConfig 

type GcpConfig struct {

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

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

func (*GcpConfig) Descriptor deprecated 

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

Deprecated: Use GcpConfig.ProtoReflect.Descriptor instead.

func (*GcpConfig) GetAccessConfig 

func (x *GcpConfig) GetAccessConfig() *AccessConfig

func (*GcpConfig) GetKmsKey 

func (x *GcpConfig) GetKmsKey() string

func (*GcpConfig) ProtoMessage 

func (*GcpConfig) ProtoMessage()

func (*GcpConfig) ProtoReflect 

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

func (*GcpConfig) Reset 

func (x *GcpConfig) Reset()

func (*GcpConfig) String 

func (x *GcpConfig) String() string

type GetAclRequest added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use GetAclRequest.ProtoReflect.Descriptor instead.

func (*GetAclRequest) GetName added in v0.6.0 

func (x *GetAclRequest) GetName() string

func (*GetAclRequest) ProtoMessage added in v0.6.0 

func (*GetAclRequest) ProtoMessage()

func (*GetAclRequest) ProtoReflect added in v0.6.0 

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

func (*GetAclRequest) Reset added in v0.6.0 

func (x *GetAclRequest) Reset()

func (*GetAclRequest) String added in v0.6.0 

func (x *GetAclRequest) String() string

type GetClusterRequest 

type GetClusterRequest struct {

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

Request for GetCluster.

func (*GetClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetName 

func (x *GetClusterRequest) GetName() string

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect 

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

func (*GetClusterRequest) Reset 

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) String 

func (x *GetClusterRequest) String() string

type GetConnectClusterRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use GetConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*GetConnectClusterRequest) GetName added in v0.5.0 

func (x *GetConnectClusterRequest) GetName() string

func (*GetConnectClusterRequest) ProtoMessage added in v0.5.0 

func (*GetConnectClusterRequest) ProtoMessage()

func (*GetConnectClusterRequest) ProtoReflect added in v0.5.0 

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

func (*GetConnectClusterRequest) Reset added in v0.5.0 

func (x *GetConnectClusterRequest) Reset()

func (*GetConnectClusterRequest) String added in v0.5.0 

func (x *GetConnectClusterRequest) String() string

type GetConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetName added in v0.5.0 

func (x *GetConnectorRequest) GetName() string

func (*GetConnectorRequest) ProtoMessage added in v0.5.0 

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*GetConnectorRequest) Reset added in v0.5.0 

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) String added in v0.5.0 

func (x *GetConnectorRequest) String() string

type GetConsumerGroupRequest 

type GetConsumerGroupRequest struct {

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

Request for GetConsumerGroup.

func (*GetConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use GetConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*GetConsumerGroupRequest) GetName 

func (x *GetConsumerGroupRequest) GetName() string

func (*GetConsumerGroupRequest) ProtoMessage 

func (*GetConsumerGroupRequest) ProtoMessage()

func (*GetConsumerGroupRequest) ProtoReflect 

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

func (*GetConsumerGroupRequest) Reset 

func (x *GetConsumerGroupRequest) Reset()

func (*GetConsumerGroupRequest) String 

func (x *GetConsumerGroupRequest) String() string

type GetTopicRequest 

type GetTopicRequest struct {

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

Request for GetTopic.

func (*GetTopicRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicRequest.ProtoReflect.Descriptor instead.

func (*GetTopicRequest) GetName 

func (x *GetTopicRequest) GetName() string

func (*GetTopicRequest) ProtoMessage 

func (*GetTopicRequest) ProtoMessage()

func (*GetTopicRequest) ProtoReflect 

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

func (*GetTopicRequest) Reset 

func (x *GetTopicRequest) Reset()

func (*GetTopicRequest) String 

func (x *GetTopicRequest) String() string

type ListAclsRequest added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use ListAclsRequest.ProtoReflect.Descriptor instead.

func (*ListAclsRequest) GetPageSize added in v0.6.0 

func (x *ListAclsRequest) GetPageSize() int32

func (*ListAclsRequest) GetPageToken added in v0.6.0 

func (x *ListAclsRequest) GetPageToken() string

func (*ListAclsRequest) GetParent added in v0.6.0 

func (x *ListAclsRequest) GetParent() string

func (*ListAclsRequest) ProtoMessage added in v0.6.0 

func (*ListAclsRequest) ProtoMessage()

func (*ListAclsRequest) ProtoReflect added in v0.6.0 

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

func (*ListAclsRequest) Reset added in v0.6.0 

func (x *ListAclsRequest) Reset()

func (*ListAclsRequest) String added in v0.6.0 

func (x *ListAclsRequest) String() string

type ListAclsResponse added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use ListAclsResponse.ProtoReflect.Descriptor instead.

func (*ListAclsResponse) GetAcls added in v0.6.0 

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

func (*ListAclsResponse) GetNextPageToken added in v0.6.0 

func (x *ListAclsResponse) GetNextPageToken() string

func (*ListAclsResponse) ProtoMessage added in v0.6.0 

func (*ListAclsResponse) ProtoMessage()

func (*ListAclsResponse) ProtoReflect added in v0.6.0 

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

func (*ListAclsResponse) Reset added in v0.6.0 

func (x *ListAclsResponse) Reset()

func (*ListAclsResponse) String added in v0.6.0 

func (x *ListAclsResponse) String() string

type ListClustersRequest 

type ListClustersRequest struct {

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

Request for ListClusters.

func (*ListClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetFilter 

func (x *ListClustersRequest) GetFilter() string

func (*ListClustersRequest) GetOrderBy 

func (x *ListClustersRequest) GetOrderBy() string

func (*ListClustersRequest) GetPageSize 

func (x *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GetPageToken 

func (x *ListClustersRequest) GetPageToken() string

func (*ListClustersRequest) GetParent 

func (x *ListClustersRequest) GetParent() string

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

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

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {

	// The list of Clusters in the requested parent.
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page of
	// results. If this field is omitted, there are no more results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Locations that could not be reached.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

Response for ListClusters.

func (*ListClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters 

func (x *ListClustersResponse) GetClusters() []*Cluster

func (*ListClustersResponse) GetNextPageToken 

func (x *ListClustersResponse) GetNextPageToken() string

func (*ListClustersResponse) GetUnreachable 

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

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

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

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type ListConnectClustersRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use ListConnectClustersRequest.ProtoReflect.Descriptor instead.

func (*ListConnectClustersRequest) GetFilter added in v0.5.0 

func (x *ListConnectClustersRequest) GetFilter() string

func (*ListConnectClustersRequest) GetOrderBy added in v0.5.0 

func (x *ListConnectClustersRequest) GetOrderBy() string

func (*ListConnectClustersRequest) GetPageSize added in v0.5.0 

func (x *ListConnectClustersRequest) GetPageSize() int32

func (*ListConnectClustersRequest) GetPageToken added in v0.5.0 

func (x *ListConnectClustersRequest) GetPageToken() string

func (*ListConnectClustersRequest) GetParent added in v0.5.0 

func (x *ListConnectClustersRequest) GetParent() string

func (*ListConnectClustersRequest) ProtoMessage added in v0.5.0 

func (*ListConnectClustersRequest) ProtoMessage()

func (*ListConnectClustersRequest) ProtoReflect added in v0.5.0 

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

func (*ListConnectClustersRequest) Reset added in v0.5.0 

func (x *ListConnectClustersRequest) Reset()

func (*ListConnectClustersRequest) String added in v0.5.0 

func (x *ListConnectClustersRequest) String() string

type ListConnectClustersResponse added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use ListConnectClustersResponse.ProtoReflect.Descriptor instead.

func (*ListConnectClustersResponse) GetConnectClusters added in v0.5.0 

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

func (*ListConnectClustersResponse) GetNextPageToken added in v0.5.0 

func (x *ListConnectClustersResponse) GetNextPageToken() string

func (*ListConnectClustersResponse) GetUnreachable added in v0.5.0 

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

func (*ListConnectClustersResponse) ProtoMessage added in v0.5.0 

func (*ListConnectClustersResponse) ProtoMessage()

func (*ListConnectClustersResponse) ProtoReflect added in v0.5.0 

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

func (*ListConnectClustersResponse) Reset added in v0.5.0 

func (x *ListConnectClustersResponse) Reset()

func (*ListConnectClustersResponse) String added in v0.5.0 

func (x *ListConnectClustersResponse) String() string

type ListConnectorsRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) GetPageSize added in v0.5.0 

func (x *ListConnectorsRequest) GetPageSize() int32

func (*ListConnectorsRequest) GetPageToken added in v0.5.0 

func (x *ListConnectorsRequest) GetPageToken() string

func (*ListConnectorsRequest) GetParent added in v0.5.0 

func (x *ListConnectorsRequest) GetParent() string

func (*ListConnectorsRequest) ProtoMessage added in v0.5.0 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect added in v0.5.0 

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

func (*ListConnectorsRequest) Reset added in v0.5.0 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) String added in v0.5.0 

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors added in v0.5.0 

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

func (*ListConnectorsResponse) GetNextPageToken added in v0.5.0 

func (x *ListConnectorsResponse) GetNextPageToken() string

func (*ListConnectorsResponse) ProtoMessage added in v0.5.0 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect added in v0.5.0 

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

func (*ListConnectorsResponse) Reset added in v0.5.0 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String added in v0.5.0 

func (x *ListConnectorsResponse) String() string

type ListConsumerGroupsRequest 

type ListConsumerGroupsRequest struct {

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

Request for ListConsumerGroups.

func (*ListConsumerGroupsRequest) Descriptor deprecated 

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

Deprecated: Use ListConsumerGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListConsumerGroupsRequest) GetPageSize 

func (x *ListConsumerGroupsRequest) GetPageSize() int32

func (*ListConsumerGroupsRequest) GetPageToken 

func (x *ListConsumerGroupsRequest) GetPageToken() string

func (*ListConsumerGroupsRequest) GetParent 

func (x *ListConsumerGroupsRequest) GetParent() string

func (*ListConsumerGroupsRequest) ProtoMessage 

func (*ListConsumerGroupsRequest) ProtoMessage()

func (*ListConsumerGroupsRequest) ProtoReflect 

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

func (*ListConsumerGroupsRequest) Reset 

func (x *ListConsumerGroupsRequest) Reset()

func (*ListConsumerGroupsRequest) String 

func (x *ListConsumerGroupsRequest) String() string

type ListConsumerGroupsResponse 

type ListConsumerGroupsResponse struct {

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

Response for ListConsumerGroups.

func (*ListConsumerGroupsResponse) Descriptor deprecated 

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

Deprecated: Use ListConsumerGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListConsumerGroupsResponse) GetConsumerGroups 

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

func (*ListConsumerGroupsResponse) GetNextPageToken 

func (x *ListConsumerGroupsResponse) GetNextPageToken() string

func (*ListConsumerGroupsResponse) ProtoMessage 

func (*ListConsumerGroupsResponse) ProtoMessage()

func (*ListConsumerGroupsResponse) ProtoReflect 

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

func (*ListConsumerGroupsResponse) Reset 

func (x *ListConsumerGroupsResponse) Reset()

func (*ListConsumerGroupsResponse) String 

func (x *ListConsumerGroupsResponse) String() string

type ListTopicsRequest 

type ListTopicsRequest struct {

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

Request for ListTopics.

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) GetPageSize 

func (x *ListTopicsRequest) GetPageSize() int32

func (*ListTopicsRequest) GetPageToken 

func (x *ListTopicsRequest) GetPageToken() string

func (*ListTopicsRequest) GetParent 

func (x *ListTopicsRequest) GetParent() string

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect 

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

func (*ListTopicsRequest) Reset 

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {

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

Response for ListTopics.

func (*ListTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetNextPageToken 

func (x *ListTopicsResponse) GetNextPageToken() string

func (*ListTopicsResponse) GetTopics 

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

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

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

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type ManagedKafkaClient 

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

type ManagedKafkaConnectClient added in v0.5.0 

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 added in v0.5.0 

func NewManagedKafkaConnectClient(cc grpc.ClientConnInterface) ManagedKafkaConnectClient

type ManagedKafkaConnectServer added in v0.5.0 

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

type ManagedKafkaServer 

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

type NetworkConfig 

type NetworkConfig struct {

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

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

func (*NetworkConfig) Descriptor deprecated 

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

Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.

func (*NetworkConfig) GetSubnet 

func (x *NetworkConfig) GetSubnet() string

func (*NetworkConfig) ProtoMessage 

func (*NetworkConfig) ProtoMessage()

func (*NetworkConfig) ProtoReflect 

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

func (*NetworkConfig) Reset 

func (x *NetworkConfig) Reset()

func (*NetworkConfig) String 

func (x *NetworkConfig) String() string

type OperationMetadata 

type OperationMetadata struct {

	// Output only. The time the operation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Server-defined resource path for the target of the operation.
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// Output only. Name of the verb executed by the operation.
	Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
	// Output only. Human-readable status of the operation, if any.
	StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// Output only. Identifies whether the user has requested cancellation
	// of the operation. Operations that have been cancelled successfully
	// have [Operation.error][] value with a
	// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
	// `Code.CANCELLED`.
	RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
	// Output only. API version used to start the operation.
	ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

Represents the metadata of the long-running operation.

func (*OperationMetadata) Descriptor deprecated 

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion 

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime 

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

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp

func (*OperationMetadata) GetRequestedCancellation 

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage 

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget 

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetVerb 

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage 

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect 

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

func (*OperationMetadata) Reset 

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String 

func (x *OperationMetadata) String() string

type PauseConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use PauseConnectorRequest.ProtoReflect.Descriptor instead.

func (*PauseConnectorRequest) GetName added in v0.5.0 

func (x *PauseConnectorRequest) GetName() string

func (*PauseConnectorRequest) ProtoMessage added in v0.5.0 

func (*PauseConnectorRequest) ProtoMessage()

func (*PauseConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*PauseConnectorRequest) Reset added in v0.5.0 

func (x *PauseConnectorRequest) Reset()

func (*PauseConnectorRequest) String added in v0.5.0 

func (x *PauseConnectorRequest) String() string

type PauseConnectorResponse added in v0.5.0 

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

Response for PauseConnector.

func (*PauseConnectorResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use PauseConnectorResponse.ProtoReflect.Descriptor instead.

func (*PauseConnectorResponse) ProtoMessage added in v0.5.0 

func (*PauseConnectorResponse) ProtoMessage()

func (*PauseConnectorResponse) ProtoReflect added in v0.5.0 

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

func (*PauseConnectorResponse) Reset added in v0.5.0 

func (x *PauseConnectorResponse) Reset()

func (*PauseConnectorResponse) String added in v0.5.0 

func (x *PauseConnectorResponse) String() string

type RebalanceConfig 

type RebalanceConfig struct {

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

Defines rebalancing behavior of a Kafka cluster.

func (*RebalanceConfig) Descriptor deprecated 

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

Deprecated: Use RebalanceConfig.ProtoReflect.Descriptor instead.

func (*RebalanceConfig) GetMode 

func (x *RebalanceConfig) GetMode() RebalanceConfig_Mode

func (*RebalanceConfig) ProtoMessage 

func (*RebalanceConfig) ProtoMessage()

func (*RebalanceConfig) ProtoReflect 

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

func (*RebalanceConfig) Reset 

func (x *RebalanceConfig) Reset()

func (*RebalanceConfig) String 

func (x *RebalanceConfig) String() string

type RebalanceConfig_Mode 

type RebalanceConfig_Mode int32

The partition rebalance mode for the cluster. 

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

func (RebalanceConfig_Mode) Descriptor 

func (RebalanceConfig_Mode) Descriptor() protoreflect.EnumDescriptor

func (RebalanceConfig_Mode) Enum 

func (x RebalanceConfig_Mode) Enum() *RebalanceConfig_Mode

func (RebalanceConfig_Mode) EnumDescriptor deprecated 

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

Deprecated: Use RebalanceConfig_Mode.Descriptor instead.

func (RebalanceConfig_Mode) Number 

func (x RebalanceConfig_Mode) Number() protoreflect.EnumNumber

func (RebalanceConfig_Mode) String 

func (x RebalanceConfig_Mode) String() string

func (RebalanceConfig_Mode) Type 

func (RebalanceConfig_Mode) Type() protoreflect.EnumType

type RemoveAclEntryRequest added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use RemoveAclEntryRequest.ProtoReflect.Descriptor instead.

func (*RemoveAclEntryRequest) GetAcl added in v0.6.0 

func (x *RemoveAclEntryRequest) GetAcl() string

func (*RemoveAclEntryRequest) GetAclEntry added in v0.6.0 

func (x *RemoveAclEntryRequest) GetAclEntry() *AclEntry

func (*RemoveAclEntryRequest) ProtoMessage added in v0.6.0 

func (*RemoveAclEntryRequest) ProtoMessage()

func (*RemoveAclEntryRequest) ProtoReflect added in v0.6.0 

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

func (*RemoveAclEntryRequest) Reset added in v0.6.0 

func (x *RemoveAclEntryRequest) Reset()

func (*RemoveAclEntryRequest) String added in v0.6.0 

func (x *RemoveAclEntryRequest) String() string

type RemoveAclEntryResponse added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use RemoveAclEntryResponse.ProtoReflect.Descriptor instead.

func (*RemoveAclEntryResponse) GetAcl added in v0.6.0 

func (x *RemoveAclEntryResponse) GetAcl() *Acl

func (*RemoveAclEntryResponse) GetAclDeleted added in v0.6.0 

func (x *RemoveAclEntryResponse) GetAclDeleted() bool

func (*RemoveAclEntryResponse) GetResult added in v0.6.0 

func (m *RemoveAclEntryResponse) GetResult() isRemoveAclEntryResponse_Result

func (*RemoveAclEntryResponse) ProtoMessage added in v0.6.0 

func (*RemoveAclEntryResponse) ProtoMessage()

func (*RemoveAclEntryResponse) ProtoReflect added in v0.6.0 

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

func (*RemoveAclEntryResponse) Reset added in v0.6.0 

func (x *RemoveAclEntryResponse) Reset()

func (*RemoveAclEntryResponse) String added in v0.6.0 

func (x *RemoveAclEntryResponse) String() string

type RemoveAclEntryResponse_Acl added in v0.6.0 

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

type RemoveAclEntryResponse_AclDeleted added in v0.6.0 

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

type RestartConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use RestartConnectorRequest.ProtoReflect.Descriptor instead.

func (*RestartConnectorRequest) GetName added in v0.5.0 

func (x *RestartConnectorRequest) GetName() string

func (*RestartConnectorRequest) ProtoMessage added in v0.5.0 

func (*RestartConnectorRequest) ProtoMessage()

func (*RestartConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*RestartConnectorRequest) Reset added in v0.5.0 

func (x *RestartConnectorRequest) Reset()

func (*RestartConnectorRequest) String added in v0.5.0 

func (x *RestartConnectorRequest) String() string

type RestartConnectorResponse added in v0.5.0 

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

Response for RestartConnector.

func (*RestartConnectorResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use RestartConnectorResponse.ProtoReflect.Descriptor instead.

func (*RestartConnectorResponse) ProtoMessage added in v0.5.0 

func (*RestartConnectorResponse) ProtoMessage()

func (*RestartConnectorResponse) ProtoReflect added in v0.5.0 

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

func (*RestartConnectorResponse) Reset added in v0.5.0 

func (x *RestartConnectorResponse) Reset()

func (*RestartConnectorResponse) String added in v0.5.0 

func (x *RestartConnectorResponse) String() string

type ResumeConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use ResumeConnectorRequest.ProtoReflect.Descriptor instead.

func (*ResumeConnectorRequest) GetName added in v0.5.0 

func (x *ResumeConnectorRequest) GetName() string

func (*ResumeConnectorRequest) ProtoMessage added in v0.5.0 

func (*ResumeConnectorRequest) ProtoMessage()

func (*ResumeConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*ResumeConnectorRequest) Reset added in v0.5.0 

func (x *ResumeConnectorRequest) Reset()

func (*ResumeConnectorRequest) String added in v0.5.0 

func (x *ResumeConnectorRequest) String() string

type ResumeConnectorResponse added in v0.5.0 

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

Response for ResumeConnector.

func (*ResumeConnectorResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use ResumeConnectorResponse.ProtoReflect.Descriptor instead.

func (*ResumeConnectorResponse) ProtoMessage added in v0.5.0 

func (*ResumeConnectorResponse) ProtoMessage()

func (*ResumeConnectorResponse) ProtoReflect added in v0.5.0 

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

func (*ResumeConnectorResponse) Reset added in v0.5.0 

func (x *ResumeConnectorResponse) Reset()

func (*ResumeConnectorResponse) String added in v0.5.0 

func (x *ResumeConnectorResponse) String() string

type StopConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use StopConnectorRequest.ProtoReflect.Descriptor instead.

func (*StopConnectorRequest) GetName added in v0.5.0 

func (x *StopConnectorRequest) GetName() string

func (*StopConnectorRequest) ProtoMessage added in v0.5.0 

func (*StopConnectorRequest) ProtoMessage()

func (*StopConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*StopConnectorRequest) Reset added in v0.5.0 

func (x *StopConnectorRequest) Reset()

func (*StopConnectorRequest) String added in v0.5.0 

func (x *StopConnectorRequest) String() string

type StopConnectorResponse added in v0.5.0 

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

Response for StopConnector.

func (*StopConnectorResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use StopConnectorResponse.ProtoReflect.Descriptor instead.

func (*StopConnectorResponse) ProtoMessage added in v0.5.0 

func (*StopConnectorResponse) ProtoMessage()

func (*StopConnectorResponse) ProtoReflect added in v0.5.0 

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

func (*StopConnectorResponse) Reset added in v0.5.0 

func (x *StopConnectorResponse) Reset()

func (*StopConnectorResponse) String added in v0.5.0 

func (x *StopConnectorResponse) String() string

type TaskRetryPolicy added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use TaskRetryPolicy.ProtoReflect.Descriptor instead.

func (*TaskRetryPolicy) GetMaximumBackoff added in v0.5.0 

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

func (*TaskRetryPolicy) GetMinimumBackoff added in v0.5.0 

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

func (*TaskRetryPolicy) ProtoMessage added in v0.5.0 

func (*TaskRetryPolicy) ProtoMessage()

func (*TaskRetryPolicy) ProtoReflect added in v0.5.0 

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

func (*TaskRetryPolicy) Reset added in v0.5.0 

func (x *TaskRetryPolicy) Reset()

func (*TaskRetryPolicy) String added in v0.5.0 

func (x *TaskRetryPolicy) String() string

type TlsConfig added in v0.7.0 

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.*$/$1@example.com/,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 `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

The TLS configuration for the Kafka cluster.

func (*TlsConfig) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use TlsConfig.ProtoReflect.Descriptor instead.

func (*TlsConfig) GetSslPrincipalMappingRules added in v0.7.0 

func (x *TlsConfig) GetSslPrincipalMappingRules() string

func (*TlsConfig) GetTrustConfig added in v0.7.0 

func (x *TlsConfig) GetTrustConfig() *TrustConfig

func (*TlsConfig) ProtoMessage added in v0.7.0 

func (*TlsConfig) ProtoMessage()

func (*TlsConfig) ProtoReflect added in v0.7.0 

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

func (*TlsConfig) Reset added in v0.7.0 

func (x *TlsConfig) Reset()

func (*TlsConfig) String added in v0.7.0 

func (x *TlsConfig) String() string

type Topic 

type Topic struct {

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

A Kafka topic in a given cluster.

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetConfigs 

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

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitionCount 

func (x *Topic) GetPartitionCount() int32

func (*Topic) GetReplicationFactor 

func (x *Topic) GetReplicationFactor() int32

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

type TrustConfig added in v0.7.0 

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 deprecated added in v0.7.0 

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

Deprecated: Use TrustConfig.ProtoReflect.Descriptor instead.

func (*TrustConfig) GetCasConfigs added in v0.7.0 

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

func (*TrustConfig) ProtoMessage added in v0.7.0 

func (*TrustConfig) ProtoMessage()

func (*TrustConfig) ProtoReflect added in v0.7.0 

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

func (*TrustConfig) Reset added in v0.7.0 

func (x *TrustConfig) Reset()

func (*TrustConfig) String added in v0.7.0 

func (x *TrustConfig) String() string

type TrustConfig_CertificateAuthorityServiceConfig added in v0.7.0 

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 deprecated added in v0.7.0 

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

Deprecated: Use TrustConfig_CertificateAuthorityServiceConfig.ProtoReflect.Descriptor instead.

func (*TrustConfig_CertificateAuthorityServiceConfig) GetCaPool added in v0.7.0 

func (x *TrustConfig_CertificateAuthorityServiceConfig) GetCaPool() string

func (*TrustConfig_CertificateAuthorityServiceConfig) ProtoMessage added in v0.7.0 

func (*TrustConfig_CertificateAuthorityServiceConfig) ProtoMessage()

func (*TrustConfig_CertificateAuthorityServiceConfig) ProtoReflect added in v0.7.0 

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

func (*TrustConfig_CertificateAuthorityServiceConfig) Reset added in v0.7.0 

func (x *TrustConfig_CertificateAuthorityServiceConfig) Reset()

func (*TrustConfig_CertificateAuthorityServiceConfig) String added in v0.7.0 

func (x *TrustConfig_CertificateAuthorityServiceConfig) String() string

type UnimplementedManagedKafkaConnectServer added in v0.5.0 

type UnimplementedManagedKafkaConnectServer struct {
}

UnimplementedManagedKafkaConnectServer should be embedded to have forward compatible implementations.

func (UnimplementedManagedKafkaConnectServer) CreateConnectCluster added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) CreateConnector added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) DeleteConnectCluster added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) DeleteConnector added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) GetConnectCluster added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) GetConnector added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) ListConnectClusters added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) ListConnectors added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) PauseConnector added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) RestartConnector added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) ResumeConnector added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) StopConnector added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) UpdateConnectCluster added in v0.5.0 

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

func (UnimplementedManagedKafkaConnectServer) UpdateConnector added in v0.5.0 

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

type UnimplementedManagedKafkaServer 

type UnimplementedManagedKafkaServer struct {
}

UnimplementedManagedKafkaServer should be embedded to have forward compatible implementations.

func (UnimplementedManagedKafkaServer) AddAclEntry added in v0.6.0 

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

func (UnimplementedManagedKafkaServer) CreateAcl added in v0.6.0 

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 added in v0.6.0 

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 added in v0.6.0 

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 added in v0.6.0 

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 added in v0.6.0 

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

func (UnimplementedManagedKafkaServer) UpdateAcl added in v0.6.0 

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)

type UnsafeManagedKafkaConnectServer added in v0.8.1 

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.

type UnsafeManagedKafkaServer added in v0.8.1 

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.

type UpdateAclRequest added in v0.6.0 

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 deprecated added in v0.6.0 

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

Deprecated: Use UpdateAclRequest.ProtoReflect.Descriptor instead.

func (*UpdateAclRequest) GetAcl added in v0.6.0 

func (x *UpdateAclRequest) GetAcl() *Acl

func (*UpdateAclRequest) GetUpdateMask added in v0.6.0 

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

func (*UpdateAclRequest) ProtoMessage added in v0.6.0 

func (*UpdateAclRequest) ProtoMessage()

func (*UpdateAclRequest) ProtoReflect added in v0.6.0 

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

func (*UpdateAclRequest) Reset added in v0.6.0 

func (x *UpdateAclRequest) Reset()

func (*UpdateAclRequest) String added in v0.6.0 

func (x *UpdateAclRequest) String() string

type UpdateClusterRequest 

type UpdateClusterRequest struct {

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

Request for UpdateCluster.

func (*UpdateClusterRequest) Descriptor deprecated 

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

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetCluster 

func (x *UpdateClusterRequest) GetCluster() *Cluster

func (*UpdateClusterRequest) GetRequestId 

func (x *UpdateClusterRequest) GetRequestId() string

func (*UpdateClusterRequest) GetUpdateMask 

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

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) ProtoReflect 

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

func (*UpdateClusterRequest) Reset 

func (x *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String 

func (x *UpdateClusterRequest) String() string

type UpdateConnectClusterRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use UpdateConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectClusterRequest) GetConnectCluster added in v0.5.0 

func (x *UpdateConnectClusterRequest) GetConnectCluster() *ConnectCluster

func (*UpdateConnectClusterRequest) GetRequestId added in v0.5.0 

func (x *UpdateConnectClusterRequest) GetRequestId() string

func (*UpdateConnectClusterRequest) GetUpdateMask added in v0.5.0 

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

func (*UpdateConnectClusterRequest) ProtoMessage added in v0.5.0 

func (*UpdateConnectClusterRequest) ProtoMessage()

func (*UpdateConnectClusterRequest) ProtoReflect added in v0.5.0 

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

func (*UpdateConnectClusterRequest) Reset added in v0.5.0 

func (x *UpdateConnectClusterRequest) Reset()

func (*UpdateConnectClusterRequest) String added in v0.5.0 

func (x *UpdateConnectClusterRequest) String() string

type UpdateConnectorRequest added in v0.5.0 

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 deprecated added in v0.5.0 

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

Deprecated: Use UpdateConnectorRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectorRequest) GetConnector added in v0.5.0 

func (x *UpdateConnectorRequest) GetConnector() *Connector

func (*UpdateConnectorRequest) GetUpdateMask added in v0.5.0 

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

func (*UpdateConnectorRequest) ProtoMessage added in v0.5.0 

func (*UpdateConnectorRequest) ProtoMessage()

func (*UpdateConnectorRequest) ProtoReflect added in v0.5.0 

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

func (*UpdateConnectorRequest) Reset added in v0.5.0 

func (x *UpdateConnectorRequest) Reset()

func (*UpdateConnectorRequest) String added in v0.5.0 

func (x *UpdateConnectorRequest) String() string

type UpdateConsumerGroupRequest 

type UpdateConsumerGroupRequest struct {

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

Request for UpdateConsumerGroup.

func (*UpdateConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*UpdateConsumerGroupRequest) GetConsumerGroup 

func (x *UpdateConsumerGroupRequest) GetConsumerGroup() *ConsumerGroup

func (*UpdateConsumerGroupRequest) GetUpdateMask 

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

func (*UpdateConsumerGroupRequest) ProtoMessage 

func (*UpdateConsumerGroupRequest) ProtoMessage()

func (*UpdateConsumerGroupRequest) ProtoReflect 

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

func (*UpdateConsumerGroupRequest) Reset 

func (x *UpdateConsumerGroupRequest) Reset()

func (*UpdateConsumerGroupRequest) String 

func (x *UpdateConsumerGroupRequest) String() string

type UpdateTopicRequest 

type UpdateTopicRequest struct {

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

Request for UpdateTopic.

func (*UpdateTopicRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTopicRequest.ProtoReflect.Descriptor instead.

func (*UpdateTopicRequest) GetTopic 

func (x *UpdateTopicRequest) GetTopic() *Topic

func (*UpdateTopicRequest) GetUpdateMask 

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

func (*UpdateTopicRequest) ProtoMessage 

func (*UpdateTopicRequest) ProtoMessage()

func (*UpdateTopicRequest) ProtoReflect 

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

func (*UpdateTopicRequest) Reset 

func (x *UpdateTopicRequest) Reset()

func (*UpdateTopicRequest) String 

func (x *UpdateTopicRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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