kafka

package
v0.0.0-...-a04abcf Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: MIT Imports: 16 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	ClusterService_Get_FullMethodName                   = "/yandex.cloud.mdb.kafka.v1.ClusterService/Get"
	ClusterService_List_FullMethodName                  = "/yandex.cloud.mdb.kafka.v1.ClusterService/List"
	ClusterService_Create_FullMethodName                = "/yandex.cloud.mdb.kafka.v1.ClusterService/Create"
	ClusterService_Update_FullMethodName                = "/yandex.cloud.mdb.kafka.v1.ClusterService/Update"
	ClusterService_Delete_FullMethodName                = "/yandex.cloud.mdb.kafka.v1.ClusterService/Delete"
	ClusterService_Move_FullMethodName                  = "/yandex.cloud.mdb.kafka.v1.ClusterService/Move"
	ClusterService_Start_FullMethodName                 = "/yandex.cloud.mdb.kafka.v1.ClusterService/Start"
	ClusterService_Stop_FullMethodName                  = "/yandex.cloud.mdb.kafka.v1.ClusterService/Stop"
	ClusterService_RescheduleMaintenance_FullMethodName = "/yandex.cloud.mdb.kafka.v1.ClusterService/RescheduleMaintenance"
	ClusterService_ListLogs_FullMethodName              = "/yandex.cloud.mdb.kafka.v1.ClusterService/ListLogs"
	ClusterService_StreamLogs_FullMethodName            = "/yandex.cloud.mdb.kafka.v1.ClusterService/StreamLogs"
	ClusterService_ListOperations_FullMethodName        = "/yandex.cloud.mdb.kafka.v1.ClusterService/ListOperations"
	ClusterService_ListHosts_FullMethodName             = "/yandex.cloud.mdb.kafka.v1.ClusterService/ListHosts"
)
View Source 
const (
	ConnectorService_Get_FullMethodName    = "/yandex.cloud.mdb.kafka.v1.ConnectorService/Get"
	ConnectorService_List_FullMethodName   = "/yandex.cloud.mdb.kafka.v1.ConnectorService/List"
	ConnectorService_Create_FullMethodName = "/yandex.cloud.mdb.kafka.v1.ConnectorService/Create"
	ConnectorService_Update_FullMethodName = "/yandex.cloud.mdb.kafka.v1.ConnectorService/Update"
	ConnectorService_Delete_FullMethodName = "/yandex.cloud.mdb.kafka.v1.ConnectorService/Delete"
	ConnectorService_Resume_FullMethodName = "/yandex.cloud.mdb.kafka.v1.ConnectorService/Resume"
	ConnectorService_Pause_FullMethodName  = "/yandex.cloud.mdb.kafka.v1.ConnectorService/Pause"
)
View Source 
const (
	ResourcePresetService_Get_FullMethodName  = "/yandex.cloud.mdb.kafka.v1.ResourcePresetService/Get"
	ResourcePresetService_List_FullMethodName = "/yandex.cloud.mdb.kafka.v1.ResourcePresetService/List"
)
View Source 
const (
	TopicService_Get_FullMethodName    = "/yandex.cloud.mdb.kafka.v1.TopicService/Get"
	TopicService_List_FullMethodName   = "/yandex.cloud.mdb.kafka.v1.TopicService/List"
	TopicService_Create_FullMethodName = "/yandex.cloud.mdb.kafka.v1.TopicService/Create"
	TopicService_Update_FullMethodName = "/yandex.cloud.mdb.kafka.v1.TopicService/Update"
	TopicService_Delete_FullMethodName = "/yandex.cloud.mdb.kafka.v1.TopicService/Delete"
)
View Source 
const (
	UserService_Get_FullMethodName              = "/yandex.cloud.mdb.kafka.v1.UserService/Get"
	UserService_List_FullMethodName             = "/yandex.cloud.mdb.kafka.v1.UserService/List"
	UserService_Create_FullMethodName           = "/yandex.cloud.mdb.kafka.v1.UserService/Create"
	UserService_Update_FullMethodName           = "/yandex.cloud.mdb.kafka.v1.UserService/Update"
	UserService_Delete_FullMethodName           = "/yandex.cloud.mdb.kafka.v1.UserService/Delete"
	UserService_GrantPermission_FullMethodName  = "/yandex.cloud.mdb.kafka.v1.UserService/GrantPermission"
	UserService_RevokePermission_FullMethodName = "/yandex.cloud.mdb.kafka.v1.UserService/RevokePermission"
)

Variables

View Source 
var (
	Cluster_Environment_name = map[int32]string{
		0: "ENVIRONMENT_UNSPECIFIED",
		1: "PRODUCTION",
		2: "PRESTABLE",
	}
	Cluster_Environment_value = map[string]int32{
		"ENVIRONMENT_UNSPECIFIED": 0,
		"PRODUCTION":              1,
		"PRESTABLE":               2,
	}
)

Enum value maps for Cluster_Environment.

View Source 
var (
	Cluster_Health_name = map[int32]string{
		0: "HEALTH_UNKNOWN",
		1: "ALIVE",
		2: "DEAD",
		3: "DEGRADED",
	}
	Cluster_Health_value = map[string]int32{
		"HEALTH_UNKNOWN": 0,
		"ALIVE":          1,
		"DEAD":           2,
		"DEGRADED":       3,
	}
)

Enum value maps for Cluster_Health.

View Source 
var (
	Cluster_Status_name = map[int32]string{
		0: "STATUS_UNKNOWN",
		1: "CREATING",
		2: "RUNNING",
		3: "ERROR",
		4: "UPDATING",
		5: "STOPPING",
		6: "STOPPED",
		7: "STARTING",
	}
	Cluster_Status_value = map[string]int32{
		"STATUS_UNKNOWN": 0,
		"CREATING":       1,
		"RUNNING":        2,
		"ERROR":          3,
		"UPDATING":       4,
		"STOPPING":       5,
		"STOPPED":        6,
		"STARTING":       7,
	}
)

Enum value maps for Cluster_Status.

View Source 
var (
	Host_Role_name = map[int32]string{
		0: "ROLE_UNSPECIFIED",
		1: "KAFKA",
		2: "ZOOKEEPER",
	}
	Host_Role_value = map[string]int32{
		"ROLE_UNSPECIFIED": 0,
		"KAFKA":            1,
		"ZOOKEEPER":        2,
	}
)

Enum value maps for Host_Role.

View Source 
var (
	Host_Health_name = map[int32]string{
		0: "UNKNOWN",
		1: "ALIVE",
		2: "DEAD",
		3: "DEGRADED",
	}
	Host_Health_value = map[string]int32{
		"UNKNOWN":  0,
		"ALIVE":    1,
		"DEAD":     2,
		"DEGRADED": 3,
	}
)

Enum value maps for Host_Health.

View Source 
var (
	RescheduleMaintenanceRequest_RescheduleType_name = map[int32]string{
		0: "RESCHEDULE_TYPE_UNSPECIFIED",
		1: "IMMEDIATE",
		2: "NEXT_AVAILABLE_WINDOW",
		3: "SPECIFIC_TIME",
	}
	RescheduleMaintenanceRequest_RescheduleType_value = map[string]int32{
		"RESCHEDULE_TYPE_UNSPECIFIED": 0,
		"IMMEDIATE":                   1,
		"NEXT_AVAILABLE_WINDOW":       2,
		"SPECIFIC_TIME":               3,
	}
)

Enum value maps for RescheduleMaintenanceRequest_RescheduleType.

View Source 
var (
	CompressionType_name = map[int32]string{
		0: "COMPRESSION_TYPE_UNSPECIFIED",
		1: "COMPRESSION_TYPE_UNCOMPRESSED",
		2: "COMPRESSION_TYPE_ZSTD",
		3: "COMPRESSION_TYPE_LZ4",
		4: "COMPRESSION_TYPE_SNAPPY",
		5: "COMPRESSION_TYPE_GZIP",
		6: "COMPRESSION_TYPE_PRODUCER",
	}
	CompressionType_value = map[string]int32{
		"COMPRESSION_TYPE_UNSPECIFIED":  0,
		"COMPRESSION_TYPE_UNCOMPRESSED": 1,
		"COMPRESSION_TYPE_ZSTD":         2,
		"COMPRESSION_TYPE_LZ4":          3,
		"COMPRESSION_TYPE_SNAPPY":       4,
		"COMPRESSION_TYPE_GZIP":         5,
		"COMPRESSION_TYPE_PRODUCER":     6,
	}
)

Enum value maps for CompressionType.

View Source 
var (
	SaslMechanism_name = map[int32]string{
		0: "SASL_MECHANISM_UNSPECIFIED",
		1: "SASL_MECHANISM_SCRAM_SHA_256",
		2: "SASL_MECHANISM_SCRAM_SHA_512",
	}
	SaslMechanism_value = map[string]int32{
		"SASL_MECHANISM_UNSPECIFIED":   0,
		"SASL_MECHANISM_SCRAM_SHA_256": 1,
		"SASL_MECHANISM_SCRAM_SHA_512": 2,
	}
)

Enum value maps for SaslMechanism.

View Source 
var (
	Connector_Health_name = map[int32]string{
		0: "HEALTH_UNKNOWN",
		1: "ALIVE",
		2: "DEAD",
	}
	Connector_Health_value = map[string]int32{
		"HEALTH_UNKNOWN": 0,
		"ALIVE":          1,
		"DEAD":           2,
	}
)

Enum value maps for Connector_Health.

View Source 
var (
	Connector_Status_name = map[int32]string{
		0: "STATUS_UNKNOWN",
		1: "RUNNING",
		2: "ERROR",
		3: "PAUSED",
	}
	Connector_Status_value = map[string]int32{
		"STATUS_UNKNOWN": 0,
		"RUNNING":        1,
		"ERROR":          2,
		"PAUSED":         3,
	}
)

Enum value maps for Connector_Status.

View Source 
var (
	WeeklyMaintenanceWindow_WeekDay_name = map[int32]string{
		0: "WEEK_DAY_UNSPECIFIED",
		1: "MON",
		2: "TUE",
		3: "WED",
		4: "THU",
		5: "FRI",
		6: "SAT",
		7: "SUN",
	}
	WeeklyMaintenanceWindow_WeekDay_value = map[string]int32{
		"WEEK_DAY_UNSPECIFIED": 0,
		"MON":                  1,
		"TUE":                  2,
		"WED":                  3,
		"THU":                  4,
		"FRI":                  5,
		"SAT":                  6,
		"SUN":                  7,
	}
)

Enum value maps for WeeklyMaintenanceWindow_WeekDay.

View Source 
var (
	TopicConfig2_8_CleanupPolicy_name = map[int32]string{
		0: "CLEANUP_POLICY_UNSPECIFIED",
		1: "CLEANUP_POLICY_DELETE",
		2: "CLEANUP_POLICY_COMPACT",
		3: "CLEANUP_POLICY_COMPACT_AND_DELETE",
	}
	TopicConfig2_8_CleanupPolicy_value = map[string]int32{
		"CLEANUP_POLICY_UNSPECIFIED":        0,
		"CLEANUP_POLICY_DELETE":             1,
		"CLEANUP_POLICY_COMPACT":            2,
		"CLEANUP_POLICY_COMPACT_AND_DELETE": 3,
	}
)

Enum value maps for TopicConfig2_8_CleanupPolicy.

View Source 
var (
	TopicConfig3_CleanupPolicy_name = map[int32]string{
		0: "CLEANUP_POLICY_UNSPECIFIED",
		1: "CLEANUP_POLICY_DELETE",
		2: "CLEANUP_POLICY_COMPACT",
		3: "CLEANUP_POLICY_COMPACT_AND_DELETE",
	}
	TopicConfig3_CleanupPolicy_value = map[string]int32{
		"CLEANUP_POLICY_UNSPECIFIED":        0,
		"CLEANUP_POLICY_DELETE":             1,
		"CLEANUP_POLICY_COMPACT":            2,
		"CLEANUP_POLICY_COMPACT_AND_DELETE": 3,
	}
)

Enum value maps for TopicConfig3_CleanupPolicy.

View Source 
var (
	Permission_AccessRole_name = map[int32]string{
		0: "ACCESS_ROLE_UNSPECIFIED",
		1: "ACCESS_ROLE_PRODUCER",
		2: "ACCESS_ROLE_CONSUMER",
		3: "ACCESS_ROLE_ADMIN",
	}
	Permission_AccessRole_value = map[string]int32{
		"ACCESS_ROLE_UNSPECIFIED": 0,
		"ACCESS_ROLE_PRODUCER":    1,
		"ACCESS_ROLE_CONSUMER":    2,
		"ACCESS_ROLE_ADMIN":       3,
	}
)

