kafka

type Cluster struct {

	// ID of the Apache Kafka® cluster.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the project that the Apache Kafka® cluster belongs to.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Type of the cloud where instances should be hosted.
	CloudType string `protobuf:"bytes,3,opt,name=cloud_type,json=cloudType,proto3" json:"cloud_type,omitempty"`
	// ID of the region to place instances.
	RegionId string `protobuf:"bytes,4,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// Creation timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Name of the Apache Kafka® cluster.
	// The name is unique within the project.
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the Apache Kafka® cluster.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Current state of the cluster.
	Status v1.ClusterStatus `protobuf:"varint,8,opt,name=status,proto3,enum=doublecloud.v1.ClusterStatus" json:"status,omitempty"`
	// Version of Apache Kafka®.
	Version string `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	// Resources allocated to the Apache Kafka® cluster.
	Resources *ClusterResources `protobuf:"bytes,10,opt,name=resources,proto3" json:"resources,omitempty"`
	// Connection information.
	ConnectionInfo *ConnectionInfo `protobuf:"bytes,11,opt,name=connection_info,json=connectionInfo,proto3" json:"connection_info,omitempty"`
	// Access settings
	Access *v1.Access `protobuf:"bytes,12,opt,name=access,proto3" json:"access,omitempty"`
	// DataEncryption settings
	Encryption *v1.DataEncryption `protobuf:"bytes,13,opt,name=encryption,proto3" json:"encryption,omitempty"`
	// ID of the network that the Apache Kafka® cluster belongs to.
	NetworkId string `protobuf:"bytes,14,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	// Private connection information.
	PrivateConnectionInfo *PrivateConnectionInfo `` /* 127-byte string literal not displayed */
	// Window of maintenance operations.
	MaintenanceWindow *v1.MaintenanceWindow `protobuf:"bytes,16,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`
	// Maintenance operation planned at nearest maintenance_window.
	PlannedOperation *v1.MaintenanceOperation `protobuf:"bytes,17,opt,name=planned_operation,json=plannedOperation,proto3" json:"planned_operation,omitempty"`
	// Configuration of the Apache Kafka cluster.
	KafkaConfig *KafkaConfig `protobuf:"bytes,18,opt,name=kafka_config,json=kafkaConfig,proto3" json:"kafka_config,omitempty"`
	// Prometheus metrics exporter endpoint HTTP basic auth information.
	MetricsExporterConnectionInfo *MetricsExporterConnectionInfo `` /* 153-byte string literal not displayed */
	// Configuration of Schema Registry.
	SchemaRegistryConfig *SchemaRegistryConfig `protobuf:"bytes,20,opt,name=schema_registry_config,json=schemaRegistryConfig,proto3" json:"schema_registry_config,omitempty"`
	// Configuration of REST API.
	RestApiConfig *RestAPIConfig `protobuf:"bytes,21,opt,name=rest_api_config,json=restApiConfig,proto3" json:"rest_api_config,omitempty"`
	// contains filtered or unexported fields
}

type ClusterConnection struct {

	// Alias of cluster connection configuration.
	// Examples: `source`, `target`.
	Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	// Type of connection to Apache Kafka® cluster.
	//
	// Types that are assignable to ClusterConnection:
	//
	//	*ClusterConnection_ThisCluster
	//	*ClusterConnection_ExternalCluster
	ClusterConnection isClusterConnection_ClusterConnection `protobuf_oneof:"cluster_connection"`
	// contains filtered or unexported fields
}

type ClusterConnectionSpec struct {

	// Alias of cluster connection configuration.
	// Examples: `source`, `target`.
	Alias *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	// Type of connection to Apache Kafka® cluster.
	//
	// Types that are assignable to ClusterConnection:
	//
	//	*ClusterConnectionSpec_ThisCluster
	//	*ClusterConnectionSpec_ExternalCluster
	ClusterConnection isClusterConnectionSpec_ClusterConnection `protobuf_oneof:"cluster_connection"`
	// contains filtered or unexported fields
}

type ClusterConnectionSpec_ExternalCluster struct {
	// Configuration of connection to an external cluster with all the necessary
	// credentials.
	ExternalCluster *ExternalClusterConnectionSpec `protobuf:"bytes,3,opt,name=external_cluster,json=externalCluster,proto3,oneof"`
}