Enum value maps for Permission_AccessRole.

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.mdb.kafka.v1.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ClusterService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ClusterService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ClusterService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ClusterService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ClusterService_Delete_Handler,
		},
		{
			MethodName: "Move",
			Handler:    _ClusterService_Move_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _ClusterService_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ClusterService_Stop_Handler,
		},
		{
			MethodName: "RescheduleMaintenance",
			Handler:    _ClusterService_RescheduleMaintenance_Handler,
		},
		{
			MethodName: "ListLogs",
			Handler:    _ClusterService_ListLogs_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _ClusterService_ListOperations_Handler,
		},
		{
			MethodName: "ListHosts",
			Handler:    _ClusterService_ListHosts_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamLogs",
			Handler:       _ClusterService_StreamLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "yandex/cloud/mdb/kafka/v1/cluster_service.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService 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 ConnectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.mdb.kafka.v1.ConnectorService",
	HandlerType: (*ConnectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ConnectorService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ConnectorService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ConnectorService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ConnectorService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ConnectorService_Delete_Handler,
		},
		{
			MethodName: "Resume",
			Handler:    _ConnectorService_Resume_Handler,
		},
		{
			MethodName: "Pause",
			Handler:    _ConnectorService_Pause_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/mdb/kafka/v1/connector_service.proto",
}

ConnectorService_ServiceDesc is the grpc.ServiceDesc for ConnectorService 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 File_yandex_cloud_mdb_kafka_v1_cluster_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_cluster_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_connector_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_connector_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_maintenance_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_resource_preset_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_resource_preset_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_topic_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_topic_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_user_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_mdb_kafka_v1_user_service_proto protoreflect.FileDescriptor
View Source 
var ResourcePresetService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.mdb.kafka.v1.ResourcePresetService",
	HandlerType: (*ResourcePresetServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ResourcePresetService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ResourcePresetService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/mdb/kafka/v1/resource_preset_service.proto",
}

ResourcePresetService_ServiceDesc is the grpc.ServiceDesc for ResourcePresetService 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 TopicService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.mdb.kafka.v1.TopicService",
	HandlerType: (*TopicServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _TopicService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _TopicService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _TopicService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _TopicService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _TopicService_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/mdb/kafka/v1/topic_service.proto",
}

TopicService_ServiceDesc is the grpc.ServiceDesc for TopicService 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 UserService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.mdb.kafka.v1.UserService",
	HandlerType: (*UserServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _UserService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _UserService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _UserService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _UserService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _UserService_Delete_Handler,
		},
		{
			MethodName: "GrantPermission",
			Handler:    _UserService_GrantPermission_Handler,
		},
		{
			MethodName: "RevokePermission",
			Handler:    _UserService_RevokePermission_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/mdb/kafka/v1/user_service.proto",
}

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

Functions

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

func RegisterConnectorServiceServer 

func RegisterConnectorServiceServer(s grpc.ServiceRegistrar, srv ConnectorServiceServer)

func RegisterResourcePresetServiceServer 

func RegisterResourcePresetServiceServer(s grpc.ServiceRegistrar, srv ResourcePresetServiceServer)

func RegisterTopicServiceServer 

func RegisterTopicServiceServer(s grpc.ServiceRegistrar, srv TopicServiceServer)

func RegisterUserServiceServer 

func RegisterUserServiceServer(s grpc.ServiceRegistrar, srv UserServiceServer)

Types

type Access 

type Access struct {

	// Allow access for DataTransfer.
	DataTransfer bool `protobuf:"varint,1,opt,name=data_transfer,json=dataTransfer,proto3" json:"data_transfer,omitempty"`
	// contains filtered or unexported fields
}

func (*Access) Descriptor deprecated 

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

Deprecated: Use Access.ProtoReflect.Descriptor instead.

func (*Access) GetDataTransfer 

func (x *Access) GetDataTransfer() bool

func (*Access) ProtoMessage 

func (*Access) ProtoMessage()

func (*Access) ProtoReflect 

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

func (*Access) Reset 

func (x *Access) Reset()

func (*Access) SetDataTransfer 

func (m *Access) SetDataTransfer(v bool)

func (*Access) String 

func (x *Access) String() string

type AnytimeMaintenanceWindow 

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

func (*AnytimeMaintenanceWindow) Descriptor deprecated 

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

Deprecated: Use AnytimeMaintenanceWindow.ProtoReflect.Descriptor instead.

func (*AnytimeMaintenanceWindow) ProtoMessage 

func (*AnytimeMaintenanceWindow) ProtoMessage()

func (*AnytimeMaintenanceWindow) ProtoReflect 

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

func (*AnytimeMaintenanceWindow) Reset 

func (x *AnytimeMaintenanceWindow) Reset()

func (*AnytimeMaintenanceWindow) String 

func (x *AnytimeMaintenanceWindow) String() string

type Cluster 

type Cluster struct {

	// ID of the Apache Kafka® cluster.
	// This ID is assigned at creation time.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the folder that the Apache Kafka® cluster belongs to.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Name of the Apache Kafka® cluster.
	// The name must be unique within the folder. 1-63 characters long. Value must match the regular expression `[a-zA-Z0-9_-]*`.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the Apache Kafka® cluster. 0-256 characters long.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Custom labels for the Apache Kafka® cluster as `key:value` pairs.
	// A maximum of 64 labels per resource is allowed.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Deployment environment of the Apache Kafka® cluster.
	Environment Cluster_Environment `` /* 127-byte string literal not displayed */
	// Description of monitoring systems relevant to the Apache Kafka® cluster.
	Monitoring []*Monitoring `protobuf:"bytes,8,rep,name=monitoring,proto3" json:"monitoring,omitempty"`
	// Configuration of the Apache Kafka® cluster.
	Config *ConfigSpec `protobuf:"bytes,9,opt,name=config,proto3" json:"config,omitempty"`
	// ID of the network that the cluster belongs to.
	NetworkId string `protobuf:"bytes,10,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	// Aggregated cluster health.
	Health Cluster_Health `protobuf:"varint,11,opt,name=health,proto3,enum=yandex.cloud.mdb.kafka.v1.Cluster_Health" json:"health,omitempty"`
	// Current state of the cluster.
	Status Cluster_Status `protobuf:"varint,12,opt,name=status,proto3,enum=yandex.cloud.mdb.kafka.v1.Cluster_Status" json:"status,omitempty"`
	// User security groups
	SecurityGroupIds []string `protobuf:"bytes,13,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"`
	// Host groups hosting VMs of the cluster.
	HostGroupIds []string `protobuf:"bytes,14,rep,name=host_group_ids,json=hostGroupIds,proto3" json:"host_group_ids,omitempty"`
	// Deletion Protection inhibits deletion of the cluster
	DeletionProtection bool `protobuf:"varint,15,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Window of maintenance operations.
	MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,16,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`
	// Scheduled maintenance operation.
	PlannedOperation *MaintenanceOperation `protobuf:"bytes,17,opt,name=planned_operation,json=plannedOperation,proto3" json:"planned_operation,omitempty"`
	// contains filtered or unexported fields
}

An Apache Kafka® cluster resource. For more information, see the [Concepts](/docs/managed-kafka/concepts) section of the documentation.

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetConfig 

func (x *Cluster) GetConfig() *ConfigSpec

func (*Cluster) GetCreatedAt 

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

func (*Cluster) GetDeletionProtection 

func (x *Cluster) GetDeletionProtection() bool

func (*Cluster) GetDescription 

func (x *Cluster) GetDescription() string

func (*Cluster) GetEnvironment 

func (x *Cluster) GetEnvironment() Cluster_Environment

func (*Cluster) GetFolderId 

func (x *Cluster) GetFolderId() string

func (*Cluster) GetHealth 

func (x *Cluster) GetHealth() Cluster_Health

func (*Cluster) GetHostGroupIds 

func (x *Cluster) GetHostGroupIds() []string

func (*Cluster) GetId 

func (x *Cluster) GetId() string

func (*Cluster) GetLabels 

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

func (*Cluster) GetMaintenanceWindow 

func (x *Cluster) GetMaintenanceWindow() *MaintenanceWindow

func (*Cluster) GetMonitoring 

func (x *Cluster) GetMonitoring() []*Monitoring

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetNetworkId 

func (x *Cluster) GetNetworkId() string

func (*Cluster) GetPlannedOperation 

func (x *Cluster) GetPlannedOperation() *MaintenanceOperation

func (*Cluster) GetSecurityGroupIds 

func (x *Cluster) GetSecurityGroupIds() []string

func (*Cluster) GetStatus 

func (x *Cluster) GetStatus() Cluster_Status

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) SetConfig 

func (m *Cluster) SetConfig(v *ConfigSpec)

func (*Cluster) SetCreatedAt 

func (m *Cluster) SetCreatedAt(v *timestamppb.Timestamp)

func (*Cluster) SetDeletionProtection 

func (m *Cluster) SetDeletionProtection(v bool)

func (*Cluster) SetDescription 

func (m *Cluster) SetDescription(v string)

func (*Cluster) SetEnvironment 

func (m *Cluster) SetEnvironment(v Cluster_Environment)

func (*Cluster) SetFolderId 

func (m *Cluster) SetFolderId(v string)

func (*Cluster) SetHealth 

func (m *Cluster) SetHealth(v Cluster_Health)

func (*Cluster) SetHostGroupIds 

func (m *Cluster) SetHostGroupIds(v []string)

func (*Cluster) SetId 

func (m *Cluster) SetId(v string)

func (*Cluster) SetLabels 

func (m *Cluster) SetLabels(v map[string]string)

func (*Cluster) SetMaintenanceWindow 

func (m *Cluster) SetMaintenanceWindow(v *MaintenanceWindow)

func (*Cluster) SetMonitoring 

func (m *Cluster) SetMonitoring(v []*Monitoring)

func (*Cluster) SetName 

func (m *Cluster) SetName(v string)

func (*Cluster) SetNetworkId 

func (m *Cluster) SetNetworkId(v string)

func (*Cluster) SetPlannedOperation 

func (m *Cluster) SetPlannedOperation(v *MaintenanceOperation)

func (*Cluster) SetSecurityGroupIds 

func (m *Cluster) SetSecurityGroupIds(v []string)

func (*Cluster) SetStatus 

func (m *Cluster) SetStatus(v Cluster_Status)

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterConnection 

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
}

func (*ClusterConnection) Descriptor deprecated 

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

Deprecated: Use ClusterConnection.ProtoReflect.Descriptor instead.

func (*ClusterConnection) GetAlias 

func (x *ClusterConnection) GetAlias() string

func (*ClusterConnection) GetClusterConnection 

func (m *ClusterConnection) GetClusterConnection() isClusterConnection_ClusterConnection

func (*ClusterConnection) GetExternalCluster 

func (x *ClusterConnection) GetExternalCluster() *ExternalClusterConnection

func (*ClusterConnection) GetThisCluster 

func (x *ClusterConnection) GetThisCluster() *ThisCluster

func (*ClusterConnection) ProtoMessage 

func (*ClusterConnection) ProtoMessage()

func (*ClusterConnection) ProtoReflect 

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

func (*ClusterConnection) Reset 

func (x *ClusterConnection) Reset()

func (*ClusterConnection) SetAlias 

func (m *ClusterConnection) SetAlias(v string)

func (*ClusterConnection) SetClusterConnection 

func (m *ClusterConnection) SetClusterConnection(v ClusterConnection_ClusterConnection)

func (*ClusterConnection) SetExternalCluster 

func (m *ClusterConnection) SetExternalCluster(v *ExternalClusterConnection)

func (*ClusterConnection) SetThisCluster 

func (m *ClusterConnection) SetThisCluster(v *ThisCluster)

func (*ClusterConnection) String 

func (x *ClusterConnection) String() string

type ClusterConnectionSpec 

type ClusterConnectionSpec 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:
	//
	//	*ClusterConnectionSpec_ThisCluster
	//	*ClusterConnectionSpec_ExternalCluster
	ClusterConnection isClusterConnectionSpec_ClusterConnection `protobuf_oneof:"cluster_connection"`
	// contains filtered or unexported fields
}

func (*ClusterConnectionSpec) Descriptor deprecated 

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

Deprecated: Use ClusterConnectionSpec.ProtoReflect.Descriptor instead.

func (*ClusterConnectionSpec) GetAlias 

func (x *ClusterConnectionSpec) GetAlias() string

func (*ClusterConnectionSpec) GetClusterConnection 

func (m *ClusterConnectionSpec) GetClusterConnection() isClusterConnectionSpec_ClusterConnection

func (*ClusterConnectionSpec) GetExternalCluster 

func (x *ClusterConnectionSpec) GetExternalCluster() *ExternalClusterConnectionSpec

func (*ClusterConnectionSpec) GetThisCluster 

func (x *ClusterConnectionSpec) GetThisCluster() *ThisClusterSpec

func (*ClusterConnectionSpec) ProtoMessage 

func (*ClusterConnectionSpec) ProtoMessage()

func (*ClusterConnectionSpec) ProtoReflect 

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

func (*ClusterConnectionSpec) Reset 

func (x *ClusterConnectionSpec) Reset()

func (*ClusterConnectionSpec) SetAlias 

func (m *ClusterConnectionSpec) SetAlias(v string)

func (*ClusterConnectionSpec) SetClusterConnection 

func (m *ClusterConnectionSpec) SetClusterConnection(v ClusterConnectionSpec_ClusterConnection)

func (*ClusterConnectionSpec) SetExternalCluster 

func (m *ClusterConnectionSpec) SetExternalCluster(v *ExternalClusterConnectionSpec)

func (*ClusterConnectionSpec) SetThisCluster 

func (m *ClusterConnectionSpec) SetThisCluster(v *ThisClusterSpec)

func (*ClusterConnectionSpec) String 

func (x *ClusterConnectionSpec) String() string

type ClusterConnectionSpec_ClusterConnection 

type ClusterConnectionSpec_ClusterConnection = isClusterConnectionSpec_ClusterConnection

type ClusterConnectionSpec_ExternalCluster 

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 

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

type ClusterConnection_ClusterConnection 

type ClusterConnection_ClusterConnection = isClusterConnection_ClusterConnection

type ClusterConnection_ExternalCluster 

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 

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 ClusterServiceClient 

type ClusterServiceClient interface {
	// Returns the specified Apache Kafka® cluster.
	//
	// To get the list of available Apache Kafka® clusters, make a [List] request.
	Get(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	// Retrieves the list of Apache Kafka® clusters that belong to the specified folder.
	List(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// Creates a new Apache Kafka® cluster in the specified folder.
	Create(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified Apache Kafka® cluster.
	Update(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified Apache Kafka® cluster.
	Delete(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Moves the specified Apache Kafka® cluster to the specified folder.
	Move(ctx context.Context, in *MoveClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Starts the specified Apache Kafka® cluster.
	Start(ctx context.Context, in *StartClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Stops the specified Apache Kafka® cluster.
	Stop(ctx context.Context, in *StopClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Reschedule planned maintenance operation.
	RescheduleMaintenance(ctx context.Context, in *RescheduleMaintenanceRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Retrieves logs for the specified Apache Kafka® cluster.
	//
	// For more information about logs, see the [Logs](/docs/managed-kafka/operations/cluster-logs) section in the documentation.
	ListLogs(ctx context.Context, in *ListClusterLogsRequest, opts ...grpc.CallOption) (*ListClusterLogsResponse, error)
	// Same as [ListLogs] but using server-side streaming. Also allows for `tail -f` semantics.
	StreamLogs(ctx context.Context, in *StreamClusterLogsRequest, opts ...grpc.CallOption) (ClusterService_StreamLogsClient, error)
	// Retrieves the list of operations for the specified Apache Kafka® cluster.
	ListOperations(ctx context.Context, in *ListClusterOperationsRequest, opts ...grpc.CallOption) (*ListClusterOperationsResponse, error)
	// Retrieves a list of hosts for the specified Apache Kafka® cluster.
	ListHosts(ctx context.Context, in *ListClusterHostsRequest, opts ...grpc.CallOption) (*ListClusterHostsResponse, error)
}

ClusterServiceClient is the client API for ClusterService 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 NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	// Returns the specified Apache Kafka® cluster.
	//
	// To get the list of available Apache Kafka® clusters, make a [List] request.
	Get(context.Context, *GetClusterRequest) (*Cluster, error)
	// Retrieves the list of Apache Kafka® clusters that belong to the specified folder.
	List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// Creates a new Apache Kafka® cluster in the specified folder.
	Create(context.Context, *CreateClusterRequest) (*operation.Operation, error)
	// Updates the specified Apache Kafka® cluster.
	Update(context.Context, *UpdateClusterRequest) (*operation.Operation, error)
	// Deletes the specified Apache Kafka® cluster.
	Delete(context.Context, *DeleteClusterRequest) (*operation.Operation, error)
	// Moves the specified Apache Kafka® cluster to the specified folder.
	Move(context.Context, *MoveClusterRequest) (*operation.Operation, error)
	// Starts the specified Apache Kafka® cluster.
	Start(context.Context, *StartClusterRequest) (*operation.Operation, error)
	// Stops the specified Apache Kafka® cluster.
	Stop(context.Context, *StopClusterRequest) (*operation.Operation, error)
	// Reschedule planned maintenance operation.
	RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*operation.Operation, error)
	// Retrieves logs for the specified Apache Kafka® cluster.
	//
	// For more information about logs, see the [Logs](/docs/managed-kafka/operations/cluster-logs) section in the documentation.
	ListLogs(context.Context, *ListClusterLogsRequest) (*ListClusterLogsResponse, error)
	// Same as [ListLogs] but using server-side streaming. Also allows for `tail -f` semantics.
	StreamLogs(*StreamClusterLogsRequest, ClusterService_StreamLogsServer) error
	// Retrieves the list of operations for the specified Apache Kafka® cluster.
	ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)
	// Retrieves a list of hosts for the specified Apache Kafka® cluster.
	ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error)
}

ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility

type ClusterService_StreamLogsClient 

type ClusterService_StreamLogsClient interface {
	Recv() (*StreamLogRecord, error)
	grpc.ClientStream
}

type ClusterService_StreamLogsServer 

type ClusterService_StreamLogsServer interface {
	Send(*StreamLogRecord) error
	grpc.ServerStream
}

type Cluster_Environment 

type Cluster_Environment int32
const (
	Cluster_ENVIRONMENT_UNSPECIFIED Cluster_Environment = 0
	// stable environment with a conservative update policy when only hotfixes are applied during regular maintenance.
	Cluster_PRODUCTION Cluster_Environment = 1
	// environment with a more aggressive update policy when new versions are rolled out irrespective of backward compatibility.
	Cluster_PRESTABLE Cluster_Environment = 2
)

func (Cluster_Environment) Descriptor 

func (Cluster_Environment) Descriptor() protoreflect.EnumDescriptor

func (Cluster_Environment) Enum 

func (x Cluster_Environment) Enum() *Cluster_Environment

func (Cluster_Environment) EnumDescriptor deprecated 

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

Deprecated: Use Cluster_Environment.Descriptor instead.

func (Cluster_Environment) Number 

func (x Cluster_Environment) Number() protoreflect.EnumNumber

func (Cluster_Environment) String 

func (x Cluster_Environment) String() string

func (Cluster_Environment) Type 

func (Cluster_Environment) Type() protoreflect.EnumType

type Cluster_Health 

type Cluster_Health int32
const (
	// state of the cluster is unknown ([Host.health] of all hosts in the cluster is `UNKNOWN`).
	Cluster_HEALTH_UNKNOWN Cluster_Health = 0
	// cluster is alive and well ([Host.health] of all hosts in the cluster is `ALIVE`).
	Cluster_ALIVE Cluster_Health = 1
	// cluster is inoperable ([Host.health] of all hosts in the cluster is `DEAD`).
	Cluster_DEAD Cluster_Health = 2
	// cluster is in degraded state ([Host.health] of at least one of the hosts in the cluster is not `ALIVE`).
	Cluster_DEGRADED Cluster_Health = 3
)

func (Cluster_Health) Descriptor 

func (Cluster_Health) Descriptor() protoreflect.EnumDescriptor

func (Cluster_Health) Enum 

func (x Cluster_Health) Enum() *Cluster_Health

func (Cluster_Health) EnumDescriptor deprecated 

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

Deprecated: Use Cluster_Health.Descriptor instead.

func (Cluster_Health) Number 

func (x Cluster_Health) Number() protoreflect.EnumNumber

func (Cluster_Health) String 

func (x Cluster_Health) String() string

func (Cluster_Health) Type 

func (Cluster_Health) Type() protoreflect.EnumType

type Cluster_Status 

type Cluster_Status int32
const (
	// cluster state is unknown.
	Cluster_STATUS_UNKNOWN Cluster_Status = 0
	// cluster is being created.
	Cluster_CREATING Cluster_Status = 1
	// cluster is running normally.
	Cluster_RUNNING Cluster_Status = 2
	// cluster encountered a problem and cannot operate.
	Cluster_ERROR Cluster_Status = 3
	// cluster is being updated.
	Cluster_UPDATING Cluster_Status = 4
	// cluster is stopping.
	Cluster_STOPPING Cluster_Status = 5
	// cluster stopped.
	Cluster_STOPPED Cluster_Status = 6
	// cluster is starting.
	Cluster_STARTING Cluster_Status = 7
)

func (Cluster_Status) Descriptor 

func (Cluster_Status) Descriptor() protoreflect.EnumDescriptor

func (Cluster_Status) Enum 

func (x Cluster_Status) Enum() *Cluster_Status

func (Cluster_Status) EnumDescriptor deprecated 

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

Deprecated: Use Cluster_Status.Descriptor instead.

func (Cluster_Status) Number 

func (x Cluster_Status) Number() protoreflect.EnumNumber

func (Cluster_Status) String 

func (x Cluster_Status) String() string

func (Cluster_Status) Type 

func (Cluster_Status) Type() protoreflect.EnumType

type CompressionType 

type CompressionType int32
const (
	CompressionType_COMPRESSION_TYPE_UNSPECIFIED CompressionType = 0
	// no codec (uncompressed).
	CompressionType_COMPRESSION_TYPE_UNCOMPRESSED CompressionType = 1
	// Zstandard codec.
	CompressionType_COMPRESSION_TYPE_ZSTD CompressionType = 2
	// LZ4 codec.
	CompressionType_COMPRESSION_TYPE_LZ4 CompressionType = 3
	// Snappy codec.
	CompressionType_COMPRESSION_TYPE_SNAPPY CompressionType = 4
	// GZip codec.
	CompressionType_COMPRESSION_TYPE_GZIP CompressionType = 5
	// the codec to use is set by a producer (can be any of `ZSTD`, `LZ4`, `GZIP` or `SNAPPY` codecs).
	CompressionType_COMPRESSION_TYPE_PRODUCER CompressionType = 6
)

func (CompressionType) Descriptor 

func (CompressionType) Descriptor() protoreflect.EnumDescriptor

func (CompressionType) Enum 

func (x CompressionType) Enum() *CompressionType

func (CompressionType) EnumDescriptor deprecated 

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

Deprecated: Use CompressionType.Descriptor instead.

func (CompressionType) Number 

func (x CompressionType) Number() protoreflect.EnumNumber

func (CompressionType) String 

func (x CompressionType) String() string

func (CompressionType) Type 

func (CompressionType) Type() protoreflect.EnumType

type ConfigSpec 

type ConfigSpec struct {

	// Version of Apache Kafka® used in the cluster. Possible values: `2.1`, `2.6`.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Configuration and resource allocation for Kafka brokers.
	Kafka *ConfigSpec_Kafka `protobuf:"bytes,2,opt,name=kafka,proto3" json:"kafka,omitempty"`
	// Configuration and resource allocation for ZooKeeper hosts.
	Zookeeper *ConfigSpec_Zookeeper `protobuf:"bytes,3,opt,name=zookeeper,proto3" json:"zookeeper,omitempty"`
	// IDs of availability zones where Kafka brokers reside.
	ZoneId []string `protobuf:"bytes,4,rep,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty"`
	// The number of Kafka brokers deployed in each availability zone.
	BrokersCount *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=brokers_count,json=brokersCount,proto3" json:"brokers_count,omitempty"`
	// The flag that defines whether a public IP address is assigned to the cluster.
	// If the value is `true`, then Apache Kafka® cluster is available on the Internet via it's public IP address.
	AssignPublicIp bool `protobuf:"varint,6,opt,name=assign_public_ip,json=assignPublicIp,proto3" json:"assign_public_ip,omitempty"`
	// Allows to manage topics via AdminAPI
	// Deprecated. Feature enabled permanently.
	//
	// Deprecated: Marked as deprecated in yandex/cloud/mdb/kafka/v1/cluster.proto.
	UnmanagedTopics bool `protobuf:"varint,7,opt,name=unmanaged_topics,json=unmanagedTopics,proto3" json:"unmanaged_topics,omitempty"`
	// Enables managed schema registry on cluster
	SchemaRegistry bool `protobuf:"varint,8,opt,name=schema_registry,json=schemaRegistry,proto3" json:"schema_registry,omitempty"`
	// Access policy for external services.
	Access *Access `protobuf:"bytes,9,opt,name=access,proto3" json:"access,omitempty"`
	// Configuration of REST API.
	RestApiConfig *ConfigSpec_RestAPIConfig `protobuf:"bytes,10,opt,name=rest_api_config,json=restApiConfig,proto3" json:"rest_api_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigSpec) Descriptor deprecated 

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

Deprecated: Use ConfigSpec.ProtoReflect.Descriptor instead.

func (*ConfigSpec) GetAccess 

func (x *ConfigSpec) GetAccess() *Access

func (*ConfigSpec) GetAssignPublicIp 

func (x *ConfigSpec) GetAssignPublicIp() bool

func (*ConfigSpec) GetBrokersCount 

func (x *ConfigSpec) GetBrokersCount() *wrapperspb.Int64Value

func (*ConfigSpec) GetKafka 

func (x *ConfigSpec) GetKafka() *ConfigSpec_Kafka

func (*ConfigSpec) GetRestApiConfig 

func (x *ConfigSpec) GetRestApiConfig() *ConfigSpec_RestAPIConfig

func (*ConfigSpec) GetSchemaRegistry 

func (x *ConfigSpec) GetSchemaRegistry() bool

func (*ConfigSpec) GetUnmanagedTopics deprecated 

func (x *ConfigSpec) GetUnmanagedTopics() bool

Deprecated: Marked as deprecated in yandex/cloud/mdb/kafka/v1/cluster.proto.

func (*ConfigSpec) GetVersion 

func (x *ConfigSpec) GetVersion() string

func (*ConfigSpec) GetZoneId 

func (x *ConfigSpec) GetZoneId() []string

func (*ConfigSpec) GetZookeeper 

func (x *ConfigSpec) GetZookeeper() *ConfigSpec_Zookeeper

func (*ConfigSpec) ProtoMessage 

func (*ConfigSpec) ProtoMessage()

func (*ConfigSpec) ProtoReflect 

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

func (*ConfigSpec) Reset 

func (x *ConfigSpec) Reset()

func (*ConfigSpec) SetAccess 

func (m *ConfigSpec) SetAccess(v *Access)

func (*ConfigSpec) SetAssignPublicIp 

func (m *ConfigSpec) SetAssignPublicIp(v bool)

func (*ConfigSpec) SetBrokersCount 

func (m *ConfigSpec) SetBrokersCount(v *wrapperspb.Int64Value)

func (*ConfigSpec) SetKafka 

func (m *ConfigSpec) SetKafka(v *ConfigSpec_Kafka)

func (*ConfigSpec) SetRestApiConfig 

func (m *ConfigSpec) SetRestApiConfig(v *ConfigSpec_RestAPIConfig)

func (*ConfigSpec) SetSchemaRegistry 

func (m *ConfigSpec) SetSchemaRegistry(v bool)

func (*ConfigSpec) SetUnmanagedTopics 

func (m *ConfigSpec) SetUnmanagedTopics(v bool)

func (*ConfigSpec) SetVersion 

func (m *ConfigSpec) SetVersion(v string)

func (*ConfigSpec) SetZoneId 

func (m *ConfigSpec) SetZoneId(v []string)

func (*ConfigSpec) SetZookeeper 

func (m *ConfigSpec) SetZookeeper(v *ConfigSpec_Zookeeper)

func (*ConfigSpec) String 

func (x *ConfigSpec) String() string

type ConfigSpec_Kafka 

type ConfigSpec_Kafka struct {

	// Resources allocated to Kafka brokers.
	Resources *Resources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
	// Kafka broker configuration.
	//
	// Types that are assignable to KafkaConfig:
	//
	//	*ConfigSpec_Kafka_KafkaConfig_2_8
	//	*ConfigSpec_Kafka_KafkaConfig_3
	KafkaConfig isConfigSpec_Kafka_KafkaConfig `protobuf_oneof:"kafka_config"`
	// contains filtered or unexported fields
}

func (*ConfigSpec_Kafka) Descriptor deprecated 

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

Deprecated: Use ConfigSpec_Kafka.ProtoReflect.Descriptor instead.

func (*ConfigSpec_Kafka) GetKafkaConfig 

func (m *ConfigSpec_Kafka) GetKafkaConfig() isConfigSpec_Kafka_KafkaConfig

func (*ConfigSpec_Kafka) GetKafkaConfig_2_8 

func (x *ConfigSpec_Kafka) GetKafkaConfig_2_8() *KafkaConfig2_8

func (*ConfigSpec_Kafka) GetKafkaConfig_3 

func (x *ConfigSpec_Kafka) GetKafkaConfig_3() *KafkaConfig3

func (*ConfigSpec_Kafka) GetResources 

func (x *ConfigSpec_Kafka) GetResources() *Resources

func (*ConfigSpec_Kafka) ProtoMessage 

func (*ConfigSpec_Kafka) ProtoMessage()

func (*ConfigSpec_Kafka) ProtoReflect 

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

func (*ConfigSpec_Kafka) Reset 

func (x *ConfigSpec_Kafka) Reset()

func (*ConfigSpec_Kafka) SetKafkaConfig 

func (m *ConfigSpec_Kafka) SetKafkaConfig(v ConfigSpec_Kafka_KafkaConfig)

func (*ConfigSpec_Kafka) SetKafkaConfig_2_8 

func (m *ConfigSpec_Kafka) SetKafkaConfig_2_8(v *KafkaConfig2_8)

func (*ConfigSpec_Kafka) SetKafkaConfig_3 

func (m *ConfigSpec_Kafka) SetKafkaConfig_3(v *KafkaConfig3)

func (*ConfigSpec_Kafka) SetResources 

func (m *ConfigSpec_Kafka) SetResources(v *Resources)

func (*ConfigSpec_Kafka) String 

func (x *ConfigSpec_Kafka) String() string

type ConfigSpec_Kafka_KafkaConfig 

type ConfigSpec_Kafka_KafkaConfig = isConfigSpec_Kafka_KafkaConfig

type ConfigSpec_Kafka_KafkaConfig_2_8 

type ConfigSpec_Kafka_KafkaConfig_2_8 struct {
	KafkaConfig_2_8 *KafkaConfig2_8 `protobuf:"bytes,4,opt,name=kafka_config_2_8,json=kafkaConfig_2_8,proto3,oneof"`
}

type ConfigSpec_Kafka_KafkaConfig_3 

type ConfigSpec_Kafka_KafkaConfig_3 struct {
	KafkaConfig_3 *KafkaConfig3 `protobuf:"bytes,5,opt,name=kafka_config_3,json=kafkaConfig_3,proto3,oneof"`
}

type ConfigSpec_RestAPIConfig 

type ConfigSpec_RestAPIConfig struct {

	// Is REST API enabled for this cluster.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigSpec_RestAPIConfig) Descriptor deprecated 

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

Deprecated: Use ConfigSpec_RestAPIConfig.ProtoReflect.Descriptor instead.

func (*ConfigSpec_RestAPIConfig) GetEnabled 

func (x *ConfigSpec_RestAPIConfig) GetEnabled() bool

func (*ConfigSpec_RestAPIConfig) ProtoMessage 

func (*ConfigSpec_RestAPIConfig) ProtoMessage()

func (*ConfigSpec_RestAPIConfig) ProtoReflect 

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

func (*ConfigSpec_RestAPIConfig) Reset 

func (x *ConfigSpec_RestAPIConfig) Reset()

func (*ConfigSpec_RestAPIConfig) SetEnabled 

func (m *ConfigSpec_RestAPIConfig) SetEnabled(v bool)

func (*ConfigSpec_RestAPIConfig) String 

func (x *ConfigSpec_RestAPIConfig) String() string

type ConfigSpec_Zookeeper 

type ConfigSpec_Zookeeper struct {

	// Resources allocated to ZooKeeper hosts.
	Resources *Resources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigSpec_Zookeeper) Descriptor deprecated 

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

Deprecated: Use ConfigSpec_Zookeeper.ProtoReflect.Descriptor instead.

func (*ConfigSpec_Zookeeper) GetResources 

func (x *ConfigSpec_Zookeeper) GetResources() *Resources

func (*ConfigSpec_Zookeeper) ProtoMessage 

func (*ConfigSpec_Zookeeper) ProtoMessage()

func (*ConfigSpec_Zookeeper) ProtoReflect 

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

func (*ConfigSpec_Zookeeper) Reset 

func (x *ConfigSpec_Zookeeper) Reset()

func (*ConfigSpec_Zookeeper) SetResources 

func (m *ConfigSpec_Zookeeper) SetResources(v *Resources)

func (*ConfigSpec_Zookeeper) String 

func (x *ConfigSpec_Zookeeper) String() string

type Connector 

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=yandex.cloud.mdb.kafka.v1.Connector_Health" json:"health,omitempty"`
	// Current status of the connector.
	Status Connector_Status `protobuf:"varint,5,opt,name=status,proto3,enum=yandex.cloud.mdb.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
}

func (*Connector) Descriptor deprecated 

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

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetClusterId 

func (x *Connector) GetClusterId() string

func (*Connector) GetConnectorConfig 

func (m *Connector) GetConnectorConfig() isConnector_ConnectorConfig

func (*Connector) GetConnectorConfigMirrormaker 

func (x *Connector) GetConnectorConfigMirrormaker() *ConnectorConfigMirrorMaker

func (*Connector) GetConnectorConfigS3Sink 

func (x *Connector) GetConnectorConfigS3Sink() *ConnectorConfigS3Sink

func (*Connector) GetHealth 

func (x *Connector) GetHealth() Connector_Health

func (*Connector) GetName 

func (x *Connector) GetName() string

func (*Connector) GetProperties 

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

func (*Connector) GetStatus 

func (x *Connector) GetStatus() Connector_Status

func (*Connector) GetTasksMax 

func (x *Connector) GetTasksMax() *wrapperspb.Int64Value

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect 

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

func (*Connector) Reset 

func (x *Connector) Reset()

func (*Connector) SetClusterId 

func (m *Connector) SetClusterId(v string)

func (*Connector) SetConnectorConfig 

func (m *Connector) SetConnectorConfig(v Connector_ConnectorConfig)

func (*Connector) SetConnectorConfigMirrormaker 

func (m *Connector) SetConnectorConfigMirrormaker(v *ConnectorConfigMirrorMaker)

func (*Connector) SetConnectorConfigS3Sink 

func (m *Connector) SetConnectorConfigS3Sink(v *ConnectorConfigS3Sink)

func (*Connector) SetHealth 

func (m *Connector) SetHealth(v Connector_Health)

func (*Connector) SetName 

func (m *Connector) SetName(v string)

func (*Connector) SetProperties 

func (m *Connector) SetProperties(v map[string]string)

func (*Connector) SetStatus 

func (m *Connector) SetStatus(v Connector_Status)

func (*Connector) SetTasksMax 

func (m *Connector) SetTasksMax(v *wrapperspb.Int64Value)

func (*Connector) String 

func (x *Connector) String() string

type ConnectorConfigMirrorMaker 

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
}

func (*ConnectorConfigMirrorMaker) Descriptor deprecated 

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

Deprecated: Use ConnectorConfigMirrorMaker.ProtoReflect.Descriptor instead.

func (*ConnectorConfigMirrorMaker) GetReplicationFactor 

func (x *ConnectorConfigMirrorMaker) GetReplicationFactor() *wrapperspb.Int64Value

func (*ConnectorConfigMirrorMaker) GetSourceCluster 

func (x *ConnectorConfigMirrorMaker) GetSourceCluster() *ClusterConnection

func (*ConnectorConfigMirrorMaker) GetTargetCluster 

func (x *ConnectorConfigMirrorMaker) GetTargetCluster() *ClusterConnection

func (*ConnectorConfigMirrorMaker) GetTopics 

func (x *ConnectorConfigMirrorMaker) GetTopics() string

func (*ConnectorConfigMirrorMaker) ProtoMessage 

func (*ConnectorConfigMirrorMaker) ProtoMessage()

func (*ConnectorConfigMirrorMaker) ProtoReflect 

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

func (*ConnectorConfigMirrorMaker) Reset 

func (x *ConnectorConfigMirrorMaker) Reset()

func (*ConnectorConfigMirrorMaker) SetReplicationFactor 

func (m *ConnectorConfigMirrorMaker) SetReplicationFactor(v *wrapperspb.Int64Value)

func (*ConnectorConfigMirrorMaker) SetSourceCluster 

func (m *ConnectorConfigMirrorMaker) SetSourceCluster(v *ClusterConnection)

func (*ConnectorConfigMirrorMaker) SetTargetCluster 

func (m *ConnectorConfigMirrorMaker) SetTargetCluster(v *ClusterConnection)

func (*ConnectorConfigMirrorMaker) SetTopics 

func (m *ConnectorConfigMirrorMaker) SetTopics(v string)

func (*ConnectorConfigMirrorMaker) String 

func (x *ConnectorConfigMirrorMaker) String() string

type ConnectorConfigMirrorMakerSpec 

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
}

func (*ConnectorConfigMirrorMakerSpec) Descriptor deprecated 

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

Deprecated: Use ConnectorConfigMirrorMakerSpec.ProtoReflect.Descriptor instead.

func (*ConnectorConfigMirrorMakerSpec) GetReplicationFactor 

func (x *ConnectorConfigMirrorMakerSpec) GetReplicationFactor() *wrapperspb.Int64Value

func (*ConnectorConfigMirrorMakerSpec) GetSourceCluster 

func (x *ConnectorConfigMirrorMakerSpec) GetSourceCluster() *ClusterConnectionSpec

func (*ConnectorConfigMirrorMakerSpec) GetTargetCluster 

func (x *ConnectorConfigMirrorMakerSpec) GetTargetCluster() *ClusterConnectionSpec

func (*ConnectorConfigMirrorMakerSpec) GetTopics 

func (x *ConnectorConfigMirrorMakerSpec) GetTopics() string

func (*ConnectorConfigMirrorMakerSpec) ProtoMessage 

func (*ConnectorConfigMirrorMakerSpec) ProtoMessage()

func (*ConnectorConfigMirrorMakerSpec) ProtoReflect 

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

func (*ConnectorConfigMirrorMakerSpec) Reset 

func (x *ConnectorConfigMirrorMakerSpec) Reset()

func (*ConnectorConfigMirrorMakerSpec) SetReplicationFactor 

func (m *ConnectorConfigMirrorMakerSpec) SetReplicationFactor(v *wrapperspb.Int64Value)

func (*ConnectorConfigMirrorMakerSpec) SetSourceCluster 

func (m *ConnectorConfigMirrorMakerSpec) SetSourceCluster(v *ClusterConnectionSpec)

func (*ConnectorConfigMirrorMakerSpec) SetTargetCluster 

func (m *ConnectorConfigMirrorMakerSpec) SetTargetCluster(v *ClusterConnectionSpec)

func (*ConnectorConfigMirrorMakerSpec) SetTopics 

func (m *ConnectorConfigMirrorMakerSpec) SetTopics(v string)

func (*ConnectorConfigMirrorMakerSpec) String 

func (x *ConnectorConfigMirrorMakerSpec) String() string

type ConnectorConfigS3Sink 

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 GCS.
	// The supported values are: `gzip`, `snappy`, `zstd`, `none`.
	// Optional, the default is `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
}

An Apache Kafka® S3-Sink connector resource.

func (*ConnectorConfigS3Sink) Descriptor deprecated 

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

Deprecated: Use ConnectorConfigS3Sink.ProtoReflect.Descriptor instead.

func (*ConnectorConfigS3Sink) GetFileCompressionType 

func (x *ConnectorConfigS3Sink) GetFileCompressionType() string

func (*ConnectorConfigS3Sink) GetFileMaxRecords 

func (x *ConnectorConfigS3Sink) GetFileMaxRecords() *wrapperspb.Int64Value

func (*ConnectorConfigS3Sink) GetS3Connection 

func (x *ConnectorConfigS3Sink) GetS3Connection() *S3Connection

func (*ConnectorConfigS3Sink) GetTopics 

func (x *ConnectorConfigS3Sink) GetTopics() string

func (*ConnectorConfigS3Sink) ProtoMessage 

func (*ConnectorConfigS3Sink) ProtoMessage()

func (*ConnectorConfigS3Sink) ProtoReflect 

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

func (*ConnectorConfigS3Sink) Reset 

func (x *ConnectorConfigS3Sink) Reset()

func (*ConnectorConfigS3Sink) SetFileCompressionType 

func (m *ConnectorConfigS3Sink) SetFileCompressionType(v string)

func (*ConnectorConfigS3Sink) SetFileMaxRecords 

func (m *ConnectorConfigS3Sink) SetFileMaxRecords(v *wrapperspb.Int64Value)

func (*ConnectorConfigS3Sink) SetS3Connection 

func (m *ConnectorConfigS3Sink) SetS3Connection(v *S3Connection)

func (*ConnectorConfigS3Sink) SetTopics 

func (m *ConnectorConfigS3Sink) SetTopics(v string)

func (*ConnectorConfigS3Sink) String 

func (x *ConnectorConfigS3Sink) String() string

type ConnectorConfigS3SinkSpec 

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 GCS.
	// The supported values are: `gzip`, `snappy`, `zstd`, `none`.
	// Optional, the default is `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
}

Specification for Kafka S3-Sink Connector.

func (*ConnectorConfigS3SinkSpec) Descriptor deprecated 

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

Deprecated: Use ConnectorConfigS3SinkSpec.ProtoReflect.Descriptor instead.

func (*ConnectorConfigS3SinkSpec) GetFileCompressionType 

func (x *ConnectorConfigS3SinkSpec) GetFileCompressionType() string

func (*ConnectorConfigS3SinkSpec) GetFileMaxRecords 

func (x *ConnectorConfigS3SinkSpec) GetFileMaxRecords() *wrapperspb.Int64Value

func (*ConnectorConfigS3SinkSpec) GetS3Connection 

func (x *ConnectorConfigS3SinkSpec) GetS3Connection() *S3ConnectionSpec

func (*ConnectorConfigS3SinkSpec) GetTopics 

func (x *ConnectorConfigS3SinkSpec) GetTopics() string

func (*ConnectorConfigS3SinkSpec) ProtoMessage 

func (*ConnectorConfigS3SinkSpec) ProtoMessage()

func (*ConnectorConfigS3SinkSpec) ProtoReflect 

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

func (*ConnectorConfigS3SinkSpec) Reset 

func (x *ConnectorConfigS3SinkSpec) Reset()

func (*ConnectorConfigS3SinkSpec) SetFileCompressionType 

func (m *ConnectorConfigS3SinkSpec) SetFileCompressionType(v string)

func (*ConnectorConfigS3SinkSpec) SetFileMaxRecords 

func (m *ConnectorConfigS3SinkSpec) SetFileMaxRecords(v *wrapperspb.Int64Value)

func (*ConnectorConfigS3SinkSpec) SetS3Connection 

func (m *ConnectorConfigS3SinkSpec) SetS3Connection(v *S3ConnectionSpec)

func (*ConnectorConfigS3SinkSpec) SetTopics 

func (m *ConnectorConfigS3SinkSpec) SetTopics(v string)

func (*ConnectorConfigS3SinkSpec) String 

func (x *ConnectorConfigS3SinkSpec) String() string

type ConnectorServiceClient 

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) (*operation.Operation, error)
	// Updates an Apache Kafka® connector.
	Update(ctx context.Context, in *UpdateConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes an Apache Kafka® connector.
	Delete(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Resumes an Apache Kafka® connector.
	Resume(ctx context.Context, in *ResumeConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Pauses an Apache Kafka® connector.
	Pause(ctx context.Context, in *PauseConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

ConnectorServiceClient is the client API for ConnectorService 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 NewConnectorServiceClient 

func NewConnectorServiceClient(cc grpc.ClientConnInterface) ConnectorServiceClient

type ConnectorServiceServer 

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) (*operation.Operation, error)
	// Updates an Apache Kafka® connector.
	Update(context.Context, *UpdateConnectorRequest) (*operation.Operation, error)
	// Deletes an Apache Kafka® connector.
	Delete(context.Context, *DeleteConnectorRequest) (*operation.Operation, error)
	// Resumes an Apache Kafka® connector.
	Resume(context.Context, *ResumeConnectorRequest) (*operation.Operation, error)
	// Pauses an Apache Kafka® connector.
	Pause(context.Context, *PauseConnectorRequest) (*operation.Operation, error)
}

ConnectorServiceServer is the server API for ConnectorService service. All implementations should embed UnimplementedConnectorServiceServer for forward compatibility

type ConnectorSpec 

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
}

An object that represents an Apache Kafka® connector.

See [the documentation](/docs/managed-kafka/concepts/connectors) for details.

func (*ConnectorSpec) Descriptor deprecated 

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

Deprecated: Use ConnectorSpec.ProtoReflect.Descriptor instead.

func (*ConnectorSpec) GetConnectorConfig 

func (m *ConnectorSpec) GetConnectorConfig() isConnectorSpec_ConnectorConfig

func (*ConnectorSpec) GetConnectorConfigMirrormaker 

func (x *ConnectorSpec) GetConnectorConfigMirrormaker() *ConnectorConfigMirrorMakerSpec

func (*ConnectorSpec) GetConnectorConfigS3Sink 

func (x *ConnectorSpec) GetConnectorConfigS3Sink() *ConnectorConfigS3SinkSpec

func (*ConnectorSpec) GetName 

func (x *ConnectorSpec) GetName() string

func (*ConnectorSpec) GetProperties 

func (x *ConnectorSpec) GetProperties() map[string]string

func (*ConnectorSpec) GetTasksMax 

func (x *ConnectorSpec) GetTasksMax() *wrapperspb.Int64Value

func (*ConnectorSpec) ProtoMessage 

func (*ConnectorSpec) ProtoMessage()

func (*ConnectorSpec) ProtoReflect 

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

func (*ConnectorSpec) Reset 

func (x *ConnectorSpec) Reset()

func (*ConnectorSpec) SetConnectorConfig 

func (m *ConnectorSpec) SetConnectorConfig(v ConnectorSpec_ConnectorConfig)

func (*ConnectorSpec) SetConnectorConfigMirrormaker 

func (m *ConnectorSpec) SetConnectorConfigMirrormaker(v *ConnectorConfigMirrorMakerSpec)

func (*ConnectorSpec) SetConnectorConfigS3Sink 

func (m *ConnectorSpec) SetConnectorConfigS3Sink(v *ConnectorConfigS3SinkSpec)

func (*ConnectorSpec) SetName 

func (m *ConnectorSpec) SetName(v string)

func (*ConnectorSpec) SetProperties 

func (m *ConnectorSpec) SetProperties(v map[string]string)

func (*ConnectorSpec) SetTasksMax 

func (m *ConnectorSpec) SetTasksMax(v *wrapperspb.Int64Value)

func (*ConnectorSpec) String 

func (x *ConnectorSpec) String() string

type ConnectorSpec_ConnectorConfig 

type ConnectorSpec_ConnectorConfig = isConnectorSpec_ConnectorConfig

type ConnectorSpec_ConnectorConfigMirrormaker 

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 

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_ConnectorConfig 

type Connector_ConnectorConfig = isConnector_ConnectorConfig

type Connector_ConnectorConfigMirrormaker 

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 

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 

type Connector_Health int32
const (
	// Health of the connector is unknown.
	Connector_HEALTH_UNKNOWN Connector_Health = 0
	// Connector is running.
	Connector_ALIVE Connector_Health = 1
	// Connector has failed to start.
	Connector_DEAD Connector_Health = 2
)

func (Connector_Health) Descriptor 

func (Connector_Health) Descriptor() protoreflect.EnumDescriptor

func (Connector_Health) Enum 

func (x Connector_Health) Enum() *Connector_Health

func (Connector_Health) EnumDescriptor deprecated 

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

Deprecated: Use Connector_Health.Descriptor instead.

func (Connector_Health) Number 

func (x Connector_Health) Number() protoreflect.EnumNumber

func (Connector_Health) String 

func (x Connector_Health) String() string

func (Connector_Health) Type 

func (Connector_Health) Type() protoreflect.EnumType

type Connector_Status 

type Connector_Status int32
const (
	// Connector state is unknown.
	Connector_STATUS_UNKNOWN Connector_Status = 0
	// Connector is running normally.
	Connector_RUNNING Connector_Status = 1
	// Connector has encountered a problem and cannot operate.
	Connector_ERROR Connector_Status = 2
	// Connector is paused.
	Connector_PAUSED Connector_Status = 3
)

func (Connector_Status) Descriptor 

func (Connector_Status) Descriptor() protoreflect.EnumDescriptor

func (Connector_Status) Enum 

func (x Connector_Status) Enum() *Connector_Status

func (Connector_Status) EnumDescriptor deprecated 

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

Deprecated: Use Connector_Status.Descriptor instead.

func (Connector_Status) Number 

func (x Connector_Status) Number() protoreflect.EnumNumber

func (Connector_Status) String 

func (x Connector_Status) String() string

func (Connector_Status) Type 

func (Connector_Status) Type() protoreflect.EnumType

type CreateClusterMetadata 

type CreateClusterMetadata struct {

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

func (*CreateClusterMetadata) Descriptor deprecated 

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

Deprecated: Use CreateClusterMetadata.ProtoReflect.Descriptor instead.

func (*CreateClusterMetadata) GetClusterId 

func (x *CreateClusterMetadata) GetClusterId() string

func (*CreateClusterMetadata) ProtoMessage 

func (*CreateClusterMetadata) ProtoMessage()

func (*CreateClusterMetadata) ProtoReflect 

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

func (*CreateClusterMetadata) Reset 

func (x *CreateClusterMetadata) Reset()

func (*CreateClusterMetadata) SetClusterId 

func (m *CreateClusterMetadata) SetClusterId(v string)

func (*CreateClusterMetadata) String 

func (x *CreateClusterMetadata) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {

	// ID of the folder to create the Apache Kafka® cluster in.
	//
	// To get the folder ID, make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the Apache Kafka® cluster. The name must be unique within the folder.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the Apache Kafka® cluster.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Custom labels for the Apache Kafka® cluster as `key:value` pairs.
	//
	// For example, "project": "mvp" or "source": "dictionary".
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Deployment environment of the Apache Kafka® cluster.
	Environment Cluster_Environment `` /* 127-byte string literal not displayed */
	// Kafka and hosts configuration the Apache Kafka® cluster.
	ConfigSpec *ConfigSpec `protobuf:"bytes,6,opt,name=config_spec,json=configSpec,proto3" json:"config_spec,omitempty"`
	// One or more configurations of topics to be created in the Apache Kafka® cluster.
	TopicSpecs []*TopicSpec `protobuf:"bytes,7,rep,name=topic_specs,json=topicSpecs,proto3" json:"topic_specs,omitempty"`
	// Configurations of accounts to be created in the Apache Kafka® cluster.
	UserSpecs []*UserSpec `protobuf:"bytes,8,rep,name=user_specs,json=userSpecs,proto3" json:"user_specs,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"`
	// IDs of subnets to create brokers in.
	SubnetId []string `protobuf:"bytes,11,rep,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	// User security groups
	SecurityGroupIds []string `protobuf:"bytes,12,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"`
	// Host groups to place VMs of cluster on.
	HostGroupIds []string `protobuf:"bytes,13,rep,name=host_group_ids,json=hostGroupIds,proto3" json:"host_group_ids,omitempty"`
	// Deletion Protection inhibits deletion of the cluster
	DeletionProtection bool `protobuf:"varint,14,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Window of maintenance operations.
	MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,15,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateClusterRequest) Descriptor deprecated 

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetConfigSpec 

func (x *CreateClusterRequest) GetConfigSpec() *ConfigSpec

func (*CreateClusterRequest) GetDeletionProtection 

func (x *CreateClusterRequest) GetDeletionProtection() bool

func (*CreateClusterRequest) GetDescription 

func (x *CreateClusterRequest) GetDescription() string

func (*CreateClusterRequest) GetEnvironment 

func (x *CreateClusterRequest) GetEnvironment() Cluster_Environment

func (*CreateClusterRequest) GetFolderId 

func (x *CreateClusterRequest) GetFolderId() string

func (*CreateClusterRequest) GetHostGroupIds 

func (x *CreateClusterRequest) GetHostGroupIds() []string

func (*CreateClusterRequest) GetLabels 

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

func (*CreateClusterRequest) GetMaintenanceWindow 

func (x *CreateClusterRequest) GetMaintenanceWindow() *MaintenanceWindow

func (*CreateClusterRequest) GetName 

func (x *CreateClusterRequest) GetName() string

func (*CreateClusterRequest) GetNetworkId 

func (x *CreateClusterRequest) GetNetworkId() string

func (*CreateClusterRequest) GetSecurityGroupIds 

func (x *CreateClusterRequest) GetSecurityGroupIds() []string

func (*CreateClusterRequest) GetSubnetId 

func (x *CreateClusterRequest) GetSubnetId() []string

func (*CreateClusterRequest) GetTopicSpecs 

func (x *CreateClusterRequest) GetTopicSpecs() []*TopicSpec

func (*CreateClusterRequest) GetUserSpecs 

func (x *CreateClusterRequest) GetUserSpecs() []*UserSpec

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

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

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) SetConfigSpec 

func (m *CreateClusterRequest) SetConfigSpec(v *ConfigSpec)

func (*CreateClusterRequest) SetDeletionProtection 

func (m *CreateClusterRequest) SetDeletionProtection(v bool)

func (*CreateClusterRequest) SetDescription 

func (m *CreateClusterRequest) SetDescription(v string)

func (*CreateClusterRequest) SetEnvironment 

func (m *CreateClusterRequest) SetEnvironment(v Cluster_Environment)

func (*CreateClusterRequest) SetFolderId 

func (m *CreateClusterRequest) SetFolderId(v string)

func (*CreateClusterRequest) SetHostGroupIds 

func (m *CreateClusterRequest) SetHostGroupIds(v []string)

func (*CreateClusterRequest) SetLabels 

func (m *CreateClusterRequest) SetLabels(v map[string]string)

func (*CreateClusterRequest) SetMaintenanceWindow 

func (m *CreateClusterRequest) SetMaintenanceWindow(v *MaintenanceWindow)

func (*CreateClusterRequest) SetName 

func (m *CreateClusterRequest) SetName(v string)

func (*CreateClusterRequest) SetNetworkId 

func (m *CreateClusterRequest) SetNetworkId(v string)

func (*CreateClusterRequest) SetSecurityGroupIds 

func (m *CreateClusterRequest) SetSecurityGroupIds(v []string)

func (*CreateClusterRequest) SetSubnetId 

func (m *CreateClusterRequest) SetSubnetId(v []string)

func (*CreateClusterRequest) SetTopicSpecs 

func (m *CreateClusterRequest) SetTopicSpecs(v []*TopicSpec)

func (*CreateClusterRequest) SetUserSpecs 

func (m *CreateClusterRequest) SetUserSpecs(v []*UserSpec)

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type CreateConnectorMetadata 

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
}

func (*CreateConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use CreateConnectorMetadata.ProtoReflect.Descriptor instead.

func (*CreateConnectorMetadata) GetClusterId 

func (x *CreateConnectorMetadata) GetClusterId() string

func (*CreateConnectorMetadata) GetConnectorName 

func (x *CreateConnectorMetadata) GetConnectorName() string

func (*CreateConnectorMetadata) ProtoMessage 

func (*CreateConnectorMetadata) ProtoMessage()

func (*CreateConnectorMetadata) ProtoReflect 

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

func (*CreateConnectorMetadata) Reset 

func (x *CreateConnectorMetadata) Reset()

func (*CreateConnectorMetadata) SetClusterId 

func (m *CreateConnectorMetadata) SetClusterId(v string)

func (*CreateConnectorMetadata) SetConnectorName 

func (m *CreateConnectorMetadata) SetConnectorName(v string)

func (*CreateConnectorMetadata) String 

func (x *CreateConnectorMetadata) String() string

type CreateConnectorRequest 

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
}

func (*CreateConnectorRequest) Descriptor deprecated 

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

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetClusterId 

func (x *CreateConnectorRequest) GetClusterId() string

func (*CreateConnectorRequest) GetConnectorSpec 

func (x *CreateConnectorRequest) GetConnectorSpec() *ConnectorSpec

func (*CreateConnectorRequest) ProtoMessage 

func (*CreateConnectorRequest) ProtoMessage()

func (*CreateConnectorRequest) ProtoReflect 

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

func (*CreateConnectorRequest) Reset 

func (x *CreateConnectorRequest) Reset()

func (*CreateConnectorRequest) SetClusterId 

func (m *CreateConnectorRequest) SetClusterId(v string)

func (*CreateConnectorRequest) SetConnectorSpec 

func (m *CreateConnectorRequest) SetConnectorSpec(v *ConnectorSpec)

func (*CreateConnectorRequest) String 

func (x *CreateConnectorRequest) String() string

type CreateTopicMetadata 

type CreateTopicMetadata struct {

	// ID of the Apache Kafka® cluster where a topic is being created.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the Kafka topic that is being created.
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicMetadata) Descriptor deprecated 

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

Deprecated: Use CreateTopicMetadata.ProtoReflect.Descriptor instead.

func (*CreateTopicMetadata) GetClusterId 

func (x *CreateTopicMetadata) GetClusterId() string

func (*CreateTopicMetadata) GetTopicName 

func (x *CreateTopicMetadata) GetTopicName() string

func (*CreateTopicMetadata) ProtoMessage 

func (*CreateTopicMetadata) ProtoMessage()

func (*CreateTopicMetadata) ProtoReflect 

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

func (*CreateTopicMetadata) Reset 

func (x *CreateTopicMetadata) Reset()

func (*CreateTopicMetadata) SetClusterId 

func (m *CreateTopicMetadata) SetClusterId(v string)

func (*CreateTopicMetadata) SetTopicName 

func (m *CreateTopicMetadata) SetTopicName(v string)

func (*CreateTopicMetadata) String 

func (x *CreateTopicMetadata) String() string

type CreateTopicRequest 

type CreateTopicRequest struct {

	// ID of the Apache Kafka® cluster to create a topic in.
	//
	// To get the cluster 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 topic to create.
	TopicSpec *TopicSpec `protobuf:"bytes,2,opt,name=topic_spec,json=topicSpec,proto3" json:"topic_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetClusterId 

func (x *CreateTopicRequest) GetClusterId() string

func (*CreateTopicRequest) GetTopicSpec 

func (x *CreateTopicRequest) GetTopicSpec() *TopicSpec

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

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

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) SetClusterId 

func (m *CreateTopicRequest) SetClusterId(v string)

func (*CreateTopicRequest) SetTopicSpec 

func (m *CreateTopicRequest) SetTopicSpec(v *TopicSpec)

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

type CreateUserMetadata 

type CreateUserMetadata struct {

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

func (*CreateUserMetadata) Descriptor deprecated 

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

Deprecated: Use CreateUserMetadata.ProtoReflect.Descriptor instead.

func (*CreateUserMetadata) GetClusterId 

func (x *CreateUserMetadata) GetClusterId() string

func (*CreateUserMetadata) GetUserName 

func (x *CreateUserMetadata) GetUserName() string

func (*CreateUserMetadata) ProtoMessage 

func (*CreateUserMetadata) ProtoMessage()

func (*CreateUserMetadata) ProtoReflect 

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

func (*CreateUserMetadata) Reset 

func (x *CreateUserMetadata) Reset()

func (*CreateUserMetadata) SetClusterId 

func (m *CreateUserMetadata) SetClusterId(v string)

func (*CreateUserMetadata) SetUserName 

func (m *CreateUserMetadata) SetUserName(v string)

func (*CreateUserMetadata) String 

func (x *CreateUserMetadata) String() string

type CreateUserRequest 

type CreateUserRequest struct {

	// ID of the Apache Kafka® cluster to create a user in.
	//
	// To get the cluster 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 user to create.
	UserSpec *UserSpec `protobuf:"bytes,2,opt,name=user_spec,json=userSpec,proto3" json:"user_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserRequest) Descriptor deprecated 

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

Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.

func (*CreateUserRequest) GetClusterId 

func (x *CreateUserRequest) GetClusterId() string

func (*CreateUserRequest) GetUserSpec 

func (x *CreateUserRequest) GetUserSpec() *UserSpec

func (*CreateUserRequest) ProtoMessage 

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) ProtoReflect 

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

func (*CreateUserRequest) Reset 

func (x *CreateUserRequest) Reset()

func (*CreateUserRequest) SetClusterId 

func (m *CreateUserRequest) SetClusterId(v string)

func (*CreateUserRequest) SetUserSpec 

func (m *CreateUserRequest) SetUserSpec(v *UserSpec)

func (*CreateUserRequest) String 

func (x *CreateUserRequest) String() string

type DeleteClusterMetadata 

type DeleteClusterMetadata struct {

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

func (*DeleteClusterMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteClusterMetadata.ProtoReflect.Descriptor instead.

func (*DeleteClusterMetadata) GetClusterId 

func (x *DeleteClusterMetadata) GetClusterId() string

func (*DeleteClusterMetadata) ProtoMessage 

func (*DeleteClusterMetadata) ProtoMessage()

func (*DeleteClusterMetadata) ProtoReflect 

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

func (*DeleteClusterMetadata) Reset 

func (x *DeleteClusterMetadata) Reset()

func (*DeleteClusterMetadata) SetClusterId 

func (m *DeleteClusterMetadata) SetClusterId(v string)

func (*DeleteClusterMetadata) String 

func (x *DeleteClusterMetadata) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {

	// ID of the Apache Kafka® cluster to delete.
	//
	// To get the Apache Kafka® cluster ID, make 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
}

func (*DeleteClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetClusterId 

func (x *DeleteClusterRequest) GetClusterId() 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) SetClusterId 

func (m *DeleteClusterRequest) SetClusterId(v string)

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteConnectorMetadata 

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
}

func (*DeleteConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteConnectorMetadata.ProtoReflect.Descriptor instead.

func (*DeleteConnectorMetadata) GetClusterId 

func (x *DeleteConnectorMetadata) GetClusterId() string

func (*DeleteConnectorMetadata) GetConnectorName 

func (x *DeleteConnectorMetadata) GetConnectorName() string

func (*DeleteConnectorMetadata) ProtoMessage 

func (*DeleteConnectorMetadata) ProtoMessage()

func (*DeleteConnectorMetadata) ProtoReflect 

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

func (*DeleteConnectorMetadata) Reset 

func (x *DeleteConnectorMetadata) Reset()

func (*DeleteConnectorMetadata) SetClusterId 

func (m *DeleteConnectorMetadata) SetClusterId(v string)

func (*DeleteConnectorMetadata) SetConnectorName 

func (m *DeleteConnectorMetadata) SetConnectorName(v string)

func (*DeleteConnectorMetadata) String 

func (x *DeleteConnectorMetadata) String() string

type DeleteConnectorRequest 

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
}

func (*DeleteConnectorRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetClusterId 

func (x *DeleteConnectorRequest) GetClusterId() string

func (*DeleteConnectorRequest) GetConnectorName 

func (x *DeleteConnectorRequest) GetConnectorName() string

func (*DeleteConnectorRequest) ProtoMessage 

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect 

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

func (*DeleteConnectorRequest) Reset 

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) SetClusterId 

func (m *DeleteConnectorRequest) SetClusterId(v string)

func (*DeleteConnectorRequest) SetConnectorName 

func (m *DeleteConnectorRequest) SetConnectorName(v string)

func (*DeleteConnectorRequest) String 

func (x *DeleteConnectorRequest) String() string

type DeleteTopicMetadata 

type DeleteTopicMetadata struct {

	// ID of the Apache Kafka® cluster where a topic is being deleted.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the Kafka topic that is being deleted.
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTopicMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteTopicMetadata.ProtoReflect.Descriptor instead.

func (*DeleteTopicMetadata) GetClusterId 

func (x *DeleteTopicMetadata) GetClusterId() string

func (*DeleteTopicMetadata) GetTopicName 

func (x *DeleteTopicMetadata) GetTopicName() string

func (*DeleteTopicMetadata) ProtoMessage 

func (*DeleteTopicMetadata) ProtoMessage()

func (*DeleteTopicMetadata) ProtoReflect 

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

func (*DeleteTopicMetadata) Reset 

func (x *DeleteTopicMetadata) Reset()

func (*DeleteTopicMetadata) SetClusterId 

func (m *DeleteTopicMetadata) SetClusterId(v string)

func (*DeleteTopicMetadata) SetTopicName 

func (m *DeleteTopicMetadata) SetTopicName(v string)

func (*DeleteTopicMetadata) String 

func (x *DeleteTopicMetadata) String() string

type DeleteTopicRequest 

type DeleteTopicRequest struct {

	// ID of the Apache Kafka® cluster to delete a topic in.
	//
	// To get the cluster 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 topic to delete.
	//
	// To get the name of the topic, make 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
}

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetClusterId 

func (x *DeleteTopicRequest) GetClusterId() string

func (*DeleteTopicRequest) GetTopicName 

func (x *DeleteTopicRequest) GetTopicName() 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) SetClusterId 

func (m *DeleteTopicRequest) SetClusterId(v string)

func (*DeleteTopicRequest) SetTopicName 

func (m *DeleteTopicRequest) SetTopicName(v string)

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

type DeleteUserMetadata 

type DeleteUserMetadata struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the user that is being deleted.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteUserMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteUserMetadata.ProtoReflect.Descriptor instead.

func (*DeleteUserMetadata) GetClusterId 

func (x *DeleteUserMetadata) GetClusterId() string

func (*DeleteUserMetadata) GetUserName 

func (x *DeleteUserMetadata) GetUserName() string

func (*DeleteUserMetadata) ProtoMessage 

func (*DeleteUserMetadata) ProtoMessage()

func (*DeleteUserMetadata) ProtoReflect 

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

func (*DeleteUserMetadata) Reset 

func (x *DeleteUserMetadata) Reset()

func (*DeleteUserMetadata) SetClusterId 

func (m *DeleteUserMetadata) SetClusterId(v string)

func (*DeleteUserMetadata) SetUserName 

func (m *DeleteUserMetadata) SetUserName(v string)

func (*DeleteUserMetadata) String 

func (x *DeleteUserMetadata) String() string

type DeleteUserRequest 

type DeleteUserRequest struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	// To get the cluster 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 user to delete.
	// To get the name of the user, make 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
}

func (*DeleteUserRequest) Descriptor deprecated 

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

Deprecated: Use DeleteUserRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserRequest) GetClusterId 

func (x *DeleteUserRequest) GetClusterId() string

func (*DeleteUserRequest) GetUserName 

func (x *DeleteUserRequest) GetUserName() string

func (*DeleteUserRequest) ProtoMessage 

func (*DeleteUserRequest) ProtoMessage()

func (*DeleteUserRequest) ProtoReflect 

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

func (*DeleteUserRequest) Reset 

func (x *DeleteUserRequest) Reset()

func (*DeleteUserRequest) SetClusterId 

func (m *DeleteUserRequest) SetClusterId(v string)

func (*DeleteUserRequest) SetUserName 

func (m *DeleteUserRequest) SetUserName(v string)

func (*DeleteUserRequest) String 

func (x *DeleteUserRequest) String() string

type ExternalClusterConnection 

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,4,opt,name=sasl_mechanism,json=saslMechanism,proto3" json:"sasl_mechanism,omitempty"`
	// Security protocol to use for connection to the cluster.
	SecurityProtocol string `protobuf:"bytes,5,opt,name=security_protocol,json=securityProtocol,proto3" json:"security_protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalClusterConnection) Descriptor deprecated 

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

Deprecated: Use ExternalClusterConnection.ProtoReflect.Descriptor instead.

func (*ExternalClusterConnection) GetBootstrapServers 

func (x *ExternalClusterConnection) GetBootstrapServers() string

func (*ExternalClusterConnection) GetSaslMechanism 

func (x *ExternalClusterConnection) GetSaslMechanism() string

func (*ExternalClusterConnection) GetSaslUsername 

func (x *ExternalClusterConnection) GetSaslUsername() string

func (*ExternalClusterConnection) GetSecurityProtocol 

func (x *ExternalClusterConnection) GetSecurityProtocol() string

func (*ExternalClusterConnection) ProtoMessage 

func (*ExternalClusterConnection) ProtoMessage()

func (*ExternalClusterConnection) ProtoReflect 

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

func (*ExternalClusterConnection) Reset 

func (x *ExternalClusterConnection) Reset()

func (*ExternalClusterConnection) SetBootstrapServers 

func (m *ExternalClusterConnection) SetBootstrapServers(v string)

func (*ExternalClusterConnection) SetSaslMechanism 

func (m *ExternalClusterConnection) SetSaslMechanism(v string)

func (*ExternalClusterConnection) SetSaslUsername 

func (m *ExternalClusterConnection) SetSaslUsername(v string)

func (*ExternalClusterConnection) SetSecurityProtocol 

func (m *ExternalClusterConnection) SetSecurityProtocol(v string)

func (*ExternalClusterConnection) String 

func (x *ExternalClusterConnection) String() string

type ExternalClusterConnectionSpec 

type ExternalClusterConnectionSpec 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 password to use for connection to the cluster.
	SaslPassword string `protobuf:"bytes,3,opt,name=sasl_password,json=saslPassword,proto3" json:"sasl_password,omitempty"`
	// SASL mechanism to use for connection to the cluster.
	SaslMechanism string `protobuf:"bytes,4,opt,name=sasl_mechanism,json=saslMechanism,proto3" json:"sasl_mechanism,omitempty"`
	// Security protocol to use for connection to the cluster.
	SecurityProtocol string `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 string `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExternalClusterConnectionSpec) Descriptor deprecated 

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

Deprecated: Use ExternalClusterConnectionSpec.ProtoReflect.Descriptor instead.

func (*ExternalClusterConnectionSpec) GetBootstrapServers 

func (x *ExternalClusterConnectionSpec) GetBootstrapServers() string

func (*ExternalClusterConnectionSpec) GetSaslMechanism 

func (x *ExternalClusterConnectionSpec) GetSaslMechanism() string

func (*ExternalClusterConnectionSpec) GetSaslPassword 

func (x *ExternalClusterConnectionSpec) GetSaslPassword() string

func (*ExternalClusterConnectionSpec) GetSaslUsername 

func (x *ExternalClusterConnectionSpec) GetSaslUsername() string

func (*ExternalClusterConnectionSpec) GetSecurityProtocol 

func (x *ExternalClusterConnectionSpec) GetSecurityProtocol() string

func (*ExternalClusterConnectionSpec) GetSslTruststoreCertificates 

func (x *ExternalClusterConnectionSpec) GetSslTruststoreCertificates() string

func (*ExternalClusterConnectionSpec) ProtoMessage 

func (*ExternalClusterConnectionSpec) ProtoMessage()

func (*ExternalClusterConnectionSpec) ProtoReflect 

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

func (*ExternalClusterConnectionSpec) Reset 

func (x *ExternalClusterConnectionSpec) Reset()

func (*ExternalClusterConnectionSpec) SetBootstrapServers 

func (m *ExternalClusterConnectionSpec) SetBootstrapServers(v string)

func (*ExternalClusterConnectionSpec) SetSaslMechanism 

func (m *ExternalClusterConnectionSpec) SetSaslMechanism(v string)

func (*ExternalClusterConnectionSpec) SetSaslPassword 

func (m *ExternalClusterConnectionSpec) SetSaslPassword(v string)

func (*ExternalClusterConnectionSpec) SetSaslUsername 

func (m *ExternalClusterConnectionSpec) SetSaslUsername(v string)

func (*ExternalClusterConnectionSpec) SetSecurityProtocol 

func (m *ExternalClusterConnectionSpec) SetSecurityProtocol(v string)

func (*ExternalClusterConnectionSpec) SetSslTruststoreCertificates 

func (m *ExternalClusterConnectionSpec) SetSslTruststoreCertificates(v string)

func (*ExternalClusterConnectionSpec) String 

func (x *ExternalClusterConnectionSpec) String() string

type ExternalS3Storage 

type ExternalS3Storage struct {
	AccessKeyId string `protobuf:"bytes,1,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	Endpoint    string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Default is 'us-east-1'
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalS3Storage) Descriptor deprecated 

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

Deprecated: Use ExternalS3Storage.ProtoReflect.Descriptor instead.

func (*ExternalS3Storage) GetAccessKeyId 

func (x *ExternalS3Storage) GetAccessKeyId() string

func (*ExternalS3Storage) GetEndpoint 

func (x *ExternalS3Storage) GetEndpoint() string

func (*ExternalS3Storage) GetRegion 

func (x *ExternalS3Storage) GetRegion() string

func (*ExternalS3Storage) ProtoMessage 

func (*ExternalS3Storage) ProtoMessage()

func (*ExternalS3Storage) ProtoReflect 

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

func (*ExternalS3Storage) Reset 

func (x *ExternalS3Storage) Reset()

func (*ExternalS3Storage) SetAccessKeyId 

func (m *ExternalS3Storage) SetAccessKeyId(v string)

func (*ExternalS3Storage) SetEndpoint 

func (m *ExternalS3Storage) SetEndpoint(v string)

func (*ExternalS3Storage) SetRegion 

func (m *ExternalS3Storage) SetRegion(v string)

func (*ExternalS3Storage) String 

func (x *ExternalS3Storage) String() string

type ExternalS3StorageSpec 

type ExternalS3StorageSpec struct {
	AccessKeyId     string `protobuf:"bytes,1,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	SecretAccessKey string `protobuf:"bytes,2,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	Endpoint        string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Default is 'us-east-1'.
	Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalS3StorageSpec) Descriptor deprecated 

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

Deprecated: Use ExternalS3StorageSpec.ProtoReflect.Descriptor instead.

func (*ExternalS3StorageSpec) GetAccessKeyId 

func (x *ExternalS3StorageSpec) GetAccessKeyId() string

func (*ExternalS3StorageSpec) GetEndpoint 

func (x *ExternalS3StorageSpec) GetEndpoint() string

func (*ExternalS3StorageSpec) GetRegion 

func (x *ExternalS3StorageSpec) GetRegion() string

func (*ExternalS3StorageSpec) GetSecretAccessKey 

func (x *ExternalS3StorageSpec) GetSecretAccessKey() string

func (*ExternalS3StorageSpec) ProtoMessage 

func (*ExternalS3StorageSpec) ProtoMessage()

func (*ExternalS3StorageSpec) ProtoReflect 

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

func (*ExternalS3StorageSpec) Reset 

func (x *ExternalS3StorageSpec) Reset()

func (*ExternalS3StorageSpec) SetAccessKeyId 

func (m *ExternalS3StorageSpec) SetAccessKeyId(v string)

func (*ExternalS3StorageSpec) SetEndpoint 

func (m *ExternalS3StorageSpec) SetEndpoint(v string)

func (*ExternalS3StorageSpec) SetRegion 

func (m *ExternalS3StorageSpec) SetRegion(v string)

func (*ExternalS3StorageSpec) SetSecretAccessKey 

func (m *ExternalS3StorageSpec) SetSecretAccessKey(v string)

func (*ExternalS3StorageSpec) String 

func (x *ExternalS3StorageSpec) String() string

type GetClusterRequest 

type GetClusterRequest struct {

	// ID of the Apache Kafka® Cluster resource to return.
	//
	// To get the cluster ID, make 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
}

func (*GetClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetClusterId 

func (x *GetClusterRequest) GetClusterId() 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) SetClusterId 

func (m *GetClusterRequest) SetClusterId(v string)

func (*GetClusterRequest) String 

func (x *GetClusterRequest) String() string

type GetConnectorRequest 

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
}

func (*GetConnectorRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetClusterId 

func (x *GetConnectorRequest) GetClusterId() string

func (*GetConnectorRequest) GetConnectorName 

func (x *GetConnectorRequest) GetConnectorName() string

func (*GetConnectorRequest) ProtoMessage 

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect 

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

func (*GetConnectorRequest) Reset 

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) SetClusterId 

func (m *GetConnectorRequest) SetClusterId(v string)

func (*GetConnectorRequest) SetConnectorName 

func (m *GetConnectorRequest) SetConnectorName(v string)

func (*GetConnectorRequest) String 

func (x *GetConnectorRequest) String() string

type GetResourcePresetRequest 