type ClusterConnectionSpec_ThisCluster struct {
	// Connection configuration of the cluster the connector belongs to. As all
	// credentials are already known, leave this parameter empty.
	ThisCluster *ThisCluster `protobuf:"bytes,2,opt,name=this_cluster,json=thisCluster,proto3,oneof"`
}

type ClusterConnection_ExternalCluster struct {
	// Configuration of connection to an external cluster with all the necessary
	// credentials.
	ExternalCluster *ExternalClusterConnection `protobuf:"bytes,3,opt,name=external_cluster,json=externalCluster,proto3,oneof"`
}

type ClusterConnection_ThisCluster struct {
	// Connection configuration of the cluster the connector belongs to. As all
	// credentials are already known, leave this parameter empty.
	ThisCluster *ThisCluster `protobuf:"bytes,2,opt,name=this_cluster,json=thisCluster,proto3,oneof"`
}

type ClusterResources struct {

	// Resources allocated to Apache Kafka® hosts.
	Kafka *ClusterResources_Kafka `protobuf:"bytes,1,opt,name=kafka,proto3" json:"kafka,omitempty"`
	// contains filtered or unexported fields
}

type ClusterResources_Kafka struct {

	// ID of the preset for computational resources available to a host (CPU, memory
	// etc.).
	// Means the minimal resource preset for autoscaling.
	ResourcePresetId string `protobuf:"bytes,1,opt,name=resource_preset_id,json=resourcePresetId,proto3" json:"resource_preset_id,omitempty"`
	// Volume of the storage available to a host, in bytes.
	DiskSize *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
	// The number of Kafka brokers deployed in each availability zone.
	BrokerCount *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=broker_count,json=brokerCount,proto3" json:"broker_count,omitempty"`
	// The number of availability zones where Kafka brokers reside.
	ZoneCount *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=zone_count,json=zoneCount,proto3" json:"zone_count,omitempty"`
	// Limit for automatical storage volume scale, in bytes. Autoscaling disabled if
	// not set.
	MaxDiskSize *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=max_disk_size,json=maxDiskSize,proto3" json:"max_disk_size,omitempty"`
	// Lower limit for automatical resource preset scale. Equal to resource_preset_id
	// on creation if not set.
	MinResourcePresetId *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=min_resource_preset_id,json=minResourcePresetId,proto3" json:"min_resource_preset_id,omitempty"`
	// Upper limit for automatical resource preset scale. Autoscaling disabled if not
	// set.
	MaxResourcePresetId *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=max_resource_preset_id,json=maxResourcePresetId,proto3" json:"max_resource_preset_id,omitempty"`
	// contains filtered or unexported fields
}

type ClusterServiceClient interface {
	// Returns the specified Apache Kafka® cluster.
	Get(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	// Retrieves a list of Apache Kafka® clusters that belong to the specified
	// project.
	List(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// Creates an Apache Kafka® cluster in the specified project.
	Create(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Updates the specified Apache Kafka® cluster.
	Update(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Deletes the specified Apache Kafka® cluster.
	Delete(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Reset credentials for the specified cluster.
	ResetCredentials(ctx context.Context, in *ResetClusterCredentialsRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Retrieves a list of hosts for the specified cluster.
	ListHosts(ctx context.Context, in *ListClusterHostsRequest, opts ...grpc.CallOption) (*ListClusterHostsResponse, error)
	// Starts stopped Kafka cluster.
	Start(ctx context.Context, in *StartClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Stops running Kafka cluster.
	Stop(ctx context.Context, in *StopClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Reschedule planned maintenance operation.
	RescheduleMaintenance(ctx context.Context, in *RescheduleMaintenanceRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// List cluster operations.
	ListOperations(ctx context.Context, in *ListClusterOperationsRequest, opts ...grpc.CallOption) (*ListClusterOperationsResponse, error)
}

type ClusterServiceServer interface {
	// Returns the specified Apache Kafka® cluster.
	Get(context.Context, *GetClusterRequest) (*Cluster, error)
	// Retrieves a list of Apache Kafka® clusters that belong to the specified
	// project.
	List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// Creates an Apache Kafka® cluster in the specified project.
	Create(context.Context, *CreateClusterRequest) (*v1.Operation, error)
	// Updates the specified Apache Kafka® cluster.
	Update(context.Context, *UpdateClusterRequest) (*v1.Operation, error)
	// Deletes the specified Apache Kafka® cluster.
	Delete(context.Context, *DeleteClusterRequest) (*v1.Operation, error)
	// Reset credentials for the specified cluster.
	ResetCredentials(context.Context, *ResetClusterCredentialsRequest) (*v1.Operation, error)
	// Retrieves a list of hosts for the specified cluster.
	ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error)
	// Starts stopped Kafka cluster.
	Start(context.Context, *StartClusterRequest) (*v1.Operation, error)
	// Stops running Kafka cluster.
	Stop(context.Context, *StopClusterRequest) (*v1.Operation, error)
	// Reschedule planned maintenance operation.
	RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*v1.Operation, error)
	// List cluster operations.
	ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)
	// contains filtered or unexported methods
}

type ClusterView int32

type ConnectionInfo struct {

	// String to use in clients.
	ConnectionString string `protobuf:"bytes,1,opt,name=connection_string,json=connectionString,proto3" json:"connection_string,omitempty"`
	// Apache Kafka® user.
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// Password for Apache Kafka® user.
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

type Connector struct {

	// Name of the connector.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Maximum number of connector tasks. Default value is the number of brokers.
	TasksMax *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=tasks_max,json=tasksMax,proto3" json:"tasks_max,omitempty"`
	// A set of properties passed to Managed Service for Apache Kafka® with the
	// connector configuration.
	// Example: `sync.topics.config.enabled: true`.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// Connector health.
	Health Connector_Health `protobuf:"varint,4,opt,name=health,proto3,enum=doublecloud.kafka.v1.Connector_Health" json:"health,omitempty"`
	// Current status of the connector.
	Status Connector_Status `protobuf:"varint,5,opt,name=status,proto3,enum=doublecloud.kafka.v1.Connector_Status" json:"status,omitempty"`
	// ID of the Apache Kafka® cluster that the connector belongs to.
	ClusterId string `protobuf:"bytes,6,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Additional settings for the connector.
	//
	// Types that are assignable to ConnectorConfig:
	//
	//	*Connector_ConnectorConfigMirrormaker
	//	*Connector_ConnectorConfigS3Sink
	ConnectorConfig isConnector_ConnectorConfig `protobuf_oneof:"connector_config"`
	// contains filtered or unexported fields
}

type ConnectorConfigMirrorMaker struct {

	// Source cluster connection configuration.
	SourceCluster *ClusterConnection `protobuf:"bytes,1,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	// Target cluster connection configuration.
	TargetCluster *ClusterConnection `protobuf:"bytes,2,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"`
	// List of Kafka topics, separated by `,`.
	Topics string `protobuf:"bytes,3,opt,name=topics,proto3" json:"topics,omitempty"`
	// Replication factor for automatically created topics.
	ReplicationFactor *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	// contains filtered or unexported fields
}

type ConnectorConfigMirrorMakerSpec struct {

	// Source cluster configuration for the MirrorMaker connector.
	SourceCluster *ClusterConnectionSpec `protobuf:"bytes,1,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	// Target cluster configuration for the MirrorMaker connector.
	TargetCluster *ClusterConnectionSpec `protobuf:"bytes,2,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"`
	// List of Kafka topics, separated by `,`.
	Topics string `protobuf:"bytes,3,opt,name=topics,proto3" json:"topics,omitempty"`
	// Replication factor for automatically created topics.
	ReplicationFactor *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	// contains filtered or unexported fields
}

type ConnectorConfigS3Sink struct {

	// List of Kafka topics, separated by ','.
	Topics string `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	// The compression type used for files put on S3.
	// The supported values are: `gzip`, `snappy`, `zstd`, `none`.
	// Optional, the default is `none`.
	// Empty value will be represent as `none`.
	FileCompressionType string `protobuf:"bytes,2,opt,name=file_compression_type,json=fileCompressionType,proto3" json:"file_compression_type,omitempty"`
	// Max records per file.
	FileMaxRecords *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=file_max_records,json=fileMaxRecords,proto3" json:"file_max_records,omitempty"`
	// Credentials for connecting to S3 storage.
	S3Connection *S3Connection `protobuf:"bytes,4,opt,name=s3_connection,json=s3Connection,proto3" json:"s3_connection,omitempty"`
	// contains filtered or unexported fields
}

type ConnectorConfigS3SinkSpec struct {

	// List of Kafka topics, separated by ','.
	Topics string `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	// The compression type used for files put on S3.
	// The supported values are: `gzip`, `snappy`, `zstd`, `none`.
	// Optional, the default is `none`.
	// Empty value will be represent as `none`.
	FileCompressionType string `protobuf:"bytes,2,opt,name=file_compression_type,json=fileCompressionType,proto3" json:"file_compression_type,omitempty"`
	// Max records per file.
	FileMaxRecords *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=file_max_records,json=fileMaxRecords,proto3" json:"file_max_records,omitempty"`
	// Credentials for connecting to S3 storage.
	S3Connection *S3ConnectionSpec `protobuf:"bytes,4,opt,name=s3_connection,json=s3Connection,proto3" json:"s3_connection,omitempty"`
	// contains filtered or unexported fields
}

type ConnectorServiceClient interface {
	// Returns information about an Apache Kafka® connector.
	Get(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	// Retrieves the list of Apache Kafka® connectors in a cluster.
	List(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	// Creates a new Apache Kafka® connector in a cluster.
	Create(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Updates an Apache Kafka® connector.
	Update(ctx context.Context, in *UpdateConnectorRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Deletes an Apache Kafka® connector.
	Delete(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Resumes an Apache Kafka® connector.
	Resume(ctx context.Context, in *ResumeConnectorRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	// Pauses an Apache Kafka® connector.
	Pause(ctx context.Context, in *PauseConnectorRequest, opts ...grpc.CallOption) (*v1.Operation, error)
}

type ConnectorServiceServer interface {
	// Returns information about an Apache Kafka® connector.
	Get(context.Context, *GetConnectorRequest) (*Connector, error)
	// Retrieves the list of Apache Kafka® connectors in a cluster.
	List(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	// Creates a new Apache Kafka® connector in a cluster.
	Create(context.Context, *CreateConnectorRequest) (*v1.Operation, error)
	// Updates an Apache Kafka® connector.
	Update(context.Context, *UpdateConnectorRequest) (*v1.Operation, error)
	// Deletes an Apache Kafka® connector.
	Delete(context.Context, *DeleteConnectorRequest) (*v1.Operation, error)
	// Resumes an Apache Kafka® connector.
	Resume(context.Context, *ResumeConnectorRequest) (*v1.Operation, error)
	// Pauses an Apache Kafka® connector.
	Pause(context.Context, *PauseConnectorRequest) (*v1.Operation, error)
	// contains filtered or unexported methods
}

type ConnectorSpec struct {

	// Name of the connector.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Maximum number of connector tasks. Default value is the number of brokers.
	TasksMax *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=tasks_max,json=tasksMax,proto3" json:"tasks_max,omitempty"`
	// A set of properties passed to Managed Service for Apache Kafka® with the
	// connector configuration.
	// Example: `sync.topics.config.enabled: true`.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// Additional settings for the connector.
	//
	// Types that are assignable to ConnectorConfig:
	//
	//	*ConnectorSpec_ConnectorConfigMirrormaker
	//	*ConnectorSpec_ConnectorConfigS3Sink
	ConnectorConfig isConnectorSpec_ConnectorConfig `protobuf_oneof:"connector_config"`
	// contains filtered or unexported fields
}

type ConnectorSpec_ConnectorConfigMirrormaker struct {
	// Configuration of the MirrorMaker connector.
	ConnectorConfigMirrormaker *ConnectorConfigMirrorMakerSpec `protobuf:"bytes,10,opt,name=connector_config_mirrormaker,json=connectorConfigMirrormaker,proto3,oneof"`
}

type ConnectorSpec_ConnectorConfigS3Sink struct {
	// Configuration of S3-Sink connector.
	ConnectorConfigS3Sink *ConnectorConfigS3SinkSpec `protobuf:"bytes,11,opt,name=connector_config_s3_sink,json=connectorConfigS3Sink,proto3,oneof"`
}

type Connector_ConnectorConfigMirrormaker struct {
	// Configuration of the MirrorMaker connector.
	ConnectorConfigMirrormaker *ConnectorConfigMirrorMaker `protobuf:"bytes,10,opt,name=connector_config_mirrormaker,json=connectorConfigMirrormaker,proto3,oneof"`
}

type Connector_ConnectorConfigS3Sink struct {
	// Configuration of S3-Sink connector.
	ConnectorConfigS3Sink *ConnectorConfigS3Sink `protobuf:"bytes,11,opt,name=connector_config_s3_sink,json=connectorConfigS3Sink,proto3,oneof"`
}

type Connector_Health int32

type Connector_Status int32

type CreateClusterRequest struct {

	// ID of the project to create the Apache Kafka® cluster in.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Type of the cloud where instances should be hosted.
	CloudType string `protobuf:"bytes,2,opt,name=cloud_type,json=cloudType,proto3" json:"cloud_type,omitempty"`
	// ID of the region to place instances.
	RegionId string `protobuf:"bytes,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// Name of the Apache Kafka® cluster. The name must be unique within the project.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the Apache Kafka® cluster.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Version of Apache Kafka®.
	Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	// Resources allocated to the Apache Kafka® cluster.
	Resources *ClusterResources `protobuf:"bytes,7,opt,name=resources,proto3" json:"resources,omitempty"`
	// Access settings
	Access *v1.Access `protobuf:"bytes,8,opt,name=access,proto3" json:"access,omitempty"`
	// DataEncryption settings
	Encryption *v1.DataEncryption `protobuf:"bytes,9,opt,name=encryption,proto3" json:"encryption,omitempty"`
	// ID of the network to create the Apache Kafka® cluster in.
	NetworkId string `protobuf:"bytes,10,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	// Window of maintenance operations.
	MaintenanceWindow *v1.MaintenanceWindow `protobuf:"bytes,11,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`
	// Configuration and resources for hosts that should be created for the Apache
	// Kafka® cluster.
	KafkaConfig *KafkaConfig `protobuf:"bytes,12,opt,name=kafka_config,json=kafkaConfig,proto3" json:"kafka_config,omitempty"`
	// Configuration of Schema Registry.
	SchemaRegistryConfig *SchemaRegistryConfig `protobuf:"bytes,13,opt,name=schema_registry_config,json=schemaRegistryConfig,proto3" json:"schema_registry_config,omitempty"`
	// Configuration of REST API.
	RestApiConfig *RestAPIConfig `protobuf:"bytes,14,opt,name=rest_api_config,json=restApiConfig,proto3" json:"rest_api_config,omitempty"`
	// contains filtered or unexported fields
}

type CreateConnectorMetadata struct {

	// ID of the Apache Kafka® cluster the connector is being created in.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the Apache Kafka® connector that is being created.
	ConnectorName string `protobuf:"bytes,2,opt,name=connector_name,json=connectorName,proto3" json:"connector_name,omitempty"`
	// contains filtered or unexported fields
}

type CreateConnectorRequest struct {

	// ID of the Apache Kafka® cluster to create the connector in.
	//
	// To get this ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Configuration of the connector to create.
	ConnectorSpec *ConnectorSpec `protobuf:"bytes,2,opt,name=connector_spec,json=connectorSpec,proto3" json:"connector_spec,omitempty"`
	// contains filtered or unexported fields
}

type CreateTopicRequest struct {

	// Required. ID of the Apache Kafka cluster to create a topic in.
	// To get the cluster ID use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Required. Configuration of the topic to create.
	TopicSpec *TopicSpec `protobuf:"bytes,2,opt,name=topic_spec,json=topicSpec,proto3" json:"topic_spec,omitempty"`
	// contains filtered or unexported fields
}

type CreateUserRequest struct {

	// Required. ID of the Apache Kafka cluster to create a user in.
	// To get the cluster ID, use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// User creation payload.
	// See [UserSpec] for details
	UserSpec *UserSpec `protobuf:"bytes,2,opt,name=user_spec,json=userSpec,proto3" json:"user_spec,omitempty"`
	// contains filtered or unexported fields
}

type DeleteClusterRequest struct {

	// ID of the Apache Kafka® cluster to delete.
	// To get the Apache Kafka® cluster ID, use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteConnectorMetadata struct {

	// ID of the Apache Kafka® cluster the connector is being deleted from.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the Apache Kafka® connector that is being deleted.
	ConnectorName string `protobuf:"bytes,2,opt,name=connector_name,json=connectorName,proto3" json:"connector_name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteConnectorRequest struct {

	// ID of the Apache Kafka® cluster to delete the connector from.
	//
	// To get this ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the connector to delete.
	//
	// To get this name, make a [ConnectorService.List] request.
	ConnectorName string `protobuf:"bytes,2,opt,name=connector_name,json=connectorName,proto3" json:"connector_name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteTopicRequest struct {

	// Required. ID of the Apache Kafka cluster to delete a topic in.
	// To get the cluster ID, use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Required. Name of the topic to delete.
	// To get the name of the topic, use a [TopicService.List] request.
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteUserRequest struct {

	// Required. ID of the Apache Kafka cluster the user belongs to.
	// To get the cluster ID, use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Required. Name of the user to delete.
	// To get the name of the user, use a [UserService.List] request.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// contains filtered or unexported fields
}

type ExternalClusterConnection struct {

	// List of bootstrap servers of the cluster, separated by `,`.
	BootstrapServers string `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	// SASL username to use for connection to the cluster.
	SaslUsername string `protobuf:"bytes,2,opt,name=sasl_username,json=saslUsername,proto3" json:"sasl_username,omitempty"`
	// SASL mechanism to use for connection to the cluster.
	SaslMechanism string `protobuf:"bytes,3,opt,name=sasl_mechanism,json=saslMechanism,proto3" json:"sasl_mechanism,omitempty"`
	// Security protocol to use for connection to the cluster.
	SecurityProtocol string `protobuf:"bytes,4,opt,name=security_protocol,json=securityProtocol,proto3" json:"security_protocol,omitempty"`
	// contains filtered or unexported fields
}

type ExternalClusterConnectionSpec struct {

	// List of bootstrap servers of the cluster, separated by `,`.
	BootstrapServers *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	// SASL username to use for connection to the cluster.
	SaslUsername *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=sasl_username,json=saslUsername,proto3" json:"sasl_username,omitempty"`
	// SASL password to use for connection to the cluster.
	SaslPassword *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=sasl_password,json=saslPassword,proto3" json:"sasl_password,omitempty"`
	// SASL mechanism to use for connection to the cluster.
	SaslMechanism *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=sasl_mechanism,json=saslMechanism,proto3" json:"sasl_mechanism,omitempty"`
	// Security protocol to use for connection to the cluster.
	SecurityProtocol *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=security_protocol,json=securityProtocol,proto3" json:"security_protocol,omitempty"`
	// CA in PEM format to connect to external cluster.
	// Lines of certificate separated by '\n' symbol.
	SslTruststoreCertificates *wrapperspb.StringValue `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetClusterRequest struct {

	// ID of the Apache Kafka® cluster resource to return.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Whether to include sensitive data in the response. If unspecified, defaults to
	// false.
	Sensitive bool `protobuf:"varint,2,opt,name=sensitive,proto3" json:"sensitive,omitempty"`
	// contains filtered or unexported fields
}

type GetConnectorRequest struct {

	// ID of the Apache Kafka® cluster the connector belongs to.
	//
	// To get this ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the Apache Kafka® connector to return information about.
	//
	// To get this name, make a [ConnectorService.List] request.
	ConnectorName string `protobuf:"bytes,2,opt,name=connector_name,json=connectorName,proto3" json:"connector_name,omitempty"`
	// contains filtered or unexported fields
}

type GetOperationRequest struct {

	// Required. ID of the operation to return.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

type GetTopicRequest struct {

	// ID of the Apache Kafka cluster that the topic belongs to.
	// To get the cluster ID use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the Apache Kafka Topic resource to return.
	// To get the name of the topic use a [TopicService.List] request.
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

type GetUserRequest struct {

	// Required. ID of the Apache Kafka cluster the user belongs to.
	// To get the cluster ID, use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Required. Name of the Apache Kafka User resource to return.
	// To get the name of the user, use a [UserService.List] request.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// contains filtered or unexported fields
}

type GrantUserPermissionRequest struct {

	// Required. ID of the Apache Kafka cluster the user belongs to.
	// To get the cluster ID, use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Required. Name of the user to grant the permission to.
	// To get the name of the user, use a [UserService.List] request.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// Required. Permission that should be granted to the specified user.
	Permission *Permission `protobuf:"bytes,3,opt,name=permission,proto3" json:"permission,omitempty"`
	// contains filtered or unexported fields
}

type Host struct {

	// Required. Name of the host.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. ID of the Apache Kafka® cluster.
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Aggregated host status
	Status v1.HostStatus `protobuf:"varint,3,opt,name=status,proto3,enum=doublecloud.v1.HostStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type KafkaConfig struct {

	// The largest record batch size allowed by Kafka. Default value: 1048588.
	MessageMaxBytes *wrapperspb.Int64Value `protobuf:"bytes,1,opt,name=message_max_bytes,json=messageMaxBytes,proto3" json:"message_max_bytes,omitempty"`
	// The number of bytes of messages to attempt to fetch for each partition. Default
	// value: 1048576.
	ReplicaFetchMaxBytes *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=replica_fetch_max_bytes,json=replicaFetchMaxBytes,proto3" json:"replica_fetch_max_bytes,omitempty"`
	// The maximum size of the log before deleting it. Default is -1.
	LogRetentionBytes *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=log_retention_bytes,json=logRetentionBytes,proto3" json:"log_retention_bytes,omitempty"`
	// The number of hours to keep a log file before deleting it (in hours), tertiary
	// to log.retention.ms property. Default: 168 hours.
	LogRetentionHours *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=log_retention_hours,json=logRetentionHours,proto3" json:"log_retention_hours,omitempty"`
	// The number of minutes to keep a log file before deleting it (in minutes),
	// secondary to log.retention.ms property. If not set, the value in
	// log.retention.hours is used.
	LogRetentionMinutes *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=log_retention_minutes,json=logRetentionMinutes,proto3" json:"log_retention_minutes,omitempty"`
	// The number of milliseconds to keep a log file before deleting it (in
	// milliseconds), If not set, the value in log.retention.minutes is used. If set to
	// -1, no time limit is applied.
	LogRetentionMs *wrapperspb.Int64Value `protobuf:"bytes,6,opt,name=log_retention_ms,json=logRetentionMs,proto3" json:"log_retention_ms,omitempty"`
	// contains filtered or unexported fields
}

type ListClusterHostsRequest struct {

	// ID of the Apache Kafka cluster.
	// To get the Apache Kafka cluster ID use a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Paging information of the request
	Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"`
	// contains filtered or unexported fields
}

type ListClusterHostsResponse struct {

	// List of Host resources.
	Hosts []*Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// Pagination information of the response
	NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"`
	// contains filtered or unexported fields
}

type ListClusterOperationsRequest struct {

	// Required. ID of the Kafka cluster.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Paging information of the request
	Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"`
	// contains filtered or unexported fields
}

type ListClusterOperationsResponse struct {
	Operations []*v1.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Pagination information of the response
	NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"`
	// contains filtered or unexported fields
}

type ListClustersRequest struct {

	// ID of the project to list Apache Kafka® clusters in.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Paging information of the request
	Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"`
	// The level of detail to be returned. If unspecified, defaults to
	// CLUSTER_VIEW_BASIC.
	View ClusterView `protobuf:"varint,3,opt,name=view,proto3,enum=doublecloud.kafka.v1.ClusterView" json:"view,omitempty"`
	// contains filtered or unexported fields
}

type ListClustersResponse struct {

	// List of Apache Kafka® cluster resources.
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// Pagination information of the response
	NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"`
	// contains filtered or unexported fields
}

type ListConnectorsRequest struct {

	// ID of the Apache Kafka® cluster to list connectors in.
	//
	// To get this ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Paging information of the request.
	// See [doublecloud.priv.v1.Paging] for details
	//
	// Following constraints applied:
	// * page_size will be set to 1000 items when exceeded
	// * page_size expected to be >= 0
	// * default page_size is 100
	Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"`
	// contains filtered or unexported fields
}

type ListConnectorsResponse struct {

	// List of Apache Kafka® Connectors.
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	// Pagination information of the response
	// See [doublecloud.priv.v1.NextPage] for details
	NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"`
	// contains filtered or unexported fields
}

type ListOperationsRequest struct {

	// ID of the project to list clusters operations in.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Paging information of the request
	Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"`
	// contains filtered or unexported fields
}