type GetResourcePresetRequest struct {

	// ID of the resource preset to return.
	//
	// To get the resource preset ID, use a [ResourcePresetService.List] request.
	ResourcePresetId string `protobuf:"bytes,1,opt,name=resource_preset_id,json=resourcePresetId,proto3" json:"resource_preset_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResourcePresetRequest) Descriptor deprecated 

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

Deprecated: Use GetResourcePresetRequest.ProtoReflect.Descriptor instead.

func (*GetResourcePresetRequest) GetResourcePresetId 

func (x *GetResourcePresetRequest) GetResourcePresetId() string

func (*GetResourcePresetRequest) ProtoMessage 

func (*GetResourcePresetRequest) ProtoMessage()

func (*GetResourcePresetRequest) ProtoReflect 

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

func (*GetResourcePresetRequest) Reset 

func (x *GetResourcePresetRequest) Reset()

func (*GetResourcePresetRequest) SetResourcePresetId 

func (m *GetResourcePresetRequest) SetResourcePresetId(v string)

func (*GetResourcePresetRequest) String 

func (x *GetResourcePresetRequest) String() string

type GetTopicRequest 

type GetTopicRequest struct {

	// ID of the Apache Kafka® cluster that the topic belongs to.
	//
	// To get the cluster 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 Kafka topic resource to return.
	//
	// To get the name of the topic, make 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
}

func (*GetTopicRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicRequest.ProtoReflect.Descriptor instead.

func (*GetTopicRequest) GetClusterId 

func (x *GetTopicRequest) GetClusterId() string

func (*GetTopicRequest) GetTopicName 

func (x *GetTopicRequest) GetTopicName() 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) SetClusterId 

func (m *GetTopicRequest) SetClusterId(v string)

func (*GetTopicRequest) SetTopicName 

func (m *GetTopicRequest) SetTopicName(v string)

func (*GetTopicRequest) String 

func (x *GetTopicRequest) String() string

type GetUserRequest 

type GetUserRequest struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	//
	// To get the cluster 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 Kafka user to return.
	//
	// To get the name of the user, make 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
}

func (*GetUserRequest) Descriptor deprecated 

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

Deprecated: Use GetUserRequest.ProtoReflect.Descriptor instead.

func (*GetUserRequest) GetClusterId 

func (x *GetUserRequest) GetClusterId() string

func (*GetUserRequest) GetUserName 

func (x *GetUserRequest) GetUserName() string

func (*GetUserRequest) ProtoMessage 

func (*GetUserRequest) ProtoMessage()

func (*GetUserRequest) ProtoReflect 

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

func (*GetUserRequest) Reset 

func (x *GetUserRequest) Reset()

func (*GetUserRequest) SetClusterId 

func (m *GetUserRequest) SetClusterId(v string)

func (*GetUserRequest) SetUserName 

func (m *GetUserRequest) SetUserName(v string)

func (*GetUserRequest) String 

func (x *GetUserRequest) String() string

type GrantUserPermissionMetadata 

type GrantUserPermissionMetadata struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	//
	// To get the cluster 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 user that is being granted a permission.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GrantUserPermissionMetadata) Descriptor deprecated 

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

Deprecated: Use GrantUserPermissionMetadata.ProtoReflect.Descriptor instead.

func (*GrantUserPermissionMetadata) GetClusterId 

func (x *GrantUserPermissionMetadata) GetClusterId() string

func (*GrantUserPermissionMetadata) GetUserName 

func (x *GrantUserPermissionMetadata) GetUserName() string

func (*GrantUserPermissionMetadata) ProtoMessage 

func (*GrantUserPermissionMetadata) ProtoMessage()

func (*GrantUserPermissionMetadata) ProtoReflect 

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

func (*GrantUserPermissionMetadata) Reset 

func (x *GrantUserPermissionMetadata) Reset()

func (*GrantUserPermissionMetadata) SetClusterId 

func (m *GrantUserPermissionMetadata) SetClusterId(v string)

func (*GrantUserPermissionMetadata) SetUserName 

func (m *GrantUserPermissionMetadata) SetUserName(v string)

func (*GrantUserPermissionMetadata) String 

func (x *GrantUserPermissionMetadata) String() string

type GrantUserPermissionRequest 

type GrantUserPermissionRequest struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	//
	// To get the cluster 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 user to grant the permission to.
	//
	// To get the name of the user, make a [UserService.List] request.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// 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
}

func (*GrantUserPermissionRequest) Descriptor deprecated 

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

Deprecated: Use GrantUserPermissionRequest.ProtoReflect.Descriptor instead.

func (*GrantUserPermissionRequest) GetClusterId 

func (x *GrantUserPermissionRequest) GetClusterId() string

func (*GrantUserPermissionRequest) GetPermission 

func (x *GrantUserPermissionRequest) GetPermission() *Permission

func (*GrantUserPermissionRequest) GetUserName 

func (x *GrantUserPermissionRequest) GetUserName() string

func (*GrantUserPermissionRequest) ProtoMessage 

func (*GrantUserPermissionRequest) ProtoMessage()

func (*GrantUserPermissionRequest) ProtoReflect 

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

func (*GrantUserPermissionRequest) Reset 

func (x *GrantUserPermissionRequest) Reset()

func (*GrantUserPermissionRequest) SetClusterId 

func (m *GrantUserPermissionRequest) SetClusterId(v string)

func (*GrantUserPermissionRequest) SetPermission 

func (m *GrantUserPermissionRequest) SetPermission(v *Permission)

func (*GrantUserPermissionRequest) SetUserName 

func (m *GrantUserPermissionRequest) SetUserName(v string)

func (*GrantUserPermissionRequest) String 

func (x *GrantUserPermissionRequest) String() string

type Host 

type Host struct {

	// Name of the host.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// ID of the Apache Kafka® cluster.
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// ID of the availability zone where the host resides.
	ZoneId string `protobuf:"bytes,3,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty"`
	// Host role.
	Role Host_Role `protobuf:"varint,4,opt,name=role,proto3,enum=yandex.cloud.mdb.kafka.v1.Host_Role" json:"role,omitempty"`
	// Computational resources allocated to the host.
	Resources *Resources `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"`
	// Aggregated host health data.
	Health Host_Health `protobuf:"varint,6,opt,name=health,proto3,enum=yandex.cloud.mdb.kafka.v1.Host_Health" json:"health,omitempty"`
	// ID of the subnet the host resides in.
	SubnetId string `protobuf:"bytes,8,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	// The flag that defines whether a public IP address is assigned to the node.
	//
	// If the value is `true`, then this node is available on the Internet via it's public IP address.
	AssignPublicIp bool `protobuf:"varint,9,opt,name=assign_public_ip,json=assignPublicIp,proto3" json:"assign_public_ip,omitempty"`
	// contains filtered or unexported fields
}

Cluster host metadata.

func (*Host) Descriptor deprecated 

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

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetAssignPublicIp 

func (x *Host) GetAssignPublicIp() bool

func (*Host) GetClusterId 

func (x *Host) GetClusterId() string

func (*Host) GetHealth 

func (x *Host) GetHealth() Host_Health

func (*Host) GetName 

func (x *Host) GetName() string

func (*Host) GetResources 

func (x *Host) GetResources() *Resources

func (*Host) GetRole 

func (x *Host) GetRole() Host_Role

func (*Host) GetSubnetId 

func (x *Host) GetSubnetId() string

func (*Host) GetZoneId 

func (x *Host) GetZoneId() string

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) ProtoReflect 

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

func (*Host) Reset 

func (x *Host) Reset()

func (*Host) SetAssignPublicIp 

func (m *Host) SetAssignPublicIp(v bool)

func (*Host) SetClusterId 

func (m *Host) SetClusterId(v string)

func (*Host) SetHealth 

func (m *Host) SetHealth(v Host_Health)

func (*Host) SetName 

func (m *Host) SetName(v string)

func (*Host) SetResources 

func (m *Host) SetResources(v *Resources)

func (*Host) SetRole 

func (m *Host) SetRole(v Host_Role)

func (*Host) SetSubnetId 

func (m *Host) SetSubnetId(v string)

func (*Host) SetZoneId 

func (m *Host) SetZoneId(v string)

func (*Host) String 

func (x *Host) String() string

type Host_Health 

type Host_Health int32
const (
	// health of the host is unknown.
	Host_UNKNOWN Host_Health = 0
	// the host is performing all its functions normally.
	Host_ALIVE Host_Health = 1
	// the host is inoperable and cannot perform any of its essential functions.
	Host_DEAD Host_Health = 2
	// the host is degraded and can perform only some of its essential functions.
	Host_DEGRADED Host_Health = 3
)

func (Host_Health) Descriptor 

func (Host_Health) Descriptor() protoreflect.EnumDescriptor

func (Host_Health) Enum 

func (x Host_Health) Enum() *Host_Health

func (Host_Health) EnumDescriptor deprecated 

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

Deprecated: Use Host_Health.Descriptor instead.

func (Host_Health) Number 

func (x Host_Health) Number() protoreflect.EnumNumber

func (Host_Health) String 

func (x Host_Health) String() string

func (Host_Health) Type 

func (Host_Health) Type() protoreflect.EnumType

type Host_Role 

type Host_Role int32
const (
	Host_ROLE_UNSPECIFIED Host_Role = 0
	// the host is a Kafka broker.
	Host_KAFKA Host_Role = 1
	// the host is a ZooKeeper server.
	Host_ZOOKEEPER Host_Role = 2
)

func (Host_Role) Descriptor 

func (Host_Role) Descriptor() protoreflect.EnumDescriptor

func (Host_Role) Enum 

func (x Host_Role) Enum() *Host_Role

func (Host_Role) EnumDescriptor deprecated 

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

Deprecated: Use Host_Role.Descriptor instead.

func (Host_Role) Number 

func (x Host_Role) Number() protoreflect.EnumNumber

func (Host_Role) String 

func (x Host_Role) String() string

func (Host_Role) Type 

func (Host_Role) Type() protoreflect.EnumType

type KafkaConfig2_8 

type KafkaConfig2_8 struct {

	// Cluster topics compression type.
	CompressionType CompressionType `` /* 154-byte string literal not displayed */
	// The number of messages accumulated on a log partition before messages are flushed to disk.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig2_8.flush_messages] setting.
	LogFlushIntervalMessages *wrapperspb.Int64Value `` /* 137-byte string literal not displayed */
	// The maximum time (in milliseconds) that a message in any topic is kept in memory before flushed to disk.
	// If not set, the value of [log_flush_scheduler_interval_ms] is used.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig2_8.flush_ms] setting.
	LogFlushIntervalMs *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=log_flush_interval_ms,json=logFlushIntervalMs,proto3" json:"log_flush_interval_ms,omitempty"`
	// The frequency of checks (in milliseconds) for any logs that need to be flushed to disk.
	// This check is done by the log flusher.
	LogFlushSchedulerIntervalMs *wrapperspb.Int64Value `` /* 148-byte string literal not displayed */
	// Partition size limit; Kafka will discard old log segments to free up space if `delete` [TopicConfig2_8.cleanup_policy] is in effect.
	// This setting is helpful if you need to control the size of a log due to limited disk space.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig2_8.retention_bytes] setting.
	LogRetentionBytes *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=log_retention_bytes,json=logRetentionBytes,proto3" json:"log_retention_bytes,omitempty"`
	// The number of hours to keep a log segment file before deleting it.
	LogRetentionHours *wrapperspb.Int64Value `protobuf:"bytes,6,opt,name=log_retention_hours,json=logRetentionHours,proto3" json:"log_retention_hours,omitempty"`
	// The number of minutes to keep a log segment file before deleting it.
	//
	// If not set, the value of [log_retention_hours] is used.
	LogRetentionMinutes *wrapperspb.Int64Value `protobuf:"bytes,7,opt,name=log_retention_minutes,json=logRetentionMinutes,proto3" json:"log_retention_minutes,omitempty"`
	// The number of milliseconds to keep a log segment file before deleting it.
	//
	// If not set, the value of [log_retention_minutes] is used.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig2_8.retention_ms] setting.
	LogRetentionMs *wrapperspb.Int64Value `protobuf:"bytes,8,opt,name=log_retention_ms,json=logRetentionMs,proto3" json:"log_retention_ms,omitempty"`
	// The maximum size of a single log file.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig2_8.segment_bytes] setting.
	LogSegmentBytes *wrapperspb.Int64Value `protobuf:"bytes,9,opt,name=log_segment_bytes,json=logSegmentBytes,proto3" json:"log_segment_bytes,omitempty"`
	// Should pre allocate file when create new segment?
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig2_8.preallocate] setting.
	LogPreallocate *wrapperspb.BoolValue `protobuf:"bytes,10,opt,name=log_preallocate,json=logPreallocate,proto3" json:"log_preallocate,omitempty"`
	// The SO_SNDBUF buffer of the socket server sockets. If the value is -1, the OS default will be used.
	SocketSendBufferBytes *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */
	// The SO_RCVBUF buffer of the socket server sockets. If the value is -1, the OS default will be used.
	SocketReceiveBufferBytes *wrapperspb.Int64Value `` /* 138-byte string literal not displayed */
	// Enable auto creation of topic on the server
	AutoCreateTopicsEnable *wrapperspb.BoolValue `` /* 132-byte string literal not displayed */
	// Default number of partitions per topic on the whole cluster
	NumPartitions *wrapperspb.Int64Value `protobuf:"bytes,14,opt,name=num_partitions,json=numPartitions,proto3" json:"num_partitions,omitempty"`
	// Default replication factor of the topic on the whole cluster
	DefaultReplicationFactor *wrapperspb.Int64Value `` /* 136-byte string literal not displayed */
	// The largest record batch size allowed by Kafka. Default value: 1048588.
	MessageMaxBytes *wrapperspb.Int64Value `protobuf:"bytes,16,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 `` /* 126-byte string literal not displayed */
	// A list of cipher suites.
	SslCipherSuites []string `protobuf:"bytes,18,rep,name=ssl_cipher_suites,json=sslCipherSuites,proto3" json:"ssl_cipher_suites,omitempty"`
	// Offset storage time after a consumer group loses all its consumers. Default: 10080.
	OffsetsRetentionMinutes *wrapperspb.Int64Value `` /* 133-byte string literal not displayed */
	// The list of SASL mechanisms enabled in the Kafka server. Default: [SCRAM_SHA_512].
	SaslEnabledMechanisms []SaslMechanism `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

Kafka version 2.8 broker configuration.

func (*KafkaConfig2_8) Descriptor deprecated 

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

Deprecated: Use KafkaConfig2_8.ProtoReflect.Descriptor instead.

func (*KafkaConfig2_8) GetAutoCreateTopicsEnable 

func (x *KafkaConfig2_8) GetAutoCreateTopicsEnable() *wrapperspb.BoolValue

func (*KafkaConfig2_8) GetCompressionType 

func (x *KafkaConfig2_8) GetCompressionType() CompressionType

func (*KafkaConfig2_8) GetDefaultReplicationFactor 

func (x *KafkaConfig2_8) GetDefaultReplicationFactor() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogFlushIntervalMessages 

func (x *KafkaConfig2_8) GetLogFlushIntervalMessages() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogFlushIntervalMs 

func (x *KafkaConfig2_8) GetLogFlushIntervalMs() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogFlushSchedulerIntervalMs 

func (x *KafkaConfig2_8) GetLogFlushSchedulerIntervalMs() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogPreallocate 

func (x *KafkaConfig2_8) GetLogPreallocate() *wrapperspb.BoolValue

func (*KafkaConfig2_8) GetLogRetentionBytes 

func (x *KafkaConfig2_8) GetLogRetentionBytes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogRetentionHours 

func (x *KafkaConfig2_8) GetLogRetentionHours() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogRetentionMinutes 

func (x *KafkaConfig2_8) GetLogRetentionMinutes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogRetentionMs 

func (x *KafkaConfig2_8) GetLogRetentionMs() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetLogSegmentBytes 

func (x *KafkaConfig2_8) GetLogSegmentBytes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetMessageMaxBytes 

func (x *KafkaConfig2_8) GetMessageMaxBytes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetNumPartitions 

func (x *KafkaConfig2_8) GetNumPartitions() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetOffsetsRetentionMinutes 

func (x *KafkaConfig2_8) GetOffsetsRetentionMinutes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetReplicaFetchMaxBytes 

func (x *KafkaConfig2_8) GetReplicaFetchMaxBytes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetSaslEnabledMechanisms 

func (x *KafkaConfig2_8) GetSaslEnabledMechanisms() []SaslMechanism

func (*KafkaConfig2_8) GetSocketReceiveBufferBytes 

func (x *KafkaConfig2_8) GetSocketReceiveBufferBytes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetSocketSendBufferBytes 

func (x *KafkaConfig2_8) GetSocketSendBufferBytes() *wrapperspb.Int64Value

func (*KafkaConfig2_8) GetSslCipherSuites 

func (x *KafkaConfig2_8) GetSslCipherSuites() []string

func (*KafkaConfig2_8) ProtoMessage 

func (*KafkaConfig2_8) ProtoMessage()

func (*KafkaConfig2_8) ProtoReflect 

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

func (*KafkaConfig2_8) Reset 

func (x *KafkaConfig2_8) Reset()

func (*KafkaConfig2_8) SetAutoCreateTopicsEnable 

func (m *KafkaConfig2_8) SetAutoCreateTopicsEnable(v *wrapperspb.BoolValue)

func (*KafkaConfig2_8) SetCompressionType 

func (m *KafkaConfig2_8) SetCompressionType(v CompressionType)

func (*KafkaConfig2_8) SetDefaultReplicationFactor 

func (m *KafkaConfig2_8) SetDefaultReplicationFactor(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogFlushIntervalMessages 

func (m *KafkaConfig2_8) SetLogFlushIntervalMessages(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogFlushIntervalMs 

func (m *KafkaConfig2_8) SetLogFlushIntervalMs(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogFlushSchedulerIntervalMs 

func (m *KafkaConfig2_8) SetLogFlushSchedulerIntervalMs(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogPreallocate 

func (m *KafkaConfig2_8) SetLogPreallocate(v *wrapperspb.BoolValue)

func (*KafkaConfig2_8) SetLogRetentionBytes 

func (m *KafkaConfig2_8) SetLogRetentionBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogRetentionHours 

func (m *KafkaConfig2_8) SetLogRetentionHours(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogRetentionMinutes 

func (m *KafkaConfig2_8) SetLogRetentionMinutes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogRetentionMs 

func (m *KafkaConfig2_8) SetLogRetentionMs(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetLogSegmentBytes 

func (m *KafkaConfig2_8) SetLogSegmentBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetMessageMaxBytes 

func (m *KafkaConfig2_8) SetMessageMaxBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetNumPartitions 

func (m *KafkaConfig2_8) SetNumPartitions(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetOffsetsRetentionMinutes 

func (m *KafkaConfig2_8) SetOffsetsRetentionMinutes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetReplicaFetchMaxBytes 

func (m *KafkaConfig2_8) SetReplicaFetchMaxBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetSaslEnabledMechanisms 

func (m *KafkaConfig2_8) SetSaslEnabledMechanisms(v []SaslMechanism)

func (*KafkaConfig2_8) SetSocketReceiveBufferBytes 

func (m *KafkaConfig2_8) SetSocketReceiveBufferBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetSocketSendBufferBytes 

func (m *KafkaConfig2_8) SetSocketSendBufferBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig2_8) SetSslCipherSuites 

func (m *KafkaConfig2_8) SetSslCipherSuites(v []string)

func (*KafkaConfig2_8) String 

func (x *KafkaConfig2_8) String() string

type KafkaConfig3 

type KafkaConfig3 struct {

	// Cluster topics compression type.
	CompressionType CompressionType `` /* 154-byte string literal not displayed */
	// The number of messages accumulated on a log partition before messages are flushed to disk.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig3.flush_messages] setting.
	LogFlushIntervalMessages *wrapperspb.Int64Value `` /* 137-byte string literal not displayed */
	// The maximum time (in milliseconds) that a message in any topic is kept in memory before flushed to disk.
	// If not set, the value of [log_flush_scheduler_interval_ms] is used.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig3.flush_ms] setting.
	LogFlushIntervalMs *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=log_flush_interval_ms,json=logFlushIntervalMs,proto3" json:"log_flush_interval_ms,omitempty"`
	// The frequency of checks (in milliseconds) for any logs that need to be flushed to disk.
	// This check is done by the log flusher.
	LogFlushSchedulerIntervalMs *wrapperspb.Int64Value `` /* 148-byte string literal not displayed */
	// Partition size limit; Kafka will discard old log segments to free up space if `delete` [TopicConfig3.cleanup_policy] is in effect.
	// This setting is helpful if you need to control the size of a log due to limited disk space.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig3.retention_bytes] setting.
	LogRetentionBytes *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=log_retention_bytes,json=logRetentionBytes,proto3" json:"log_retention_bytes,omitempty"`
	// The number of hours to keep a log segment file before deleting it.
	LogRetentionHours *wrapperspb.Int64Value `protobuf:"bytes,6,opt,name=log_retention_hours,json=logRetentionHours,proto3" json:"log_retention_hours,omitempty"`
	// The number of minutes to keep a log segment file before deleting it.
	//
	// If not set, the value of [log_retention_hours] is used.
	LogRetentionMinutes *wrapperspb.Int64Value `protobuf:"bytes,7,opt,name=log_retention_minutes,json=logRetentionMinutes,proto3" json:"log_retention_minutes,omitempty"`
	// The number of milliseconds to keep a log segment file before deleting it.
	//
	// If not set, the value of [log_retention_minutes] is used.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig3.retention_ms] setting.
	LogRetentionMs *wrapperspb.Int64Value `protobuf:"bytes,8,opt,name=log_retention_ms,json=logRetentionMs,proto3" json:"log_retention_ms,omitempty"`
	// The maximum size of a single log file.
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig3.segment_bytes] setting.
	LogSegmentBytes *wrapperspb.Int64Value `protobuf:"bytes,9,opt,name=log_segment_bytes,json=logSegmentBytes,proto3" json:"log_segment_bytes,omitempty"`
	// Should pre allocate file when create new segment?
	//
	// This is the global cluster-level setting that can be overridden on a topic level by using the [TopicConfig3.preallocate] setting.
	LogPreallocate *wrapperspb.BoolValue `protobuf:"bytes,10,opt,name=log_preallocate,json=logPreallocate,proto3" json:"log_preallocate,omitempty"`
	// The SO_SNDBUF buffer of the socket server sockets. If the value is -1, the OS default will be used.
	SocketSendBufferBytes *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */
	// The SO_RCVBUF buffer of the socket server sockets. If the value is -1, the OS default will be used.
	SocketReceiveBufferBytes *wrapperspb.Int64Value `` /* 138-byte string literal not displayed */
	// Enable auto creation of topic on the server
	AutoCreateTopicsEnable *wrapperspb.BoolValue `` /* 132-byte string literal not displayed */
	// Default number of partitions per topic on the whole cluster
	NumPartitions *wrapperspb.Int64Value `protobuf:"bytes,14,opt,name=num_partitions,json=numPartitions,proto3" json:"num_partitions,omitempty"`
	// Default replication factor of the topic on the whole cluster
	DefaultReplicationFactor *wrapperspb.Int64Value `` /* 136-byte string literal not displayed */
	// The largest record batch size allowed by Kafka. Default value: 1048588.
	MessageMaxBytes *wrapperspb.Int64Value `protobuf:"bytes,16,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 `` /* 126-byte string literal not displayed */
	// A list of cipher suites.
	SslCipherSuites []string `protobuf:"bytes,18,rep,name=ssl_cipher_suites,json=sslCipherSuites,proto3" json:"ssl_cipher_suites,omitempty"`
	// Offset storage time after a consumer group loses all its consumers. Default: 10080.
	OffsetsRetentionMinutes *wrapperspb.Int64Value `` /* 133-byte string literal not displayed */
	// The list of SASL mechanisms enabled in the Kafka server. Default: [SCRAM_SHA_512].
	SaslEnabledMechanisms []SaslMechanism `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

Kafka version 3.x broker configuration.

func (*KafkaConfig3) Descriptor deprecated 

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

Deprecated: Use KafkaConfig3.ProtoReflect.Descriptor instead.

func (*KafkaConfig3) GetAutoCreateTopicsEnable 

func (x *KafkaConfig3) GetAutoCreateTopicsEnable() *wrapperspb.BoolValue

func (*KafkaConfig3) GetCompressionType 

func (x *KafkaConfig3) GetCompressionType() CompressionType

func (*KafkaConfig3) GetDefaultReplicationFactor 

func (x *KafkaConfig3) GetDefaultReplicationFactor() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogFlushIntervalMessages 

func (x *KafkaConfig3) GetLogFlushIntervalMessages() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogFlushIntervalMs 

func (x *KafkaConfig3) GetLogFlushIntervalMs() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogFlushSchedulerIntervalMs 

func (x *KafkaConfig3) GetLogFlushSchedulerIntervalMs() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogPreallocate 

func (x *KafkaConfig3) GetLogPreallocate() *wrapperspb.BoolValue

func (*KafkaConfig3) GetLogRetentionBytes 

func (x *KafkaConfig3) GetLogRetentionBytes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogRetentionHours 

func (x *KafkaConfig3) GetLogRetentionHours() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogRetentionMinutes 

func (x *KafkaConfig3) GetLogRetentionMinutes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogRetentionMs 

func (x *KafkaConfig3) GetLogRetentionMs() *wrapperspb.Int64Value

func (*KafkaConfig3) GetLogSegmentBytes 

func (x *KafkaConfig3) GetLogSegmentBytes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetMessageMaxBytes 

func (x *KafkaConfig3) GetMessageMaxBytes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetNumPartitions 

func (x *KafkaConfig3) GetNumPartitions() *wrapperspb.Int64Value

func (*KafkaConfig3) GetOffsetsRetentionMinutes 

func (x *KafkaConfig3) GetOffsetsRetentionMinutes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetReplicaFetchMaxBytes 

func (x *KafkaConfig3) GetReplicaFetchMaxBytes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetSaslEnabledMechanisms 

func (x *KafkaConfig3) GetSaslEnabledMechanisms() []SaslMechanism

func (*KafkaConfig3) GetSocketReceiveBufferBytes 

func (x *KafkaConfig3) GetSocketReceiveBufferBytes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetSocketSendBufferBytes 

func (x *KafkaConfig3) GetSocketSendBufferBytes() *wrapperspb.Int64Value

func (*KafkaConfig3) GetSslCipherSuites 

func (x *KafkaConfig3) GetSslCipherSuites() []string

func (*KafkaConfig3) ProtoMessage 

func (*KafkaConfig3) ProtoMessage()

func (*KafkaConfig3) ProtoReflect 

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

func (*KafkaConfig3) Reset 

func (x *KafkaConfig3) Reset()

func (*KafkaConfig3) SetAutoCreateTopicsEnable 

func (m *KafkaConfig3) SetAutoCreateTopicsEnable(v *wrapperspb.BoolValue)

func (*KafkaConfig3) SetCompressionType 

func (m *KafkaConfig3) SetCompressionType(v CompressionType)

func (*KafkaConfig3) SetDefaultReplicationFactor 

func (m *KafkaConfig3) SetDefaultReplicationFactor(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogFlushIntervalMessages 

func (m *KafkaConfig3) SetLogFlushIntervalMessages(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogFlushIntervalMs 

func (m *KafkaConfig3) SetLogFlushIntervalMs(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogFlushSchedulerIntervalMs 

func (m *KafkaConfig3) SetLogFlushSchedulerIntervalMs(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogPreallocate 

func (m *KafkaConfig3) SetLogPreallocate(v *wrapperspb.BoolValue)

func (*KafkaConfig3) SetLogRetentionBytes 

func (m *KafkaConfig3) SetLogRetentionBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogRetentionHours 

func (m *KafkaConfig3) SetLogRetentionHours(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogRetentionMinutes 

func (m *KafkaConfig3) SetLogRetentionMinutes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogRetentionMs 

func (m *KafkaConfig3) SetLogRetentionMs(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetLogSegmentBytes 

func (m *KafkaConfig3) SetLogSegmentBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetMessageMaxBytes 

func (m *KafkaConfig3) SetMessageMaxBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetNumPartitions 

func (m *KafkaConfig3) SetNumPartitions(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetOffsetsRetentionMinutes 

func (m *KafkaConfig3) SetOffsetsRetentionMinutes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetReplicaFetchMaxBytes 

func (m *KafkaConfig3) SetReplicaFetchMaxBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetSaslEnabledMechanisms 

func (m *KafkaConfig3) SetSaslEnabledMechanisms(v []SaslMechanism)

func (*KafkaConfig3) SetSocketReceiveBufferBytes 

func (m *KafkaConfig3) SetSocketReceiveBufferBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetSocketSendBufferBytes 

func (m *KafkaConfig3) SetSocketSendBufferBytes(v *wrapperspb.Int64Value)

func (*KafkaConfig3) SetSslCipherSuites 

func (m *KafkaConfig3) SetSslCipherSuites(v []string)

func (*KafkaConfig3) String 

func (x *KafkaConfig3) String() string

type ListClusterHostsRequest 

type ListClusterHostsRequest struct {

	// ID of the Apache Kafka® cluster.
	//
	// To get the Apache Kafka® cluster ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the service returns a [ListClusterHostsResponse.next_page_token] that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.
	//
	// To get the next page of results, set [page_token] to the [ListClusterHostsResponse.next_page_token] returned by the previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterHostsRequest) Descriptor deprecated 

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

Deprecated: Use ListClusterHostsRequest.ProtoReflect.Descriptor instead.

func (*ListClusterHostsRequest) GetClusterId 

func (x *ListClusterHostsRequest) GetClusterId() string

func (*ListClusterHostsRequest) GetPageSize 

func (x *ListClusterHostsRequest) GetPageSize() int64

func (*ListClusterHostsRequest) GetPageToken 

func (x *ListClusterHostsRequest) GetPageToken() string

func (*ListClusterHostsRequest) ProtoMessage 

func (*ListClusterHostsRequest) ProtoMessage()

func (*ListClusterHostsRequest) ProtoReflect 

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

func (*ListClusterHostsRequest) Reset 

func (x *ListClusterHostsRequest) Reset()

func (*ListClusterHostsRequest) SetClusterId 

func (m *ListClusterHostsRequest) SetClusterId(v string)

func (*ListClusterHostsRequest) SetPageSize 

func (m *ListClusterHostsRequest) SetPageSize(v int64)

func (*ListClusterHostsRequest) SetPageToken 

func (m *ListClusterHostsRequest) SetPageToken(v string)

func (*ListClusterHostsRequest) String 

func (x *ListClusterHostsRequest) String() string

type ListClusterHostsResponse 

type ListClusterHostsResponse struct {

	// List of hosts.
	Hosts []*Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// Token that allows you to get the next page of results for list requests.
	//
	// If the number of results is larger than [ListClusterHostsRequest.page_size], use the [next_page_token] as the value for the [ListClusterHostsRequest.page_token] query parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterHostsResponse) Descriptor deprecated 

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

Deprecated: Use ListClusterHostsResponse.ProtoReflect.Descriptor instead.

func (*ListClusterHostsResponse) GetHosts 

func (x *ListClusterHostsResponse) GetHosts() []*Host

func (*ListClusterHostsResponse) GetNextPageToken 

func (x *ListClusterHostsResponse) GetNextPageToken() string

func (*ListClusterHostsResponse) ProtoMessage 

func (*ListClusterHostsResponse) ProtoMessage()

func (*ListClusterHostsResponse) ProtoReflect 

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

func (*ListClusterHostsResponse) Reset 

func (x *ListClusterHostsResponse) Reset()

func (*ListClusterHostsResponse) SetHosts 

func (m *ListClusterHostsResponse) SetHosts(v []*Host)

func (*ListClusterHostsResponse) SetNextPageToken 

func (m *ListClusterHostsResponse) SetNextPageToken(v string)

func (*ListClusterHostsResponse) String 

func (x *ListClusterHostsResponse) String() string

type ListClusterLogsRequest 

type ListClusterLogsRequest struct {

	// ID of the Apache Kafka® cluster to request logs for.
	//
	// To get the Apache Kafka® cluster ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Columns from the logs table to request.
	//
	// If no columns are specified, full log records are returned.
	ColumnFilter []string `protobuf:"bytes,2,rep,name=column_filter,json=columnFilter,proto3" json:"column_filter,omitempty"`
	// Start timestamp for the logs request.
	FromTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	// End timestamp for the logs request.
	ToTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=to_time,json=toTime,proto3" json:"to_time,omitempty"`
	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the service returns a [ListClusterLogsResponse.next_page_token] that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.
	//
	// To get the next page of results, set [page_token] to the [ListClusterLogsResponse.next_page_token] returned by the previous list request.
	PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The flag that defines behavior of providing the next page token.
	//
	// If this flag is set to `true`, this API method will always return [ListClusterLogsResponse.next_page_token], even if current page is empty.
	AlwaysNextPageToken bool `protobuf:"varint,7,opt,name=always_next_page_token,json=alwaysNextPageToken,proto3" json:"always_next_page_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	//
	// The expression must specify:
	// 1. The field name to filter by. Currently filtering can be applied to the `hostname` field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 1-63 characters long and match the regular expression `[a-z0-9.-]{1,61}`.
	//
	// Example of a filter: `message.hostname='node1.db.cloud.yandex.net'`
	Filter string `protobuf:"bytes,8,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterLogsRequest) Descriptor deprecated 

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

Deprecated: Use ListClusterLogsRequest.ProtoReflect.Descriptor instead.

func (*ListClusterLogsRequest) GetAlwaysNextPageToken 

func (x *ListClusterLogsRequest) GetAlwaysNextPageToken() bool

func (*ListClusterLogsRequest) GetClusterId 

func (x *ListClusterLogsRequest) GetClusterId() string

func (*ListClusterLogsRequest) GetColumnFilter 

func (x *ListClusterLogsRequest) GetColumnFilter() []string

func (*ListClusterLogsRequest) GetFilter 

func (x *ListClusterLogsRequest) GetFilter() string

func (*ListClusterLogsRequest) GetFromTime 

func (x *ListClusterLogsRequest) GetFromTime() *timestamppb.Timestamp

func (*ListClusterLogsRequest) GetPageSize 

func (x *ListClusterLogsRequest) GetPageSize() int64

func (*ListClusterLogsRequest) GetPageToken 

func (x *ListClusterLogsRequest) GetPageToken() string

func (*ListClusterLogsRequest) GetToTime 

func (x *ListClusterLogsRequest) GetToTime() *timestamppb.Timestamp

func (*ListClusterLogsRequest) ProtoMessage 

func (*ListClusterLogsRequest) ProtoMessage()

func (*ListClusterLogsRequest) ProtoReflect 

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

func (*ListClusterLogsRequest) Reset 

func (x *ListClusterLogsRequest) Reset()

func (*ListClusterLogsRequest) SetAlwaysNextPageToken 

func (m *ListClusterLogsRequest) SetAlwaysNextPageToken(v bool)

func (*ListClusterLogsRequest) SetClusterId 

func (m *ListClusterLogsRequest) SetClusterId(v string)

func (*ListClusterLogsRequest) SetColumnFilter 

func (m *ListClusterLogsRequest) SetColumnFilter(v []string)

func (*ListClusterLogsRequest) SetFilter 

func (m *ListClusterLogsRequest) SetFilter(v string)

func (*ListClusterLogsRequest) SetFromTime 

func (m *ListClusterLogsRequest) SetFromTime(v *timestamppb.Timestamp)

func (*ListClusterLogsRequest) SetPageSize 

func (m *ListClusterLogsRequest) SetPageSize(v int64)

func (*ListClusterLogsRequest) SetPageToken 

func (m *ListClusterLogsRequest) SetPageToken(v string)

func (*ListClusterLogsRequest) SetToTime 

func (m *ListClusterLogsRequest) SetToTime(v *timestamppb.Timestamp)

func (*ListClusterLogsRequest) String 

func (x *ListClusterLogsRequest) String() string

type ListClusterLogsResponse 

type ListClusterLogsResponse struct {

	// Requested log records.
	Logs []*LogRecord `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// Token that allows you to get the next page of results for list requests.
	//
	// If the number of results is larger than [ListClusterLogsRequest.page_size], use [next_page_token] as the value for the [ListClusterLogsRequest.page_token] query parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	// This value is interchangeable with [StreamLogRecord.next_record_token] from StreamLogs method.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterLogsResponse) Descriptor deprecated 

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

Deprecated: Use ListClusterLogsResponse.ProtoReflect.Descriptor instead.

func (*ListClusterLogsResponse) GetLogs 

func (x *ListClusterLogsResponse) GetLogs() []*LogRecord

func (*ListClusterLogsResponse) GetNextPageToken 

func (x *ListClusterLogsResponse) GetNextPageToken() string

func (*ListClusterLogsResponse) ProtoMessage 

func (*ListClusterLogsResponse) ProtoMessage()

func (*ListClusterLogsResponse) ProtoReflect 

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

func (*ListClusterLogsResponse) Reset 

func (x *ListClusterLogsResponse) Reset()

func (*ListClusterLogsResponse) SetLogs 

func (m *ListClusterLogsResponse) SetLogs(v []*LogRecord)

func (*ListClusterLogsResponse) SetNextPageToken 

func (m *ListClusterLogsResponse) SetNextPageToken(v string)

func (*ListClusterLogsResponse) String 

func (x *ListClusterLogsResponse) String() string

type ListClusterOperationsRequest 

type ListClusterOperationsRequest struct {

	// ID of the Apache Kafka® cluster to list operations for.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the service returns a [ListClusterOperationsResponse.next_page_token] that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.
	//
	// To get the next page of results, set [page_token] to the [ListClusterOperationsResponse.next_page_token] returned by the previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListClusterOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListClusterOperationsRequest) GetClusterId 

func (x *ListClusterOperationsRequest) GetClusterId() string

func (*ListClusterOperationsRequest) GetPageSize 

func (x *ListClusterOperationsRequest) GetPageSize() int64

func (*ListClusterOperationsRequest) GetPageToken 

func (x *ListClusterOperationsRequest) GetPageToken() string

func (*ListClusterOperationsRequest) ProtoMessage 

func (*ListClusterOperationsRequest) ProtoMessage()

func (*ListClusterOperationsRequest) ProtoReflect 

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

func (*ListClusterOperationsRequest) Reset 

func (x *ListClusterOperationsRequest) Reset()

func (*ListClusterOperationsRequest) SetClusterId 

func (m *ListClusterOperationsRequest) SetClusterId(v string)

func (*ListClusterOperationsRequest) SetPageSize 

func (m *ListClusterOperationsRequest) SetPageSize(v int64)

func (*ListClusterOperationsRequest) SetPageToken 

func (m *ListClusterOperationsRequest) SetPageToken(v string)

func (*ListClusterOperationsRequest) String 

func (x *ListClusterOperationsRequest) String() string

type ListClusterOperationsResponse 

type ListClusterOperationsResponse struct {

	// List of operations for the specified Apache Kafka® cluster.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token that allows you to get the next page of results for list requests.
	//
	// If the number of results is larger than [ListClusterOperationsRequest.page_size], use [next_page_token] as the value for the [ListClusterOperationsRequest.page_token] query parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListClusterOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListClusterOperationsResponse) GetNextPageToken 

func (x *ListClusterOperationsResponse) GetNextPageToken() string

func (*ListClusterOperationsResponse) GetOperations 

func (x *ListClusterOperationsResponse) GetOperations() []*operation.Operation

func (*ListClusterOperationsResponse) ProtoMessage 

func (*ListClusterOperationsResponse) ProtoMessage()

func (*ListClusterOperationsResponse) ProtoReflect 

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

func (*ListClusterOperationsResponse) Reset 

func (x *ListClusterOperationsResponse) Reset()

func (*ListClusterOperationsResponse) SetNextPageToken 

func (m *ListClusterOperationsResponse) SetNextPageToken(v string)

func (*ListClusterOperationsResponse) SetOperations 

func (m *ListClusterOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListClusterOperationsResponse) String 

func (x *ListClusterOperationsResponse) String() string

type ListClustersRequest 

type ListClustersRequest struct {

	// ID of the folder to list Apache Kafka® clusters in.
	//
	// To get the folder ID, make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the service returns a [ListClustersResponse.next_page_token] that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.
	//
	// To get the next page of results, set [page_token] to the [ListClustersResponse.next_page_token] returned by the previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Filter support is not currently implemented. Any filters are ignored.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListClustersRequest) GetFolderId() string

func (*ListClustersRequest) GetPageSize 

func (x *ListClustersRequest) GetPageSize() int64

func (*ListClustersRequest) GetPageToken 

func (x *ListClustersRequest) GetPageToken() 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) SetFilter 

func (m *ListClustersRequest) SetFilter(v string)

func (*ListClustersRequest) SetFolderId 

func (m *ListClustersRequest) SetFolderId(v string)

func (*ListClustersRequest) SetPageSize 

func (m *ListClustersRequest) SetPageSize(v int64)

func (*ListClustersRequest) SetPageToken 

func (m *ListClustersRequest) SetPageToken(v string)

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {

	// List of Apache Kafka® clusters.
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// Token that allows you to get the next page of results for list requests.
	//
	// If the number of results is larger than [ListClustersRequest.page_size], use [next_page_token] as the value for the [ListClustersRequest.page_token] parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

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

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) SetClusters 

func (m *ListClustersResponse) SetClusters(v []*Cluster)

func (*ListClustersResponse) SetNextPageToken 

func (m *ListClustersResponse) SetNextPageToken(v string)

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type ListConnectorsRequest 

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"`
	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the API returns a [ListConnectorsResponse.next_page_token] that can be used to get the next page of results in the subsequent [ConnectorService.List] requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token that can be used to iterate through multiple pages of results.
	//
	// To get the next page of results, set [page_token] to the [ListConnectorsResponse.next_page_token] returned by the previous [ConnectorService.List] request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) GetClusterId 

func (x *ListConnectorsRequest) GetClusterId() string

func (*ListConnectorsRequest) GetPageSize 

func (x *ListConnectorsRequest) GetPageSize() int64

func (*ListConnectorsRequest) GetPageToken 

func (x *ListConnectorsRequest) GetPageToken() string

func (*ListConnectorsRequest) ProtoMessage 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect 

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

func (*ListConnectorsRequest) Reset 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) SetClusterId 

func (m *ListConnectorsRequest) SetClusterId(v string)

func (*ListConnectorsRequest) SetPageSize 

func (m *ListConnectorsRequest) SetPageSize(v int64)

func (*ListConnectorsRequest) SetPageToken 

func (m *ListConnectorsRequest) SetPageToken(v string)

func (*ListConnectorsRequest) String 

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse 

type ListConnectorsResponse struct {

	// List of Apache Kafka® Connectors.
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	// The token that can be used to get the next page of results.
	//
	// If the number of results is larger than [ListConnectorsRequest.page_size], use the [next_page_token] as the value for the [ListConnectorsRequest.page_token] in the subsequent [ConnectorService.List] request to iterate through multiple pages of results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors 

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

func (*ListConnectorsResponse) GetNextPageToken 

func (x *ListConnectorsResponse) GetNextPageToken() string

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

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

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) SetConnectors 

func (m *ListConnectorsResponse) SetConnectors(v []*Connector)

func (*ListConnectorsResponse) SetNextPageToken 

func (m *ListConnectorsResponse) SetNextPageToken(v string)

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type ListResourcePresetsRequest 

type ListResourcePresetsRequest struct {

	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the service returns a [ListResourcePresetsResponse.next_page_token] that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.
	//
	// To get the next page of results, set [page_token] to the [ListResourcePresetsResponse.next_page_token], returned by the previous list request.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResourcePresetsRequest) Descriptor deprecated 

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

Deprecated: Use ListResourcePresetsRequest.ProtoReflect.Descriptor instead.

func (*ListResourcePresetsRequest) GetPageSize 

func (x *ListResourcePresetsRequest) GetPageSize() int64

func (*ListResourcePresetsRequest) GetPageToken 

func (x *ListResourcePresetsRequest) GetPageToken() string

func (*ListResourcePresetsRequest) ProtoMessage 

func (*ListResourcePresetsRequest) ProtoMessage()

func (*ListResourcePresetsRequest) ProtoReflect 

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

func (*ListResourcePresetsRequest) Reset 

func (x *ListResourcePresetsRequest) Reset()

func (*ListResourcePresetsRequest) SetPageSize 

func (m *ListResourcePresetsRequest) SetPageSize(v int64)

func (*ListResourcePresetsRequest) SetPageToken 

func (m *ListResourcePresetsRequest) SetPageToken(v string)

func (*ListResourcePresetsRequest) String 

func (x *ListResourcePresetsRequest) String() string

type ListResourcePresetsResponse 

type ListResourcePresetsResponse struct {

	// List of resource presets.
	ResourcePresets []*ResourcePreset `protobuf:"bytes,1,rep,name=resource_presets,json=resourcePresets,proto3" json:"resource_presets,omitempty"`
	// This token allows you to get the next page of results for list requests.
	//
	// If the number of results is larger than [ListResourcePresetsRequest.page_size], use [next_page_token] as the value for the [ListResourcePresetsRequest.page_token] parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResourcePresetsResponse) Descriptor deprecated 

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

Deprecated: Use ListResourcePresetsResponse.ProtoReflect.Descriptor instead.

func (*ListResourcePresetsResponse) GetNextPageToken 

func (x *ListResourcePresetsResponse) GetNextPageToken() string

func (*ListResourcePresetsResponse) GetResourcePresets 

func (x *ListResourcePresetsResponse) GetResourcePresets() []*ResourcePreset

func (*ListResourcePresetsResponse) ProtoMessage 

func (*ListResourcePresetsResponse) ProtoMessage()

func (*ListResourcePresetsResponse) ProtoReflect 

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

func (*ListResourcePresetsResponse) Reset 

func (x *ListResourcePresetsResponse) Reset()

func (*ListResourcePresetsResponse) SetNextPageToken 

func (m *ListResourcePresetsResponse) SetNextPageToken(v string)

func (*ListResourcePresetsResponse) SetResourcePresets 

func (m *ListResourcePresetsResponse) SetResourcePresets(v []*ResourcePreset)

func (*ListResourcePresetsResponse) String 

func (x *ListResourcePresetsResponse) String() string

type ListTopicsRequest 

type ListTopicsRequest struct {

	// ID of the Apache Kafka® cluster to list topics in.
	//
	// To get the cluster ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the service returns a [ListTopicsResponse.next_page_token] that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.
	//
	// To get the next page of results, set [page_token] to the [ListTopicsResponse.next_page_token] returned by the previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) GetClusterId 

func (x *ListTopicsRequest) GetClusterId() string

func (*ListTopicsRequest) GetPageSize 

func (x *ListTopicsRequest) GetPageSize() int64

func (*ListTopicsRequest) GetPageToken 

func (x *ListTopicsRequest) GetPageToken() 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) SetClusterId 

func (m *ListTopicsRequest) SetClusterId(v string)

func (*ListTopicsRequest) SetPageSize 

func (m *ListTopicsRequest) SetPageSize(v int64)

func (*ListTopicsRequest) SetPageToken 

func (m *ListTopicsRequest) SetPageToken(v string)

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {

	// List of Kafka topics.
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// This token allows you to get the next page of results for list requests.
	//
	// If the number of results is larger than [ListTopicsRequest.page_size], use the [next_page_token] as the value for the [ListTopicsRequest.page_token] parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (m *ListTopicsResponse) SetNextPageToken(v string)

func (*ListTopicsResponse) SetTopics 

func (m *ListTopicsResponse) SetTopics(v []*Topic)

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type ListUsersRequest 

type ListUsersRequest struct {

	// ID of the Apache Kafka® cluster to list Kafka users in.
	//
	// To get the Apache Kafka® cluster ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The maximum number of results per page to return.
	//
	// If the number of available results is larger than [page_size], the service returns a [ListUsersResponse.next_page_token] that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.
	//
	// To get the next page of results, set [page_token] to the [ListUsersResponse.next_page_token] returned by the previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUsersRequest) Descriptor deprecated 

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

Deprecated: Use ListUsersRequest.ProtoReflect.Descriptor instead.

func (*ListUsersRequest) GetClusterId 

func (x *ListUsersRequest) GetClusterId() string

func (*ListUsersRequest) GetPageSize 

func (x *ListUsersRequest) GetPageSize() int64

func (*ListUsersRequest) GetPageToken 

func (x *ListUsersRequest) GetPageToken() string

func (*ListUsersRequest) ProtoMessage 

func (*ListUsersRequest) ProtoMessage()

func (*ListUsersRequest) ProtoReflect 

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

func (*ListUsersRequest) Reset 

func (x *ListUsersRequest) Reset()

func (*ListUsersRequest) SetClusterId 

func (m *ListUsersRequest) SetClusterId(v string)

func (*ListUsersRequest) SetPageSize 

func (m *ListUsersRequest) SetPageSize(v int64)

func (*ListUsersRequest) SetPageToken 

func (m *ListUsersRequest) SetPageToken(v string)

func (*ListUsersRequest) String 

func (x *ListUsersRequest) String() string

type ListUsersResponse 

type ListUsersResponse struct {

	// List of Kafka users.
	Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// This token allows you to get the next page of results for list requests.
	//
	// If the number of results is larger than [ListUsersRequest.page_size], use the [next_page_token] as the value for the [ListUsersRequest.page_token] parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUsersResponse) Descriptor deprecated 

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

Deprecated: Use ListUsersResponse.ProtoReflect.Descriptor instead.

func (*ListUsersResponse) GetNextPageToken 

func (x *ListUsersResponse) GetNextPageToken() string

func (*ListUsersResponse) GetUsers 

func (x *ListUsersResponse) GetUsers() []*User

func (*ListUsersResponse) ProtoMessage 

func (*ListUsersResponse) ProtoMessage()

func (*ListUsersResponse) ProtoReflect 

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

func (*ListUsersResponse) Reset 

func (x *ListUsersResponse) Reset()

func (*ListUsersResponse) SetNextPageToken 

func (m *ListUsersResponse) SetNextPageToken(v string)

func (*ListUsersResponse) SetUsers 

func (m *ListUsersResponse) SetUsers(v []*User)

func (*ListUsersResponse) String 

func (x *ListUsersResponse) String() string

type LogRecord 

type LogRecord struct {

	// Log record timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Contents of the log record.
	Message map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

A single log record.

func (*LogRecord) Descriptor deprecated 

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

Deprecated: Use LogRecord.ProtoReflect.Descriptor instead.

func (*LogRecord) GetMessage 

func (x *LogRecord) GetMessage() map[string]string

func (*LogRecord) GetTimestamp 

func (x *LogRecord) GetTimestamp() *timestamppb.Timestamp

func (*LogRecord) ProtoMessage 

func (*LogRecord) ProtoMessage()

func (*LogRecord) ProtoReflect 

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

func (*LogRecord) Reset 

func (x *LogRecord) Reset()

func (*LogRecord) SetMessage 

func (m *LogRecord) SetMessage(v map[string]string)

func (*LogRecord) SetTimestamp 

func (m *LogRecord) SetTimestamp(v *timestamppb.Timestamp)

func (*LogRecord) String 

func (x *LogRecord) String() string

type MaintenanceOperation 

type MaintenanceOperation struct {
	Info         string                 `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	DelayedUntil *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=delayed_until,json=delayedUntil,proto3" json:"delayed_until,omitempty"`
	// contains filtered or unexported fields
}

func (*MaintenanceOperation) Descriptor deprecated 

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

Deprecated: Use MaintenanceOperation.ProtoReflect.Descriptor instead.

func (*MaintenanceOperation) GetDelayedUntil 

func (x *MaintenanceOperation) GetDelayedUntil() *timestamppb.Timestamp

func (*MaintenanceOperation) GetInfo 

func (x *MaintenanceOperation) GetInfo() string

func (*MaintenanceOperation) ProtoMessage 

func (*MaintenanceOperation) ProtoMessage()

func (*MaintenanceOperation) ProtoReflect 

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

func (*MaintenanceOperation) Reset 

func (x *MaintenanceOperation) Reset()

func (*MaintenanceOperation) SetDelayedUntil 

func (m *MaintenanceOperation) SetDelayedUntil(v *timestamppb.Timestamp)

func (*MaintenanceOperation) SetInfo 

func (m *MaintenanceOperation) SetInfo(v string)

func (*MaintenanceOperation) String 

func (x *MaintenanceOperation) String() string

type MaintenanceWindow 

type MaintenanceWindow struct {

	// Types that are assignable to Policy:
	//
	//	*MaintenanceWindow_Anytime
	//	*MaintenanceWindow_WeeklyMaintenanceWindow
	Policy isMaintenanceWindow_Policy `protobuf_oneof:"policy"`
	// contains filtered or unexported fields
}

func (*MaintenanceWindow) Descriptor deprecated 

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

Deprecated: Use MaintenanceWindow.ProtoReflect.Descriptor instead.

func (*MaintenanceWindow) GetAnytime 

func (x *MaintenanceWindow) GetAnytime() *AnytimeMaintenanceWindow

func (*MaintenanceWindow) GetPolicy 

func (m *MaintenanceWindow) GetPolicy() isMaintenanceWindow_Policy

func (*MaintenanceWindow) GetWeeklyMaintenanceWindow 

func (x *MaintenanceWindow) GetWeeklyMaintenanceWindow() *WeeklyMaintenanceWindow

func (*MaintenanceWindow) ProtoMessage 

func (*MaintenanceWindow) ProtoMessage()

func (*MaintenanceWindow) ProtoReflect 

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

func (*MaintenanceWindow) Reset 

func (x *MaintenanceWindow) Reset()

func (*MaintenanceWindow) SetAnytime 

func (m *MaintenanceWindow) SetAnytime(v *AnytimeMaintenanceWindow)

func (*MaintenanceWindow) SetPolicy 

func (m *MaintenanceWindow) SetPolicy(v MaintenanceWindow_Policy)

func (*MaintenanceWindow) SetWeeklyMaintenanceWindow 

func (m *MaintenanceWindow) SetWeeklyMaintenanceWindow(v *WeeklyMaintenanceWindow)

func (*MaintenanceWindow) String 

func (x *MaintenanceWindow) String() string

type MaintenanceWindow_Anytime 

type MaintenanceWindow_Anytime struct {
	Anytime *AnytimeMaintenanceWindow `protobuf:"bytes,1,opt,name=anytime,proto3,oneof"`
}

type MaintenanceWindow_Policy 

type MaintenanceWindow_Policy = isMaintenanceWindow_Policy

type MaintenanceWindow_WeeklyMaintenanceWindow 

type MaintenanceWindow_WeeklyMaintenanceWindow struct {
	WeeklyMaintenanceWindow *WeeklyMaintenanceWindow `protobuf:"bytes,2,opt,name=weekly_maintenance_window,json=weeklyMaintenanceWindow,proto3,oneof"`
}

type Monitoring 

type Monitoring struct {

	// Name of the monitoring system.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the monitoring system.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Link to the monitoring system charts for the Apache Kafka® cluster.
	Link string `protobuf:"bytes,3,opt,name=link,proto3" json:"link,omitempty"`
	// contains filtered or unexported fields
}

Metadata of monitoring system.

func (*Monitoring) Descriptor deprecated 

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

Deprecated: Use Monitoring.ProtoReflect.Descriptor instead.

func (*Monitoring) GetDescription 

func (x *Monitoring) GetDescription() string
func (x *Monitoring) GetLink() string

func (*Monitoring) GetName 

func (x *Monitoring) GetName() string

func (*Monitoring) ProtoMessage 

func (*Monitoring) ProtoMessage()

func (*Monitoring) ProtoReflect 

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

func (*Monitoring) Reset 

func (x *Monitoring) Reset()

func (*Monitoring) SetDescription 

func (m *Monitoring) SetDescription(v string)
func (m *Monitoring) SetLink(v string)

func (*Monitoring) SetName 

func (m *Monitoring) SetName(v string)

func (*Monitoring) String 

func (x *Monitoring) String() string

type MoveClusterMetadata 

type MoveClusterMetadata struct {

	// ID of the Apache Kafka® cluster being moved.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// ID of the source folder.
	SourceFolderId string `protobuf:"bytes,2,opt,name=source_folder_id,json=sourceFolderId,proto3" json:"source_folder_id,omitempty"`
	// ID of the destnation folder.
	DestinationFolderId string `protobuf:"bytes,3,opt,name=destination_folder_id,json=destinationFolderId,proto3" json:"destination_folder_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveClusterMetadata) Descriptor deprecated 

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

Deprecated: Use MoveClusterMetadata.ProtoReflect.Descriptor instead.

func (*MoveClusterMetadata) GetClusterId 

func (x *MoveClusterMetadata) GetClusterId() string

func (*MoveClusterMetadata) GetDestinationFolderId 

func (x *MoveClusterMetadata) GetDestinationFolderId() string

func (*MoveClusterMetadata) GetSourceFolderId 

func (x *MoveClusterMetadata) GetSourceFolderId() string

func (*MoveClusterMetadata) ProtoMessage 

func (*MoveClusterMetadata) ProtoMessage()

func (*MoveClusterMetadata) ProtoReflect 

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

func (*MoveClusterMetadata) Reset 

func (x *MoveClusterMetadata) Reset()

func (*MoveClusterMetadata) SetClusterId 

func (m *MoveClusterMetadata) SetClusterId(v string)

func (*MoveClusterMetadata) SetDestinationFolderId 

func (m *MoveClusterMetadata) SetDestinationFolderId(v string)

func (*MoveClusterMetadata) SetSourceFolderId 

func (m *MoveClusterMetadata) SetSourceFolderId(v string)

func (*MoveClusterMetadata) String 

func (x *MoveClusterMetadata) String() string

type MoveClusterRequest 

type MoveClusterRequest struct {

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

func (*MoveClusterRequest) Descriptor deprecated 

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

Deprecated: Use MoveClusterRequest.ProtoReflect.Descriptor instead.

func (*MoveClusterRequest) GetClusterId 

func (x *MoveClusterRequest) GetClusterId() string

func (*MoveClusterRequest) GetDestinationFolderId 

func (x *MoveClusterRequest) GetDestinationFolderId() string

func (*MoveClusterRequest) ProtoMessage 

func (*MoveClusterRequest) ProtoMessage()

func (*MoveClusterRequest) ProtoReflect 

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

func (*MoveClusterRequest) Reset 

func (x *MoveClusterRequest) Reset()

func (*MoveClusterRequest) SetClusterId 

func (m *MoveClusterRequest) SetClusterId(v string)

func (*MoveClusterRequest) SetDestinationFolderId 

func (m *MoveClusterRequest) SetDestinationFolderId(v string)

func (*MoveClusterRequest) String 

func (x *MoveClusterRequest) String() string

type PauseConnectorMetadata 

type PauseConnectorMetadata struct {

	// ID of the Apache Kafka® cluster the connector is being paused 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 paused.
	ConnectorName string `protobuf:"bytes,2,opt,name=connector_name,json=connectorName,proto3" json:"connector_name,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use PauseConnectorMetadata.ProtoReflect.Descriptor instead.

func (*PauseConnectorMetadata) GetClusterId 

func (x *PauseConnectorMetadata) GetClusterId() string

func (*PauseConnectorMetadata) GetConnectorName 

func (x *PauseConnectorMetadata) GetConnectorName() string

func (*PauseConnectorMetadata) ProtoMessage 

func (*PauseConnectorMetadata) ProtoMessage()

func (*PauseConnectorMetadata) ProtoReflect 

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

func (*PauseConnectorMetadata) Reset 

func (x *PauseConnectorMetadata) Reset()

func (*PauseConnectorMetadata) SetClusterId 

func (m *PauseConnectorMetadata) SetClusterId(v string)

func (*PauseConnectorMetadata) SetConnectorName 

func (m *PauseConnectorMetadata) SetConnectorName(v string)

func (*PauseConnectorMetadata) String 

func (x *PauseConnectorMetadata) String() string

type PauseConnectorRequest 

type PauseConnectorRequest struct {

	// ID of the Apache Kafka® cluster to pause 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"`
	// Name of the Apache Kafka® connector to pause.
	//
	// 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
}

func (*PauseConnectorRequest) Descriptor deprecated 

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

Deprecated: Use PauseConnectorRequest.ProtoReflect.Descriptor instead.

func (*PauseConnectorRequest) GetClusterId 

func (x *PauseConnectorRequest) GetClusterId() string

func (*PauseConnectorRequest) GetConnectorName 

func (x *PauseConnectorRequest) GetConnectorName() string

func (*PauseConnectorRequest) ProtoMessage 

func (*PauseConnectorRequest) ProtoMessage()

func (*PauseConnectorRequest) ProtoReflect 

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

func (*PauseConnectorRequest) Reset 

func (x *PauseConnectorRequest) Reset()

func (*PauseConnectorRequest) SetClusterId 

func (m *PauseConnectorRequest) SetClusterId(v string)

func (*PauseConnectorRequest) SetConnectorName 

func (m *PauseConnectorRequest) SetConnectorName(v string)

func (*PauseConnectorRequest) String 

func (x *PauseConnectorRequest) String() string

type Permission 

type Permission struct {

	// Name or prefix-pattern with wildcard for the topic that the permission grants access to.
	//
	// To get the topic name, make a [TopicService.List] request.
	TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// Access role type to grant to the user.
	Role Permission_AccessRole `protobuf:"varint,2,opt,name=role,proto3,enum=yandex.cloud.mdb.kafka.v1.Permission_AccessRole" json:"role,omitempty"`
	// Lists hosts allowed for this permission.
	// When not defined, access from any host is allowed.
	//
	// Bare in mind that the same host might appear in multiple permissions at the same time,
	// hence removing individual permission doesn't automatically restricts access from the [allow_hosts] of the permission.
	// If the same host(s) is listed for another permission of the same principal/topic, the host(s) remains allowed.
	AllowHosts []string `protobuf:"bytes,4,rep,name=allow_hosts,json=allowHosts,proto3" json:"allow_hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*Permission) Descriptor deprecated 

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

Deprecated: Use Permission.ProtoReflect.Descriptor instead.

func (*Permission) GetAllowHosts 

func (x *Permission) GetAllowHosts() []string

func (*Permission) GetRole 

func (x *Permission) GetRole() Permission_AccessRole

func (*Permission) GetTopicName 

func (x *Permission) GetTopicName() string

func (*Permission) ProtoMessage 

func (*Permission) ProtoMessage()

func (*Permission) ProtoReflect 

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

func (*Permission) Reset 

func (x *Permission) Reset()

func (*Permission) SetAllowHosts 

func (m *Permission) SetAllowHosts(v []string)

func (*Permission) SetRole 

func (m *Permission) SetRole(v Permission_AccessRole)

func (*Permission) SetTopicName 

func (m *Permission) SetTopicName(v string)

func (*Permission) String 

func (x *Permission) String() string

type Permission_AccessRole 

type Permission_AccessRole int32
const (
	Permission_ACCESS_ROLE_UNSPECIFIED Permission_AccessRole = 0
	// producer role for the user.
	Permission_ACCESS_ROLE_PRODUCER Permission_AccessRole = 1
	// consumer role for the user.
	Permission_ACCESS_ROLE_CONSUMER Permission_AccessRole = 2
	// admin role for the user.
	Permission_ACCESS_ROLE_ADMIN Permission_AccessRole = 3
)

func (Permission_AccessRole) Descriptor 

func (Permission_AccessRole) Descriptor() protoreflect.EnumDescriptor

func (Permission_AccessRole) Enum 

func (x Permission_AccessRole) Enum() *Permission_AccessRole

func (Permission_AccessRole) EnumDescriptor deprecated 

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

Deprecated: Use Permission_AccessRole.Descriptor instead.

func (Permission_AccessRole) Number 

func (x Permission_AccessRole) Number() protoreflect.EnumNumber

func (Permission_AccessRole) String 

func (x Permission_AccessRole) String() string

func (Permission_AccessRole) Type 

func (Permission_AccessRole) Type() protoreflect.EnumType

type RescheduleMaintenanceMetadata 

type RescheduleMaintenanceMetadata struct {

	// ID of the Kafka cluster.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The time until which this maintenance operation is to be delayed.
	DelayedUntil *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=delayed_until,json=delayedUntil,proto3" json:"delayed_until,omitempty"`
	// contains filtered or unexported fields
}

func (*RescheduleMaintenanceMetadata) Descriptor deprecated 

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

Deprecated: Use RescheduleMaintenanceMetadata.ProtoReflect.Descriptor instead.

func (*RescheduleMaintenanceMetadata) GetClusterId 

func (x *RescheduleMaintenanceMetadata) GetClusterId() string

func (*RescheduleMaintenanceMetadata) GetDelayedUntil 

func (x *RescheduleMaintenanceMetadata) GetDelayedUntil() *timestamppb.Timestamp

func (*RescheduleMaintenanceMetadata) ProtoMessage 

func (*RescheduleMaintenanceMetadata) ProtoMessage()

func (*RescheduleMaintenanceMetadata) ProtoReflect 

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

func (*RescheduleMaintenanceMetadata) Reset 

func (x *RescheduleMaintenanceMetadata) Reset()

func (*RescheduleMaintenanceMetadata) SetClusterId 

func (m *RescheduleMaintenanceMetadata) SetClusterId(v string)

func (*RescheduleMaintenanceMetadata) SetDelayedUntil 

func (m *RescheduleMaintenanceMetadata) SetDelayedUntil(v *timestamppb.Timestamp)

func (*RescheduleMaintenanceMetadata) String 

func (x *RescheduleMaintenanceMetadata) String() string

type RescheduleMaintenanceRequest 

type RescheduleMaintenanceRequest struct {

	// ID of the Kafka cluster to reschedule the maintenance operation for.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The type of reschedule request.
	RescheduleType RescheduleMaintenanceRequest_RescheduleType `` /* 179-byte string literal not displayed */
	// The time until which this maintenance operation should be delayed. The value should be ahead of the first time when the maintenance operation has been scheduled for no more than two weeks. The value can also point to the past moment of time if [reschedule_type.IMMEDIATE] reschedule type is chosen.
	DelayedUntil *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=delayed_until,json=delayedUntil,proto3" json:"delayed_until,omitempty"`
	// contains filtered or unexported fields
}

func (*RescheduleMaintenanceRequest) Descriptor deprecated 

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

Deprecated: Use RescheduleMaintenanceRequest.ProtoReflect.Descriptor instead.

func (*RescheduleMaintenanceRequest) GetClusterId 

func (x *RescheduleMaintenanceRequest) GetClusterId() string

func (*RescheduleMaintenanceRequest) GetDelayedUntil 

func (x *RescheduleMaintenanceRequest) GetDelayedUntil() *timestamppb.Timestamp

func (*RescheduleMaintenanceRequest) GetRescheduleType 

func (x *RescheduleMaintenanceRequest) GetRescheduleType() RescheduleMaintenanceRequest_RescheduleType

func (*RescheduleMaintenanceRequest) ProtoMessage 

func (*RescheduleMaintenanceRequest) ProtoMessage()

func (*RescheduleMaintenanceRequest) ProtoReflect 

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

func (*RescheduleMaintenanceRequest) Reset 

func (x *RescheduleMaintenanceRequest) Reset()

func (*RescheduleMaintenanceRequest) SetClusterId 

func (m *RescheduleMaintenanceRequest) SetClusterId(v string)

func (*RescheduleMaintenanceRequest) SetDelayedUntil 

func (m *RescheduleMaintenanceRequest) SetDelayedUntil(v *timestamppb.Timestamp)

func (*RescheduleMaintenanceRequest) SetRescheduleType 

func (m *RescheduleMaintenanceRequest) SetRescheduleType(v RescheduleMaintenanceRequest_RescheduleType)

func (*RescheduleMaintenanceRequest) String 

func (x *RescheduleMaintenanceRequest) String() string

type RescheduleMaintenanceRequest_RescheduleType 

type RescheduleMaintenanceRequest_RescheduleType int32
const (
	RescheduleMaintenanceRequest_RESCHEDULE_TYPE_UNSPECIFIED RescheduleMaintenanceRequest_RescheduleType = 0
	// Start the maintenance operation immediately.
	RescheduleMaintenanceRequest_IMMEDIATE RescheduleMaintenanceRequest_RescheduleType = 1
	// Start the maintenance operation within the next available maintenance window.
	RescheduleMaintenanceRequest_NEXT_AVAILABLE_WINDOW RescheduleMaintenanceRequest_RescheduleType = 2
	// Start the maintenance operation at the specific time.
	RescheduleMaintenanceRequest_SPECIFIC_TIME RescheduleMaintenanceRequest_RescheduleType = 3
)

func (RescheduleMaintenanceRequest_RescheduleType) Descriptor 

func (RescheduleMaintenanceRequest_RescheduleType) Descriptor() protoreflect.EnumDescriptor

func (RescheduleMaintenanceRequest_RescheduleType) Enum 

func (x RescheduleMaintenanceRequest_RescheduleType) Enum() *RescheduleMaintenanceRequest_RescheduleType

func (RescheduleMaintenanceRequest_RescheduleType) EnumDescriptor deprecated 

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

Deprecated: Use RescheduleMaintenanceRequest_RescheduleType.Descriptor instead.

func (RescheduleMaintenanceRequest_RescheduleType) Number 

func (x RescheduleMaintenanceRequest_RescheduleType) Number() protoreflect.EnumNumber

func (RescheduleMaintenanceRequest_RescheduleType) String 

func (x RescheduleMaintenanceRequest_RescheduleType) String() string

func (RescheduleMaintenanceRequest_RescheduleType) Type 

func (RescheduleMaintenanceRequest_RescheduleType) Type() protoreflect.EnumType

type ResourcePreset 

type ResourcePreset struct {

	// ID of the resource preset.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// IDs of availability zones where the resource preset is available.
	ZoneIds []string `protobuf:"bytes,2,rep,name=zone_ids,json=zoneIds,proto3" json:"zone_ids,omitempty"`
	// Number of CPU cores for a Kafka broker created with the preset.
	Cores int64 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"`
	// RAM volume for a Kafka broker created with the preset, in bytes.
	Memory int64 `protobuf:"varint,4,opt,name=memory,proto3" json:"memory,omitempty"`
	// contains filtered or unexported fields
}

A ResourcePreset resource for describing hardware configuration presets.

func (*ResourcePreset) Descriptor deprecated 

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

Deprecated: Use ResourcePreset.ProtoReflect.Descriptor instead.

func (*ResourcePreset) GetCores 

func (x *ResourcePreset) GetCores() int64

func (*ResourcePreset) GetId 

func (x *ResourcePreset) GetId() string

func (*ResourcePreset) GetMemory 

func (x *ResourcePreset) GetMemory() int64

func (*ResourcePreset) GetZoneIds 

func (x *ResourcePreset) GetZoneIds() []string

func (*ResourcePreset) ProtoMessage 

func (*ResourcePreset) ProtoMessage()

func (*ResourcePreset) ProtoReflect 

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

func (*ResourcePreset) Reset 

func (x *ResourcePreset) Reset()

func (*ResourcePreset) SetCores 

func (m *ResourcePreset) SetCores(v int64)

func (*ResourcePreset) SetId 

func (m *ResourcePreset) SetId(v string)

func (*ResourcePreset) SetMemory 

func (m *ResourcePreset) SetMemory(v int64)

func (*ResourcePreset) SetZoneIds 

func (m *ResourcePreset) SetZoneIds(v []string)

func (*ResourcePreset) String 

func (x *ResourcePreset) String() string

type ResourcePresetServiceClient 

type ResourcePresetServiceClient interface {
	// Returns the specified resource preset.
	//
	// To get the list of available resource presets, make a [List] request.
	Get(ctx context.Context, in *GetResourcePresetRequest, opts ...grpc.CallOption) (*ResourcePreset, error)
	// Retrieves the list of available resource presets.
	List(ctx context.Context, in *ListResourcePresetsRequest, opts ...grpc.CallOption) (*ListResourcePresetsResponse, error)
}

ResourcePresetServiceClient is the client API for ResourcePresetService 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 NewResourcePresetServiceClient 

func NewResourcePresetServiceClient(cc grpc.ClientConnInterface) ResourcePresetServiceClient

type ResourcePresetServiceServer 

type ResourcePresetServiceServer interface {
	// Returns the specified resource preset.
	//
	// To get the list of available resource presets, make a [List] request.
	Get(context.Context, *GetResourcePresetRequest) (*ResourcePreset, error)
	// Retrieves the list of available resource presets.
	List(context.Context, *ListResourcePresetsRequest) (*ListResourcePresetsResponse, error)
}

ResourcePresetServiceServer is the server API for ResourcePresetService service. All implementations should embed UnimplementedResourcePresetServiceServer for forward compatibility

type Resources 

type Resources struct {

	// ID of the preset for computational resources available to a host (CPU, memory, etc.).
	// All available presets are listed in the [documentation](/docs/managed-kafka/concepts/instance-types).
	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. Must be greater than 2 * partition segment size in bytes * partitions count, so each partition can have one active segment file and one closed segment file that can be deleted.
	DiskSize int64 `protobuf:"varint,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
	// Type of the storage environment for the host.
	DiskTypeId string `protobuf:"bytes,3,opt,name=disk_type_id,json=diskTypeId,proto3" json:"disk_type_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Resources) Descriptor deprecated 

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetDiskSize 

func (x *Resources) GetDiskSize() int64

func (*Resources) GetDiskTypeId 

func (x *Resources) GetDiskTypeId() string

func (*Resources) GetResourcePresetId 

func (x *Resources) GetResourcePresetId() string

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect 

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

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) SetDiskSize 

func (m *Resources) SetDiskSize(v int64)

func (*Resources) SetDiskTypeId 

func (m *Resources) SetDiskTypeId(v string)

func (*Resources) SetResourcePresetId 

func (m *Resources) SetResourcePresetId(v string)

func (*Resources) String 

func (x *Resources) String() string

type ResumeConnectorMetadata 

type ResumeConnectorMetadata struct {

	// ID of the Apache Kafka® cluster the connector is being resumed 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 beign resumed.
	ConnectorName string `protobuf:"bytes,2,opt,name=connector_name,json=connectorName,proto3" json:"connector_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use ResumeConnectorMetadata.ProtoReflect.Descriptor instead.

func (*ResumeConnectorMetadata) GetClusterId 

func (x *ResumeConnectorMetadata) GetClusterId() string

func (*ResumeConnectorMetadata) GetConnectorName 

func (x *ResumeConnectorMetadata) GetConnectorName() string

func (*ResumeConnectorMetadata) ProtoMessage 

func (*ResumeConnectorMetadata) ProtoMessage()

func (*ResumeConnectorMetadata) ProtoReflect 

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

func (*ResumeConnectorMetadata) Reset 

func (x *ResumeConnectorMetadata) Reset()

func (*ResumeConnectorMetadata) SetClusterId 

func (m *ResumeConnectorMetadata) SetClusterId(v string)

func (*ResumeConnectorMetadata) SetConnectorName 

func (m *ResumeConnectorMetadata) SetConnectorName(v string)

func (*ResumeConnectorMetadata) String 

func (x *ResumeConnectorMetadata) String() string

type ResumeConnectorRequest 

type ResumeConnectorRequest struct {

	// ID of the Apache Kafka® cluster to resume 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"`
	// Name of the Apache Kafka® connector to resume.
	//
	// 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
}

func (*ResumeConnectorRequest) Descriptor deprecated 

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

Deprecated: Use ResumeConnectorRequest.ProtoReflect.Descriptor instead.

func (*ResumeConnectorRequest) GetClusterId 

func (x *ResumeConnectorRequest) GetClusterId() string

func (*ResumeConnectorRequest) GetConnectorName 

func (x *ResumeConnectorRequest) GetConnectorName() string

func (*ResumeConnectorRequest) ProtoMessage 

func (*ResumeConnectorRequest) ProtoMessage()

func (*ResumeConnectorRequest) ProtoReflect 

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

func (*ResumeConnectorRequest) Reset 

func (x *ResumeConnectorRequest) Reset()

func (*ResumeConnectorRequest) SetClusterId 

func (m *ResumeConnectorRequest) SetClusterId(v string)

func (*ResumeConnectorRequest) SetConnectorName 

func (m *ResumeConnectorRequest) SetConnectorName(v string)

func (*ResumeConnectorRequest) String 

func (x *ResumeConnectorRequest) String() string

type RevokeUserPermissionMetadata 

type RevokeUserPermissionMetadata struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the user whose permission is being revoked.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeUserPermissionMetadata) Descriptor deprecated 

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

Deprecated: Use RevokeUserPermissionMetadata.ProtoReflect.Descriptor instead.

func (*RevokeUserPermissionMetadata) GetClusterId 

func (x *RevokeUserPermissionMetadata) GetClusterId() string

func (*RevokeUserPermissionMetadata) GetUserName 

func (x *RevokeUserPermissionMetadata) GetUserName() string

func (*RevokeUserPermissionMetadata) ProtoMessage 

func (*RevokeUserPermissionMetadata) ProtoMessage()

func (*RevokeUserPermissionMetadata) ProtoReflect 

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

func (*RevokeUserPermissionMetadata) Reset 

func (x *RevokeUserPermissionMetadata) Reset()

func (*RevokeUserPermissionMetadata) SetClusterId 

func (m *RevokeUserPermissionMetadata) SetClusterId(v string)

func (*RevokeUserPermissionMetadata) SetUserName 

func (m *RevokeUserPermissionMetadata) SetUserName(v string)

func (*RevokeUserPermissionMetadata) String 

func (x *RevokeUserPermissionMetadata) String() string

type RevokeUserPermissionRequest 

type RevokeUserPermissionRequest struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	//
	// To get the cluster 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 user to revoke a permission from.
	//
	// To get the name of the user, make a [UserService.List] request.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// Permission that should be revoked from the specified user.
	Permission *Permission `protobuf:"bytes,3,opt,name=permission,proto3" json:"permission,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeUserPermissionRequest) Descriptor deprecated 

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

Deprecated: Use RevokeUserPermissionRequest.ProtoReflect.Descriptor instead.

func (*RevokeUserPermissionRequest) GetClusterId 

func (x *RevokeUserPermissionRequest) GetClusterId() string

func (*RevokeUserPermissionRequest) GetPermission 

func (x *RevokeUserPermissionRequest) GetPermission() *Permission

func (*RevokeUserPermissionRequest) GetUserName 

func (x *RevokeUserPermissionRequest) GetUserName() string

func (*RevokeUserPermissionRequest) ProtoMessage 

func (*RevokeUserPermissionRequest) ProtoMessage()

func (*RevokeUserPermissionRequest) ProtoReflect 

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

func (*RevokeUserPermissionRequest) Reset 

func (x *RevokeUserPermissionRequest) Reset()

func (*RevokeUserPermissionRequest) SetClusterId 

func (m *RevokeUserPermissionRequest) SetClusterId(v string)

func (*RevokeUserPermissionRequest) SetPermission 

func (m *RevokeUserPermissionRequest) SetPermission(v *Permission)

func (*RevokeUserPermissionRequest) SetUserName 

func (m *RevokeUserPermissionRequest) SetUserName(v string)

func (*RevokeUserPermissionRequest) String 

func (x *RevokeUserPermissionRequest) String() string

type S3Connection 

type S3Connection struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Types that are assignable to Storage:
	//
	//	*S3Connection_ExternalS3
	Storage isS3Connection_Storage `protobuf_oneof:"storage"`
	// contains filtered or unexported fields
}

Resource for S3Connection - settings of connection to AWS-compatible S3 storage, that are source or target of Kafka S3-connectors. YC Object Storage is AWS-compatible.

func (*S3Connection) Descriptor deprecated 

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

Deprecated: Use S3Connection.ProtoReflect.Descriptor instead.

func (*S3Connection) GetBucketName 

func (x *S3Connection) GetBucketName() string

func (*S3Connection) GetExternalS3 

func (x *S3Connection) GetExternalS3() *ExternalS3Storage

func (*S3Connection) GetStorage 

func (m *S3Connection) GetStorage() isS3Connection_Storage

func (*S3Connection) ProtoMessage 

func (*S3Connection) ProtoMessage()

func (*S3Connection) ProtoReflect 

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

func (*S3Connection) Reset 

func (x *S3Connection) Reset()

func (*S3Connection) SetBucketName 

func (m *S3Connection) SetBucketName(v string)

func (*S3Connection) SetExternalS3 

func (m *S3Connection) SetExternalS3(v *ExternalS3Storage)

func (*S3Connection) SetStorage 

func (m *S3Connection) SetStorage(v S3Connection_Storage)

func (*S3Connection) String 

func (x *S3Connection) String() string

type S3ConnectionSpec 

type S3ConnectionSpec struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// Types that are assignable to Storage:
	//
	//	*S3ConnectionSpec_ExternalS3
	Storage isS3ConnectionSpec_Storage `protobuf_oneof:"storage"`
	// contains filtered or unexported fields
}

Specification for S3Connection - settings of connection to AWS-compatible S3 storage, that are source or target of Kafka S3-connectors. YC Object Storage is AWS-compatible.

func (*S3ConnectionSpec) Descriptor deprecated 

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

Deprecated: Use S3ConnectionSpec.ProtoReflect.Descriptor instead.

func (*S3ConnectionSpec) GetBucketName 

func (x *S3ConnectionSpec) GetBucketName() string

func (*S3ConnectionSpec) GetExternalS3 

func (x *S3ConnectionSpec) GetExternalS3() *ExternalS3StorageSpec

func (*S3ConnectionSpec) GetStorage 

func (m *S3ConnectionSpec) GetStorage() isS3ConnectionSpec_Storage

func (*S3ConnectionSpec) ProtoMessage 

func (*S3ConnectionSpec) ProtoMessage()

func (*S3ConnectionSpec) ProtoReflect 

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

func (*S3ConnectionSpec) Reset 

func (x *S3ConnectionSpec) Reset()

func (*S3ConnectionSpec) SetBucketName 

func (m *S3ConnectionSpec) SetBucketName(v string)

func (*S3ConnectionSpec) SetExternalS3 

func (m *S3ConnectionSpec) SetExternalS3(v *ExternalS3StorageSpec)

func (*S3ConnectionSpec) SetStorage 

func (m *S3ConnectionSpec) SetStorage(v S3ConnectionSpec_Storage)

func (*S3ConnectionSpec) String 

func (x *S3ConnectionSpec) String() string

type S3ConnectionSpec_ExternalS3 

type S3ConnectionSpec_ExternalS3 struct {
	ExternalS3 *ExternalS3StorageSpec `protobuf:"bytes,2,opt,name=external_s3,json=externalS3,proto3,oneof"`
}

type S3ConnectionSpec_Storage 

type S3ConnectionSpec_Storage = isS3ConnectionSpec_Storage

type S3Connection_ExternalS3 

type S3Connection_ExternalS3 struct {
	ExternalS3 *ExternalS3Storage `protobuf:"bytes,2,opt,name=external_s3,json=externalS3,proto3,oneof"`
}

type S3Connection_Storage 

type S3Connection_Storage = isS3Connection_Storage

type SaslMechanism 

type SaslMechanism int32
const (
	SaslMechanism_SASL_MECHANISM_UNSPECIFIED   SaslMechanism = 0
	SaslMechanism_SASL_MECHANISM_SCRAM_SHA_256 SaslMechanism = 1
	SaslMechanism_SASL_MECHANISM_SCRAM_SHA_512 SaslMechanism = 2
)

func (SaslMechanism) Descriptor 

func (SaslMechanism) Descriptor() protoreflect.EnumDescriptor

func (SaslMechanism) Enum 

func (x SaslMechanism) Enum() *SaslMechanism

func (SaslMechanism) EnumDescriptor deprecated 

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

Deprecated: Use SaslMechanism.Descriptor instead.

func (SaslMechanism) Number 

func (x SaslMechanism) Number() protoreflect.EnumNumber

func (SaslMechanism) String 

func (x SaslMechanism) String() string

func (SaslMechanism) Type 

func (SaslMechanism) Type() protoreflect.EnumType

type StartClusterMetadata 

type StartClusterMetadata struct {

	// ID of the Apache Kafka® cluster.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartClusterMetadata) Descriptor deprecated 

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

Deprecated: Use StartClusterMetadata.ProtoReflect.Descriptor instead.

func (*StartClusterMetadata) GetClusterId 

func (x *StartClusterMetadata) GetClusterId() string

func (*StartClusterMetadata) ProtoMessage 

func (*StartClusterMetadata) ProtoMessage()

func (*StartClusterMetadata) ProtoReflect 

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

func (*StartClusterMetadata) Reset 

func (x *StartClusterMetadata) Reset()

func (*StartClusterMetadata) SetClusterId 

func (m *StartClusterMetadata) SetClusterId(v string)

func (*StartClusterMetadata) String 

func (x *StartClusterMetadata) String() string

type StartClusterRequest 

type StartClusterRequest struct {

	// ID of the Apache Kafka® cluster to start.
	//
	// To get the Apache Kafka® cluster ID, make 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
}

func (*StartClusterRequest) Descriptor deprecated 

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

Deprecated: Use StartClusterRequest.ProtoReflect.Descriptor instead.

func (*StartClusterRequest) GetClusterId 

func (x *StartClusterRequest) GetClusterId() string

func (*StartClusterRequest) ProtoMessage 

func (*StartClusterRequest) ProtoMessage()

func (*StartClusterRequest) ProtoReflect 

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

func (*StartClusterRequest) Reset 

func (x *StartClusterRequest) Reset()

func (*StartClusterRequest) SetClusterId 

func (m *StartClusterRequest) SetClusterId(v string)

func (*StartClusterRequest) String 

func (x *StartClusterRequest) String() string

type StopClusterMetadata 

type StopClusterMetadata struct {

	// ID of the Apache Kafka® cluster.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopClusterMetadata) Descriptor deprecated 

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

Deprecated: Use StopClusterMetadata.ProtoReflect.Descriptor instead.

func (*StopClusterMetadata) GetClusterId 

func (x *StopClusterMetadata) GetClusterId() string

func (*StopClusterMetadata) ProtoMessage 

func (*StopClusterMetadata) ProtoMessage()

func (*StopClusterMetadata) ProtoReflect 

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

func (*StopClusterMetadata) Reset 

func (x *StopClusterMetadata) Reset()

func (*StopClusterMetadata) SetClusterId 

func (m *StopClusterMetadata) SetClusterId(v string)

func (*StopClusterMetadata) String 

func (x *StopClusterMetadata) String() string

type StopClusterRequest 

type StopClusterRequest struct {

	// ID of the Apache Kafka® cluster to stop.
	//
	// To get the Apache Kafka® cluster ID, make 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
}

func (*StopClusterRequest) Descriptor deprecated 

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

Deprecated: Use StopClusterRequest.ProtoReflect.Descriptor instead.

func (*StopClusterRequest) GetClusterId 

func (x *StopClusterRequest) GetClusterId() string

func (*StopClusterRequest) ProtoMessage 

func (*StopClusterRequest) ProtoMessage()

func (*StopClusterRequest) ProtoReflect 

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

func (*StopClusterRequest) Reset 

func (x *StopClusterRequest) Reset()

func (*StopClusterRequest) SetClusterId 

func (m *StopClusterRequest) SetClusterId(v string)

func (*StopClusterRequest) String 

func (x *StopClusterRequest) String() string

type StreamClusterLogsRequest 

type StreamClusterLogsRequest struct {

	// ID of the Apache Kafka® cluster.
	//
	// To get the Apache Kafka® cluster ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Columns from logs table to get in the response.
	//
	// If no columns are specified, full log records are returned.
	ColumnFilter []string `protobuf:"bytes,2,rep,name=column_filter,json=columnFilter,proto3" json:"column_filter,omitempty"`
	// Start timestamp for the logs request.
	FromTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	// End timestamp for the logs request.
	//
	// If this field is not set, all existing logs will be sent and then the new ones as they appear.
	// In essence it has `tail -f` semantics.
	ToTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=to_time,json=toTime,proto3" json:"to_time,omitempty"`
	// Record token.
	//
	// Set [record_token] to the [StreamLogRecord.next_record_token] returned by a previous [ClusterService.StreamLogs] request to start streaming from next log record.
	RecordToken string `protobuf:"bytes,5,opt,name=record_token,json=recordToken,proto3" json:"record_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	//
	// The expression must specify:
	// 1. The field name to filter by. Currently filtering can be applied to the `hostname` field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	//
	// Example of a filter: `message.hostname='node1.db.cloud.yandex.net'`
	Filter string `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamClusterLogsRequest) Descriptor deprecated 

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

Deprecated: Use StreamClusterLogsRequest.ProtoReflect.Descriptor instead.

func (*StreamClusterLogsRequest) GetClusterId 

func (x *StreamClusterLogsRequest) GetClusterId() string

func (*StreamClusterLogsRequest) GetColumnFilter 

func (x *StreamClusterLogsRequest) GetColumnFilter() []string

func (*StreamClusterLogsRequest) GetFilter 

func (x *StreamClusterLogsRequest) GetFilter() string

func (*StreamClusterLogsRequest) GetFromTime 

func (x *StreamClusterLogsRequest) GetFromTime() *timestamppb.Timestamp

func (*StreamClusterLogsRequest) GetRecordToken 

func (x *StreamClusterLogsRequest) GetRecordToken() string

func (*StreamClusterLogsRequest) GetToTime 

func (x *StreamClusterLogsRequest) GetToTime() *timestamppb.Timestamp

func (*StreamClusterLogsRequest) ProtoMessage 

func (*StreamClusterLogsRequest) ProtoMessage()

func (*StreamClusterLogsRequest) ProtoReflect 

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

func (*StreamClusterLogsRequest) Reset 

func (x *StreamClusterLogsRequest) Reset()

func (*StreamClusterLogsRequest) SetClusterId 

func (m *StreamClusterLogsRequest) SetClusterId(v string)

func (*StreamClusterLogsRequest) SetColumnFilter 

func (m *StreamClusterLogsRequest) SetColumnFilter(v []string)

func (*StreamClusterLogsRequest) SetFilter 

func (m *StreamClusterLogsRequest) SetFilter(v string)

func (*StreamClusterLogsRequest) SetFromTime 

func (m *StreamClusterLogsRequest) SetFromTime(v *timestamppb.Timestamp)

func (*StreamClusterLogsRequest) SetRecordToken 

func (m *StreamClusterLogsRequest) SetRecordToken(v string)

func (*StreamClusterLogsRequest) SetToTime 

func (m *StreamClusterLogsRequest) SetToTime(v *timestamppb.Timestamp)

func (*StreamClusterLogsRequest) String 

func (x *StreamClusterLogsRequest) String() string

type StreamLogRecord 

type StreamLogRecord struct {

	// One of the requested log records.
	Record *LogRecord `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// This token allows you to continue streaming logs starting from the exact same record.
	//
	// To continue streaming, specify value of [next_record_token] as value for [StreamClusterLogsRequest.record_token] parameter in the next StreamLogs request.
	//
	// This value is interchangeable with [ListClusterLogsResponse.next_page_token] from ListLogs method.
	NextRecordToken string `protobuf:"bytes,2,opt,name=next_record_token,json=nextRecordToken,proto3" json:"next_record_token,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamLogRecord) Descriptor deprecated 

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

Deprecated: Use StreamLogRecord.ProtoReflect.Descriptor instead.

func (*StreamLogRecord) GetNextRecordToken 

func (x *StreamLogRecord) GetNextRecordToken() string

func (*StreamLogRecord) GetRecord 

func (x *StreamLogRecord) GetRecord() *LogRecord

func (*StreamLogRecord) ProtoMessage 

func (*StreamLogRecord) ProtoMessage()

func (*StreamLogRecord) ProtoReflect 

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

func (*StreamLogRecord) Reset 

func (x *StreamLogRecord) Reset()

func (*StreamLogRecord) SetNextRecordToken 

func (m *StreamLogRecord) SetNextRecordToken(v string)

func (*StreamLogRecord) SetRecord 

func (m *StreamLogRecord) SetRecord(v *LogRecord)

func (*StreamLogRecord) String 

func (x *StreamLogRecord) String() string

type ThisCluster 

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

func (*ThisCluster) Descriptor deprecated 

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

Deprecated: Use ThisCluster.ProtoReflect.Descriptor instead.

func (*ThisCluster) ProtoMessage 

func (*ThisCluster) ProtoMessage()

func (*ThisCluster) ProtoReflect 

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

func (*ThisCluster) Reset 

func (x *ThisCluster) Reset()

func (*ThisCluster) String 

func (x *ThisCluster) String() string

type ThisClusterSpec 

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

func (*ThisClusterSpec) Descriptor deprecated 

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

Deprecated: Use ThisClusterSpec.ProtoReflect.Descriptor instead.

func (*ThisClusterSpec) ProtoMessage 

func (*ThisClusterSpec) ProtoMessage()

func (*ThisClusterSpec) ProtoReflect 

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

func (*ThisClusterSpec) Reset 

func (x *ThisClusterSpec) Reset()

func (*ThisClusterSpec) String 

func (x *ThisClusterSpec) String() string

type Topic 

type Topic struct {

	// Name of the topic.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// ID of an Apache Kafka® cluster that the topic belongs to.
	//
	// To get the Apache Kafka® cluster ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The number of the topic's partitions.
	Partitions *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=partitions,proto3" json:"partitions,omitempty"`
	// Amount of data copies (replicas) for the topic in the cluster.
	ReplicationFactor *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	// User-defined settings for the topic.
	//
	// Types that are assignable to TopicConfig:
	//
	//	*Topic_TopicConfig_2_8
	//	*Topic_TopicConfig_3
	TopicConfig isTopic_TopicConfig `protobuf_oneof:"topic_config"`
	// contains filtered or unexported fields
}

An Kafka topic. For more information, see the [Concepts -> Topics and partitions](/docs/managed-kafka/concepts/topics) section of the documentation.

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetClusterId 

func (x *Topic) GetClusterId() string

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitions 

func (x *Topic) GetPartitions() *wrapperspb.Int64Value

func (*Topic) GetReplicationFactor 

func (x *Topic) GetReplicationFactor() *wrapperspb.Int64Value

func (*Topic) GetTopicConfig 

func (m *Topic) GetTopicConfig() isTopic_TopicConfig

func (*Topic) GetTopicConfig_2_8 

func (x *Topic) GetTopicConfig_2_8() *TopicConfig2_8

func (*Topic) GetTopicConfig_3 

func (x *Topic) GetTopicConfig_3() *TopicConfig3

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) SetClusterId 

func (m *Topic) SetClusterId(v string)

func (*Topic) SetName 

func (m *Topic) SetName(v string)

func (*Topic) SetPartitions 

func (m *Topic) SetPartitions(v *wrapperspb.Int64Value)

func (*Topic) SetReplicationFactor 

func (m *Topic) SetReplicationFactor(v *wrapperspb.Int64Value)

func (*Topic) SetTopicConfig 

func (m *Topic) SetTopicConfig(v Topic_TopicConfig)

func (*Topic) SetTopicConfig_2_8 

func (m *Topic) SetTopicConfig_2_8(v *TopicConfig2_8)

func (*Topic) SetTopicConfig_3 

func (m *Topic) SetTopicConfig_3(v *TopicConfig3)

func (*Topic) String 

func (x *Topic) String() string

type TopicConfig2_8 

type TopicConfig2_8 struct {

	// Retention policy to use on old log messages.
	CleanupPolicy TopicConfig2_8_CleanupPolicy `` /* 161-byte string literal not displayed */
	// The compression type for a given topic.
	CompressionType CompressionType `` /* 154-byte string literal not displayed */
	// The amount of time in milliseconds to retain delete tombstone markers for log compacted topics.
	DeleteRetentionMs *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=delete_retention_ms,json=deleteRetentionMs,proto3" json:"delete_retention_ms,omitempty"`
	// The time to wait before deleting a file from the filesystem.
	FileDeleteDelayMs *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=file_delete_delay_ms,json=fileDeleteDelayMs,proto3" json:"file_delete_delay_ms,omitempty"`
	// The number of messages accumulated on a log partition before messages are flushed to disk.
	//
	// This setting overrides the cluster-level [KafkaConfig2_8.log_flush_interval_messages] setting on the topic level.
	FlushMessages *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=flush_messages,json=flushMessages,proto3" json:"flush_messages,omitempty"`
	// The maximum time in milliseconds that a message in the topic is kept in memory before flushed to disk.
	//
	// This setting overrides the cluster-level [KafkaConfig2_8.log_flush_interval_ms] setting on the topic level.
	FlushMs *wrapperspb.Int64Value `protobuf:"bytes,6,opt,name=flush_ms,json=flushMs,proto3" json:"flush_ms,omitempty"`
	// The minimum time in milliseconds a message will remain uncompacted in the log.
	MinCompactionLagMs *wrapperspb.Int64Value `protobuf:"bytes,7,opt,name=min_compaction_lag_ms,json=minCompactionLagMs,proto3" json:"min_compaction_lag_ms,omitempty"`
	// The maximum size a partition can grow to before Kafka will discard old log segments to free up space if the `delete` [cleanup_policy] is in effect.
	// It is helpful if you need to control the size of log due to limited disk space.
	//
	// This setting overrides the cluster-level [KafkaConfig2_8.log_retention_bytes] setting on the topic level.
	RetentionBytes *wrapperspb.Int64Value `protobuf:"bytes,8,opt,name=retention_bytes,json=retentionBytes,proto3" json:"retention_bytes,omitempty"`
	// The number of milliseconds to keep a log segment's file before deleting it.
	//
	// This setting overrides the cluster-level [KafkaConfig2_8.log_retention_ms] setting on the topic level.
	RetentionMs *wrapperspb.Int64Value `protobuf:"bytes,9,opt,name=retention_ms,json=retentionMs,proto3" json:"retention_ms,omitempty"`
	// The largest record batch size allowed in topic.
	MaxMessageBytes *wrapperspb.Int64Value `protobuf:"bytes,10,opt,name=max_message_bytes,json=maxMessageBytes,proto3" json:"max_message_bytes,omitempty"`
	// This configuration specifies the minimum number of replicas that must acknowledge a write to topic for the write
	// to be considered successful (when a producer sets acks to "all").
	MinInsyncReplicas *wrapperspb.Int64Value `protobuf:"bytes,11,opt,name=min_insync_replicas,json=minInsyncReplicas,proto3" json:"min_insync_replicas,omitempty"`
	// This configuration controls the segment file size for the log. Retention and cleaning is always done a file
	// at a time so a larger segment size means fewer files but less granular control over retention.
	//
	// This setting overrides the cluster-level [KafkaConfig2_8.log_segment_bytes] setting on the topic level.
	SegmentBytes *wrapperspb.Int64Value `protobuf:"bytes,12,opt,name=segment_bytes,json=segmentBytes,proto3" json:"segment_bytes,omitempty"`
	// True if we should preallocate the file on disk when creating a new log segment.
	//
	// This setting overrides the cluster-level [KafkaConfig2_8.log_preallocate] setting on the topic level.
	Preallocate *wrapperspb.BoolValue `protobuf:"bytes,13,opt,name=preallocate,proto3" json:"preallocate,omitempty"`
	// contains filtered or unexported fields
}

A topic settings for 2.8

func (*TopicConfig2_8) Descriptor deprecated 

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

Deprecated: Use TopicConfig2_8.ProtoReflect.Descriptor instead.

func (*TopicConfig2_8) GetCleanupPolicy 

func (x *TopicConfig2_8) GetCleanupPolicy() TopicConfig2_8_CleanupPolicy

func (*TopicConfig2_8) GetCompressionType 

func (x *TopicConfig2_8) GetCompressionType() CompressionType

func (*TopicConfig2_8) GetDeleteRetentionMs 

func (x *TopicConfig2_8) GetDeleteRetentionMs() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetFileDeleteDelayMs 

func (x *TopicConfig2_8) GetFileDeleteDelayMs() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetFlushMessages 

func (x *TopicConfig2_8) GetFlushMessages() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetFlushMs 

func (x *TopicConfig2_8) GetFlushMs() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetMaxMessageBytes 

func (x *TopicConfig2_8) GetMaxMessageBytes() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetMinCompactionLagMs 

func (x *TopicConfig2_8) GetMinCompactionLagMs() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetMinInsyncReplicas 

func (x *TopicConfig2_8) GetMinInsyncReplicas() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetPreallocate 

func (x *TopicConfig2_8) GetPreallocate() *wrapperspb.BoolValue

func (*TopicConfig2_8) GetRetentionBytes 

func (x *TopicConfig2_8) GetRetentionBytes() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetRetentionMs 

func (x *TopicConfig2_8) GetRetentionMs() *wrapperspb.Int64Value

func (*TopicConfig2_8) GetSegmentBytes 

func (x *TopicConfig2_8) GetSegmentBytes() *wrapperspb.Int64Value

func (*TopicConfig2_8) ProtoMessage 

func (*TopicConfig2_8) ProtoMessage()

func (*TopicConfig2_8) ProtoReflect 

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

func (*TopicConfig2_8) Reset 

func (x *TopicConfig2_8) Reset()

func (*TopicConfig2_8) SetCleanupPolicy 

func (m *TopicConfig2_8) SetCleanupPolicy(v TopicConfig2_8_CleanupPolicy)

func (*TopicConfig2_8) SetCompressionType 

func (m *TopicConfig2_8) SetCompressionType(v CompressionType)

func (*TopicConfig2_8) SetDeleteRetentionMs 

func (m *TopicConfig2_8) SetDeleteRetentionMs(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetFileDeleteDelayMs 

func (m *TopicConfig2_8) SetFileDeleteDelayMs(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetFlushMessages 

func (m *TopicConfig2_8) SetFlushMessages(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetFlushMs 

func (m *TopicConfig2_8) SetFlushMs(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetMaxMessageBytes 

func (m *TopicConfig2_8) SetMaxMessageBytes(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetMinCompactionLagMs 

func (m *TopicConfig2_8) SetMinCompactionLagMs(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetMinInsyncReplicas 

func (m *TopicConfig2_8) SetMinInsyncReplicas(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetPreallocate 

func (m *TopicConfig2_8) SetPreallocate(v *wrapperspb.BoolValue)

func (*TopicConfig2_8) SetRetentionBytes 

func (m *TopicConfig2_8) SetRetentionBytes(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetRetentionMs 

func (m *TopicConfig2_8) SetRetentionMs(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) SetSegmentBytes 

func (m *TopicConfig2_8) SetSegmentBytes(v *wrapperspb.Int64Value)

func (*TopicConfig2_8) String 

func (x *TopicConfig2_8) String() string

type TopicConfig2_8_CleanupPolicy 

type TopicConfig2_8_CleanupPolicy int32
const (
	TopicConfig2_8_CLEANUP_POLICY_UNSPECIFIED TopicConfig2_8_CleanupPolicy = 0
	// this policy discards log segments when either their retention time or log size limit is reached. See also: [KafkaConfig2_8.log_retention_ms] and other similar parameters.
	TopicConfig2_8_CLEANUP_POLICY_DELETE TopicConfig2_8_CleanupPolicy = 1
	// this policy compacts messages in log.
	TopicConfig2_8_CLEANUP_POLICY_COMPACT TopicConfig2_8_CleanupPolicy = 2
	// this policy use both compaction and deletion for messages and log segments.
	TopicConfig2_8_CLEANUP_POLICY_COMPACT_AND_DELETE TopicConfig2_8_CleanupPolicy = 3
)

func (TopicConfig2_8_CleanupPolicy) Descriptor 

func (TopicConfig2_8_CleanupPolicy) Descriptor() protoreflect.EnumDescriptor

func (TopicConfig2_8_CleanupPolicy) Enum 

func (x TopicConfig2_8_CleanupPolicy) Enum() *TopicConfig2_8_CleanupPolicy

func (TopicConfig2_8_CleanupPolicy) EnumDescriptor deprecated 

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

Deprecated: Use TopicConfig2_8_CleanupPolicy.Descriptor instead.

func (TopicConfig2_8_CleanupPolicy) Number 

func (x TopicConfig2_8_CleanupPolicy) Number() protoreflect.EnumNumber

func (TopicConfig2_8_CleanupPolicy) String 

func (x TopicConfig2_8_CleanupPolicy) String() string

func (TopicConfig2_8_CleanupPolicy) Type 

func (TopicConfig2_8_CleanupPolicy) Type() protoreflect.EnumType

type TopicConfig3 

type TopicConfig3 struct {

	// Retention policy to use on old log messages.
	CleanupPolicy TopicConfig3_CleanupPolicy `` /* 159-byte string literal not displayed */
	// The compression type for a given topic.
	CompressionType CompressionType `` /* 154-byte string literal not displayed */
	// The amount of time in milliseconds to retain delete tombstone markers for log compacted topics.
	DeleteRetentionMs *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=delete_retention_ms,json=deleteRetentionMs,proto3" json:"delete_retention_ms,omitempty"`
	// The time to wait before deleting a file from the filesystem.
	FileDeleteDelayMs *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=file_delete_delay_ms,json=fileDeleteDelayMs,proto3" json:"file_delete_delay_ms,omitempty"`
	// The number of messages accumulated on a log partition before messages are flushed to disk.
	//
	// This setting overrides the cluster-level [KafkaConfig3.log_flush_interval_messages] setting on the topic level.
	FlushMessages *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=flush_messages,json=flushMessages,proto3" json:"flush_messages,omitempty"`
	// The maximum time in milliseconds that a message in the topic is kept in memory before flushed to disk.
	//
	// This setting overrides the cluster-level [KafkaConfig3.log_flush_interval_ms] setting on the topic level.
	FlushMs *wrapperspb.Int64Value `protobuf:"bytes,6,opt,name=flush_ms,json=flushMs,proto3" json:"flush_ms,omitempty"`
	// The minimum time in milliseconds a message will remain uncompacted in the log.
	MinCompactionLagMs *wrapperspb.Int64Value `protobuf:"bytes,7,opt,name=min_compaction_lag_ms,json=minCompactionLagMs,proto3" json:"min_compaction_lag_ms,omitempty"`
	// The maximum size a partition can grow to before Kafka will discard old log segments to free up space if the `delete` [cleanup_policy] is in effect.
	// It is helpful if you need to control the size of log due to limited disk space.
	//
	// This setting overrides the cluster-level [KafkaConfig3.log_retention_bytes] setting on the topic level.
	RetentionBytes *wrapperspb.Int64Value `protobuf:"bytes,8,opt,name=retention_bytes,json=retentionBytes,proto3" json:"retention_bytes,omitempty"`
	// The number of milliseconds to keep a log segment's file before deleting it.
	//
	// This setting overrides the cluster-level [KafkaConfig3.log_retention_ms] setting on the topic level.
	RetentionMs *wrapperspb.Int64Value `protobuf:"bytes,9,opt,name=retention_ms,json=retentionMs,proto3" json:"retention_ms,omitempty"`
	// The largest record batch size allowed in topic.
	MaxMessageBytes *wrapperspb.Int64Value `protobuf:"bytes,10,opt,name=max_message_bytes,json=maxMessageBytes,proto3" json:"max_message_bytes,omitempty"`
	// This configuration specifies the minimum number of replicas that must acknowledge a write to topic for the write
	// to be considered successful (when a producer sets acks to "all").
	MinInsyncReplicas *wrapperspb.Int64Value `protobuf:"bytes,11,opt,name=min_insync_replicas,json=minInsyncReplicas,proto3" json:"min_insync_replicas,omitempty"`
	// This configuration controls the segment file size for the log. Retention and cleaning is always done a file
	// at a time so a larger segment size means fewer files but less granular control over retention.
	//
	// This setting overrides the cluster-level [KafkaConfig3.log_segment_bytes] setting on the topic level.
	SegmentBytes *wrapperspb.Int64Value `protobuf:"bytes,12,opt,name=segment_bytes,json=segmentBytes,proto3" json:"segment_bytes,omitempty"`
	// True if we should preallocate the file on disk when creating a new log segment.
	//
	// This setting overrides the cluster-level [KafkaConfig3.log_preallocate] setting on the topic level.
	Preallocate *wrapperspb.BoolValue `protobuf:"bytes,13,opt,name=preallocate,proto3" json:"preallocate,omitempty"`
	// contains filtered or unexported fields
}

A topic settings for 3.x

func (*TopicConfig3) Descriptor deprecated 

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

Deprecated: Use TopicConfig3.ProtoReflect.Descriptor instead.

func (*TopicConfig3) GetCleanupPolicy 

func (x *TopicConfig3) GetCleanupPolicy() TopicConfig3_CleanupPolicy

func (*TopicConfig3) GetCompressionType 

func (x *TopicConfig3) GetCompressionType() CompressionType

func (*TopicConfig3) GetDeleteRetentionMs 

func (x *TopicConfig3) GetDeleteRetentionMs() *wrapperspb.Int64Value

func (*TopicConfig3) GetFileDeleteDelayMs 

func (x *TopicConfig3) GetFileDeleteDelayMs() *wrapperspb.Int64Value

func (*TopicConfig3) GetFlushMessages 

func (x *TopicConfig3) GetFlushMessages() *wrapperspb.Int64Value

func (*TopicConfig3) GetFlushMs 

func (x *TopicConfig3) GetFlushMs() *wrapperspb.Int64Value

func (*TopicConfig3) GetMaxMessageBytes 

func (x *TopicConfig3) GetMaxMessageBytes() *wrapperspb.Int64Value

func (*TopicConfig3) GetMinCompactionLagMs 

func (x *TopicConfig3) GetMinCompactionLagMs() *wrapperspb.Int64Value

func (*TopicConfig3) GetMinInsyncReplicas 

func (x *TopicConfig3) GetMinInsyncReplicas() *wrapperspb.Int64Value

func (*TopicConfig3) GetPreallocate 

func (x *TopicConfig3) GetPreallocate() *wrapperspb.BoolValue

func (*TopicConfig3) GetRetentionBytes 

func (x *TopicConfig3) GetRetentionBytes() *wrapperspb.Int64Value

func (*TopicConfig3) GetRetentionMs 

func (x *TopicConfig3) GetRetentionMs() *wrapperspb.Int64Value

func (*TopicConfig3) GetSegmentBytes 

func (x *TopicConfig3) GetSegmentBytes() *wrapperspb.Int64Value

func (*TopicConfig3) ProtoMessage 

func (*TopicConfig3) ProtoMessage()

func (*TopicConfig3) ProtoReflect 

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

func (*TopicConfig3) Reset 

func (x *TopicConfig3) Reset()

func (*TopicConfig3) SetCleanupPolicy 

func (m *TopicConfig3) SetCleanupPolicy(v TopicConfig3_CleanupPolicy)

func (*TopicConfig3) SetCompressionType 

func (m *TopicConfig3) SetCompressionType(v CompressionType)

func (*TopicConfig3) SetDeleteRetentionMs 

func (m *TopicConfig3) SetDeleteRetentionMs(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetFileDeleteDelayMs 

func (m *TopicConfig3) SetFileDeleteDelayMs(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetFlushMessages 

func (m *TopicConfig3) SetFlushMessages(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetFlushMs 

func (m *TopicConfig3) SetFlushMs(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetMaxMessageBytes 

func (m *TopicConfig3) SetMaxMessageBytes(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetMinCompactionLagMs 

func (m *TopicConfig3) SetMinCompactionLagMs(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetMinInsyncReplicas 

func (m *TopicConfig3) SetMinInsyncReplicas(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetPreallocate 

func (m *TopicConfig3) SetPreallocate(v *wrapperspb.BoolValue)

func (*TopicConfig3) SetRetentionBytes 

func (m *TopicConfig3) SetRetentionBytes(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetRetentionMs 

func (m *TopicConfig3) SetRetentionMs(v *wrapperspb.Int64Value)

func (*TopicConfig3) SetSegmentBytes 

func (m *TopicConfig3) SetSegmentBytes(v *wrapperspb.Int64Value)

func (*TopicConfig3) String 

func (x *TopicConfig3) String() string

type TopicConfig3_CleanupPolicy 

type TopicConfig3_CleanupPolicy int32
const (
	TopicConfig3_CLEANUP_POLICY_UNSPECIFIED TopicConfig3_CleanupPolicy = 0
	// this policy discards log segments when either their retention time or log size limit is reached. See also: [KafkaConfig3.log_retention_ms] and other similar parameters.
	TopicConfig3_CLEANUP_POLICY_DELETE TopicConfig3_CleanupPolicy = 1
	// this policy compacts messages in log.
	TopicConfig3_CLEANUP_POLICY_COMPACT TopicConfig3_CleanupPolicy = 2
	// this policy use both compaction and deletion for messages and log segments.
	TopicConfig3_CLEANUP_POLICY_COMPACT_AND_DELETE TopicConfig3_CleanupPolicy = 3
)

func (TopicConfig3_CleanupPolicy) Descriptor 

func (TopicConfig3_CleanupPolicy) Descriptor() protoreflect.EnumDescriptor

func (TopicConfig3_CleanupPolicy) Enum 

func (x TopicConfig3_CleanupPolicy) Enum() *TopicConfig3_CleanupPolicy

func (TopicConfig3_CleanupPolicy) EnumDescriptor deprecated 

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

Deprecated: Use TopicConfig3_CleanupPolicy.Descriptor instead.

func (TopicConfig3_CleanupPolicy) Number 

func (x TopicConfig3_CleanupPolicy) Number() protoreflect.EnumNumber

func (TopicConfig3_CleanupPolicy) String 

func (x TopicConfig3_CleanupPolicy) String() string

func (TopicConfig3_CleanupPolicy) Type 

func (TopicConfig3_CleanupPolicy) Type() protoreflect.EnumType

type TopicServiceClient 

type TopicServiceClient interface {
	// Returns the specified Kafka topic.
	//
	// To get the list of available Kafka topics, make a [List] request.
	Get(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Retrieves the list of Kafka topics in the specified cluster.
	List(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	// Creates a new Kafka topic in the specified cluster.
	Create(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified Kafka topic.
	Update(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified Kafka topic.
	Delete(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

TopicServiceClient is the client API for TopicService 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 NewTopicServiceClient 

func NewTopicServiceClient(cc grpc.ClientConnInterface) TopicServiceClient

type TopicServiceServer 

type TopicServiceServer interface {
	// Returns the specified Kafka topic.
	//
	// To get the list of available Kafka topics, make a [List] request.
	Get(context.Context, *GetTopicRequest) (*Topic, error)
	// Retrieves the list of Kafka topics in the specified cluster.
	List(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	// Creates a new Kafka topic in the specified cluster.
	Create(context.Context, *CreateTopicRequest) (*operation.Operation, error)
	// Updates the specified Kafka topic.
	Update(context.Context, *UpdateTopicRequest) (*operation.Operation, error)
	// Deletes the specified Kafka topic.
	Delete(context.Context, *DeleteTopicRequest) (*operation.Operation, error)
}

TopicServiceServer is the server API for TopicService service. All implementations should embed UnimplementedTopicServiceServer for forward compatibility

type TopicSpec 

type TopicSpec struct {

	// Name of the topic.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The number of the topic's partitions.
	Partitions *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	// Amount of copies of a topic data kept in the cluster.
	ReplicationFactor *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	// User-defined settings for the topic.
	//
	// Types that are assignable to TopicConfig:
	//
	//	*TopicSpec_TopicConfig_2_8
	//	*TopicSpec_TopicConfig_3
	TopicConfig isTopicSpec_TopicConfig `protobuf_oneof:"topic_config"`
	// contains filtered or unexported fields
}

func (*TopicSpec) Descriptor deprecated 

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

Deprecated: Use TopicSpec.ProtoReflect.Descriptor instead.

func (*TopicSpec) GetName 

func (x *TopicSpec) GetName() string

func (*TopicSpec) GetPartitions 

func (x *TopicSpec) GetPartitions() *wrapperspb.Int64Value

func (*TopicSpec) GetReplicationFactor 

func (x *TopicSpec) GetReplicationFactor() *wrapperspb.Int64Value

func (*TopicSpec) GetTopicConfig 

func (m *TopicSpec) GetTopicConfig() isTopicSpec_TopicConfig

func (*TopicSpec) GetTopicConfig_2_8 

func (x *TopicSpec) GetTopicConfig_2_8() *TopicConfig2_8

func (*TopicSpec) GetTopicConfig_3 

func (x *TopicSpec) GetTopicConfig_3() *TopicConfig3

func (*TopicSpec) ProtoMessage 

func (*TopicSpec) ProtoMessage()

func (*TopicSpec) ProtoReflect 

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

func (*TopicSpec) Reset 

func (x *TopicSpec) Reset()

func (*TopicSpec) SetName 

func (m *TopicSpec) SetName(v string)

func (*TopicSpec) SetPartitions 

func (m *TopicSpec) SetPartitions(v *wrapperspb.Int64Value)

func (*TopicSpec) SetReplicationFactor 

func (m *TopicSpec) SetReplicationFactor(v *wrapperspb.Int64Value)

func (*TopicSpec) SetTopicConfig 

func (m *TopicSpec) SetTopicConfig(v TopicSpec_TopicConfig)

func (*TopicSpec) SetTopicConfig_2_8 

func (m *TopicSpec) SetTopicConfig_2_8(v *TopicConfig2_8)

func (*TopicSpec) SetTopicConfig_3 

func (m *TopicSpec) SetTopicConfig_3(v *TopicConfig3)

func (*TopicSpec) String 

func (x *TopicSpec) String() string

type TopicSpec_TopicConfig 

type TopicSpec_TopicConfig = isTopicSpec_TopicConfig

type TopicSpec_TopicConfig_2_8 

type TopicSpec_TopicConfig_2_8 struct {
	TopicConfig_2_8 *TopicConfig2_8 `protobuf:"bytes,6,opt,name=topic_config_2_8,json=topicConfig_2_8,proto3,oneof"`
}

type TopicSpec_TopicConfig_3 

type TopicSpec_TopicConfig_3 struct {
	TopicConfig_3 *TopicConfig3 `protobuf:"bytes,7,opt,name=topic_config_3,json=topicConfig_3,proto3,oneof"`
}

type Topic_TopicConfig 

type Topic_TopicConfig = isTopic_TopicConfig

type Topic_TopicConfig_2_8 

type Topic_TopicConfig_2_8 struct {
	TopicConfig_2_8 *TopicConfig2_8 `protobuf:"bytes,7,opt,name=topic_config_2_8,json=topicConfig_2_8,proto3,oneof"`
}

type Topic_TopicConfig_3 

type Topic_TopicConfig_3 struct {
	TopicConfig_3 *TopicConfig3 `protobuf:"bytes,8,opt,name=topic_config_3,json=topicConfig_3,proto3,oneof"`
}

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) Create 

func (UnimplementedClusterServiceServer) Create(context.Context, *CreateClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Delete 

func (UnimplementedClusterServiceServer) Delete(context.Context, *DeleteClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Get 

func (UnimplementedClusterServiceServer) Get(context.Context, *GetClusterRequest) (*Cluster, error)

func (UnimplementedClusterServiceServer) List 

func (UnimplementedClusterServiceServer) List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

func (UnimplementedClusterServiceServer) ListHosts 

func (UnimplementedClusterServiceServer) ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error)

func (UnimplementedClusterServiceServer) ListLogs 

func (UnimplementedClusterServiceServer) ListLogs(context.Context, *ListClusterLogsRequest) (*ListClusterLogsResponse, error)

func (UnimplementedClusterServiceServer) ListOperations 

func (UnimplementedClusterServiceServer) ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)

func (UnimplementedClusterServiceServer) Move 

func (UnimplementedClusterServiceServer) Move(context.Context, *MoveClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) RescheduleMaintenance 

func (UnimplementedClusterServiceServer) RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Start 

func (UnimplementedClusterServiceServer) Start(context.Context, *StartClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Stop 

func (UnimplementedClusterServiceServer) Stop(context.Context, *StopClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) StreamLogs 

func (UnimplementedClusterServiceServer) StreamLogs(*StreamClusterLogsRequest, ClusterService_StreamLogsServer) error

func (UnimplementedClusterServiceServer) Update 

func (UnimplementedClusterServiceServer) Update(context.Context, *UpdateClusterRequest) (*operation.Operation, error)

type UnimplementedConnectorServiceServer 

type UnimplementedConnectorServiceServer struct {
}

UnimplementedConnectorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedConnectorServiceServer) Create 

func (UnimplementedConnectorServiceServer) Create(context.Context, *CreateConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Delete 

func (UnimplementedConnectorServiceServer) Delete(context.Context, *DeleteConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Get 

func (UnimplementedConnectorServiceServer) Get(context.Context, *GetConnectorRequest) (*Connector, error)

func (UnimplementedConnectorServiceServer) List 

func (UnimplementedConnectorServiceServer) List(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

func (UnimplementedConnectorServiceServer) Pause 

func (UnimplementedConnectorServiceServer) Pause(context.Context, *PauseConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Resume 

func (UnimplementedConnectorServiceServer) Resume(context.Context, *ResumeConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Update 

func (UnimplementedConnectorServiceServer) Update(context.Context, *UpdateConnectorRequest) (*operation.Operation, error)

type UnimplementedResourcePresetServiceServer 

type UnimplementedResourcePresetServiceServer struct {
}

UnimplementedResourcePresetServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedResourcePresetServiceServer) Get 

func (UnimplementedResourcePresetServiceServer) Get(context.Context, *GetResourcePresetRequest) (*ResourcePreset, error)

func (UnimplementedResourcePresetServiceServer) List 

func (UnimplementedResourcePresetServiceServer) List(context.Context, *ListResourcePresetsRequest) (*ListResourcePresetsResponse, error)

type UnimplementedTopicServiceServer 

type UnimplementedTopicServiceServer struct {
}

UnimplementedTopicServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTopicServiceServer) Create 

func (UnimplementedTopicServiceServer) Create(context.Context, *CreateTopicRequest) (*operation.Operation, error)

func (UnimplementedTopicServiceServer) Delete 

func (UnimplementedTopicServiceServer) Delete(context.Context, *DeleteTopicRequest) (*operation.Operation, error)

func (UnimplementedTopicServiceServer) Get 

func (UnimplementedTopicServiceServer) Get(context.Context, *GetTopicRequest) (*Topic, error)

func (UnimplementedTopicServiceServer) List 

func (UnimplementedTopicServiceServer) List(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

func (UnimplementedTopicServiceServer) Update 

func (UnimplementedTopicServiceServer) Update(context.Context, *UpdateTopicRequest) (*operation.Operation, error)

type UnimplementedUserServiceServer 

type UnimplementedUserServiceServer struct {
}

UnimplementedUserServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUserServiceServer) Create 

func (UnimplementedUserServiceServer) Create(context.Context, *CreateUserRequest) (*operation.Operation, error)

func (UnimplementedUserServiceServer) Delete 

func (UnimplementedUserServiceServer) Delete(context.Context, *DeleteUserRequest) (*operation.Operation, error)

func (UnimplementedUserServiceServer) Get 

func (UnimplementedUserServiceServer) Get(context.Context, *GetUserRequest) (*User, error)

func (UnimplementedUserServiceServer) GrantPermission 

func (UnimplementedUserServiceServer) GrantPermission(context.Context, *GrantUserPermissionRequest) (*operation.Operation, error)

func (UnimplementedUserServiceServer) List 

func (UnimplementedUserServiceServer) List(context.Context, *ListUsersRequest) (*ListUsersResponse, error)

func (UnimplementedUserServiceServer) RevokePermission 

func (UnimplementedUserServiceServer) RevokePermission(context.Context, *RevokeUserPermissionRequest) (*operation.Operation, error)

func (UnimplementedUserServiceServer) Update 

func (UnimplementedUserServiceServer) Update(context.Context, *UpdateUserRequest) (*operation.Operation, error)

type UnsafeClusterServiceServer 

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

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

type UnsafeConnectorServiceServer 

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

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

type UnsafeResourcePresetServiceServer 

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

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

type UnsafeTopicServiceServer 

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

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

type UnsafeUserServiceServer 

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

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

type UpdateClusterMetadata 

type UpdateClusterMetadata struct {

	// ID of the Apache Kafka® cluster that is being updated.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateClusterMetadata.ProtoReflect.Descriptor instead.

func (*UpdateClusterMetadata) GetClusterId 

func (x *UpdateClusterMetadata) GetClusterId() string

func (*UpdateClusterMetadata) ProtoMessage 

func (*UpdateClusterMetadata) ProtoMessage()

func (*UpdateClusterMetadata) ProtoReflect 

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

func (*UpdateClusterMetadata) Reset 

func (x *UpdateClusterMetadata) Reset()

func (*UpdateClusterMetadata) SetClusterId 

func (m *UpdateClusterMetadata) SetClusterId(v string)

func (*UpdateClusterMetadata) String 

func (x *UpdateClusterMetadata) String() string

type UpdateClusterRequest 

type UpdateClusterRequest struct {

	// ID of the Apache Kafka® cluster to update.
	//
	// To get the Apache Kafka® cluster ID, make a [ClusterService.List] request.
	ClusterId  string                 `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New description of the Apache Kafka® cluster.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Custom labels for the Apache Kafka® cluster as `key:value` pairs.
	//
	// For example, "project": "mvp" or "source": "dictionary".
	//
	// The new set of labels will completely replace the old ones.
	// To add a label, request the current set with the [ClusterService.Get] method, then send an [ClusterService.Update] request with the new label added to the set.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// New configuration and resources for hosts in the Apache Kafka® cluster.
	//
	// Use [update_mask] to prevent reverting all cluster settings that are not listed in [config_spec] to their default values.
	ConfigSpec *ConfigSpec `protobuf:"bytes,5,opt,name=config_spec,json=configSpec,proto3" json:"config_spec,omitempty"`
	// New name for the Apache Kafka® cluster.
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// User security groups
	SecurityGroupIds []string `protobuf:"bytes,7,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"`
	// Deletion Protection inhibits deletion of the cluster
	DeletionProtection bool `protobuf:"varint,8,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// New maintenance window settings for the cluster.
	MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,9,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`
	// IDs of subnets where the hosts are located or a new host is being created
	SubnetIds []string `protobuf:"bytes,11,rep,name=subnet_ids,json=subnetIds,proto3" json:"subnet_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterRequest) Descriptor deprecated 

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

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetClusterId 

func (x *UpdateClusterRequest) GetClusterId() string

func (*UpdateClusterRequest) GetConfigSpec 

func (x *UpdateClusterRequest) GetConfigSpec() *ConfigSpec

func (*UpdateClusterRequest) GetDeletionProtection 

func (x *UpdateClusterRequest) GetDeletionProtection() bool

func (*UpdateClusterRequest) GetDescription 

func (x *UpdateClusterRequest) GetDescription() string

func (*UpdateClusterRequest) GetLabels 

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

func (*UpdateClusterRequest) GetMaintenanceWindow 

func (x *UpdateClusterRequest) GetMaintenanceWindow() *MaintenanceWindow

func (*UpdateClusterRequest) GetName 

func (x *UpdateClusterRequest) GetName() string

func (*UpdateClusterRequest) GetSecurityGroupIds 

func (x *UpdateClusterRequest) GetSecurityGroupIds() []string

func (*UpdateClusterRequest) GetSubnetIds 

func (x *UpdateClusterRequest) GetSubnetIds() []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) SetClusterId 

func (m *UpdateClusterRequest) SetClusterId(v string)

func (*UpdateClusterRequest) SetConfigSpec 

func (m *UpdateClusterRequest) SetConfigSpec(v *ConfigSpec)

func (*UpdateClusterRequest) SetDeletionProtection 

func (m *UpdateClusterRequest) SetDeletionProtection(v bool)

func (*UpdateClusterRequest) SetDescription 

func (m *UpdateClusterRequest) SetDescription(v string)

func (*UpdateClusterRequest) SetLabels 

func (m *UpdateClusterRequest) SetLabels(v map[string]string)

func (*UpdateClusterRequest) SetMaintenanceWindow 

func (m *UpdateClusterRequest) SetMaintenanceWindow(v *MaintenanceWindow)

func (*UpdateClusterRequest) SetName 

func (m *UpdateClusterRequest) SetName(v string)

func (*UpdateClusterRequest) SetSecurityGroupIds 

func (m *UpdateClusterRequest) SetSecurityGroupIds(v []string)

func (*UpdateClusterRequest) SetSubnetIds 

func (m *UpdateClusterRequest) SetSubnetIds(v []string)

func (*UpdateClusterRequest) SetUpdateMask 

func (m *UpdateClusterRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateClusterRequest) String 

func (x *UpdateClusterRequest) String() string

type UpdateConnectorConfigS3SinkSpec 

type UpdateConnectorConfigS3SinkSpec struct {

	// List of Kafka topics, separated by ','.
	Topics string `protobuf:"bytes,1,opt,name=topics,proto3" json:"topics,omitempty"`
	// Max records per file.
	FileMaxRecords *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=file_max_records,json=fileMaxRecords,proto3" json:"file_max_records,omitempty"`
	// Credentials for connecting to S3 storage.
	S3Connection *S3ConnectionSpec `protobuf:"bytes,3,opt,name=s3_connection,json=s3Connection,proto3" json:"s3_connection,omitempty"`
	// contains filtered or unexported fields
}

Specification for update Kafka S3-Sink Connector.

func (*UpdateConnectorConfigS3SinkSpec) Descriptor deprecated 

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

Deprecated: Use UpdateConnectorConfigS3SinkSpec.ProtoReflect.Descriptor instead.

func (*UpdateConnectorConfigS3SinkSpec) GetFileMaxRecords 

func (x *UpdateConnectorConfigS3SinkSpec) GetFileMaxRecords() *wrapperspb.Int64Value

func (*UpdateConnectorConfigS3SinkSpec) GetS3Connection 

func (x *UpdateConnectorConfigS3SinkSpec) GetS3Connection() *S3ConnectionSpec

func (*UpdateConnectorConfigS3SinkSpec) GetTopics 

func (x *UpdateConnectorConfigS3SinkSpec) GetTopics() string

func (*UpdateConnectorConfigS3SinkSpec) ProtoMessage 

func (*UpdateConnectorConfigS3SinkSpec) ProtoMessage()

func (*UpdateConnectorConfigS3SinkSpec) ProtoReflect 

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

func (*UpdateConnectorConfigS3SinkSpec) Reset 

func (x *UpdateConnectorConfigS3SinkSpec) Reset()

func (*UpdateConnectorConfigS3SinkSpec) SetFileMaxRecords 

func (m *UpdateConnectorConfigS3SinkSpec) SetFileMaxRecords(v *wrapperspb.Int64Value)

func (*UpdateConnectorConfigS3SinkSpec) SetS3Connection 

func (m *UpdateConnectorConfigS3SinkSpec) SetS3Connection(v *S3ConnectionSpec)

func (*UpdateConnectorConfigS3SinkSpec) SetTopics 

func (m *UpdateConnectorConfigS3SinkSpec) SetTopics(v string)

func (*UpdateConnectorConfigS3SinkSpec) String 

func (x *UpdateConnectorConfigS3SinkSpec) String() string

type UpdateConnectorMetadata 

type UpdateConnectorMetadata struct {

	// ID of the Apache Kafka® cluster the connector is being updated 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 updated.
	ConnectorName string `protobuf:"bytes,2,opt,name=connector_name,json=connectorName,proto3" json:"connector_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateConnectorMetadata.ProtoReflect.Descriptor instead.

func (*UpdateConnectorMetadata) GetClusterId 

func (x *UpdateConnectorMetadata) GetClusterId() string

func (*UpdateConnectorMetadata) GetConnectorName 

func (x *UpdateConnectorMetadata) GetConnectorName() string

func (*UpdateConnectorMetadata) ProtoMessage 

func (*UpdateConnectorMetadata) ProtoMessage()

func (*UpdateConnectorMetadata) ProtoReflect 

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

func (*UpdateConnectorMetadata) Reset 

func (x *UpdateConnectorMetadata) Reset()

func (*UpdateConnectorMetadata) SetClusterId 

func (m *UpdateConnectorMetadata) SetClusterId(v string)

func (*UpdateConnectorMetadata) SetConnectorName 

func (m *UpdateConnectorMetadata) SetConnectorName(v string)

func (*UpdateConnectorMetadata) String 

func (x *UpdateConnectorMetadata) String() string

type UpdateConnectorRequest 

type UpdateConnectorRequest struct {

	// ID of the Apache Kafka® cluster to update 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"`
	// Name of the connector to update.
	//
	// 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"`
	// Field mask that specifies which settings of the connector should be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Configuration of the connector to update.
	ConnectorSpec *UpdateConnectorSpec `protobuf:"bytes,4,opt,name=connector_spec,json=connectorSpec,proto3" json:"connector_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectorRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConnectorRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectorRequest) GetClusterId 

func (x *UpdateConnectorRequest) GetClusterId() string

func (*UpdateConnectorRequest) GetConnectorName 

func (x *UpdateConnectorRequest) GetConnectorName() string

func (*UpdateConnectorRequest) GetConnectorSpec 

func (x *UpdateConnectorRequest) GetConnectorSpec() *UpdateConnectorSpec

func (*UpdateConnectorRequest) GetUpdateMask 

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

func (*UpdateConnectorRequest) ProtoMessage 

func (*UpdateConnectorRequest) ProtoMessage()

func (*UpdateConnectorRequest) ProtoReflect 

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

func (*UpdateConnectorRequest) Reset 

func (x *UpdateConnectorRequest) Reset()

func (*UpdateConnectorRequest) SetClusterId 

func (m *UpdateConnectorRequest) SetClusterId(v string)

func (*UpdateConnectorRequest) SetConnectorName 

func (m *UpdateConnectorRequest) SetConnectorName(v string)

func (*UpdateConnectorRequest) SetConnectorSpec 

func (m *UpdateConnectorRequest) SetConnectorSpec(v *UpdateConnectorSpec)

func (*UpdateConnectorRequest) SetUpdateMask 

func (m *UpdateConnectorRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateConnectorRequest) String 

func (x *UpdateConnectorRequest) String() string

type UpdateConnectorSpec 

type UpdateConnectorSpec struct {

	// Maximum number of connector tasks to update.
	TasksMax *wrapperspb.Int64Value `protobuf:"bytes,1,opt,name=tasks_max,json=tasksMax,proto3" json:"tasks_max,omitempty"`
	// A set of new or changed properties to update for the connector. They are passed with the connector configuration to Managed Service for Apache Kafka®.
	// Example: `sync.topics.config.enabled: false`.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// Updated configuration for the connector.
	//
	// Types that are assignable to ConnectorConfig:
	//
	//	*UpdateConnectorSpec_ConnectorConfigMirrormaker
	//	*UpdateConnectorSpec_ConnectorConfigS3Sink
	ConnectorConfig isUpdateConnectorSpec_ConnectorConfig `protobuf_oneof:"connector_config"`
	// contains filtered or unexported fields
}

func (*UpdateConnectorSpec) Descriptor deprecated 

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

Deprecated: Use UpdateConnectorSpec.ProtoReflect.Descriptor instead.

func (*UpdateConnectorSpec) GetConnectorConfig 

func (m *UpdateConnectorSpec) GetConnectorConfig() isUpdateConnectorSpec_ConnectorConfig

func (*UpdateConnectorSpec) GetConnectorConfigMirrormaker 

func (x *UpdateConnectorSpec) GetConnectorConfigMirrormaker() *ConnectorConfigMirrorMakerSpec

func (*UpdateConnectorSpec) GetConnectorConfigS3Sink 

func (x *UpdateConnectorSpec) GetConnectorConfigS3Sink() *UpdateConnectorConfigS3SinkSpec

func (*UpdateConnectorSpec) GetProperties 

func (x *UpdateConnectorSpec) GetProperties() map[string]string

func (*UpdateConnectorSpec) GetTasksMax 

func (x *UpdateConnectorSpec) GetTasksMax() *wrapperspb.Int64Value

func (*UpdateConnectorSpec) ProtoMessage 

func (*UpdateConnectorSpec) ProtoMessage()

func (*UpdateConnectorSpec) ProtoReflect 

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

func (*UpdateConnectorSpec) Reset 

func (x *UpdateConnectorSpec) Reset()

func (*UpdateConnectorSpec) SetConnectorConfig 

func (m *UpdateConnectorSpec) SetConnectorConfig(v UpdateConnectorSpec_ConnectorConfig)

func (*UpdateConnectorSpec) SetConnectorConfigMirrormaker 

func (m *UpdateConnectorSpec) SetConnectorConfigMirrormaker(v *ConnectorConfigMirrorMakerSpec)

func (*UpdateConnectorSpec) SetConnectorConfigS3Sink 

func (m *UpdateConnectorSpec) SetConnectorConfigS3Sink(v *UpdateConnectorConfigS3SinkSpec)

func (*UpdateConnectorSpec) SetProperties 

func (m *UpdateConnectorSpec) SetProperties(v map[string]string)

func (*UpdateConnectorSpec) SetTasksMax 

func (m *UpdateConnectorSpec) SetTasksMax(v *wrapperspb.Int64Value)

func (*UpdateConnectorSpec) String 

func (x *UpdateConnectorSpec) String() string

type UpdateConnectorSpec_ConnectorConfig 

type UpdateConnectorSpec_ConnectorConfig = isUpdateConnectorSpec_ConnectorConfig

type UpdateConnectorSpec_ConnectorConfigMirrormaker 

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

type UpdateConnectorSpec_ConnectorConfigS3Sink 

type UpdateConnectorSpec_ConnectorConfigS3Sink struct {
	// Update specification for S3-Sink Connector.
	ConnectorConfigS3Sink *UpdateConnectorConfigS3SinkSpec `protobuf:"bytes,11,opt,name=connector_config_s3_sink,json=connectorConfigS3Sink,proto3,oneof"`
}

type UpdateTopicMetadata 

type UpdateTopicMetadata struct {

	// ID of the Apache Kafka® cluster where a topic is being updated.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the Kafka topic that is being updated.
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTopicMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateTopicMetadata.ProtoReflect.Descriptor instead.

func (*UpdateTopicMetadata) GetClusterId 

func (x *UpdateTopicMetadata) GetClusterId() string

func (*UpdateTopicMetadata) GetTopicName 

func (x *UpdateTopicMetadata) GetTopicName() string

func (*UpdateTopicMetadata) ProtoMessage 

func (*UpdateTopicMetadata) ProtoMessage()

func (*UpdateTopicMetadata) ProtoReflect 

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

func (*UpdateTopicMetadata) Reset 

func (x *UpdateTopicMetadata) Reset()

func (*UpdateTopicMetadata) SetClusterId 

func (m *UpdateTopicMetadata) SetClusterId(v string)

func (*UpdateTopicMetadata) SetTopicName 

func (m *UpdateTopicMetadata) SetTopicName(v string)

func (*UpdateTopicMetadata) String 

func (x *UpdateTopicMetadata) String() string

type UpdateTopicRequest 

type UpdateTopicRequest struct {

	// ID of the Apache Kafka® cluster to update a topic in.
	//
	// To get the cluster 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 topic to update.
	//
	// To get the name of the topic, make a [TopicService.List] request.
	TopicName  string                 `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New configuration of the topic.
	//
	// Use [update_mask] to prevent reverting all topic settings that are not listed in [topic_spec] to their default values.
	TopicSpec *TopicSpec `protobuf:"bytes,4,opt,name=topic_spec,json=topicSpec,proto3" json:"topic_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTopicRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTopicRequest.ProtoReflect.Descriptor instead.

func (*UpdateTopicRequest) GetClusterId 

func (x *UpdateTopicRequest) GetClusterId() string

func (*UpdateTopicRequest) GetTopicName 

func (x *UpdateTopicRequest) GetTopicName() string

func (*UpdateTopicRequest) GetTopicSpec 

func (x *UpdateTopicRequest) GetTopicSpec() *TopicSpec

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

func (m *UpdateTopicRequest) SetClusterId(v string)

func (*UpdateTopicRequest) SetTopicName 

func (m *UpdateTopicRequest) SetTopicName(v string)

func (*UpdateTopicRequest) SetTopicSpec 

func (m *UpdateTopicRequest) SetTopicSpec(v *TopicSpec)

func (*UpdateTopicRequest) SetUpdateMask 

func (m *UpdateTopicRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateTopicRequest) String 

func (x *UpdateTopicRequest) String() string

type UpdateUserMetadata 

type UpdateUserMetadata struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Name of the user that is being updated.
	UserName string `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateUserMetadata.ProtoReflect.Descriptor instead.

func (*UpdateUserMetadata) GetClusterId 

func (x *UpdateUserMetadata) GetClusterId() string

func (*UpdateUserMetadata) GetUserName 

func (x *UpdateUserMetadata) GetUserName() string

func (*UpdateUserMetadata) ProtoMessage 

func (*UpdateUserMetadata) ProtoMessage()

func (*UpdateUserMetadata) ProtoReflect 

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

func (*UpdateUserMetadata) Reset 

func (x *UpdateUserMetadata) Reset()

func (*UpdateUserMetadata) SetClusterId 

func (m *UpdateUserMetadata) SetClusterId(v string)

func (*UpdateUserMetadata) SetUserName 

func (m *UpdateUserMetadata) SetUserName(v string)

func (*UpdateUserMetadata) String 

func (x *UpdateUserMetadata) String() string

type UpdateUserRequest 

type UpdateUserRequest struct {

	// ID of the Apache Kafka® cluster the user belongs to.
	//
	// To get the cluster 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 user to be updated.
	//
	// To get the name of the user, make a [UserService.List] request.
	UserName   string                 `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New password for the user.
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// New set of permissions for the user.
	Permissions []*Permission `protobuf:"bytes,5,rep,name=permissions,proto3" json:"permissions,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserRequest) Descriptor deprecated 

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

Deprecated: Use UpdateUserRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserRequest) GetClusterId 

func (x *UpdateUserRequest) GetClusterId() string

func (*UpdateUserRequest) GetPassword 

func (x *UpdateUserRequest) GetPassword() string

func (*UpdateUserRequest) GetPermissions 

func (x *UpdateUserRequest) GetPermissions() []*Permission

func (*UpdateUserRequest) GetUpdateMask 

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

func (*UpdateUserRequest) GetUserName 

func (x *UpdateUserRequest) GetUserName() string

func (*UpdateUserRequest) ProtoMessage 

func (*UpdateUserRequest) ProtoMessage()

func (*UpdateUserRequest) ProtoReflect 

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

func (*UpdateUserRequest) Reset 

func (x *UpdateUserRequest) Reset()

func (*UpdateUserRequest) SetClusterId 

func (m *UpdateUserRequest) SetClusterId(v string)

func (*UpdateUserRequest) SetPassword 

func (m *UpdateUserRequest) SetPassword(v string)

func (*UpdateUserRequest) SetPermissions 

func (m *UpdateUserRequest) SetPermissions(v []*Permission)

func (*UpdateUserRequest) SetUpdateMask 

func (m *UpdateUserRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateUserRequest) SetUserName 

func (m *UpdateUserRequest) SetUserName(v string)

func (*UpdateUserRequest) String 

func (x *UpdateUserRequest) String() string

type User 

type User struct {

	// Name of the Kafka user.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// ID of the Apache Kafka® cluster the user belongs to.
	//
	// To get the Apache Kafka® cluster ID, make a [ClusterService.List] request.
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Set of permissions granted to this user.
	Permissions []*Permission `protobuf:"bytes,3,rep,name=permissions,proto3" json:"permissions,omitempty"`
	// contains filtered or unexported fields
}

A Kafka user. For more information, see the [Operations -> Accounts](/docs/managed-kafka/operations/cluster-accounts) section of the documentation.

func (*User) Descriptor deprecated 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetClusterId 

func (x *User) GetClusterId() string

func (*User) GetName 

func (x *User) GetName() string

func (*User) GetPermissions 

func (x *User) GetPermissions() []*Permission

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect 

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

func (*User) Reset 

func (x *User) Reset()

func (*User) SetClusterId 

func (m *User) SetClusterId(v string)

func (*User) SetName 

func (m *User) SetName(v string)

func (*User) SetPermissions 

func (m *User) SetPermissions(v []*Permission)

func (*User) String 

func (x *User) String() string

type UserServiceClient 

type UserServiceClient interface {
	// Returns the specified Kafka user.
	//
	// To get the list of available Kafka users, make a [List] request.
	Get(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*User, error)
	// Retrieves the list of Kafka users in the specified cluster.
	List(ctx context.Context, in *ListUsersRequest, opts ...grpc.CallOption) (*ListUsersResponse, error)
	// Creates a Kafka user in the specified cluster.
	Create(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified Kafka user.
	Update(ctx context.Context, in *UpdateUserRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified Kafka user.
	Delete(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Grants permission to the specified Kafka user.
	GrantPermission(ctx context.Context, in *GrantUserPermissionRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Revokes permission from the specified Kafka user.
	RevokePermission(ctx context.Context, in *RevokeUserPermissionRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

UserServiceClient is the client API for UserService 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 NewUserServiceClient 

func NewUserServiceClient(cc grpc.ClientConnInterface) UserServiceClient

type UserServiceServer 

type UserServiceServer interface {
	// Returns the specified Kafka user.
	//
	// To get the list of available Kafka users, make a [List] request.
	Get(context.Context, *GetUserRequest) (*User, error)
	// Retrieves the list of Kafka users in the specified cluster.
	List(context.Context, *ListUsersRequest) (*ListUsersResponse, error)
	// Creates a Kafka user in the specified cluster.
	Create(context.Context, *CreateUserRequest) (*operation.Operation, error)
	// Updates the specified Kafka user.
	Update(context.Context, *UpdateUserRequest) (*operation.Operation, error)
	// Deletes the specified Kafka user.
	Delete(context.Context, *DeleteUserRequest) (*operation.Operation, error)
	// Grants permission to the specified Kafka user.
	GrantPermission(context.Context, *GrantUserPermissionRequest) (*operation.Operation, error)
	// Revokes permission from the specified Kafka user.
	RevokePermission(context.Context, *RevokeUserPermissionRequest) (*operation.Operation, error)
}

UserServiceServer is the server API for UserService service. All implementations should embed UnimplementedUserServiceServer for forward compatibility

type UserSpec 

type UserSpec struct {

	// Name of the Kafka user.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Password of the Kafka user.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// Set of permissions granted to the user.
	Permissions []*Permission `protobuf:"bytes,3,rep,name=permissions,proto3" json:"permissions,omitempty"`
	// contains filtered or unexported fields
}

func (*UserSpec) Descriptor deprecated 

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

Deprecated: Use UserSpec.ProtoReflect.Descriptor instead.

func (*UserSpec) GetName 

func (x *UserSpec) GetName() string

func (*UserSpec) GetPassword 

func (x *UserSpec) GetPassword() string

func (*UserSpec) GetPermissions 

func (x *UserSpec) GetPermissions() []*Permission

func (*UserSpec) ProtoMessage 

func (*UserSpec) ProtoMessage()

func (*UserSpec) ProtoReflect 

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

func (*UserSpec) Reset 

func (x *UserSpec) Reset()

func (*UserSpec) SetName 

func (m *UserSpec) SetName(v string)

func (*UserSpec) SetPassword 

func (m *UserSpec) SetPassword(v string)

func (*UserSpec) SetPermissions 

func (m *UserSpec) SetPermissions(v []*Permission)

func (*UserSpec) String 

func (x *UserSpec) String() string

type WeeklyMaintenanceWindow 

type WeeklyMaintenanceWindow struct {
	Day WeeklyMaintenanceWindow_WeekDay `protobuf:"varint,1,opt,name=day,proto3,enum=yandex.cloud.mdb.kafka.v1.WeeklyMaintenanceWindow_WeekDay" json:"day,omitempty"`
	// Hour of the day in UTC.
	Hour int64 `protobuf:"varint,2,opt,name=hour,proto3" json:"hour,omitempty"`
	// contains filtered or unexported fields
}

func (*WeeklyMaintenanceWindow) Descriptor deprecated 

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

Deprecated: Use WeeklyMaintenanceWindow.ProtoReflect.Descriptor instead.

func (*WeeklyMaintenanceWindow) GetDay 

func (x *WeeklyMaintenanceWindow) GetDay() WeeklyMaintenanceWindow_WeekDay

func (*WeeklyMaintenanceWindow) GetHour 

func (x *WeeklyMaintenanceWindow) GetHour() int64

func (*WeeklyMaintenanceWindow) ProtoMessage 

func (*WeeklyMaintenanceWindow) ProtoMessage()

func (*WeeklyMaintenanceWindow) ProtoReflect 

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

func (*WeeklyMaintenanceWindow) Reset 

func (x *WeeklyMaintenanceWindow) Reset()

func (*WeeklyMaintenanceWindow) SetDay 

func (m *WeeklyMaintenanceWindow) SetDay(v WeeklyMaintenanceWindow_WeekDay)

func (*WeeklyMaintenanceWindow) SetHour 

func (m *WeeklyMaintenanceWindow) SetHour(v int64)

func (*WeeklyMaintenanceWindow) String 

func (x *WeeklyMaintenanceWindow) String() string

type WeeklyMaintenanceWindow_WeekDay 

type WeeklyMaintenanceWindow_WeekDay int32
const (
	WeeklyMaintenanceWindow_WEEK_DAY_UNSPECIFIED WeeklyMaintenanceWindow_WeekDay = 0
	WeeklyMaintenanceWindow_MON                  WeeklyMaintenanceWindow_WeekDay = 1
	WeeklyMaintenanceWindow_TUE                  WeeklyMaintenanceWindow_WeekDay = 2
	WeeklyMaintenanceWindow_WED                  WeeklyMaintenanceWindow_WeekDay = 3
	WeeklyMaintenanceWindow_THU                  WeeklyMaintenanceWindow_WeekDay = 4
	WeeklyMaintenanceWindow_FRI                  WeeklyMaintenanceWindow_WeekDay = 5
	WeeklyMaintenanceWindow_SAT                  WeeklyMaintenanceWindow_WeekDay = 6
	WeeklyMaintenanceWindow_SUN                  WeeklyMaintenanceWindow_WeekDay = 7
)

func (WeeklyMaintenanceWindow_WeekDay) Descriptor 

func (WeeklyMaintenanceWindow_WeekDay) Descriptor() protoreflect.EnumDescriptor

func (WeeklyMaintenanceWindow_WeekDay) Enum 

func (x WeeklyMaintenanceWindow_WeekDay) Enum() *WeeklyMaintenanceWindow_WeekDay

func (WeeklyMaintenanceWindow_WeekDay) EnumDescriptor deprecated 

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

Deprecated: Use WeeklyMaintenanceWindow_WeekDay.Descriptor instead.

func (WeeklyMaintenanceWindow_WeekDay) Number 

func (x WeeklyMaintenanceWindow_WeekDay) Number() protoreflect.EnumNumber

func (WeeklyMaintenanceWindow_WeekDay) String 

func (x WeeklyMaintenanceWindow_WeekDay) String() string

func (WeeklyMaintenanceWindow_WeekDay) Type 

func (WeeklyMaintenanceWindow_WeekDay) Type() protoreflect.EnumType

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.