dataplanev1alpha1

package
v0.4.3 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ACLService_ListACLs_FullMethodName   = "/redpanda.api.dataplane.v1alpha1.ACLService/ListACLs"
	ACLService_CreateACL_FullMethodName  = "/redpanda.api.dataplane.v1alpha1.ACLService/CreateACL"
	ACLService_DeleteACLs_FullMethodName = "/redpanda.api.dataplane.v1alpha1.ACLService/DeleteACLs"
)
View Source 
const (
	KafkaConnectService_ListConnectClusters_FullMethodName  = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/ListConnectClusters"
	KafkaConnectService_GetConnectCluster_FullMethodName    = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/GetConnectCluster"
	KafkaConnectService_ListConnectors_FullMethodName       = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/ListConnectors"
	KafkaConnectService_CreateConnector_FullMethodName      = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/CreateConnector"
	KafkaConnectService_RestartConnector_FullMethodName     = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/RestartConnector"
	KafkaConnectService_GetConnector_FullMethodName         = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/GetConnector"
	KafkaConnectService_GetConnectorStatus_FullMethodName   = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/GetConnectorStatus"
	KafkaConnectService_PauseConnector_FullMethodName       = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/PauseConnector"
	KafkaConnectService_ResumeConnector_FullMethodName      = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/ResumeConnector"
	KafkaConnectService_StopConnector_FullMethodName        = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/StopConnector"
	KafkaConnectService_DeleteConnector_FullMethodName      = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/DeleteConnector"
	KafkaConnectService_UpsertConnector_FullMethodName      = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/UpsertConnector"
	KafkaConnectService_GetConnectorConfig_FullMethodName   = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/GetConnectorConfig"
	KafkaConnectService_ListConnectorTopics_FullMethodName  = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/ListConnectorTopics"
	KafkaConnectService_ResetConnectorTopics_FullMethodName = "/redpanda.api.dataplane.v1alpha1.KafkaConnectService/ResetConnectorTopics"
)
View Source 
const (
	SecretService_GetSecret_FullMethodName           = "/redpanda.api.dataplane.v1alpha1.SecretService/GetSecret"
	SecretService_ListSecrets_FullMethodName         = "/redpanda.api.dataplane.v1alpha1.SecretService/ListSecrets"
	SecretService_CreateSecret_FullMethodName        = "/redpanda.api.dataplane.v1alpha1.SecretService/CreateSecret"
	SecretService_UpdateSecret_FullMethodName        = "/redpanda.api.dataplane.v1alpha1.SecretService/UpdateSecret"
	SecretService_DeleteSecret_FullMethodName        = "/redpanda.api.dataplane.v1alpha1.SecretService/DeleteSecret"
	SecretService_GetConnectSecret_FullMethodName    = "/redpanda.api.dataplane.v1alpha1.SecretService/GetConnectSecret"
	SecretService_ListConnectSecrets_FullMethodName  = "/redpanda.api.dataplane.v1alpha1.SecretService/ListConnectSecrets"
	SecretService_CreateConnectSecret_FullMethodName = "/redpanda.api.dataplane.v1alpha1.SecretService/CreateConnectSecret"
	SecretService_UpdateConnectSecret_FullMethodName = "/redpanda.api.dataplane.v1alpha1.SecretService/UpdateConnectSecret"
	SecretService_DeleteConnectSecret_FullMethodName = "/redpanda.api.dataplane.v1alpha1.SecretService/DeleteConnectSecret"
)
View Source 
const (
	TopicService_CreateTopic_FullMethodName               = "/redpanda.api.dataplane.v1alpha1.TopicService/CreateTopic"
	TopicService_ListTopics_FullMethodName                = "/redpanda.api.dataplane.v1alpha1.TopicService/ListTopics"
	TopicService_DeleteTopic_FullMethodName               = "/redpanda.api.dataplane.v1alpha1.TopicService/DeleteTopic"
	TopicService_GetTopicConfigurations_FullMethodName    = "/redpanda.api.dataplane.v1alpha1.TopicService/GetTopicConfigurations"
	TopicService_UpdateTopicConfigurations_FullMethodName = "/redpanda.api.dataplane.v1alpha1.TopicService/UpdateTopicConfigurations"
	TopicService_SetTopicConfigurations_FullMethodName    = "/redpanda.api.dataplane.v1alpha1.TopicService/SetTopicConfigurations"
)
View Source 
const (
	TransformService_ListTransforms_FullMethodName  = "/redpanda.api.dataplane.v1alpha1.TransformService/ListTransforms"
	TransformService_GetTransform_FullMethodName    = "/redpanda.api.dataplane.v1alpha1.TransformService/GetTransform"
	TransformService_DeleteTransform_FullMethodName = "/redpanda.api.dataplane.v1alpha1.TransformService/DeleteTransform"
)
View Source 
const (
	UserService_CreateUser_FullMethodName = "/redpanda.api.dataplane.v1alpha1.UserService/CreateUser"
	UserService_UpdateUser_FullMethodName = "/redpanda.api.dataplane.v1alpha1.UserService/UpdateUser"
	UserService_ListUsers_FullMethodName  = "/redpanda.api.dataplane.v1alpha1.UserService/ListUsers"
	UserService_DeleteUser_FullMethodName = "/redpanda.api.dataplane.v1alpha1.UserService/DeleteUser"
)
View Source 
const (
	DummyService_DummyMethod_FullMethodName = "/redpanda.api.dataplane.v1alpha1.DummyService/DummyMethod"
)

Variables

View Source 
var (
	ACL_ResourceType_name = map[int32]string{
		0: "RESOURCE_TYPE_UNSPECIFIED",
		1: "RESOURCE_TYPE_ANY",
		2: "RESOURCE_TYPE_TOPIC",
		3: "RESOURCE_TYPE_GROUP",
		4: "RESOURCE_TYPE_CLUSTER",
		5: "RESOURCE_TYPE_TRANSACTIONAL_ID",
		6: "RESOURCE_TYPE_DELEGATION_TOKEN",
		7: "RESOURCE_TYPE_USER",
	}
	ACL_ResourceType_value = map[string]int32{
		"RESOURCE_TYPE_UNSPECIFIED":      0,
		"RESOURCE_TYPE_ANY":              1,
		"RESOURCE_TYPE_TOPIC":            2,
		"RESOURCE_TYPE_GROUP":            3,
		"RESOURCE_TYPE_CLUSTER":          4,
		"RESOURCE_TYPE_TRANSACTIONAL_ID": 5,
		"RESOURCE_TYPE_DELEGATION_TOKEN": 6,
		"RESOURCE_TYPE_USER":             7,
	}
)

Enum value maps for ACL_ResourceType.

View Source 
var (
	ACL_ResourcePatternType_name = map[int32]string{
		0: "RESOURCE_PATTERN_TYPE_UNSPECIFIED",
		1: "RESOURCE_PATTERN_TYPE_ANY",
		2: "RESOURCE_PATTERN_TYPE_MATCH",
		3: "RESOURCE_PATTERN_TYPE_LITERAL",
		4: "RESOURCE_PATTERN_TYPE_PREFIXED",
	}
	ACL_ResourcePatternType_value = map[string]int32{
		"RESOURCE_PATTERN_TYPE_UNSPECIFIED": 0,
		"RESOURCE_PATTERN_TYPE_ANY":         1,
		"RESOURCE_PATTERN_TYPE_MATCH":       2,
		"RESOURCE_PATTERN_TYPE_LITERAL":     3,
		"RESOURCE_PATTERN_TYPE_PREFIXED":    4,
	}
)

Enum value maps for ACL_ResourcePatternType.

View Source 
var (
	ACL_Operation_name = map[int32]string{
		0:  "OPERATION_UNSPECIFIED",
		1:  "OPERATION_ANY",
		2:  "OPERATION_ALL",
		3:  "OPERATION_READ",
		4:  "OPERATION_WRITE",
		5:  "OPERATION_CREATE",
		6:  "OPERATION_DELETE",
		7:  "OPERATION_ALTER",
		8:  "OPERATION_DESCRIBE",
		9:  "OPERATION_CLUSTER_ACTION",
		10: "OPERATION_DESCRIBE_CONFIGS",
		11: "OPERATION_ALTER_CONFIGS",
		12: "OPERATION_IDEMPOTENT_WRITE",
		13: "OPERATION_CREATE_TOKENS",
		14: "OPERATION_DESCRIBE_TOKENS",
	}
	ACL_Operation_value = map[string]int32{
		"OPERATION_UNSPECIFIED":      0,
		"OPERATION_ANY":              1,
		"OPERATION_ALL":              2,
		"OPERATION_READ":             3,
		"OPERATION_WRITE":            4,
		"OPERATION_CREATE":           5,
		"OPERATION_DELETE":           6,
		"OPERATION_ALTER":            7,
		"OPERATION_DESCRIBE":         8,
		"OPERATION_CLUSTER_ACTION":   9,
		"OPERATION_DESCRIBE_CONFIGS": 10,
		"OPERATION_ALTER_CONFIGS":    11,
		"OPERATION_IDEMPOTENT_WRITE": 12,
		"OPERATION_CREATE_TOKENS":    13,
		"OPERATION_DESCRIBE_TOKENS":  14,
	}
)

Enum value maps for ACL_Operation.

View Source 
var (
	ACL_PermissionType_name = map[int32]string{
		0: "PERMISSION_TYPE_UNSPECIFIED",
		1: "PERMISSION_TYPE_ANY",
		2: "PERMISSION_TYPE_DENY",
		3: "PERMISSION_TYPE_ALLOW",
	}
	ACL_PermissionType_value = map[string]int32{
		"PERMISSION_TYPE_UNSPECIFIED": 0,
		"PERMISSION_TYPE_ANY":         1,
		"PERMISSION_TYPE_DENY":        2,
		"PERMISSION_TYPE_ALLOW":       3,
	}
)

Enum value maps for ACL_PermissionType.

View Source 
var (
	ConfigSource_name = map[int32]string{
		0: "CONFIG_SOURCE_UNSPECIFIED",
		1: "CONFIG_SOURCE_DYNAMIC_TOPIC_CONFIG",
		2: "CONFIG_SOURCE_DYNAMIC_BROKER_CONFIG",
		3: "CONFIG_SOURCE_DYNAMIC_DEFAULT_BROKER_CONFIG",
		4: "CONFIG_SOURCE_STATIC_BROKER_CONFIG",
		5: "CONFIG_SOURCE_DEFAULT_CONFIG",
		6: "CONFIG_SOURCE_DYNAMIC_BROKER_LOGGER_CONFIG",
	}
	ConfigSource_value = map[string]int32{
		"CONFIG_SOURCE_UNSPECIFIED":                   0,
		"CONFIG_SOURCE_DYNAMIC_TOPIC_CONFIG":          1,
		"CONFIG_SOURCE_DYNAMIC_BROKER_CONFIG":         2,
		"CONFIG_SOURCE_DYNAMIC_DEFAULT_BROKER_CONFIG": 3,
		"CONFIG_SOURCE_STATIC_BROKER_CONFIG":          4,
		"CONFIG_SOURCE_DEFAULT_CONFIG":                5,
		"CONFIG_SOURCE_DYNAMIC_BROKER_LOGGER_CONFIG":  6,
	}
)

Enum value maps for ConfigSource.

View Source 
var (
	ConfigType_name = map[int32]string{
		0: "CONFIG_TYPE_UNSPECIFIED",
		1: "CONFIG_TYPE_BOOLEAN",
		2: "CONFIG_TYPE_STRING",
		3: "CONFIG_TYPE_INT",
		4: "CONFIG_TYPE_SHORT",
		5: "CONFIG_TYPE_LONG",
		6: "CONFIG_TYPE_DOUBLE",
		7: "CONFIG_TYPE_LIST",
		8: "CONFIG_TYPE_CLASS",
		9: "CONFIG_TYPE_PASSWORD",
	}
	ConfigType_value = map[string]int32{
		"CONFIG_TYPE_UNSPECIFIED": 0,
		"CONFIG_TYPE_BOOLEAN":     1,
		"CONFIG_TYPE_STRING":      2,
		"CONFIG_TYPE_INT":         3,
		"CONFIG_TYPE_SHORT":       4,
		"CONFIG_TYPE_LONG":        5,
		"CONFIG_TYPE_DOUBLE":      6,
		"CONFIG_TYPE_LIST":        7,
		"CONFIG_TYPE_CLASS":       8,
		"CONFIG_TYPE_PASSWORD":    9,
	}
)

Enum value maps for ConfigType.

View Source 
var (
	ConfigAlterOperation_name = map[int32]string{
		0: "CONFIG_ALTER_OPERATION_UNSPECIFIED",
		1: "CONFIG_ALTER_OPERATION_SET",
		2: "CONFIG_ALTER_OPERATION_DELETE",
		3: "CONFIG_ALTER_OPERATION_APPEND",
		4: "CONFIG_ALTER_OPERATION_SUBTRACT",
	}
	ConfigAlterOperation_value = map[string]int32{
		"CONFIG_ALTER_OPERATION_UNSPECIFIED": 0,
		"CONFIG_ALTER_OPERATION_SET":         1,
		"CONFIG_ALTER_OPERATION_DELETE":      2,
		"CONFIG_ALTER_OPERATION_APPEND":      3,
		"CONFIG_ALTER_OPERATION_SUBTRACT":    4,
	}
)

Enum value maps for ConfigAlterOperation.

View Source 
var (
	Reason_name = map[int32]string{
		0: "REASON_UNSPECIFIED",
		1: "REASON_FEATURE_NOT_CONFIGURED",
		2: "REASON_CONSOLE_ERROR",
		3: "REASON_REDPANDA_ADMIN_API_ERROR",
		4: "REASON_KAFKA_API_ERROR",
		5: "REASON_KAFKA_CONNECT_API_ERROR",
		6: "REASON_TYPE_MAPPING_ERROR",
		7: "REASON_SECRET_STORE_ERROR",
	}
	Reason_value = map[string]int32{
		"REASON_UNSPECIFIED":              0,
		"REASON_FEATURE_NOT_CONFIGURED":   1,
		"REASON_CONSOLE_ERROR":            2,
		"REASON_REDPANDA_ADMIN_API_ERROR": 3,
		"REASON_KAFKA_API_ERROR":          4,
		"REASON_KAFKA_CONNECT_API_ERROR":  5,
		"REASON_TYPE_MAPPING_ERROR":       6,
		"REASON_SECRET_STORE_ERROR":       7,
	}
)

Enum value maps for Reason.

View Source 
var (
	ConnectorHolisticState_name = map[int32]string{
		0: "CONNECTOR_HOLISTIC_STATE_UNSPECIFIED",
		1: "CONNECTOR_HOLISTIC_STATE_PAUSED",
		2: "CONNECTOR_HOLISTIC_STATE_RESTARTING",
		3: "CONNECTOR_HOLISTIC_STATE_DESTROYED",
		4: "CONNECTOR_HOLISTIC_STATE_STOPPED",
		5: "CONNECTOR_HOLISTIC_STATE_UNASSIGNED",
		6: "CONNECTOR_HOLISTIC_STATE_HEALTHY",
		7: "CONNECTOR_HOLISTIC_STATE_UNHEALTHY",
		8: "CONNECTOR_HOLISTIC_STATE_DEGRADED",
		9: "CONNECTOR_HOLISTIC_STATE_UNKNOWN",
	}
	ConnectorHolisticState_value = map[string]int32{
		"CONNECTOR_HOLISTIC_STATE_UNSPECIFIED": 0,
		"CONNECTOR_HOLISTIC_STATE_PAUSED":      1,
		"CONNECTOR_HOLISTIC_STATE_RESTARTING":  2,
		"CONNECTOR_HOLISTIC_STATE_DESTROYED":   3,
		"CONNECTOR_HOLISTIC_STATE_STOPPED":     4,
		"CONNECTOR_HOLISTIC_STATE_UNASSIGNED":  5,
		"CONNECTOR_HOLISTIC_STATE_HEALTHY":     6,
		"CONNECTOR_HOLISTIC_STATE_UNHEALTHY":   7,
		"CONNECTOR_HOLISTIC_STATE_DEGRADED":    8,
		"CONNECTOR_HOLISTIC_STATE_UNKNOWN":     9,
	}
)

Enum value maps for ConnectorHolisticState.

View Source 
var (
	ConnectorError_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_ERROR",
		2: "TYPE_WARNING",
	}
	ConnectorError_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_ERROR":       1,
		"TYPE_WARNING":     2,
	}
)

Enum value maps for ConnectorError_Type.

View Source 
var (
	PartitionTransformStatus_PartitionStatus_name = map[int32]string{
		0: "PARTITION_STATUS_UNSPECIFIED",
		1: "PARTITION_STATUS_RUNNING",
		2: "PARTITION_STATUS_INACTIVE",
		3: "PARTITION_STATUS_ERRORED",
		4: "PARTITION_STATUS_UNKNOWN",
	}
	PartitionTransformStatus_PartitionStatus_value = map[string]int32{
		"PARTITION_STATUS_UNSPECIFIED": 0,
		"PARTITION_STATUS_RUNNING":     1,
		"PARTITION_STATUS_INACTIVE":    2,
		"PARTITION_STATUS_ERRORED":     3,
		"PARTITION_STATUS_UNKNOWN":     4,
	}
)

Enum value maps for PartitionTransformStatus_PartitionStatus.

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 ACLService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.dataplane.v1alpha1.ACLService",
	HandlerType: (*ACLServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListACLs",
			Handler:    _ACLService_ListACLs_Handler,
		},
		{
			MethodName: "CreateACL",
			Handler:    _ACLService_CreateACL_Handler,
		},
		{
			MethodName: "DeleteACLs",
			Handler:    _ACLService_DeleteACLs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/dataplane/v1alpha1/acl.proto",
}

ACLService_ServiceDesc is the grpc.ServiceDesc for ACLService 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 DummyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.dataplane.v1alpha1.DummyService",
	HandlerType: (*DummyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DummyMethod",
			Handler:    _DummyService_DummyMethod_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/dataplane/v1alpha1/dummy.proto",
}

DummyService_ServiceDesc is the grpc.ServiceDesc for DummyService 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_redpanda_api_dataplane_v1alpha1_acl_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_common_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_dummy_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_error_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_kafka_connect_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_secret_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_swagger_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_topic_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_transform_proto protoreflect.FileDescriptor
View Source 
var File_redpanda_api_dataplane_v1alpha1_user_proto protoreflect.FileDescriptor
View Source 
var KafkaConnectService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.dataplane.v1alpha1.KafkaConnectService",
	HandlerType: (*KafkaConnectServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListConnectClusters",
			Handler:    _KafkaConnectService_ListConnectClusters_Handler,
		},
		{
			MethodName: "GetConnectCluster",
			Handler:    _KafkaConnectService_GetConnectCluster_Handler,
		},
		{
			MethodName: "ListConnectors",
			Handler:    _KafkaConnectService_ListConnectors_Handler,
		},
		{
			MethodName: "CreateConnector",
			Handler:    _KafkaConnectService_CreateConnector_Handler,
		},
		{
			MethodName: "RestartConnector",
			Handler:    _KafkaConnectService_RestartConnector_Handler,
		},
		{
			MethodName: "GetConnector",
			Handler:    _KafkaConnectService_GetConnector_Handler,
		},
		{
			MethodName: "GetConnectorStatus",
			Handler:    _KafkaConnectService_GetConnectorStatus_Handler,
		},
		{
			MethodName: "PauseConnector",
			Handler:    _KafkaConnectService_PauseConnector_Handler,
		},
		{
			MethodName: "ResumeConnector",
			Handler:    _KafkaConnectService_ResumeConnector_Handler,
		},
		{
			MethodName: "StopConnector",
			Handler:    _KafkaConnectService_StopConnector_Handler,
		},
		{
			MethodName: "DeleteConnector",
			Handler:    _KafkaConnectService_DeleteConnector_Handler,
		},
		{
			MethodName: "UpsertConnector",
			Handler:    _KafkaConnectService_UpsertConnector_Handler,
		},
		{
			MethodName: "GetConnectorConfig",
			Handler:    _KafkaConnectService_GetConnectorConfig_Handler,
		},
		{
			MethodName: "ListConnectorTopics",
			Handler:    _KafkaConnectService_ListConnectorTopics_Handler,
		},
		{
			MethodName: "ResetConnectorTopics",
			Handler:    _KafkaConnectService_ResetConnectorTopics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/dataplane/v1alpha1/kafka_connect.proto",
}

KafkaConnectService_ServiceDesc is the grpc.ServiceDesc for KafkaConnectService 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 SecretService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.dataplane.v1alpha1.SecretService",
	HandlerType: (*SecretServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSecret",
			Handler:    _SecretService_GetSecret_Handler,
		},
		{
			MethodName: "ListSecrets",
			Handler:    _SecretService_ListSecrets_Handler,
		},
		{
			MethodName: "CreateSecret",
			Handler:    _SecretService_CreateSecret_Handler,
		},
		{
			MethodName: "UpdateSecret",
			Handler:    _SecretService_UpdateSecret_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _SecretService_DeleteSecret_Handler,
		},
		{
			MethodName: "GetConnectSecret",
			Handler:    _SecretService_GetConnectSecret_Handler,
		},
		{
			MethodName: "ListConnectSecrets",
			Handler:    _SecretService_ListConnectSecrets_Handler,
		},
		{
			MethodName: "CreateConnectSecret",
			Handler:    _SecretService_CreateConnectSecret_Handler,
		},
		{
			MethodName: "UpdateConnectSecret",
			Handler:    _SecretService_UpdateConnectSecret_Handler,
		},
		{
			MethodName: "DeleteConnectSecret",
			Handler:    _SecretService_DeleteConnectSecret_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/dataplane/v1alpha1/secret.proto",
}

SecretService_ServiceDesc is the grpc.ServiceDesc for SecretService 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: "redpanda.api.dataplane.v1alpha1.TopicService",
	HandlerType: (*TopicServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTopic",
			Handler:    _TopicService_CreateTopic_Handler,
		},
		{
			MethodName: "ListTopics",
			Handler:    _TopicService_ListTopics_Handler,
		},
		{
			MethodName: "DeleteTopic",
			Handler:    _TopicService_DeleteTopic_Handler,
		},
		{
			MethodName: "GetTopicConfigurations",
			Handler:    _TopicService_GetTopicConfigurations_Handler,
		},
		{
			MethodName: "UpdateTopicConfigurations",
			Handler:    _TopicService_UpdateTopicConfigurations_Handler,
		},
		{
			MethodName: "SetTopicConfigurations",
			Handler:    _TopicService_SetTopicConfigurations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/dataplane/v1alpha1/topic.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 TransformService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.dataplane.v1alpha1.TransformService",
	HandlerType: (*TransformServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTransforms",
			Handler:    _TransformService_ListTransforms_Handler,
		},
		{
			MethodName: "GetTransform",
			Handler:    _TransformService_GetTransform_Handler,
		},
		{
			MethodName: "DeleteTransform",
			Handler:    _TransformService_DeleteTransform_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/dataplane/v1alpha1/transform.proto",
}

TransformService_ServiceDesc is the grpc.ServiceDesc for TransformService 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: "redpanda.api.dataplane.v1alpha1.UserService",
	HandlerType: (*UserServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateUser",
			Handler:    _UserService_CreateUser_Handler,
		},
		{
			MethodName: "UpdateUser",
			Handler:    _UserService_UpdateUser_Handler,
		},
		{
			MethodName: "ListUsers",
			Handler:    _UserService_ListUsers_Handler,
		},
		{
			MethodName: "DeleteUser",
			Handler:    _UserService_DeleteUser_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/dataplane/v1alpha1/user.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 RegisterACLServiceServer 

func RegisterACLServiceServer(s grpc.ServiceRegistrar, srv ACLServiceServer)

func RegisterDummyServiceServer 

func RegisterDummyServiceServer(s grpc.ServiceRegistrar, srv DummyServiceServer)

func RegisterKafkaConnectServiceServer 

func RegisterKafkaConnectServiceServer(s grpc.ServiceRegistrar, srv KafkaConnectServiceServer)

func RegisterSecretServiceServer 

func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)

func RegisterTopicServiceServer 

func RegisterTopicServiceServer(s grpc.ServiceRegistrar, srv TopicServiceServer)

func RegisterTransformServiceServer added in v0.3.0 

func RegisterTransformServiceServer(s grpc.ServiceRegistrar, srv TransformServiceServer)

func RegisterUserServiceServer 

func RegisterUserServiceServer(s grpc.ServiceRegistrar, srv UserServiceServer)

Types

type ACL 

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

func (*ACL) Descriptor deprecated 

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

Deprecated: Use ACL.ProtoReflect.Descriptor instead.

func (*ACL) ProtoMessage 

func (*ACL) ProtoMessage()

func (*ACL) ProtoReflect 

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

func (*ACL) Reset 

func (x *ACL) Reset()

func (*ACL) String 

func (x *ACL) String() string

type ACLServiceClient 

type ACLServiceClient interface {
	ListACLs(ctx context.Context, in *ListACLsRequest, opts ...grpc.CallOption) (*ListACLsResponse, error)
	CreateACL(ctx context.Context, in *CreateACLRequest, opts ...grpc.CallOption) (*CreateACLResponse, error)
	DeleteACLs(ctx context.Context, in *DeleteACLsRequest, opts ...grpc.CallOption) (*DeleteACLsResponse, error)
}

ACLServiceClient is the client API for ACLService 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 NewACLServiceClient 

func NewACLServiceClient(cc grpc.ClientConnInterface) ACLServiceClient

type ACLServiceServer 

type ACLServiceServer interface {
	ListACLs(context.Context, *ListACLsRequest) (*ListACLsResponse, error)
	CreateACL(context.Context, *CreateACLRequest) (*CreateACLResponse, error)
	DeleteACLs(context.Context, *DeleteACLsRequest) (*DeleteACLsResponse, error)
}

ACLServiceServer is the server API for ACLService service. All implementations should embed UnimplementedACLServiceServer for forward compatibility

type ACL_Operation 

type ACL_Operation int32
const (
	ACL_OPERATION_UNSPECIFIED      ACL_Operation = 0
	ACL_OPERATION_ANY              ACL_Operation = 1
	ACL_OPERATION_ALL              ACL_Operation = 2
	ACL_OPERATION_READ             ACL_Operation = 3
	ACL_OPERATION_WRITE            ACL_Operation = 4
	ACL_OPERATION_CREATE           ACL_Operation = 5
	ACL_OPERATION_DELETE           ACL_Operation = 6
	ACL_OPERATION_ALTER            ACL_Operation = 7
	ACL_OPERATION_DESCRIBE         ACL_Operation = 8
	ACL_OPERATION_CLUSTER_ACTION   ACL_Operation = 9
	ACL_OPERATION_DESCRIBE_CONFIGS ACL_Operation = 10
	ACL_OPERATION_ALTER_CONFIGS    ACL_Operation = 11
	ACL_OPERATION_IDEMPOTENT_WRITE ACL_Operation = 12
	ACL_OPERATION_CREATE_TOKENS    ACL_Operation = 13
	ACL_OPERATION_DESCRIBE_TOKENS  ACL_Operation = 14
)

func (ACL_Operation) Descriptor 

func (ACL_Operation) Descriptor() protoreflect.EnumDescriptor

func (ACL_Operation) Enum 

func (x ACL_Operation) Enum() *ACL_Operation

func (ACL_Operation) EnumDescriptor deprecated 

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

Deprecated: Use ACL_Operation.Descriptor instead.

func (ACL_Operation) Number 

func (x ACL_Operation) Number() protoreflect.EnumNumber

func (ACL_Operation) String 

func (x ACL_Operation) String() string

func (ACL_Operation) Type 

func (ACL_Operation) Type() protoreflect.EnumType

type ACL_PermissionType 

type ACL_PermissionType int32
const (
	ACL_PERMISSION_TYPE_UNSPECIFIED ACL_PermissionType = 0
	ACL_PERMISSION_TYPE_ANY         ACL_PermissionType = 1
	ACL_PERMISSION_TYPE_DENY        ACL_PermissionType = 2
	ACL_PERMISSION_TYPE_ALLOW       ACL_PermissionType = 3
)

func (ACL_PermissionType) Descriptor 

func (ACL_PermissionType) Descriptor() protoreflect.EnumDescriptor

func (ACL_PermissionType) Enum 

func (x ACL_PermissionType) Enum() *ACL_PermissionType

func (ACL_PermissionType) EnumDescriptor deprecated 

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

Deprecated: Use ACL_PermissionType.Descriptor instead.

func (ACL_PermissionType) Number 

func (x ACL_PermissionType) Number() protoreflect.EnumNumber

func (ACL_PermissionType) String 

func (x ACL_PermissionType) String() string

func (ACL_PermissionType) Type 

func (ACL_PermissionType) Type() protoreflect.EnumType

type ACL_ResourcePatternType 

type ACL_ResourcePatternType int32
const (
	ACL_RESOURCE_PATTERN_TYPE_UNSPECIFIED ACL_ResourcePatternType = 0
	ACL_RESOURCE_PATTERN_TYPE_ANY         ACL_ResourcePatternType = 1
	ACL_RESOURCE_PATTERN_TYPE_MATCH       ACL_ResourcePatternType = 2
	ACL_RESOURCE_PATTERN_TYPE_LITERAL     ACL_ResourcePatternType = 3
	ACL_RESOURCE_PATTERN_TYPE_PREFIXED    ACL_ResourcePatternType = 4
)

func (ACL_ResourcePatternType) Descriptor 

func (ACL_ResourcePatternType) Descriptor() protoreflect.EnumDescriptor

func (ACL_ResourcePatternType) Enum 

func (x ACL_ResourcePatternType) Enum() *ACL_ResourcePatternType

func (ACL_ResourcePatternType) EnumDescriptor deprecated 

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

Deprecated: Use ACL_ResourcePatternType.Descriptor instead.

func (ACL_ResourcePatternType) Number 

func (x ACL_ResourcePatternType) Number() protoreflect.EnumNumber

func (ACL_ResourcePatternType) String 

func (x ACL_ResourcePatternType) String() string

func (ACL_ResourcePatternType) Type 

func (ACL_ResourcePatternType) Type() protoreflect.EnumType

type ACL_ResourceType 

type ACL_ResourceType int32
const (
	ACL_RESOURCE_TYPE_UNSPECIFIED      ACL_ResourceType = 0
	ACL_RESOURCE_TYPE_ANY              ACL_ResourceType = 1
	ACL_RESOURCE_TYPE_TOPIC            ACL_ResourceType = 2
	ACL_RESOURCE_TYPE_GROUP            ACL_ResourceType = 3
	ACL_RESOURCE_TYPE_CLUSTER          ACL_ResourceType = 4
	ACL_RESOURCE_TYPE_TRANSACTIONAL_ID ACL_ResourceType = 5
	ACL_RESOURCE_TYPE_DELEGATION_TOKEN ACL_ResourceType = 6
	ACL_RESOURCE_TYPE_USER             ACL_ResourceType = 7
)

func (ACL_ResourceType) Descriptor 

func (ACL_ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ACL_ResourceType) Enum 

func (x ACL_ResourceType) Enum() *ACL_ResourceType

func (ACL_ResourceType) EnumDescriptor deprecated 

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

Deprecated: Use ACL_ResourceType.Descriptor instead.

func (ACL_ResourceType) Number 

func (x ACL_ResourceType) Number() protoreflect.EnumNumber

func (ACL_ResourceType) String 

func (x ACL_ResourceType) String() string

func (ACL_ResourceType) Type 

func (ACL_ResourceType) Type() protoreflect.EnumType

type ConfigAlterOperation 

type ConfigAlterOperation int32
const (
	ConfigAlterOperation_CONFIG_ALTER_OPERATION_UNSPECIFIED ConfigAlterOperation = 0
	ConfigAlterOperation_CONFIG_ALTER_OPERATION_SET         ConfigAlterOperation = 1
	ConfigAlterOperation_CONFIG_ALTER_OPERATION_DELETE      ConfigAlterOperation = 2
	ConfigAlterOperation_CONFIG_ALTER_OPERATION_APPEND      ConfigAlterOperation = 3
	ConfigAlterOperation_CONFIG_ALTER_OPERATION_SUBTRACT    ConfigAlterOperation = 4
)

func (ConfigAlterOperation) Descriptor 

func (ConfigAlterOperation) Descriptor() protoreflect.EnumDescriptor

func (ConfigAlterOperation) Enum 

func (x ConfigAlterOperation) Enum() *ConfigAlterOperation

func (ConfigAlterOperation) EnumDescriptor deprecated 

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

Deprecated: Use ConfigAlterOperation.Descriptor instead.

func (ConfigAlterOperation) Number 

func (x ConfigAlterOperation) Number() protoreflect.EnumNumber

func (ConfigAlterOperation) String 

func (x ConfigAlterOperation) String() string

func (ConfigAlterOperation) Type 

func (ConfigAlterOperation) Type() protoreflect.EnumType

type ConfigSource 

type ConfigSource int32
const (
	ConfigSource_CONFIG_SOURCE_UNSPECIFIED                   ConfigSource = 0
	ConfigSource_CONFIG_SOURCE_DYNAMIC_TOPIC_CONFIG          ConfigSource = 1
	ConfigSource_CONFIG_SOURCE_DYNAMIC_BROKER_CONFIG         ConfigSource = 2
	ConfigSource_CONFIG_SOURCE_DYNAMIC_DEFAULT_BROKER_CONFIG ConfigSource = 3
	ConfigSource_CONFIG_SOURCE_STATIC_BROKER_CONFIG          ConfigSource = 4
	ConfigSource_CONFIG_SOURCE_DEFAULT_CONFIG                ConfigSource = 5
	ConfigSource_CONFIG_SOURCE_DYNAMIC_BROKER_LOGGER_CONFIG  ConfigSource = 6
)

func (ConfigSource) Descriptor 

func (ConfigSource) Descriptor() protoreflect.EnumDescriptor

func (ConfigSource) Enum 

func (x ConfigSource) Enum() *ConfigSource

func (ConfigSource) EnumDescriptor deprecated 

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

Deprecated: Use ConfigSource.Descriptor instead.

func (ConfigSource) Number 

func (x ConfigSource) Number() protoreflect.EnumNumber

func (ConfigSource) String 

func (x ConfigSource) String() string

func (ConfigSource) Type 

func (ConfigSource) Type() protoreflect.EnumType

type ConfigSynonym 

type ConfigSynonym struct {
	Name   string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value  *string      `protobuf:"bytes,2,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Source ConfigSource `protobuf:"varint,3,opt,name=source,proto3,enum=redpanda.api.dataplane.v1alpha1.ConfigSource" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigSynonym) Descriptor deprecated 

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

Deprecated: Use ConfigSynonym.ProtoReflect.Descriptor instead.

func (*ConfigSynonym) GetName 

func (x *ConfigSynonym) GetName() string

func (*ConfigSynonym) GetSource 

func (x *ConfigSynonym) GetSource() ConfigSource

func (*ConfigSynonym) GetValue 

func (x *ConfigSynonym) GetValue() string

func (*ConfigSynonym) ProtoMessage 

func (*ConfigSynonym) ProtoMessage()

func (*ConfigSynonym) ProtoReflect 

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

func (*ConfigSynonym) Reset 

func (x *ConfigSynonym) Reset()

func (*ConfigSynonym) String 

func (x *ConfigSynonym) String() string

type ConfigType 

type ConfigType int32
const (
	ConfigType_CONFIG_TYPE_UNSPECIFIED ConfigType = 0
	ConfigType_CONFIG_TYPE_BOOLEAN     ConfigType = 1
	ConfigType_CONFIG_TYPE_STRING      ConfigType = 2
	ConfigType_CONFIG_TYPE_INT         ConfigType = 3
	ConfigType_CONFIG_TYPE_SHORT       ConfigType = 4
	ConfigType_CONFIG_TYPE_LONG        ConfigType = 5
	ConfigType_CONFIG_TYPE_DOUBLE      ConfigType = 6
	ConfigType_CONFIG_TYPE_LIST        ConfigType = 7
	ConfigType_CONFIG_TYPE_CLASS       ConfigType = 8
	ConfigType_CONFIG_TYPE_PASSWORD    ConfigType = 9
)

func (ConfigType) Descriptor 

func (ConfigType) Descriptor() protoreflect.EnumDescriptor

func (ConfigType) Enum 

func (x ConfigType) Enum() *ConfigType

func (ConfigType) EnumDescriptor deprecated 

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

Deprecated: Use ConfigType.Descriptor instead.

func (ConfigType) Number 

func (x ConfigType) Number() protoreflect.EnumNumber

func (ConfigType) String 

func (x ConfigType) String() string

func (ConfigType) Type 

func (ConfigType) Type() protoreflect.EnumType

type ConnectCluster 

type ConnectCluster struct {
	Name    string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Address string               `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Info    *ConnectCluster_Info `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Plugins []*ConnectorPlugin   `protobuf:"bytes,4,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectCluster) Descriptor deprecated 

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

Deprecated: Use ConnectCluster.ProtoReflect.Descriptor instead.

func (*ConnectCluster) GetAddress 

func (x *ConnectCluster) GetAddress() string

func (*ConnectCluster) GetInfo 

func (x *ConnectCluster) GetInfo() *ConnectCluster_Info

func (*ConnectCluster) GetName 

func (x *ConnectCluster) GetName() string

func (*ConnectCluster) GetPlugins 

func (x *ConnectCluster) GetPlugins() []*ConnectorPlugin

func (*ConnectCluster) ProtoMessage 

func (*ConnectCluster) ProtoMessage()

func (*ConnectCluster) ProtoReflect 

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

func (*ConnectCluster) Reset 

func (x *ConnectCluster) Reset()

func (*ConnectCluster) String 

func (x *ConnectCluster) String() string

type ConnectCluster_Info 

type ConnectCluster_Info struct {
	Version        string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Commit         string `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
	KafkaClusterId string `protobuf:"bytes,3,opt,name=kafka_cluster_id,json=kafkaClusterId,proto3" json:"kafka_cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectCluster_Info) Descriptor deprecated 

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

Deprecated: Use ConnectCluster_Info.ProtoReflect.Descriptor instead.

func (*ConnectCluster_Info) GetCommit 

func (x *ConnectCluster_Info) GetCommit() string

func (*ConnectCluster_Info) GetKafkaClusterId 

func (x *ConnectCluster_Info) GetKafkaClusterId() string

func (*ConnectCluster_Info) GetVersion 

func (x *ConnectCluster_Info) GetVersion() string

func (*ConnectCluster_Info) ProtoMessage 

func (*ConnectCluster_Info) ProtoMessage()

func (*ConnectCluster_Info) ProtoReflect 

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

func (*ConnectCluster_Info) Reset 

func (x *ConnectCluster_Info) Reset()

func (*ConnectCluster_Info) String 

func (x *ConnectCluster_Info) String() string

type ConnectorError 

type ConnectorError struct {
	Type    ConnectorError_Type `protobuf:"varint,1,opt,name=type,proto3,enum=redpanda.api.dataplane.v1alpha1.ConnectorError_Type" json:"type,omitempty"`
	Title   string              `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Content string              `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

ConnectorError is the error of a connector, this is holistic error abstraction, made parsing the error trace of connector or Task

func (*ConnectorError) Descriptor deprecated 

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

Deprecated: Use ConnectorError.ProtoReflect.Descriptor instead.

func (*ConnectorError) GetContent 

func (x *ConnectorError) GetContent() string

func (*ConnectorError) GetTitle 

func (x *ConnectorError) GetTitle() string

func (*ConnectorError) GetType 

func (x *ConnectorError) GetType() ConnectorError_Type

func (*ConnectorError) ProtoMessage 

func (*ConnectorError) ProtoMessage()

func (*ConnectorError) ProtoReflect 

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

func (*ConnectorError) Reset 

func (x *ConnectorError) Reset()

func (*ConnectorError) String 

func (x *ConnectorError) String() string

type ConnectorError_Type 

type ConnectorError_Type int32
const (
	ConnectorError_TYPE_UNSPECIFIED ConnectorError_Type = 0
	ConnectorError_TYPE_ERROR       ConnectorError_Type = 1
	ConnectorError_TYPE_WARNING     ConnectorError_Type = 2
)

func (ConnectorError_Type) Descriptor 

func (ConnectorError_Type) Descriptor() protoreflect.EnumDescriptor

func (ConnectorError_Type) Enum 

func (x ConnectorError_Type) Enum() *ConnectorError_Type

func (ConnectorError_Type) EnumDescriptor deprecated 

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

Deprecated: Use ConnectorError_Type.Descriptor instead.

func (ConnectorError_Type) Number 

func (x ConnectorError_Type) Number() protoreflect.EnumNumber

func (ConnectorError_Type) String 

func (x ConnectorError_Type) String() string

func (ConnectorError_Type) Type 

func (ConnectorError_Type) Type() protoreflect.EnumType

type ConnectorHolisticState 

type ConnectorHolisticState int32

The following states are possible for a connector or one of its tasks implement the state interface described in the Kafka connect API @see https://docs.confluent.io/platform/current/connect/monitoring.html#connector-and-task-status this includes holistic unified connector status that takes into account not just the connector instance state, but also state of all the tasks within the connector 

const (
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_UNSPECIFIED ConnectorHolisticState = 0
	// PAUSED: The connector/task has been administratively paused.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_PAUSED ConnectorHolisticState = 1
	// RESTARTING: he connector/task is restarting.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_RESTARTING ConnectorHolisticState = 2
	// DESTROYED: Connector is in destroyed state, regardless of any tasks.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_DESTROYED ConnectorHolisticState = 3
	// STOPPED: The connector/task has been stopped.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_STOPPED ConnectorHolisticState = 4
	// The connector/task has not yet been assigned to a worker
	// UNASSIGNED: Connector is in unassigned state.
	//
	//	Or Connector is in running state, and there are unassigned tasks.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_UNASSIGNED ConnectorHolisticState = 5
	// HEALTHY: Connector is in running state, > 0 tasks, all of them in running state.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_HEALTHY ConnectorHolisticState = 6
	// UNHEALTHY: Connector is failed state.
	//
	//	Or Connector is in running state but has 0 tasks.
	//	Or Connector is in running state, has > 0 tasks, and all tasks are in failed state.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_UNHEALTHY ConnectorHolisticState = 7
	// DEGRADED: Connector is in running state, has > 0 tasks, but has at least one state in failed state, but not all tasks are failed.
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_DEGRADED ConnectorHolisticState = 8
	// UNKNOWN: The connector/task could no be determined
	ConnectorHolisticState_CONNECTOR_HOLISTIC_STATE_UNKNOWN ConnectorHolisticState = 9
)

func (ConnectorHolisticState) Descriptor 

func (ConnectorHolisticState) Descriptor() protoreflect.EnumDescriptor

func (ConnectorHolisticState) Enum 

func (x ConnectorHolisticState) Enum() *ConnectorHolisticState

func (ConnectorHolisticState) EnumDescriptor deprecated 

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

Deprecated: Use ConnectorHolisticState.Descriptor instead.

func (ConnectorHolisticState) Number 

func (x ConnectorHolisticState) Number() protoreflect.EnumNumber

func (ConnectorHolisticState) String 

func (x ConnectorHolisticState) String() string

func (ConnectorHolisticState) Type 

func (ConnectorHolisticState) Type() protoreflect.EnumType

type ConnectorPlugin 

type ConnectorPlugin struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Class   string `protobuf:"bytes,3,opt,name=class,proto3" json:"class,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectorPlugin) Descriptor deprecated 

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

Deprecated: Use ConnectorPlugin.ProtoReflect.Descriptor instead.

func (*ConnectorPlugin) GetClass 

func (x *ConnectorPlugin) GetClass() string

func (*ConnectorPlugin) GetType 

func (x *ConnectorPlugin) GetType() string

func (*ConnectorPlugin) GetVersion 

func (x *ConnectorPlugin) GetVersion() string

func (*ConnectorPlugin) ProtoMessage 

func (*ConnectorPlugin) ProtoMessage()

func (*ConnectorPlugin) ProtoReflect 

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

func (*ConnectorPlugin) Reset 

func (x *ConnectorPlugin) Reset()

func (*ConnectorPlugin) String 

func (x *ConnectorPlugin) String() string

type ConnectorSpec 

type ConnectorSpec struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Config map[string]string `` /* 153-byte string literal not displayed */
	Tasks  []*TaskInfo       `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Type   string            `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

ConectorInfo is the spec of the connector, as defined in the Kafka connect API, it can be used as input of the connector creation or output of the connectors

func (*ConnectorSpec) Descriptor deprecated 

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

Deprecated: Use ConnectorSpec.ProtoReflect.Descriptor instead.

func (*ConnectorSpec) GetConfig 

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

func (*ConnectorSpec) GetName 

func (x *ConnectorSpec) GetName() string

func (*ConnectorSpec) GetTasks 

func (x *ConnectorSpec) GetTasks() []*TaskInfo

func (*ConnectorSpec) GetType 

func (x *ConnectorSpec) GetType() string

func (*ConnectorSpec) ProtoMessage 

func (*ConnectorSpec) ProtoMessage()

func (*ConnectorSpec) ProtoReflect 

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

func (*ConnectorSpec) Reset 

func (x *ConnectorSpec) Reset()

func (*ConnectorSpec) String 

func (x *ConnectorSpec) String() string

type ConnectorStatus 

type ConnectorStatus struct {
	Name      string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Connector *ConnectorStatus_Connector `protobuf:"bytes,2,opt,name=connector,proto3" json:"connector,omitempty"`
	Tasks     []*TaskStatus              `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Type      string                     `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// holistic_state of all the tasks within the connector this is our internal
	// holistic state concept
	HolisticState ConnectorHolisticState `` /* 161-byte string literal not displayed */
	// Errors is list of parsed connectors' and tasks' errors
	Errors []*ConnectorError `protobuf:"bytes,6,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectorStatus) Descriptor deprecated 

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

Deprecated: Use ConnectorStatus.ProtoReflect.Descriptor instead.

func (*ConnectorStatus) GetConnector 

func (x *ConnectorStatus) GetConnector() *ConnectorStatus_Connector

func (*ConnectorStatus) GetErrors 

func (x *ConnectorStatus) GetErrors() []*ConnectorError

func (*ConnectorStatus) GetHolisticState 

func (x *ConnectorStatus) GetHolisticState() ConnectorHolisticState

func (*ConnectorStatus) GetName 

func (x *ConnectorStatus) GetName() string

func (*ConnectorStatus) GetTasks 

func (x *ConnectorStatus) GetTasks() []*TaskStatus

func (*ConnectorStatus) GetType 

func (x *ConnectorStatus) GetType() string

func (*ConnectorStatus) ProtoMessage 

func (*ConnectorStatus) ProtoMessage()

func (*ConnectorStatus) ProtoReflect 

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

func (*ConnectorStatus) Reset 

func (x *ConnectorStatus) Reset()

func (*ConnectorStatus) String 

func (x *ConnectorStatus) String() string

type ConnectorStatus_Connector 

type ConnectorStatus_Connector struct {
	State    string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Trace    string `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectorStatus_Connector) Descriptor deprecated 

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

Deprecated: Use ConnectorStatus_Connector.ProtoReflect.Descriptor instead.

func (*ConnectorStatus_Connector) GetState 

func (x *ConnectorStatus_Connector) GetState() string

func (*ConnectorStatus_Connector) GetTrace 

func (x *ConnectorStatus_Connector) GetTrace() string

func (*ConnectorStatus_Connector) GetWorkerId 

func (x *ConnectorStatus_Connector) GetWorkerId() string

func (*ConnectorStatus_Connector) ProtoMessage 

func (*ConnectorStatus_Connector) ProtoMessage()

func (*ConnectorStatus_Connector) ProtoReflect 

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

func (*ConnectorStatus_Connector) Reset 

func (x *ConnectorStatus_Connector) Reset()

func (*ConnectorStatus_Connector) String 

func (x *ConnectorStatus_Connector) String() string

type CreateACLRequest 

type CreateACLRequest struct {

	// ResourceType determines the type of the resource (Topic, ConsumerGroup etc) this
	// ACL shall target.
	ResourceType ACL_ResourceType `` /* 152-byte string literal not displayed */
	// ResourceName is the name of the resource this acl entry will be on.
	// For requests with resource_type CLUSTER, this will default to the expected
	// value "kafka-cluster".
	ResourceName string `protobuf:"bytes,2,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	// ResourcePattern type determines the strategy how the provided resource_name
	// is matched (exact match, prefixed, ...) against the actual resource names.
	ResourcePatternType ACL_ResourcePatternType `` /* 182-byte string literal not displayed */
	// Principal is the user to apply this acl for. With the Kafka simple
	// authorizer, this must begin with "User:".
	Principal string `protobuf:"bytes,4,opt,name=principal,proto3" json:"principal,omitempty"`
	// Host is the host address to use for this acl. Each host to allow
	// the principal access from must be specified as a new creation.
	Host string `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	// Operation is the operation that shall be allowed (e.g. READ).
	Operation ACL_Operation `protobuf:"varint,6,opt,name=operation,proto3,enum=redpanda.api.dataplane.v1alpha1.ACL_Operation" json:"operation,omitempty"`
	// PermissionType determines whether the operation should be allowed or denied.
	PermissionType ACL_PermissionType `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateACLRequest) Descriptor deprecated 

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

Deprecated: Use CreateACLRequest.ProtoReflect.Descriptor instead.

func (*CreateACLRequest) GetHost 

func (x *CreateACLRequest) GetHost() string

func (*CreateACLRequest) GetOperation 

func (x *CreateACLRequest) GetOperation() ACL_Operation

func (*CreateACLRequest) GetPermissionType 

func (x *CreateACLRequest) GetPermissionType() ACL_PermissionType

func (*CreateACLRequest) GetPrincipal 

func (x *CreateACLRequest) GetPrincipal() string

func (*CreateACLRequest) GetResourceName 

func (x *CreateACLRequest) GetResourceName() string

func (*CreateACLRequest) GetResourcePatternType 

func (x *CreateACLRequest) GetResourcePatternType() ACL_ResourcePatternType

func (*CreateACLRequest) GetResourceType 

func (x *CreateACLRequest) GetResourceType() ACL_ResourceType

func (*CreateACLRequest) ProtoMessage 

func (*CreateACLRequest) ProtoMessage()

func (*CreateACLRequest) ProtoReflect 

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

func (*CreateACLRequest) Reset 

func (x *CreateACLRequest) Reset()

func (*CreateACLRequest) String 

func (x *CreateACLRequest) String() string

type CreateACLResponse 

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

func (*CreateACLResponse) Descriptor deprecated 

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

Deprecated: Use CreateACLResponse.ProtoReflect.Descriptor instead.

func (*CreateACLResponse) ProtoMessage 

func (*CreateACLResponse) ProtoMessage()

func (*CreateACLResponse) ProtoReflect 

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

func (*CreateACLResponse) Reset 

func (x *CreateACLResponse) Reset()

func (*CreateACLResponse) String 

func (x *CreateACLResponse) String() string

type CreateConnectSecretRequest added in v0.3.0 

type CreateConnectSecretRequest struct {

	// The unique name of target connect cluster.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// The Connect name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The input for the secret to create.
	Secret *SecretInput `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

CreateConnectSecretRequest is the request of CreateConnectSecret.

func (*CreateConnectSecretRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use CreateConnectSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectSecretRequest) GetClusterName added in v0.3.0 

func (x *CreateConnectSecretRequest) GetClusterName() string

func (*CreateConnectSecretRequest) GetName added in v0.3.0 

func (x *CreateConnectSecretRequest) GetName() string

func (*CreateConnectSecretRequest) GetSecret added in v0.3.0 

func (x *CreateConnectSecretRequest) GetSecret() *SecretInput

func (*CreateConnectSecretRequest) ProtoMessage added in v0.3.0 

func (*CreateConnectSecretRequest) ProtoMessage()

func (*CreateConnectSecretRequest) ProtoReflect added in v0.3.0 

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

func (*CreateConnectSecretRequest) Reset added in v0.3.0 

func (x *CreateConnectSecretRequest) Reset()

func (*CreateConnectSecretRequest) String added in v0.3.0 

func (x *CreateConnectSecretRequest) String() string

type CreateConnectSecretResponse added in v0.3.0 

type CreateConnectSecretResponse struct {

	// The created secret.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

CreateConnectSecretResponse is the response of CreateConnectSecret.

func (*CreateConnectSecretResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use CreateConnectSecretResponse.ProtoReflect.Descriptor instead.

func (*CreateConnectSecretResponse) GetSecret added in v0.3.0 

func (x *CreateConnectSecretResponse) GetSecret() *Secret

func (*CreateConnectSecretResponse) ProtoMessage added in v0.3.0 

func (*CreateConnectSecretResponse) ProtoMessage()

func (*CreateConnectSecretResponse) ProtoReflect added in v0.3.0 

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

func (*CreateConnectSecretResponse) Reset added in v0.3.0 

func (x *CreateConnectSecretResponse) Reset()

func (*CreateConnectSecretResponse) String added in v0.3.0 

func (x *CreateConnectSecretResponse) String() string

type CreateConnectorRequest 

type CreateConnectorRequest struct {
	ClusterName string         `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Connector   *ConnectorSpec `protobuf:"bytes,2,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConnectorRequest) Descriptor deprecated 

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

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetClusterName 

func (x *CreateConnectorRequest) GetClusterName() string

func (*CreateConnectorRequest) GetConnector 

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

func (x *CreateConnectorRequest) String() string

type CreateConnectorResponse 

type CreateConnectorResponse struct {
	Connector *ConnectorSpec `protobuf:"bytes,1,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConnectorResponse) Descriptor deprecated 

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

Deprecated: Use CreateConnectorResponse.ProtoReflect.Descriptor instead.

func (*CreateConnectorResponse) GetConnector 

func (x *CreateConnectorResponse) GetConnector() *ConnectorSpec

func (*CreateConnectorResponse) ProtoMessage 

func (*CreateConnectorResponse) ProtoMessage()

func (*CreateConnectorResponse) ProtoReflect 

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

func (*CreateConnectorResponse) Reset 

func (x *CreateConnectorResponse) Reset()

func (*CreateConnectorResponse) String 

func (x *CreateConnectorResponse) String() string

type CreateSecretRequest 

type CreateSecretRequest struct {

	// Secret identifier.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The input for the secret to create.
	Secret *SecretInput `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

CreateSecretRequest is the request of CreateSecret.

func (*CreateSecretRequest) Descriptor deprecated 

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

Deprecated: Use CreateSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateSecretRequest) GetId added in v0.3.0 

func (x *CreateSecretRequest) GetId() string

func (*CreateSecretRequest) GetSecret 

func (x *CreateSecretRequest) GetSecret() *SecretInput

func (*CreateSecretRequest) ProtoMessage 

func (*CreateSecretRequest) ProtoMessage()

func (*CreateSecretRequest) ProtoReflect 

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

func (*CreateSecretRequest) Reset 

func (x *CreateSecretRequest) Reset()

func (*CreateSecretRequest) String 

func (x *CreateSecretRequest) String() string

type CreateSecretResponse 

type CreateSecretResponse struct {

	// The created secret.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

CreateSecretResponse is the response of CreateSecret.

func (*CreateSecretResponse) Descriptor deprecated 

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

Deprecated: Use CreateSecretResponse.ProtoReflect.Descriptor instead.

func (*CreateSecretResponse) GetSecret 

func (x *CreateSecretResponse) GetSecret() *Secret

func (*CreateSecretResponse) ProtoMessage 

func (*CreateSecretResponse) ProtoMessage()

func (*CreateSecretResponse) ProtoReflect 

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

func (*CreateSecretResponse) Reset 

func (x *CreateSecretResponse) Reset()

func (*CreateSecretResponse) String 

func (x *CreateSecretResponse) String() string

type CreateTopicRequest 

type CreateTopicRequest struct {

	// Topic is the topic to attempt to create.
	Topic *CreateTopicRequest_Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// ValidateOnly makes this request a dry-run; everything is validated but
	// no topics are actually created.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetTopic 

func (x *CreateTopicRequest) GetTopic() *CreateTopicRequest_Topic

func (*CreateTopicRequest) GetValidateOnly 

func (x *CreateTopicRequest) GetValidateOnly() bool

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

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

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

type CreateTopicRequest_Topic 

type CreateTopicRequest_Topic struct {

	// Name is the topic's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// PartitionCount is how many partitions to give a topic. This must
	// be null if specifying partitions manually (see ReplicaAssignment)
	// or, to use the cluster default partitions.
	PartitionCount *int32 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3,oneof" json:"partition_count,omitempty"`
	// ReplicationFactor is how many replicas every partition must have.
	// This must be null if specifying partitions manually (see ReplicaAssignment)
	// or, to use the cluster default replication factor.
	ReplicationFactor *int32 `protobuf:"varint,3,opt,name=replication_factor,json=replicationFactor,proto3,oneof" json:"replication_factor,omitempty"`
	// ReplicaAssignment is an array to manually dictate replicas and their
	// partitions for a topic. If using this, both ReplicationFactor and
	// NumPartitions must be -1.
	ReplicaAssignments []*CreateTopicRequest_Topic_ReplicaAssignment `protobuf:"bytes,4,rep,name=replica_assignments,json=replicaAssignments,proto3" json:"replica_assignments,omitempty"`
	// Configs is an array of key value config pairs for a topic.
	// These correspond to Kafka Topic-Level Configs.
	Configs []*CreateTopicRequest_Topic_Config `protobuf:"bytes,5,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicRequest_Topic) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest_Topic.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest_Topic) GetConfigs 

func (x *CreateTopicRequest_Topic) GetConfigs() []*CreateTopicRequest_Topic_Config

func (*CreateTopicRequest_Topic) GetName 

func (x *CreateTopicRequest_Topic) GetName() string

func (*CreateTopicRequest_Topic) GetPartitionCount 

func (x *CreateTopicRequest_Topic) GetPartitionCount() int32

func (*CreateTopicRequest_Topic) GetReplicaAssignments added in v0.3.0 

func (x *CreateTopicRequest_Topic) GetReplicaAssignments() []*CreateTopicRequest_Topic_ReplicaAssignment

func (*CreateTopicRequest_Topic) GetReplicationFactor 

func (x *CreateTopicRequest_Topic) GetReplicationFactor() int32

func (*CreateTopicRequest_Topic) ProtoMessage 

func (*CreateTopicRequest_Topic) ProtoMessage()

func (*CreateTopicRequest_Topic) ProtoReflect 

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

func (*CreateTopicRequest_Topic) Reset 

func (x *CreateTopicRequest_Topic) Reset()

func (*CreateTopicRequest_Topic) String 

func (x *CreateTopicRequest_Topic) String() string

type CreateTopicRequest_Topic_Config 

type CreateTopicRequest_Topic_Config struct {

	// Name is a topic level config key (e.g. segment.bytes).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value is a topic level config value (e.g. 1073741824)
	Value *string `protobuf:"bytes,2,opt,name=value,proto3,oneof" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicRequest_Topic_Config) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest_Topic_Config.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest_Topic_Config) GetName 

func (x *CreateTopicRequest_Topic_Config) GetName() string

func (*CreateTopicRequest_Topic_Config) GetValue 

func (x *CreateTopicRequest_Topic_Config) GetValue() string

func (*CreateTopicRequest_Topic_Config) ProtoMessage 

func (*CreateTopicRequest_Topic_Config) ProtoMessage()

func (*CreateTopicRequest_Topic_Config) ProtoReflect 

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

func (*CreateTopicRequest_Topic_Config) Reset 

func (x *CreateTopicRequest_Topic_Config) Reset()

func (*CreateTopicRequest_Topic_Config) String 

func (x *CreateTopicRequest_Topic_Config) String() string

type CreateTopicRequest_Topic_ReplicaAssignment 

type CreateTopicRequest_Topic_ReplicaAssignment struct {

	// Partition is a partition to create.
	PartitionId int32 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Replicas are the broker IDs the partition must exist on.
	ReplicaIds []int32 `protobuf:"varint,2,rep,packed,name=replica_ids,json=replicaIds,proto3" json:"replica_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicRequest_Topic_ReplicaAssignment) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest_Topic_ReplicaAssignment.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest_Topic_ReplicaAssignment) GetPartitionId added in v0.3.0 

func (x *CreateTopicRequest_Topic_ReplicaAssignment) GetPartitionId() int32

func (*CreateTopicRequest_Topic_ReplicaAssignment) GetReplicaIds added in v0.3.0 

func (x *CreateTopicRequest_Topic_ReplicaAssignment) GetReplicaIds() []int32

func (*CreateTopicRequest_Topic_ReplicaAssignment) ProtoMessage 

func (*CreateTopicRequest_Topic_ReplicaAssignment) ProtoMessage()

func (*CreateTopicRequest_Topic_ReplicaAssignment) ProtoReflect 

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

func (*CreateTopicRequest_Topic_ReplicaAssignment) Reset 

func (x *CreateTopicRequest_Topic_ReplicaAssignment) Reset()

func (*CreateTopicRequest_Topic_ReplicaAssignment) String 

func (x *CreateTopicRequest_Topic_ReplicaAssignment) String() string

type CreateTopicResponse 

type CreateTopicResponse struct {

	// Name is the topic's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// PartitionCount is how many partitions were created for this topic.
	// This field has a default of -1, which may be returned if the broker
	// does not support v5+ of this request which added support for returning
	// this information.
	PartitionCount int32 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// ReplicationFactor is how many replicas every partition has for this topic.
	// This field has a default of -1, which may be returned if the broker
	// does not support v5+ of this request which added support for returning
	// this information.
	ReplicationFactor int32 `protobuf:"varint,3,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicResponse) Descriptor deprecated 

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

Deprecated: Use CreateTopicResponse.ProtoReflect.Descriptor instead.

func (*CreateTopicResponse) GetName 

func (x *CreateTopicResponse) GetName() string

func (*CreateTopicResponse) GetPartitionCount added in v0.3.0 

func (x *CreateTopicResponse) GetPartitionCount() int32

func (*CreateTopicResponse) GetReplicationFactor added in v0.3.0 

func (x *CreateTopicResponse) GetReplicationFactor() int32

func (*CreateTopicResponse) ProtoMessage 

func (*CreateTopicResponse) ProtoMessage()

func (*CreateTopicResponse) ProtoReflect 

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

func (*CreateTopicResponse) Reset 

func (x *CreateTopicResponse) Reset()

func (*CreateTopicResponse) String 

func (x *CreateTopicResponse) String() string

type CreateUserRequest 

type CreateUserRequest struct {
	User *CreateUserRequest_User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserRequest) Descriptor deprecated 

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

Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.

func (*CreateUserRequest) GetUser 

func (x *CreateUserRequest) GetUser() *CreateUserRequest_User

func (*CreateUserRequest) ProtoMessage 

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) ProtoReflect 

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

func (*CreateUserRequest) Reset 

func (x *CreateUserRequest) Reset()

func (*CreateUserRequest) String 

func (x *CreateUserRequest) String() string

type CreateUserRequest_User 

type CreateUserRequest_User struct {
	Name      string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Password  string        `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Mechanism SASLMechanism `protobuf:"varint,3,opt,name=mechanism,proto3,enum=redpanda.api.dataplane.v1alpha1.SASLMechanism" json:"mechanism,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserRequest_User) Descriptor deprecated 

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

Deprecated: Use CreateUserRequest_User.ProtoReflect.Descriptor instead.

func (*CreateUserRequest_User) GetMechanism 

func (x *CreateUserRequest_User) GetMechanism() SASLMechanism

func (*CreateUserRequest_User) GetName 

func (x *CreateUserRequest_User) GetName() string

func (*CreateUserRequest_User) GetPassword 

func (x *CreateUserRequest_User) GetPassword() string

func (*CreateUserRequest_User) ProtoMessage 

func (*CreateUserRequest_User) ProtoMessage()

func (*CreateUserRequest_User) ProtoReflect 

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

func (*CreateUserRequest_User) Reset 

func (x *CreateUserRequest_User) Reset()

func (*CreateUserRequest_User) String 

func (x *CreateUserRequest_User) String() string

type CreateUserResponse 

type CreateUserResponse struct {
	User *CreateUserResponse_User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUserResponse) Descriptor deprecated 

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

Deprecated: Use CreateUserResponse.ProtoReflect.Descriptor instead.

func (*CreateUserResponse) GetUser 

func (x *CreateUserResponse) GetUser() *CreateUserResponse_User

func (*CreateUserResponse) ProtoMessage 

func (*CreateUserResponse) ProtoMessage()

func (*CreateUserResponse) ProtoReflect 

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

func (*CreateUserResponse) Reset 

func (x *CreateUserResponse) Reset()

func (*CreateUserResponse) String 

func (x *CreateUserResponse) String() string

type CreateUserResponse_User 

type CreateUserResponse_User struct {
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mechanism *SASLMechanism `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateUserResponse_User) Descriptor deprecated 

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

Deprecated: Use CreateUserResponse_User.ProtoReflect.Descriptor instead.

func (*CreateUserResponse_User) GetMechanism 

func (x *CreateUserResponse_User) GetMechanism() SASLMechanism

func (*CreateUserResponse_User) GetName 

func (x *CreateUserResponse_User) GetName() string

func (*CreateUserResponse_User) ProtoMessage 

func (*CreateUserResponse_User) ProtoMessage()

func (*CreateUserResponse_User) ProtoReflect 

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

func (*CreateUserResponse_User) Reset 

func (x *CreateUserResponse_User) Reset()

func (*CreateUserResponse_User) String 

func (x *CreateUserResponse_User) String() string

type DeleteACLsRequest 

type DeleteACLsRequest struct {
	Filter *DeleteACLsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteACLsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteACLsRequest.ProtoReflect.Descriptor instead.

func (*DeleteACLsRequest) GetFilter 

func (x *DeleteACLsRequest) GetFilter() *DeleteACLsRequest_Filter

func (*DeleteACLsRequest) ProtoMessage 

func (*DeleteACLsRequest) ProtoMessage()

func (*DeleteACLsRequest) ProtoReflect 

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

func (*DeleteACLsRequest) Reset 

func (x *DeleteACLsRequest) Reset()

func (*DeleteACLsRequest) String 

func (x *DeleteACLsRequest) String() string

type DeleteACLsRequest_Filter 

type DeleteACLsRequest_Filter struct {
	ResourceType        ACL_ResourceType        `` /* 152-byte string literal not displayed */
	ResourceName        *string                 `protobuf:"bytes,2,opt,name=resource_name,json=resourceName,proto3,oneof" json:"resource_name,omitempty"`
	ResourcePatternType ACL_ResourcePatternType `` /* 182-byte string literal not displayed */
	Principal           *string                 `protobuf:"bytes,4,opt,name=principal,proto3,oneof" json:"principal,omitempty"`
	Host                *string                 `protobuf:"bytes,5,opt,name=host,proto3,oneof" json:"host,omitempty"`
	Operation           ACL_Operation           `protobuf:"varint,6,opt,name=operation,proto3,enum=redpanda.api.dataplane.v1alpha1.ACL_Operation" json:"operation,omitempty"`
	PermissionType      ACL_PermissionType      `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeleteACLsRequest_Filter) Descriptor deprecated 

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

Deprecated: Use DeleteACLsRequest_Filter.ProtoReflect.Descriptor instead.

func (*DeleteACLsRequest_Filter) GetHost 

func (x *DeleteACLsRequest_Filter) GetHost() string

func (*DeleteACLsRequest_Filter) GetOperation 

func (x *DeleteACLsRequest_Filter) GetOperation() ACL_Operation

func (*DeleteACLsRequest_Filter) GetPermissionType 

func (x *DeleteACLsRequest_Filter) GetPermissionType() ACL_PermissionType

func (*DeleteACLsRequest_Filter) GetPrincipal 

func (x *DeleteACLsRequest_Filter) GetPrincipal() string

func (*DeleteACLsRequest_Filter) GetResourceName 

func (x *DeleteACLsRequest_Filter) GetResourceName() string

func (*DeleteACLsRequest_Filter) GetResourcePatternType 

func (x *DeleteACLsRequest_Filter) GetResourcePatternType() ACL_ResourcePatternType

func (*DeleteACLsRequest_Filter) GetResourceType 

func (x *DeleteACLsRequest_Filter) GetResourceType() ACL_ResourceType

func (*DeleteACLsRequest_Filter) ProtoMessage 

func (*DeleteACLsRequest_Filter) ProtoMessage()

func (*DeleteACLsRequest_Filter) ProtoReflect 

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

func (*DeleteACLsRequest_Filter) Reset 

func (x *DeleteACLsRequest_Filter) Reset()

func (*DeleteACLsRequest_Filter) String 

func (x *DeleteACLsRequest_Filter) String() string

type DeleteACLsResponse 

type DeleteACLsResponse struct {
	MatchingAcls []*DeleteACLsResponse_MatchingACL `protobuf:"bytes,1,rep,name=matching_acls,json=matchingAcls,proto3" json:"matching_acls,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteACLsResponse) Descriptor deprecated 

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

Deprecated: Use DeleteACLsResponse.ProtoReflect.Descriptor instead.

func (*DeleteACLsResponse) GetMatchingAcls 

func (x *DeleteACLsResponse) GetMatchingAcls() []*DeleteACLsResponse_MatchingACL

func (*DeleteACLsResponse) ProtoMessage 

func (*DeleteACLsResponse) ProtoMessage()

func (*DeleteACLsResponse) ProtoReflect 

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

func (*DeleteACLsResponse) Reset 

func (x *DeleteACLsResponse) Reset()

func (*DeleteACLsResponse) String 

func (x *DeleteACLsResponse) String() string

type DeleteACLsResponse_MatchingACL 

type DeleteACLsResponse_MatchingACL struct {
	ResourceType        ACL_ResourceType        `` /* 152-byte string literal not displayed */
	ResourceName        string                  `protobuf:"bytes,2,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	ResourcePatternType ACL_ResourcePatternType `` /* 182-byte string literal not displayed */
	Principal           string                  `protobuf:"bytes,4,opt,name=principal,proto3" json:"principal,omitempty"`
	Host                string                  `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	Operation           ACL_Operation           `protobuf:"varint,6,opt,name=operation,proto3,enum=redpanda.api.dataplane.v1alpha1.ACL_Operation" json:"operation,omitempty"`
	PermissionType      ACL_PermissionType      `` /* 160-byte string literal not displayed */
	Error               *status.Status          `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteACLsResponse_MatchingACL) Descriptor deprecated 

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

Deprecated: Use DeleteACLsResponse_MatchingACL.ProtoReflect.Descriptor instead.

func (*DeleteACLsResponse_MatchingACL) GetError 

func (x *DeleteACLsResponse_MatchingACL) GetError() *status.Status

func (*DeleteACLsResponse_MatchingACL) GetHost 

func (x *DeleteACLsResponse_MatchingACL) GetHost() string

func (*DeleteACLsResponse_MatchingACL) GetOperation 

func (x *DeleteACLsResponse_MatchingACL) GetOperation() ACL_Operation

func (*DeleteACLsResponse_MatchingACL) GetPermissionType 

func (x *DeleteACLsResponse_MatchingACL) GetPermissionType() ACL_PermissionType

func (*DeleteACLsResponse_MatchingACL) GetPrincipal 

func (x *DeleteACLsResponse_MatchingACL) GetPrincipal() string

func (*DeleteACLsResponse_MatchingACL) GetResourceName 

func (x *DeleteACLsResponse_MatchingACL) GetResourceName() string

func (*DeleteACLsResponse_MatchingACL) GetResourcePatternType 

func (x *DeleteACLsResponse_MatchingACL) GetResourcePatternType() ACL_ResourcePatternType

func (*DeleteACLsResponse_MatchingACL) GetResourceType 

func (x *DeleteACLsResponse_MatchingACL) GetResourceType() ACL_ResourceType

func (*DeleteACLsResponse_MatchingACL) ProtoMessage 

func (*DeleteACLsResponse_MatchingACL) ProtoMessage()

func (*DeleteACLsResponse_MatchingACL) ProtoReflect 

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

func (*DeleteACLsResponse_MatchingACL) Reset 

func (x *DeleteACLsResponse_MatchingACL) Reset()

func (*DeleteACLsResponse_MatchingACL) String 

func (x *DeleteACLsResponse_MatchingACL) String() string

type DeleteConnectSecretRequest added in v0.3.0 

type DeleteConnectSecretRequest struct {

	// The unique name of target connect cluster.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// The id of the secret to delete.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

DeleteConnectSecretRequest is the request of DeleteConnectSecret.

func (*DeleteConnectSecretRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use DeleteConnectSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectSecretRequest) GetClusterName added in v0.3.0 

func (x *DeleteConnectSecretRequest) GetClusterName() string

func (*DeleteConnectSecretRequest) GetId added in v0.3.0 

func (x *DeleteConnectSecretRequest) GetId() string

func (*DeleteConnectSecretRequest) ProtoMessage added in v0.3.0 

func (*DeleteConnectSecretRequest) ProtoMessage()

func (*DeleteConnectSecretRequest) ProtoReflect added in v0.3.0 

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

func (*DeleteConnectSecretRequest) Reset added in v0.3.0 

func (x *DeleteConnectSecretRequest) Reset()

func (*DeleteConnectSecretRequest) String added in v0.3.0 

func (x *DeleteConnectSecretRequest) String() string

type DeleteConnectSecretResponse added in v0.3.0 

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

DeleteConnectSecretResponse is the response of DeleteConnectSecret.

func (*DeleteConnectSecretResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use DeleteConnectSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteConnectSecretResponse) ProtoMessage added in v0.3.0 

func (*DeleteConnectSecretResponse) ProtoMessage()

func (*DeleteConnectSecretResponse) ProtoReflect added in v0.3.0 

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

func (*DeleteConnectSecretResponse) Reset added in v0.3.0 

func (x *DeleteConnectSecretResponse) Reset()

func (*DeleteConnectSecretResponse) String added in v0.3.0 

func (x *DeleteConnectSecretResponse) String() string

type DeleteConnectorRequest 

type DeleteConnectorRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConnectorRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetClusterName 

func (x *DeleteConnectorRequest) GetClusterName() string

func (*DeleteConnectorRequest) GetName 

func (x *DeleteConnectorRequest) GetName() string

func (*DeleteConnectorRequest) ProtoMessage 

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect 

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

func (*DeleteConnectorRequest) Reset 

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) String 

func (x *DeleteConnectorRequest) String() string

type DeleteSecretRequest 

type DeleteSecretRequest struct {

	// The id of the secret to delete.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

DeleteSecretRequest is the request of DeleteSecret.

func (*DeleteSecretRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetId 

func (x *DeleteSecretRequest) GetId() string

func (*DeleteSecretRequest) ProtoMessage 

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect 

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

func (*DeleteSecretRequest) Reset 

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String 

func (x *DeleteSecretRequest) String() string

type DeleteSecretResponse 

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

DeleteSecretResponse is the response of DeleteSecret.

func (*DeleteSecretResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteSecretResponse) ProtoMessage 

func (*DeleteSecretResponse) ProtoMessage()

func (*DeleteSecretResponse) ProtoReflect 

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

func (*DeleteSecretResponse) Reset 

func (x *DeleteSecretResponse) Reset()

func (*DeleteSecretResponse) String 

func (x *DeleteSecretResponse) String() string

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetName 

func (x *DeleteTopicRequest) GetName() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect 

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

func (*DeleteTopicRequest) Reset 

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

type DeleteTopicResponse 

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

func (*DeleteTopicResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTopicResponse.ProtoReflect.Descriptor instead.

func (*DeleteTopicResponse) ProtoMessage 

func (*DeleteTopicResponse) ProtoMessage()

func (*DeleteTopicResponse) ProtoReflect 

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

func (*DeleteTopicResponse) Reset 

func (x *DeleteTopicResponse) Reset()

func (*DeleteTopicResponse) String 

func (x *DeleteTopicResponse) String() string

type DeleteTransformRequest added in v0.3.0 

type DeleteTransformRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTransformRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use DeleteTransformRequest.ProtoReflect.Descriptor instead.

func (*DeleteTransformRequest) GetName added in v0.3.0 

func (x *DeleteTransformRequest) GetName() string

func (*DeleteTransformRequest) ProtoMessage added in v0.3.0 

func (*DeleteTransformRequest) ProtoMessage()

func (*DeleteTransformRequest) ProtoReflect added in v0.3.0 

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

func (*DeleteTransformRequest) Reset added in v0.3.0 

func (x *DeleteTransformRequest) Reset()

func (*DeleteTransformRequest) String added in v0.3.0 

func (x *DeleteTransformRequest) String() string

type DeleteTransformResponse added in v0.3.0 

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

func (*DeleteTransformResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use DeleteTransformResponse.ProtoReflect.Descriptor instead.

func (*DeleteTransformResponse) ProtoMessage added in v0.3.0 

func (*DeleteTransformResponse) ProtoMessage()

func (*DeleteTransformResponse) ProtoReflect added in v0.3.0 

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

func (*DeleteTransformResponse) Reset added in v0.3.0 

func (x *DeleteTransformResponse) Reset()

func (*DeleteTransformResponse) String added in v0.3.0 

func (x *DeleteTransformResponse) String() string

type DeleteUserRequest 

type DeleteUserRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteUserRequest) Descriptor deprecated 

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

Deprecated: Use DeleteUserRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserRequest) GetName 

func (x *DeleteUserRequest) GetName() 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) String 

func (x *DeleteUserRequest) String() string

type DeleteUserResponse 

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

func (*DeleteUserResponse) Descriptor deprecated 

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

Deprecated: Use DeleteUserResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserResponse) ProtoMessage 

func (*DeleteUserResponse) ProtoMessage()

func (*DeleteUserResponse) ProtoReflect 

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

func (*DeleteUserResponse) Reset 

func (x *DeleteUserResponse) Reset()

func (*DeleteUserResponse) String 

func (x *DeleteUserResponse) String() string

type DeployTransformRequest added in v0.3.0 

type DeployTransformRequest struct {
	Name                 string                                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InputTopicName       string                                   `protobuf:"bytes,2,opt,name=input_topic_name,json=inputTopicName,proto3" json:"input_topic_name,omitempty"`
	OutputTopicNames     []string                                 `protobuf:"bytes,3,rep,name=output_topic_names,json=outputTopicNames,proto3" json:"output_topic_names,omitempty"`
	EnvironmentVariables []*TransformMetadata_EnvironmentVariable `protobuf:"bytes,4,rep,name=environment_variables,json=environmentVariables,proto3" json:"environment_variables,omitempty"`
	// contains filtered or unexported fields
}

DeployTransformRequest is the metadata that is required to deploy a new WASM transform in a Redpanda cluster.

func (*DeployTransformRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use DeployTransformRequest.ProtoReflect.Descriptor instead.

func (*DeployTransformRequest) GetEnvironmentVariables added in v0.3.0 

func (x *DeployTransformRequest) GetEnvironmentVariables() []*TransformMetadata_EnvironmentVariable

func (*DeployTransformRequest) GetInputTopicName added in v0.3.0 

func (x *DeployTransformRequest) GetInputTopicName() string

func (*DeployTransformRequest) GetName added in v0.3.0 

func (x *DeployTransformRequest) GetName() string

func (*DeployTransformRequest) GetOutputTopicNames added in v0.3.0 

func (x *DeployTransformRequest) GetOutputTopicNames() []string

func (*DeployTransformRequest) ProtoMessage added in v0.3.0 

func (*DeployTransformRequest) ProtoMessage()

func (*DeployTransformRequest) ProtoReflect added in v0.3.0 

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

func (*DeployTransformRequest) Reset added in v0.3.0 

func (x *DeployTransformRequest) Reset()

func (*DeployTransformRequest) String added in v0.3.0 

func (x *DeployTransformRequest) String() string

type DummyMethodResponse 

type DummyMethodResponse struct {
	BadRequest             *errdetails.BadRequest   `protobuf:"bytes,1,opt,name=bad_request,json=badRequest,proto3" json:"bad_request,omitempty"`
	ErrorInfo              *errdetails.ErrorInfo    `protobuf:"bytes,2,opt,name=error_info,json=errorInfo,proto3" json:"error_info,omitempty"`
	QuotaFailure           *errdetails.QuotaFailure `protobuf:"bytes,3,opt,name=quota_failure,json=quotaFailure,proto3" json:"quota_failure,omitempty"`
	Help                   *errdetails.Help         `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`
	DeployTransformRequest *DeployTransformRequest  `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DummyMethodResponse) Descriptor deprecated 

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

Deprecated: Use DummyMethodResponse.ProtoReflect.Descriptor instead.

func (*DummyMethodResponse) GetBadRequest 

func (x *DummyMethodResponse) GetBadRequest() *errdetails.BadRequest

func (*DummyMethodResponse) GetDeployTransformRequest added in v0.3.0 

func (x *DummyMethodResponse) GetDeployTransformRequest() *DeployTransformRequest

func (*DummyMethodResponse) GetErrorInfo 

func (x *DummyMethodResponse) GetErrorInfo() *errdetails.ErrorInfo

func (*DummyMethodResponse) GetHelp 

func (x *DummyMethodResponse) GetHelp() *errdetails.Help

func (*DummyMethodResponse) GetQuotaFailure 

func (x *DummyMethodResponse) GetQuotaFailure() *errdetails.QuotaFailure

func (*DummyMethodResponse) ProtoMessage 

func (*DummyMethodResponse) ProtoMessage()

func (*DummyMethodResponse) ProtoReflect 

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

func (*DummyMethodResponse) Reset 

func (x *DummyMethodResponse) Reset()

func (*DummyMethodResponse) String 

func (x *DummyMethodResponse) String() string

type DummyServiceClient 

type DummyServiceClient interface {
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyMethod(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DummyMethodResponse, error)
}

DummyServiceClient is the client API for DummyService 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 NewDummyServiceClient 

func NewDummyServiceClient(cc grpc.ClientConnInterface) DummyServiceClient

type DummyServiceServer 

type DummyServiceServer interface {
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyMethod(context.Context, *emptypb.Empty) (*DummyMethodResponse, error)
}

DummyServiceServer is the server API for DummyService service. All implementations should embed UnimplementedDummyServiceServer for forward compatibility

type GetConnectClusterRequest 

type GetConnectClusterRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectClusterRequest.ProtoReflect.Descriptor instead.

func (*GetConnectClusterRequest) GetClusterName 

func (x *GetConnectClusterRequest) GetClusterName() string

func (*GetConnectClusterRequest) ProtoMessage 

func (*GetConnectClusterRequest) ProtoMessage()

func (*GetConnectClusterRequest) ProtoReflect 

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

func (*GetConnectClusterRequest) Reset 

func (x *GetConnectClusterRequest) Reset()

func (*GetConnectClusterRequest) String 

func (x *GetConnectClusterRequest) String() string

type GetConnectClusterResponse 

type GetConnectClusterResponse struct {
	Cluster *ConnectCluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectClusterResponse) Descriptor deprecated 

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

Deprecated: Use GetConnectClusterResponse.ProtoReflect.Descriptor instead.

func (*GetConnectClusterResponse) GetCluster 

func (x *GetConnectClusterResponse) GetCluster() *ConnectCluster

func (*GetConnectClusterResponse) ProtoMessage 

func (*GetConnectClusterResponse) ProtoMessage()

func (*GetConnectClusterResponse) ProtoReflect 

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

func (*GetConnectClusterResponse) Reset 

func (x *GetConnectClusterResponse) Reset()

func (*GetConnectClusterResponse) String 

func (x *GetConnectClusterResponse) String() string

type GetConnectSecretRequest added in v0.3.0 

type GetConnectSecretRequest struct {

	// The unique name of target connect cluster.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// The id of the secret to retrieve.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetConnectSecretRequest is the request of GetSecret.

func (*GetConnectSecretRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use GetConnectSecretRequest.ProtoReflect.Descriptor instead.

func (*GetConnectSecretRequest) GetClusterName added in v0.3.0 

func (x *GetConnectSecretRequest) GetClusterName() string

func (*GetConnectSecretRequest) GetId added in v0.3.0 

func (x *GetConnectSecretRequest) GetId() string

func (*GetConnectSecretRequest) ProtoMessage added in v0.3.0 

func (*GetConnectSecretRequest) ProtoMessage()

func (*GetConnectSecretRequest) ProtoReflect added in v0.3.0 

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

func (*GetConnectSecretRequest) Reset added in v0.3.0 

func (x *GetConnectSecretRequest) Reset()

func (*GetConnectSecretRequest) String added in v0.3.0 

func (x *GetConnectSecretRequest) String() string

type GetConnectSecretResponse added in v0.3.0 

type GetConnectSecretResponse struct {

	// The created secret.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

GetConnectSecretResponse is the response of GetConnectSecret.

func (*GetConnectSecretResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use GetConnectSecretResponse.ProtoReflect.Descriptor instead.

func (*GetConnectSecretResponse) GetSecret added in v0.3.0 

func (x *GetConnectSecretResponse) GetSecret() *Secret

func (*GetConnectSecretResponse) ProtoMessage added in v0.3.0 

func (*GetConnectSecretResponse) ProtoMessage()

func (*GetConnectSecretResponse) ProtoReflect added in v0.3.0 

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

func (*GetConnectSecretResponse) Reset added in v0.3.0 

func (x *GetConnectSecretResponse) Reset()

func (*GetConnectSecretResponse) String added in v0.3.0 

func (x *GetConnectSecretResponse) String() string

type GetConnectorConfigRequest 

type GetConnectorConfigRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectorConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorConfigRequest) GetClusterName 

func (x *GetConnectorConfigRequest) GetClusterName() string

func (*GetConnectorConfigRequest) GetName 

func (x *GetConnectorConfigRequest) GetName() string

func (*GetConnectorConfigRequest) ProtoMessage 

func (*GetConnectorConfigRequest) ProtoMessage()

func (*GetConnectorConfigRequest) ProtoReflect 

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

func (*GetConnectorConfigRequest) Reset 

func (x *GetConnectorConfigRequest) Reset()

func (*GetConnectorConfigRequest) String 

func (x *GetConnectorConfigRequest) String() string

type GetConnectorConfigResponse 

type GetConnectorConfigResponse struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetConnectorConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetConnectorConfigResponse.ProtoReflect.Descriptor instead.

func (*GetConnectorConfigResponse) GetConfig 

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

func (*GetConnectorConfigResponse) ProtoMessage 

func (*GetConnectorConfigResponse) ProtoMessage()

func (*GetConnectorConfigResponse) ProtoReflect 

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

func (*GetConnectorConfigResponse) Reset 

func (x *GetConnectorConfigResponse) Reset()

func (*GetConnectorConfigResponse) String 

func (x *GetConnectorConfigResponse) String() string

type GetConnectorRequest 

type GetConnectorRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetClusterName 

func (x *GetConnectorRequest) GetClusterName() string

func (*GetConnectorRequest) GetName 

func (x *GetConnectorRequest) GetName() string

func (*GetConnectorRequest) ProtoMessage 

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect 

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

func (*GetConnectorRequest) Reset 

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) String 

func (x *GetConnectorRequest) String() string

type GetConnectorResponse 

type GetConnectorResponse struct {
	Connector *ConnectorSpec `protobuf:"bytes,1,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorResponse) Descriptor deprecated 

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

Deprecated: Use GetConnectorResponse.ProtoReflect.Descriptor instead.

func (*GetConnectorResponse) GetConnector 

func (x *GetConnectorResponse) GetConnector() *ConnectorSpec

func (*GetConnectorResponse) ProtoMessage 

func (*GetConnectorResponse) ProtoMessage()

func (*GetConnectorResponse) ProtoReflect 

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

func (*GetConnectorResponse) Reset 

func (x *GetConnectorResponse) Reset()

func (*GetConnectorResponse) String 

func (x *GetConnectorResponse) String() string

type GetConnectorStatusRequest 

type GetConnectorStatusRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectorStatusRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorStatusRequest) GetClusterName 

func (x *GetConnectorStatusRequest) GetClusterName() string

func (*GetConnectorStatusRequest) GetName 

func (x *GetConnectorStatusRequest) GetName() string

func (*GetConnectorStatusRequest) ProtoMessage 

func (*GetConnectorStatusRequest) ProtoMessage()

func (*GetConnectorStatusRequest) ProtoReflect 

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

func (*GetConnectorStatusRequest) Reset 

func (x *GetConnectorStatusRequest) Reset()

func (*GetConnectorStatusRequest) String 

func (x *GetConnectorStatusRequest) String() string

type GetConnectorStatusResponse 

type GetConnectorStatusResponse struct {
	Status *ConnectorStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetConnectorStatusResponse.ProtoReflect.Descriptor instead.

func (*GetConnectorStatusResponse) GetStatus 

func (x *GetConnectorStatusResponse) GetStatus() *ConnectorStatus

func (*GetConnectorStatusResponse) ProtoMessage 

func (*GetConnectorStatusResponse) ProtoMessage()

func (*GetConnectorStatusResponse) ProtoReflect 

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

func (*GetConnectorStatusResponse) Reset 

func (x *GetConnectorStatusResponse) Reset()

func (*GetConnectorStatusResponse) String 

func (x *GetConnectorStatusResponse) String() string

type GetSecretRequest added in v0.3.0 

type GetSecretRequest struct {

	// The id of the secret to retrieve.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetSecretRequest is the request of GetSecret.

func (*GetSecretRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetId added in v0.3.0 

func (x *GetSecretRequest) GetId() string

func (*GetSecretRequest) ProtoMessage added in v0.3.0 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect added in v0.3.0 

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

func (*GetSecretRequest) Reset added in v0.3.0 

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String added in v0.3.0 

func (x *GetSecretRequest) String() string

type GetSecretResponse added in v0.3.0 

type GetSecretResponse struct {

	// The created secret.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

GetSecretResponse is the response of GetSecret.

func (*GetSecretResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetSecret added in v0.3.0 

func (x *GetSecretResponse) GetSecret() *Secret

func (*GetSecretResponse) ProtoMessage added in v0.3.0 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect added in v0.3.0 

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

func (*GetSecretResponse) Reset added in v0.3.0 

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String added in v0.3.0 

func (x *GetSecretResponse) String() string

type GetTopicConfigurationsRequest 

type GetTopicConfigurationsRequest struct {
	TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopicConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*GetTopicConfigurationsRequest) GetTopicName 

func (x *GetTopicConfigurationsRequest) GetTopicName() string

func (*GetTopicConfigurationsRequest) ProtoMessage 

func (*GetTopicConfigurationsRequest) ProtoMessage()

func (*GetTopicConfigurationsRequest) ProtoReflect 

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

func (*GetTopicConfigurationsRequest) Reset 

func (x *GetTopicConfigurationsRequest) Reset()

func (*GetTopicConfigurationsRequest) String 

func (x *GetTopicConfigurationsRequest) String() string

type GetTopicConfigurationsResponse 

type GetTopicConfigurationsResponse struct {
	Configurations []*Topic_Configuration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopicConfigurationsResponse) Descriptor deprecated 

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

Deprecated: Use GetTopicConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*GetTopicConfigurationsResponse) GetConfigurations 

func (x *GetTopicConfigurationsResponse) GetConfigurations() []*Topic_Configuration

func (*GetTopicConfigurationsResponse) ProtoMessage 

func (*GetTopicConfigurationsResponse) ProtoMessage()

func (*GetTopicConfigurationsResponse) ProtoReflect 

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

func (*GetTopicConfigurationsResponse) Reset 

func (x *GetTopicConfigurationsResponse) Reset()

func (*GetTopicConfigurationsResponse) String 

func (x *GetTopicConfigurationsResponse) String() string

type GetTransformRequest added in v0.3.0 

type GetTransformRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransformRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use GetTransformRequest.ProtoReflect.Descriptor instead.

func (*GetTransformRequest) GetName added in v0.3.0 

func (x *GetTransformRequest) GetName() string

func (*GetTransformRequest) ProtoMessage added in v0.3.0 

func (*GetTransformRequest) ProtoMessage()

func (*GetTransformRequest) ProtoReflect added in v0.3.0 

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

func (*GetTransformRequest) Reset added in v0.3.0 

func (x *GetTransformRequest) Reset()

func (*GetTransformRequest) String added in v0.3.0 

func (x *GetTransformRequest) String() string

type GetTransformResponse added in v0.3.0 

type GetTransformResponse struct {
	Transform *TransformMetadata `protobuf:"bytes,1,opt,name=transform,proto3" json:"transform,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransformResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use GetTransformResponse.ProtoReflect.Descriptor instead.

func (*GetTransformResponse) GetTransform added in v0.3.0 

func (x *GetTransformResponse) GetTransform() *TransformMetadata

func (*GetTransformResponse) ProtoMessage added in v0.3.0 

func (*GetTransformResponse) ProtoMessage()

func (*GetTransformResponse) ProtoReflect added in v0.3.0 

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

func (*GetTransformResponse) Reset added in v0.3.0 

func (x *GetTransformResponse) Reset()

func (*GetTransformResponse) String added in v0.3.0 

func (x *GetTransformResponse) String() string

type KafkaConnectServiceClient 

type KafkaConnectServiceClient interface {
	// ListConnectClusters implements the list clusters method, list connect
	// clusters available in the console configuration
	ListConnectClusters(ctx context.Context, in *ListConnectClustersRequest, opts ...grpc.CallOption) (*ListConnectClustersResponse, error)
	// GetConnectCluster implements the get cluster info method, exposes a Kafka
	// Connect equivalent REST endpoint
	GetConnectCluster(ctx context.Context, in *GetConnectClusterRequest, opts ...grpc.CallOption) (*GetConnectClusterResponse, error)
	// ListConnectors implements the list connectors method, exposes a Kafka
	// Connect equivalent REST endpoint
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	// CreateConnector implements the create connector method, and exposes an
	// equivalent REST endpoint as the Kafka connect API endpoint
	CreateConnector(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*CreateConnectorResponse, error)
	// RestartConnector implements the restart connector method, exposes a Kafka
	// Connect equivalent REST endpoint
	RestartConnector(ctx context.Context, in *RestartConnectorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetConnector implements the get connector method, exposes a Kafka
	// Connect equivalent REST endpoint
	GetConnector(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*GetConnectorResponse, error)
	// GetConnectorStatus implement the get status method, Gets the current status of the connector, including:
	// Whether it is running or restarting, or if it has failed or paused
	// Which worker it is assigned to
	// Error information if it has failed
	// The state of all its tasks
	GetConnectorStatus(ctx context.Context, in *GetConnectorStatusRequest, opts ...grpc.CallOption) (*GetConnectorStatusResponse, error)
	// PauseConnector implements the pause connector method, exposes a Kafka
	// connect equivalent REST endpoint
	PauseConnector(ctx context.Context, in *PauseConnectorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ResumeConnector implements the resume connector method, exposes a Kafka
	// connect equivalent REST endpoint
	ResumeConnector(ctx context.Context, in *ResumeConnectorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// StopConnector implements the stop connector method, exposes a Kafka
	// connect equivalent REST endpoint it stops the connector but does not
	// delete the connector. All tasks for the connector are shut down completely
	StopConnector(ctx context.Context, in *StopConnectorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteConnector implements the delete connector method, exposes a Kafka
	// connect equivalent REST endpoint
	DeleteConnector(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// UpsertConector implements the update or create connector method, it
	// exposes a kafka connect equivalent REST endpoint
	UpsertConnector(ctx context.Context, in *UpsertConnectorRequest, opts ...grpc.CallOption) (*UpsertConnectorResponse, error)
	// GetConnectorConfig implements the get connector configuration method, expose a kafka connect equivalent REST endpoint
	GetConnectorConfig(ctx context.Context, in *GetConnectorConfigRequest, opts ...grpc.CallOption) (*GetConnectorConfigResponse, error)
	// ListConnectorTopics implements the list connector topics method, expose a kafka connect equivalent REST endpoint
	ListConnectorTopics(ctx context.Context, in *ListConnectorTopicsRequest, opts ...grpc.CallOption) (*ListConnectorTopicsResponse, error)
	// ResetConnectorTopics implements the reset connector topics method, expose a kafka connect equivalent REST endpoint
	// the request body is empty.
	ResetConnectorTopics(ctx context.Context, in *ResetConnectorTopicsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

KafkaConnectServiceClient is the client API for KafkaConnectService 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 NewKafkaConnectServiceClient 

func NewKafkaConnectServiceClient(cc grpc.ClientConnInterface) KafkaConnectServiceClient

type KafkaConnectServiceServer 

type KafkaConnectServiceServer interface {
	// ListConnectClusters implements the list clusters method, list connect
	// clusters available in the console configuration
	ListConnectClusters(context.Context, *ListConnectClustersRequest) (*ListConnectClustersResponse, error)
	// GetConnectCluster implements the get cluster info method, exposes a Kafka
	// Connect equivalent REST endpoint
	GetConnectCluster(context.Context, *GetConnectClusterRequest) (*GetConnectClusterResponse, error)
	// ListConnectors implements the list connectors method, exposes a Kafka
	// Connect equivalent REST endpoint
	ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	// CreateConnector implements the create connector method, and exposes an
	// equivalent REST endpoint as the Kafka connect API endpoint
	CreateConnector(context.Context, *CreateConnectorRequest) (*CreateConnectorResponse, error)
	// RestartConnector implements the restart connector method, exposes a Kafka
	// Connect equivalent REST endpoint
	RestartConnector(context.Context, *RestartConnectorRequest) (*emptypb.Empty, error)
	// GetConnector implements the get connector method, exposes a Kafka
	// Connect equivalent REST endpoint
	GetConnector(context.Context, *GetConnectorRequest) (*GetConnectorResponse, error)
	// GetConnectorStatus implement the get status method, Gets the current status of the connector, including:
	// Whether it is running or restarting, or if it has failed or paused
	// Which worker it is assigned to
	// Error information if it has failed
	// The state of all its tasks
	GetConnectorStatus(context.Context, *GetConnectorStatusRequest) (*GetConnectorStatusResponse, error)
	// PauseConnector implements the pause connector method, exposes a Kafka
	// connect equivalent REST endpoint
	PauseConnector(context.Context, *PauseConnectorRequest) (*emptypb.Empty, error)
	// ResumeConnector implements the resume connector method, exposes a Kafka
	// connect equivalent REST endpoint
	ResumeConnector(context.Context, *ResumeConnectorRequest) (*emptypb.Empty, error)
	// StopConnector implements the stop connector method, exposes a Kafka
	// connect equivalent REST endpoint it stops the connector but does not
	// delete the connector. All tasks for the connector are shut down completely
	StopConnector(context.Context, *StopConnectorRequest) (*emptypb.Empty, error)
	// DeleteConnector implements the delete connector method, exposes a Kafka
	// connect equivalent REST endpoint
	DeleteConnector(context.Context, *DeleteConnectorRequest) (*emptypb.Empty, error)
	// UpsertConector implements the update or create connector method, it
	// exposes a kafka connect equivalent REST endpoint
	UpsertConnector(context.Context, *UpsertConnectorRequest) (*UpsertConnectorResponse, error)
	// GetConnectorConfig implements the get connector configuration method, expose a kafka connect equivalent REST endpoint
	GetConnectorConfig(context.Context, *GetConnectorConfigRequest) (*GetConnectorConfigResponse, error)
	// ListConnectorTopics implements the list connector topics method, expose a kafka connect equivalent REST endpoint
	ListConnectorTopics(context.Context, *ListConnectorTopicsRequest) (*ListConnectorTopicsResponse, error)
	// ResetConnectorTopics implements the reset connector topics method, expose a kafka connect equivalent REST endpoint
	// the request body is empty.
	ResetConnectorTopics(context.Context, *ResetConnectorTopicsRequest) (*emptypb.Empty, error)
}

KafkaConnectServiceServer is the server API for KafkaConnectService service. All implementations should embed UnimplementedKafkaConnectServiceServer for forward compatibility

type ListACLsRequest 

type ListACLsRequest struct {
	Filter   *ListACLsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize int32                   `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Value of the next_page_token field returned by the previous response.
	// If not provided, the system assumes the first page is requested.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListACLsRequest) Descriptor deprecated 

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

Deprecated: Use ListACLsRequest.ProtoReflect.Descriptor instead.

func (*ListACLsRequest) GetFilter 

func (x *ListACLsRequest) GetFilter() *ListACLsRequest_Filter

func (*ListACLsRequest) GetPageSize 

func (x *ListACLsRequest) GetPageSize() int32

func (*ListACLsRequest) GetPageToken 

func (x *ListACLsRequest) GetPageToken() string

func (*ListACLsRequest) ProtoMessage 

func (*ListACLsRequest) ProtoMessage()

func (*ListACLsRequest) ProtoReflect 

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

func (*ListACLsRequest) Reset 

func (x *ListACLsRequest) Reset()

func (*ListACLsRequest) String 

func (x *ListACLsRequest) String() string

type ListACLsRequest_Filter 

type ListACLsRequest_Filter struct {
	ResourceType        ACL_ResourceType        `` /* 152-byte string literal not displayed */
	ResourceName        *string                 `protobuf:"bytes,2,opt,name=resource_name,json=resourceName,proto3,oneof" json:"resource_name,omitempty"`
	ResourcePatternType ACL_ResourcePatternType `` /* 182-byte string literal not displayed */
	Principal           *string                 `protobuf:"bytes,4,opt,name=principal,proto3,oneof" json:"principal,omitempty"`
	Host                *string                 `protobuf:"bytes,5,opt,name=host,proto3,oneof" json:"host,omitempty"`
	Operation           ACL_Operation           `protobuf:"varint,6,opt,name=operation,proto3,enum=redpanda.api.dataplane.v1alpha1.ACL_Operation" json:"operation,omitempty"`
	PermissionType      ACL_PermissionType      `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListACLsRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListACLsRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListACLsRequest_Filter) GetHost 

func (x *ListACLsRequest_Filter) GetHost() string

func (*ListACLsRequest_Filter) GetOperation 

func (x *ListACLsRequest_Filter) GetOperation() ACL_Operation

func (*ListACLsRequest_Filter) GetPermissionType 

func (x *ListACLsRequest_Filter) GetPermissionType() ACL_PermissionType

func (*ListACLsRequest_Filter) GetPrincipal 

func (x *ListACLsRequest_Filter) GetPrincipal() string

func (*ListACLsRequest_Filter) GetResourceName 

func (x *ListACLsRequest_Filter) GetResourceName() string

func (*ListACLsRequest_Filter) GetResourcePatternType 

func (x *ListACLsRequest_Filter) GetResourcePatternType() ACL_ResourcePatternType

func (*ListACLsRequest_Filter) GetResourceType 

func (x *ListACLsRequest_Filter) GetResourceType() ACL_ResourceType

func (*ListACLsRequest_Filter) ProtoMessage 

func (*ListACLsRequest_Filter) ProtoMessage()

func (*ListACLsRequest_Filter) ProtoReflect 

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

func (*ListACLsRequest_Filter) Reset 

func (x *ListACLsRequest_Filter) Reset()

func (*ListACLsRequest_Filter) String 

func (x *ListACLsRequest_Filter) String() string

type ListACLsResponse 

type ListACLsResponse struct {
	Resources []*ListACLsResponse_Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ListACLsResponse) Descriptor deprecated 

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

Deprecated: Use ListACLsResponse.ProtoReflect.Descriptor instead.

func (*ListACLsResponse) GetResources 

func (x *ListACLsResponse) GetResources() []*ListACLsResponse_Resource

func (*ListACLsResponse) ProtoMessage 

func (*ListACLsResponse) ProtoMessage()

func (*ListACLsResponse) ProtoReflect 

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

func (*ListACLsResponse) Reset 

func (x *ListACLsResponse) Reset()

func (*ListACLsResponse) String 

func (x *ListACLsResponse) String() string

type ListACLsResponse_Policy 

type ListACLsResponse_Policy struct {
	Principal      string             `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Host           string             `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Operation      ACL_Operation      `protobuf:"varint,3,opt,name=operation,proto3,enum=redpanda.api.dataplane.v1alpha1.ACL_Operation" json:"operation,omitempty"`
	PermissionType ACL_PermissionType `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListACLsResponse_Policy) Descriptor deprecated 

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

Deprecated: Use ListACLsResponse_Policy.ProtoReflect.Descriptor instead.

func (*ListACLsResponse_Policy) GetHost 

func (x *ListACLsResponse_Policy) GetHost() string

func (*ListACLsResponse_Policy) GetOperation 

func (x *ListACLsResponse_Policy) GetOperation() ACL_Operation

func (*ListACLsResponse_Policy) GetPermissionType 

func (x *ListACLsResponse_Policy) GetPermissionType() ACL_PermissionType

func (*ListACLsResponse_Policy) GetPrincipal 

func (x *ListACLsResponse_Policy) GetPrincipal() string

func (*ListACLsResponse_Policy) ProtoMessage 

func (*ListACLsResponse_Policy) ProtoMessage()

func (*ListACLsResponse_Policy) ProtoReflect 

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

func (*ListACLsResponse_Policy) Reset 

func (x *ListACLsResponse_Policy) Reset()

func (*ListACLsResponse_Policy) String 

func (x *ListACLsResponse_Policy) String() string

type ListACLsResponse_Resource 

type ListACLsResponse_Resource struct {
	ResourceType        ACL_ResourceType           `` /* 152-byte string literal not displayed */
	ResourceName        string                     `protobuf:"bytes,2,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	ResourcePatternType ACL_ResourcePatternType    `` /* 182-byte string literal not displayed */
	Acls                []*ListACLsResponse_Policy `protobuf:"bytes,4,rep,name=acls,proto3" json:"acls,omitempty"`
	// contains filtered or unexported fields
}

func (*ListACLsResponse_Resource) Descriptor deprecated 

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

Deprecated: Use ListACLsResponse_Resource.ProtoReflect.Descriptor instead.

func (*ListACLsResponse_Resource) GetAcls 

func (x *ListACLsResponse_Resource) GetAcls() []*ListACLsResponse_Policy

func (*ListACLsResponse_Resource) GetResourceName 

func (x *ListACLsResponse_Resource) GetResourceName() string

func (*ListACLsResponse_Resource) GetResourcePatternType 

func (x *ListACLsResponse_Resource) GetResourcePatternType() ACL_ResourcePatternType

func (*ListACLsResponse_Resource) GetResourceType 

func (x *ListACLsResponse_Resource) GetResourceType() ACL_ResourceType

func (*ListACLsResponse_Resource) ProtoMessage 

func (*ListACLsResponse_Resource) ProtoMessage()

func (*ListACLsResponse_Resource) ProtoReflect 

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

func (*ListACLsResponse_Resource) Reset 

func (x *ListACLsResponse_Resource) Reset()

func (*ListACLsResponse_Resource) String 

func (x *ListACLsResponse_Resource) String() string

type ListConnectClustersRequest 

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

func (*ListConnectClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectClustersRequest.ProtoReflect.Descriptor instead.

func (*ListConnectClustersRequest) ProtoMessage 

func (*ListConnectClustersRequest) ProtoMessage()

func (*ListConnectClustersRequest) ProtoReflect 

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

func (*ListConnectClustersRequest) Reset 

func (x *ListConnectClustersRequest) Reset()

func (*ListConnectClustersRequest) String 

func (x *ListConnectClustersRequest) String() string

type ListConnectClustersResponse 

type ListConnectClustersResponse struct {
	Clusters []*ConnectCluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectClustersResponse.ProtoReflect.Descriptor instead.

func (*ListConnectClustersResponse) GetClusters 

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

func (*ListConnectClustersResponse) ProtoMessage 

func (*ListConnectClustersResponse) ProtoMessage()

func (*ListConnectClustersResponse) ProtoReflect 

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

func (*ListConnectClustersResponse) Reset 

func (x *ListConnectClustersResponse) Reset()

func (*ListConnectClustersResponse) String 

func (x *ListConnectClustersResponse) String() string

type ListConnectSecretsRequest added in v0.3.0 

type ListConnectSecretsRequest struct {

	// The unique name of target connect cluster.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// List filter.
	Filter *ListSecretsFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// Value of the next_page_token field returned by the previous response.
	// If not provided, the system assumes the first page is requested.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Limit the paginated response to a number of items.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

ListConnectSecretRequest is the request of ListConnectSecrets.

func (*ListConnectSecretsRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ListConnectSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectSecretsRequest) GetClusterName added in v0.3.0 

func (x *ListConnectSecretsRequest) GetClusterName() string

func (*ListConnectSecretsRequest) GetFilter added in v0.3.0 

func (x *ListConnectSecretsRequest) GetFilter() *ListSecretsFilter

func (*ListConnectSecretsRequest) GetPageSize added in v0.3.0 

func (x *ListConnectSecretsRequest) GetPageSize() int32

func (*ListConnectSecretsRequest) GetPageToken added in v0.3.0 

func (x *ListConnectSecretsRequest) GetPageToken() string

func (*ListConnectSecretsRequest) ProtoMessage added in v0.3.0 

func (*ListConnectSecretsRequest) ProtoMessage()

func (*ListConnectSecretsRequest) ProtoReflect added in v0.3.0 

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

func (*ListConnectSecretsRequest) Reset added in v0.3.0 

func (x *ListConnectSecretsRequest) Reset()

func (*ListConnectSecretsRequest) String added in v0.3.0 

func (x *ListConnectSecretsRequest) String() string

type ListConnectSecretsResponse added in v0.3.0 

type ListConnectSecretsResponse struct {

	// Secrets retrieved.
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// Token to retrieve the next page.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListConnectSecretsResponse is the response of ListConnectSecrets.

func (*ListConnectSecretsResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ListConnectSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectSecretsResponse) GetNextPageToken added in v0.3.0 

func (x *ListConnectSecretsResponse) GetNextPageToken() string

func (*ListConnectSecretsResponse) GetSecrets added in v0.3.0 

func (x *ListConnectSecretsResponse) GetSecrets() []*Secret

func (*ListConnectSecretsResponse) ProtoMessage added in v0.3.0 

func (*ListConnectSecretsResponse) ProtoMessage()

func (*ListConnectSecretsResponse) ProtoReflect added in v0.3.0 

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

func (*ListConnectSecretsResponse) Reset added in v0.3.0 

func (x *ListConnectSecretsResponse) Reset()

func (*ListConnectSecretsResponse) String added in v0.3.0 

func (x *ListConnectSecretsResponse) String() string

type ListConnectorTopicsRequest 

type ListConnectorTopicsRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectorTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorTopicsRequest) GetClusterName 

func (x *ListConnectorTopicsRequest) GetClusterName() string

func (*ListConnectorTopicsRequest) GetName 

func (x *ListConnectorTopicsRequest) GetName() string

func (*ListConnectorTopicsRequest) ProtoMessage 

func (*ListConnectorTopicsRequest) ProtoMessage()

func (*ListConnectorTopicsRequest) ProtoReflect 

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

func (*ListConnectorTopicsRequest) Reset 

func (x *ListConnectorTopicsRequest) Reset()

func (*ListConnectorTopicsRequest) String 

func (x *ListConnectorTopicsRequest) String() string

type ListConnectorTopicsResponse 

type ListConnectorTopicsResponse struct {
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectorTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorTopicsResponse) GetTopics 

func (x *ListConnectorTopicsResponse) GetTopics() []string

func (*ListConnectorTopicsResponse) ProtoMessage 

func (*ListConnectorTopicsResponse) ProtoMessage()

func (*ListConnectorTopicsResponse) ProtoReflect 

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

func (*ListConnectorTopicsResponse) Reset 

func (x *ListConnectorTopicsResponse) Reset()

func (*ListConnectorTopicsResponse) String 

func (x *ListConnectorTopicsResponse) String() string

type ListConnectorsRequest 

type ListConnectorsRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// Value of the next_page_token field returned by the previous response. If not provided, the system assumes the first page is requested.
	PageToken string `protobuf:"bytes,2,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) GetClusterName 

func (x *ListConnectorsRequest) GetClusterName() string

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

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse 

type ListConnectorsResponse struct {

	// connectors is the list of connectors the key is the connector name
	Connectors    []*ListConnectorsResponse_ConnectorInfoStatus `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	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() []*ListConnectorsResponse_ConnectorInfoStatus

func (*ListConnectorsResponse) GetNextPageToken 

func (x *ListConnectorsResponse) GetNextPageToken() string

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

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

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type ListConnectorsResponse_ConnectorInfoStatus 

type ListConnectorsResponse_ConnectorInfoStatus struct {

	// name is the connector name
	Name   string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Info   *ConnectorSpec   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Status *ConnectorStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorsResponse_ConnectorInfoStatus) Descriptor deprecated 

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

Deprecated: Use ListConnectorsResponse_ConnectorInfoStatus.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse_ConnectorInfoStatus) GetInfo 

func (x *ListConnectorsResponse_ConnectorInfoStatus) GetInfo() *ConnectorSpec

func (*ListConnectorsResponse_ConnectorInfoStatus) GetName 

func (x *ListConnectorsResponse_ConnectorInfoStatus) GetName() string

func (*ListConnectorsResponse_ConnectorInfoStatus) GetStatus 

func (x *ListConnectorsResponse_ConnectorInfoStatus) GetStatus() *ConnectorStatus

func (*ListConnectorsResponse_ConnectorInfoStatus) ProtoMessage 

func (*ListConnectorsResponse_ConnectorInfoStatus) ProtoMessage()

func (*ListConnectorsResponse_ConnectorInfoStatus) ProtoReflect 

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

func (*ListConnectorsResponse_ConnectorInfoStatus) Reset 

func (x *ListConnectorsResponse_ConnectorInfoStatus) Reset()

func (*ListConnectorsResponse_ConnectorInfoStatus) String 

func (x *ListConnectorsResponse_ConnectorInfoStatus) String() string

type ListSecretsFilter added in v0.3.0 

type ListSecretsFilter struct {

	// The secret ID or name to search for.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The secret labels to search for.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

ListSecretsFilter are the filter options for listing secrets.

func (*ListSecretsFilter) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ListSecretsFilter.ProtoReflect.Descriptor instead.

func (*ListSecretsFilter) GetLabels added in v0.3.0 

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

func (*ListSecretsFilter) GetName added in v0.3.0 

func (x *ListSecretsFilter) GetName() string

func (*ListSecretsFilter) ProtoMessage added in v0.3.0 

func (*ListSecretsFilter) ProtoMessage()

func (*ListSecretsFilter) ProtoReflect added in v0.3.0 

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

func (*ListSecretsFilter) Reset added in v0.3.0 

func (x *ListSecretsFilter) Reset()

func (*ListSecretsFilter) String added in v0.3.0 

func (x *ListSecretsFilter) String() string

type ListSecretsRequest 

type ListSecretsRequest struct {

	// List filter.
	Filter *ListSecretsFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// Value of the next_page_token field returned by the previous response.
	// If not provided, the system assumes the first page is requested.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Limit the paginated response to a number of items.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

ListSecretsRequest is the request of ListSecrets.

func (*ListSecretsRequest) Descriptor deprecated 

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

Deprecated: Use ListSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListSecretsRequest) GetFilter 

func (x *ListSecretsRequest) GetFilter() *ListSecretsFilter

func (*ListSecretsRequest) GetPageSize 

func (x *ListSecretsRequest) GetPageSize() int32

func (*ListSecretsRequest) GetPageToken 

func (x *ListSecretsRequest) GetPageToken() string

func (*ListSecretsRequest) ProtoMessage 

func (*ListSecretsRequest) ProtoMessage()

func (*ListSecretsRequest) ProtoReflect 

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

func (*ListSecretsRequest) Reset 

func (x *ListSecretsRequest) Reset()

func (*ListSecretsRequest) String 

func (x *ListSecretsRequest) String() string

type ListSecretsResponse 

type ListSecretsResponse struct {

	// Secrets retrieved.
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// Token to retrieve the next page.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListSecretsResponse is the response of ListSecrets.

func (*ListSecretsResponse) Descriptor deprecated 

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

Deprecated: Use ListSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListSecretsResponse) GetNextPageToken 

func (x *ListSecretsResponse) GetNextPageToken() string

func (*ListSecretsResponse) GetSecrets 

func (x *ListSecretsResponse) GetSecrets() []*Secret

func (*ListSecretsResponse) ProtoMessage 

func (*ListSecretsResponse) ProtoMessage()

func (*ListSecretsResponse) ProtoReflect 

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

func (*ListSecretsResponse) Reset 

func (x *ListSecretsResponse) Reset()

func (*ListSecretsResponse) String 

func (x *ListSecretsResponse) String() string

type ListTopicsRequest 

type ListTopicsRequest struct {
	Filter   *ListTopicsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize int32                     `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Value of the next_page_token field returned by the previous response. If not provided, the system assumes the first page is requested.
	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) GetFilter 

func (x *ListTopicsRequest) GetFilter() *ListTopicsRequest_Filter

func (*ListTopicsRequest) GetPageSize 

func (x *ListTopicsRequest) GetPageSize() int32

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

func (x *ListTopicsRequest) String() string

type ListTopicsRequest_Filter 

type ListTopicsRequest_Filter struct {
	NameContains string `protobuf:"bytes,1,opt,name=name_contains,json=nameContains,proto3" json:"name_contains,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTopicsRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest_Filter) GetNameContains 

func (x *ListTopicsRequest_Filter) GetNameContains() string

func (*ListTopicsRequest_Filter) ProtoMessage 

func (*ListTopicsRequest_Filter) ProtoMessage()

func (*ListTopicsRequest_Filter) ProtoReflect 

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

func (*ListTopicsRequest_Filter) Reset 

func (x *ListTopicsRequest_Filter) Reset()

func (*ListTopicsRequest_Filter) String 

func (x *ListTopicsRequest_Filter) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {
	Topics        []*ListTopicsResponse_Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	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() []*ListTopicsResponse_Topic

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

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

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type ListTopicsResponse_Topic 

type ListTopicsResponse_Topic struct {
	Name              string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Internal          bool   `protobuf:"varint,2,opt,name=internal,proto3" json:"internal,omitempty"`
	PartitionCount    int32  `protobuf:"varint,3,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	ReplicationFactor int32  `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTopicsResponse_Topic) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse_Topic.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse_Topic) GetInternal added in v0.3.0 

func (x *ListTopicsResponse_Topic) GetInternal() bool

func (*ListTopicsResponse_Topic) GetName 

func (x *ListTopicsResponse_Topic) GetName() string

func (*ListTopicsResponse_Topic) GetPartitionCount 

func (x *ListTopicsResponse_Topic) GetPartitionCount() int32

func (*ListTopicsResponse_Topic) GetReplicationFactor 

func (x *ListTopicsResponse_Topic) GetReplicationFactor() int32

func (*ListTopicsResponse_Topic) ProtoMessage 

func (*ListTopicsResponse_Topic) ProtoMessage()

func (*ListTopicsResponse_Topic) ProtoReflect 

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

func (*ListTopicsResponse_Topic) Reset 

func (x *ListTopicsResponse_Topic) Reset()

func (*ListTopicsResponse_Topic) String 

func (x *ListTopicsResponse_Topic) String() string

type ListTransformsRequest added in v0.3.0 

type ListTransformsRequest struct {
	Filter    *ListTransformsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	PageToken string                        `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTransformsRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ListTransformsRequest.ProtoReflect.Descriptor instead.

func (*ListTransformsRequest) GetFilter added in v0.3.0 

func (x *ListTransformsRequest) GetFilter() *ListTransformsRequest_Filter

func (*ListTransformsRequest) GetPageToken added in v0.3.0 

func (x *ListTransformsRequest) GetPageToken() string

func (*ListTransformsRequest) ProtoMessage added in v0.3.0 

func (*ListTransformsRequest) ProtoMessage()

func (*ListTransformsRequest) ProtoReflect added in v0.3.0 

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

func (*ListTransformsRequest) Reset added in v0.3.0 

func (x *ListTransformsRequest) Reset()

func (*ListTransformsRequest) String added in v0.3.0 

func (x *ListTransformsRequest) String() string

type ListTransformsRequest_Filter added in v0.3.0 

type ListTransformsRequest_Filter struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTransformsRequest_Filter) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ListTransformsRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListTransformsRequest_Filter) GetName added in v0.3.0 

func (x *ListTransformsRequest_Filter) GetName() string

func (*ListTransformsRequest_Filter) ProtoMessage added in v0.3.0 

func (*ListTransformsRequest_Filter) ProtoMessage()

func (*ListTransformsRequest_Filter) ProtoReflect added in v0.3.0 

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

func (*ListTransformsRequest_Filter) Reset added in v0.3.0 

func (x *ListTransformsRequest_Filter) Reset()

func (*ListTransformsRequest_Filter) String added in v0.3.0 

func (x *ListTransformsRequest_Filter) String() string

type ListTransformsResponse added in v0.3.0 

type ListTransformsResponse struct {
	NextPageToken string               `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Transforms    []*TransformMetadata `protobuf:"bytes,2,rep,name=transforms,proto3" json:"transforms,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTransformsResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ListTransformsResponse.ProtoReflect.Descriptor instead.

func (*ListTransformsResponse) GetNextPageToken added in v0.3.0 

func (x *ListTransformsResponse) GetNextPageToken() string

func (*ListTransformsResponse) GetTransforms added in v0.3.0 

func (x *ListTransformsResponse) GetTransforms() []*TransformMetadata

func (*ListTransformsResponse) ProtoMessage added in v0.3.0 

func (*ListTransformsResponse) ProtoMessage()

func (*ListTransformsResponse) ProtoReflect added in v0.3.0 

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

func (*ListTransformsResponse) Reset added in v0.3.0 

func (x *ListTransformsResponse) Reset()

func (*ListTransformsResponse) String added in v0.3.0 

func (x *ListTransformsResponse) String() string

type ListUsersRequest 

type ListUsersRequest struct {
	Filter *ListUsersRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUsersRequest) Descriptor deprecated 

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

Deprecated: Use ListUsersRequest.ProtoReflect.Descriptor instead.

func (*ListUsersRequest) GetFilter 

func (x *ListUsersRequest) GetFilter() *ListUsersRequest_Filter

func (*ListUsersRequest) ProtoMessage 

func (*ListUsersRequest) ProtoMessage()

func (*ListUsersRequest) ProtoReflect 

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

func (*ListUsersRequest) Reset 

func (x *ListUsersRequest) Reset()

func (*ListUsersRequest) String 

func (x *ListUsersRequest) String() string

type ListUsersRequest_Filter 

type ListUsersRequest_Filter struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NameContains string `protobuf:"bytes,2,opt,name=name_contains,json=nameContains,proto3" json:"name_contains,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUsersRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListUsersRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListUsersRequest_Filter) GetName 

func (x *ListUsersRequest_Filter) GetName() string

func (*ListUsersRequest_Filter) GetNameContains 

func (x *ListUsersRequest_Filter) GetNameContains() string

func (*ListUsersRequest_Filter) ProtoMessage 

func (*ListUsersRequest_Filter) ProtoMessage()

func (*ListUsersRequest_Filter) ProtoReflect 

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

func (*ListUsersRequest_Filter) Reset 

func (x *ListUsersRequest_Filter) Reset()

func (*ListUsersRequest_Filter) String 

func (x *ListUsersRequest_Filter) String() string

type ListUsersResponse 

type ListUsersResponse struct {
	Users []*ListUsersResponse_User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUsersResponse) Descriptor deprecated 

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

Deprecated: Use ListUsersResponse.ProtoReflect.Descriptor instead.

func (*ListUsersResponse) GetUsers 

func (x *ListUsersResponse) GetUsers() []*ListUsersResponse_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) String 

func (x *ListUsersResponse) String() string

type ListUsersResponse_User 

type ListUsersResponse_User struct {
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mechanism *SASLMechanism `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListUsersResponse_User) Descriptor deprecated 

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

Deprecated: Use ListUsersResponse_User.ProtoReflect.Descriptor instead.

func (*ListUsersResponse_User) GetMechanism 

func (x *ListUsersResponse_User) GetMechanism() SASLMechanism

func (*ListUsersResponse_User) GetName 

func (x *ListUsersResponse_User) GetName() string

func (*ListUsersResponse_User) ProtoMessage 

func (*ListUsersResponse_User) ProtoMessage()

func (*ListUsersResponse_User) ProtoReflect 

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

func (*ListUsersResponse_User) Reset 

func (x *ListUsersResponse_User) Reset()

func (*ListUsersResponse_User) String 

func (x *ListUsersResponse_User) String() string

type PartitionTransformStatus added in v0.3.0 

type PartitionTransformStatus struct {
	BrokerId    int32                                    `protobuf:"varint,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	PartitionId int32                                    `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Status      PartitionTransformStatus_PartitionStatus `` /* 144-byte string literal not displayed */
	Lag         int32                                    `protobuf:"varint,4,opt,name=lag,proto3" json:"lag,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionTransformStatus) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use PartitionTransformStatus.ProtoReflect.Descriptor instead.

func (*PartitionTransformStatus) GetBrokerId added in v0.3.0 

func (x *PartitionTransformStatus) GetBrokerId() int32

func (*PartitionTransformStatus) GetLag added in v0.3.0 

func (x *PartitionTransformStatus) GetLag() int32

func (*PartitionTransformStatus) GetPartitionId added in v0.3.0 

func (x *PartitionTransformStatus) GetPartitionId() int32

func (*PartitionTransformStatus) GetStatus added in v0.3.0 

func (x *PartitionTransformStatus) GetStatus() PartitionTransformStatus_PartitionStatus

func (*PartitionTransformStatus) ProtoMessage added in v0.3.0 

func (*PartitionTransformStatus) ProtoMessage()

func (*PartitionTransformStatus) ProtoReflect added in v0.3.0 

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

func (*PartitionTransformStatus) Reset added in v0.3.0 

func (x *PartitionTransformStatus) Reset()

func (*PartitionTransformStatus) String added in v0.3.0 

func (x *PartitionTransformStatus) String() string

type PartitionTransformStatus_PartitionStatus added in v0.3.0 

type PartitionTransformStatus_PartitionStatus int32
const (
	PartitionTransformStatus_PARTITION_STATUS_UNSPECIFIED PartitionTransformStatus_PartitionStatus = 0
	PartitionTransformStatus_PARTITION_STATUS_RUNNING     PartitionTransformStatus_PartitionStatus = 1
	PartitionTransformStatus_PARTITION_STATUS_INACTIVE    PartitionTransformStatus_PartitionStatus = 2
	PartitionTransformStatus_PARTITION_STATUS_ERRORED     PartitionTransformStatus_PartitionStatus = 3
	PartitionTransformStatus_PARTITION_STATUS_UNKNOWN     PartitionTransformStatus_PartitionStatus = 4
)

func (PartitionTransformStatus_PartitionStatus) Descriptor added in v0.3.0 

func (PartitionTransformStatus_PartitionStatus) Descriptor() protoreflect.EnumDescriptor

func (PartitionTransformStatus_PartitionStatus) Enum added in v0.3.0 

func (x PartitionTransformStatus_PartitionStatus) Enum() *PartitionTransformStatus_PartitionStatus

func (PartitionTransformStatus_PartitionStatus) EnumDescriptor deprecated added in v0.3.0 

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

Deprecated: Use PartitionTransformStatus_PartitionStatus.Descriptor instead.

func (PartitionTransformStatus_PartitionStatus) Number added in v0.3.0 

func (x PartitionTransformStatus_PartitionStatus) Number() protoreflect.EnumNumber

func (PartitionTransformStatus_PartitionStatus) String added in v0.3.0 

func (x PartitionTransformStatus_PartitionStatus) String() string

func (PartitionTransformStatus_PartitionStatus) Type added in v0.3.0 

func (PartitionTransformStatus_PartitionStatus) Type() protoreflect.EnumType

type PauseConnectorRequest 

type PauseConnectorRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseConnectorRequest) Descriptor deprecated 

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

Deprecated: Use PauseConnectorRequest.ProtoReflect.Descriptor instead.

func (*PauseConnectorRequest) GetClusterName 

func (x *PauseConnectorRequest) GetClusterName() string

func (*PauseConnectorRequest) GetName 

func (x *PauseConnectorRequest) GetName() string

func (*PauseConnectorRequest) ProtoMessage 

func (*PauseConnectorRequest) ProtoMessage()

func (*PauseConnectorRequest) ProtoReflect 

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

func (*PauseConnectorRequest) Reset 

func (x *PauseConnectorRequest) Reset()

func (*PauseConnectorRequest) String 

func (x *PauseConnectorRequest) String() string

type Reason 

type Reason int32
const (
	Reason_REASON_UNSPECIFIED              Reason = 0
	Reason_REASON_FEATURE_NOT_CONFIGURED   Reason = 1
	Reason_REASON_CONSOLE_ERROR            Reason = 2
	Reason_REASON_REDPANDA_ADMIN_API_ERROR Reason = 3
	Reason_REASON_KAFKA_API_ERROR          Reason = 4
	Reason_REASON_KAFKA_CONNECT_API_ERROR  Reason = 5
	Reason_REASON_TYPE_MAPPING_ERROR       Reason = 6
	Reason_REASON_SECRET_STORE_ERROR       Reason = 7
)

func (Reason) Descriptor 

func (Reason) Descriptor() protoreflect.EnumDescriptor

func (Reason) Enum 

func (x Reason) Enum() *Reason

func (Reason) EnumDescriptor deprecated 

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

Deprecated: Use Reason.Descriptor instead.

func (Reason) Number 

func (x Reason) Number() protoreflect.EnumNumber

func (Reason) String 

func (x Reason) String() string

func (Reason) Type 

func (Reason) Type() protoreflect.EnumType

type ResetConnectorTopicsRequest 

type ResetConnectorTopicsRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetConnectorTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ResetConnectorTopicsRequest.ProtoReflect.Descriptor instead.

func (*ResetConnectorTopicsRequest) GetClusterName 

func (x *ResetConnectorTopicsRequest) GetClusterName() string

func (*ResetConnectorTopicsRequest) GetName 

func (x *ResetConnectorTopicsRequest) GetName() string

func (*ResetConnectorTopicsRequest) ProtoMessage 

func (*ResetConnectorTopicsRequest) ProtoMessage()

func (*ResetConnectorTopicsRequest) ProtoReflect 

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

func (*ResetConnectorTopicsRequest) Reset 

func (x *ResetConnectorTopicsRequest) Reset()

func (*ResetConnectorTopicsRequest) String 

func (x *ResetConnectorTopicsRequest) String() string

type RestartConnectorRequest 

type RestartConnectorRequest struct {
	ClusterName string                           `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string                           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Options     *RestartConnectorRequest_Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartConnectorRequest) Descriptor deprecated 

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

Deprecated: Use RestartConnectorRequest.ProtoReflect.Descriptor instead.

func (*RestartConnectorRequest) GetClusterName 

func (x *RestartConnectorRequest) GetClusterName() string

func (*RestartConnectorRequest) GetName 

func (x *RestartConnectorRequest) GetName() string

func (*RestartConnectorRequest) GetOptions 

func (x *RestartConnectorRequest) GetOptions() *RestartConnectorRequest_Options

func (*RestartConnectorRequest) ProtoMessage 

func (*RestartConnectorRequest) ProtoMessage()

func (*RestartConnectorRequest) ProtoReflect 

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

func (*RestartConnectorRequest) Reset 

func (x *RestartConnectorRequest) Reset()

func (*RestartConnectorRequest) String 

func (x *RestartConnectorRequest) String() string

type RestartConnectorRequest_Options 

type RestartConnectorRequest_Options struct {
	IncludeTasks bool `protobuf:"varint,1,opt,name=include_tasks,json=includeTasks,proto3" json:"include_tasks,omitempty"`
	OnlyFailed   bool `protobuf:"varint,2,opt,name=only_failed,json=onlyFailed,proto3" json:"only_failed,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartConnectorRequest_Options) Descriptor deprecated 

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

Deprecated: Use RestartConnectorRequest_Options.ProtoReflect.Descriptor instead.

func (*RestartConnectorRequest_Options) GetIncludeTasks 

func (x *RestartConnectorRequest_Options) GetIncludeTasks() bool

func (*RestartConnectorRequest_Options) GetOnlyFailed 

func (x *RestartConnectorRequest_Options) GetOnlyFailed() bool

func (*RestartConnectorRequest_Options) ProtoMessage 

func (*RestartConnectorRequest_Options) ProtoMessage()

func (*RestartConnectorRequest_Options) ProtoReflect 

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

func (*RestartConnectorRequest_Options) Reset 

func (x *RestartConnectorRequest_Options) Reset()

func (*RestartConnectorRequest_Options) String 

func (x *RestartConnectorRequest_Options) String() string

type ResumeConnectorRequest 

type ResumeConnectorRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeConnectorRequest) Descriptor deprecated 

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

Deprecated: Use ResumeConnectorRequest.ProtoReflect.Descriptor instead.

func (*ResumeConnectorRequest) GetClusterName 

func (x *ResumeConnectorRequest) GetClusterName() string

func (*ResumeConnectorRequest) GetName 

func (x *ResumeConnectorRequest) GetName() string

func (*ResumeConnectorRequest) ProtoMessage 

func (*ResumeConnectorRequest) ProtoMessage()

func (*ResumeConnectorRequest) ProtoReflect 

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

func (*ResumeConnectorRequest) Reset 

func (x *ResumeConnectorRequest) Reset()

func (*ResumeConnectorRequest) String 

func (x *ResumeConnectorRequest) String() string

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 Secret 

type Secret struct {

	// Secret identifier.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Secret labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Secret defienes the secret resource.

func (*Secret) Descriptor deprecated 

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetId 

func (x *Secret) GetId() string

func (*Secret) GetLabels 

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

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect 

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

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) String 

func (x *Secret) String() string

type SecretInput 

type SecretInput struct {

	// Secret labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The secret data.
	SecretData []byte `protobuf:"bytes,3,opt,name=secret_data,json=secretData,proto3" json:"secret_data,omitempty"`
	// contains filtered or unexported fields
}

SecretInput defienes the secret input for secret API actions.

func (*SecretInput) Descriptor deprecated 

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

Deprecated: Use SecretInput.ProtoReflect.Descriptor instead.

func (*SecretInput) GetLabels 

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

func (*SecretInput) GetSecretData 

func (x *SecretInput) GetSecretData() []byte

func (*SecretInput) ProtoMessage 

func (*SecretInput) ProtoMessage()

func (*SecretInput) ProtoReflect 

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

func (*SecretInput) Reset 

func (x *SecretInput) Reset()

func (*SecretInput) String 

func (x *SecretInput) String() string

type SecretServiceClient 

type SecretServiceClient interface {
	// GetSecret retrieves the specific secret.
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	// ListSecrets lists the secrets based on optional filter.
	ListSecrets(ctx context.Context, in *ListSecretsRequest, opts ...grpc.CallOption) (*ListSecretsResponse, error)
	// CreateSecret creates the secret.
	CreateSecret(ctx context.Context, in *CreateSecretRequest, opts ...grpc.CallOption) (*CreateSecretResponse, error)
	// UpdateSecret updates the secret.
	UpdateSecret(ctx context.Context, in *UpdateSecretRequest, opts ...grpc.CallOption) (*UpdateSecretResponse, error)
	// DeleteSecret deletes the secret.
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*DeleteSecretResponse, error)
	// GetConnectSecret retrieves the specific secret for a specific Connect.
	GetConnectSecret(ctx context.Context, in *GetConnectSecretRequest, opts ...grpc.CallOption) (*GetConnectSecretResponse, error)
	// ListConnectSecrets lists the Connect secrets based on optional filter.
	ListConnectSecrets(ctx context.Context, in *ListConnectSecretsRequest, opts ...grpc.CallOption) (*ListConnectSecretsResponse, error)
	// CreateConnectSecret creates the secret for a Connect.
	CreateConnectSecret(ctx context.Context, in *CreateConnectSecretRequest, opts ...grpc.CallOption) (*CreateConnectSecretResponse, error)
	// UpdateConnectSecret updates the Connect secret.
	UpdateConnectSecret(ctx context.Context, in *UpdateConnectSecretRequest, opts ...grpc.CallOption) (*UpdateConnectSecretResponse, error)
	// DeleteSecret deletes the secret.
	DeleteConnectSecret(ctx context.Context, in *DeleteConnectSecretRequest, opts ...grpc.CallOption) (*DeleteConnectSecretResponse, error)
}

SecretServiceClient is the client API for SecretService 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 NewSecretServiceClient 

func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient

type SecretServiceServer 

type SecretServiceServer interface {
	// GetSecret retrieves the specific secret.
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	// ListSecrets lists the secrets based on optional filter.
	ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
	// CreateSecret creates the secret.
	CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)
	// UpdateSecret updates the secret.
	UpdateSecret(context.Context, *UpdateSecretRequest) (*UpdateSecretResponse, error)
	// DeleteSecret deletes the secret.
	DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
	// GetConnectSecret retrieves the specific secret for a specific Connect.
	GetConnectSecret(context.Context, *GetConnectSecretRequest) (*GetConnectSecretResponse, error)
	// ListConnectSecrets lists the Connect secrets based on optional filter.
	ListConnectSecrets(context.Context, *ListConnectSecretsRequest) (*ListConnectSecretsResponse, error)
	// CreateConnectSecret creates the secret for a Connect.
	CreateConnectSecret(context.Context, *CreateConnectSecretRequest) (*CreateConnectSecretResponse, error)
	// UpdateConnectSecret updates the Connect secret.
	UpdateConnectSecret(context.Context, *UpdateConnectSecretRequest) (*UpdateConnectSecretResponse, error)
	// DeleteSecret deletes the secret.
	DeleteConnectSecret(context.Context, *DeleteConnectSecretRequest) (*DeleteConnectSecretResponse, error)
}

SecretServiceServer is the server API for SecretService service. All implementations should embed UnimplementedSecretServiceServer for forward compatibility

type SetTopicConfigurationsRequest 

type SetTopicConfigurationsRequest struct {
	TopicName      string                                            `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Configurations []*SetTopicConfigurationsRequest_SetConfiguration `protobuf:"bytes,2,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTopicConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use SetTopicConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*SetTopicConfigurationsRequest) GetConfigurations 

func (x *SetTopicConfigurationsRequest) GetConfigurations() []*SetTopicConfigurationsRequest_SetConfiguration

func (*SetTopicConfigurationsRequest) GetTopicName 

func (x *SetTopicConfigurationsRequest) GetTopicName() string

func (*SetTopicConfigurationsRequest) ProtoMessage 

func (*SetTopicConfigurationsRequest) ProtoMessage()

func (*SetTopicConfigurationsRequest) ProtoReflect 

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

func (*SetTopicConfigurationsRequest) Reset 

func (x *SetTopicConfigurationsRequest) Reset()

func (*SetTopicConfigurationsRequest) String 

func (x *SetTopicConfigurationsRequest) String() string

type SetTopicConfigurationsRequest_SetConfiguration 

type SetTopicConfigurationsRequest_SetConfiguration struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value *string `protobuf:"bytes,2,opt,name=value,proto3,oneof" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTopicConfigurationsRequest_SetConfiguration) Descriptor deprecated 

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

Deprecated: Use SetTopicConfigurationsRequest_SetConfiguration.ProtoReflect.Descriptor instead.

func (*SetTopicConfigurationsRequest_SetConfiguration) GetName added in v0.3.0 

func (x *SetTopicConfigurationsRequest_SetConfiguration) GetName() string

func (*SetTopicConfigurationsRequest_SetConfiguration) GetValue 

func (x *SetTopicConfigurationsRequest_SetConfiguration) GetValue() string

func (*SetTopicConfigurationsRequest_SetConfiguration) ProtoMessage 

func (*SetTopicConfigurationsRequest_SetConfiguration) ProtoMessage()

func (*SetTopicConfigurationsRequest_SetConfiguration) ProtoReflect 

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

func (*SetTopicConfigurationsRequest_SetConfiguration) Reset 

func (x *SetTopicConfigurationsRequest_SetConfiguration) Reset()

func (*SetTopicConfigurationsRequest_SetConfiguration) String 

func (x *SetTopicConfigurationsRequest_SetConfiguration) String() string

type SetTopicConfigurationsResponse 

type SetTopicConfigurationsResponse struct {
	Configurations []*Topic_Configuration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTopicConfigurationsResponse) Descriptor deprecated 

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

Deprecated: Use SetTopicConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*SetTopicConfigurationsResponse) GetConfigurations 

func (x *SetTopicConfigurationsResponse) GetConfigurations() []*Topic_Configuration

func (*SetTopicConfigurationsResponse) ProtoMessage 

func (*SetTopicConfigurationsResponse) ProtoMessage()

func (*SetTopicConfigurationsResponse) ProtoReflect 

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

func (*SetTopicConfigurationsResponse) Reset 

func (x *SetTopicConfigurationsResponse) Reset()

func (*SetTopicConfigurationsResponse) String 

func (x *SetTopicConfigurationsResponse) String() string

type StopConnectorRequest 

type StopConnectorRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*StopConnectorRequest) Descriptor deprecated 

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

Deprecated: Use StopConnectorRequest.ProtoReflect.Descriptor instead.

func (*StopConnectorRequest) GetClusterName 

func (x *StopConnectorRequest) GetClusterName() string

func (*StopConnectorRequest) GetName 

func (x *StopConnectorRequest) GetName() string

func (*StopConnectorRequest) ProtoMessage 

func (*StopConnectorRequest) ProtoMessage()

func (*StopConnectorRequest) ProtoReflect 

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

func (*StopConnectorRequest) Reset 

func (x *StopConnectorRequest) Reset()

func (*StopConnectorRequest) String 

func (x *StopConnectorRequest) String() string

type TaskInfo 

type TaskInfo struct {
	Connector string `protobuf:"bytes,1,opt,name=connector,proto3" json:"connector,omitempty"`
	Task      int32  `protobuf:"varint,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInfo) Descriptor deprecated 

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

Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.

func (*TaskInfo) GetConnector 

func (x *TaskInfo) GetConnector() string

func (*TaskInfo) GetTask 

func (x *TaskInfo) GetTask() int32

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) ProtoReflect 

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

func (*TaskInfo) Reset 

func (x *TaskInfo) Reset()

func (*TaskInfo) String 

func (x *TaskInfo) String() string

type TaskStatus 

type TaskStatus struct {
	Id       int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	State    string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	WorkerId string `protobuf:"bytes,3,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Trace    string `protobuf:"bytes,4,opt,name=trace,proto3" json:"trace,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatus) Descriptor deprecated 

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

Deprecated: Use TaskStatus.ProtoReflect.Descriptor instead.

func (*TaskStatus) GetId 

func (x *TaskStatus) GetId() int32

func (*TaskStatus) GetState 

func (x *TaskStatus) GetState() string

func (*TaskStatus) GetTrace 

func (x *TaskStatus) GetTrace() string

func (*TaskStatus) GetWorkerId 

func (x *TaskStatus) GetWorkerId() string

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) ProtoReflect 

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

func (*TaskStatus) Reset 

func (x *TaskStatus) Reset()

func (*TaskStatus) String 

func (x *TaskStatus) String() string

type Topic 

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

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

type TopicServiceClient 

type TopicServiceClient interface {
	CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*CreateTopicResponse, error)
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*DeleteTopicResponse, error)
	GetTopicConfigurations(ctx context.Context, in *GetTopicConfigurationsRequest, opts ...grpc.CallOption) (*GetTopicConfigurationsResponse, error)
	UpdateTopicConfigurations(ctx context.Context, in *UpdateTopicConfigurationsRequest, opts ...grpc.CallOption) (*UpdateTopicConfigurationsResponse, error)
	SetTopicConfigurations(ctx context.Context, in *SetTopicConfigurationsRequest, opts ...grpc.CallOption) (*SetTopicConfigurationsResponse, 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 {
	CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	DeleteTopic(context.Context, *DeleteTopicRequest) (*DeleteTopicResponse, error)
	GetTopicConfigurations(context.Context, *GetTopicConfigurationsRequest) (*GetTopicConfigurationsResponse, error)
	UpdateTopicConfigurations(context.Context, *UpdateTopicConfigurationsRequest) (*UpdateTopicConfigurationsResponse, error)
	SetTopicConfigurations(context.Context, *SetTopicConfigurationsRequest) (*SetTopicConfigurationsResponse, error)
}

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

type Topic_Configuration 

type Topic_Configuration struct {
	Name           string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type           ConfigType       `protobuf:"varint,2,opt,name=type,proto3,enum=redpanda.api.dataplane.v1alpha1.ConfigType" json:"type,omitempty"`
	Value          *string          `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Source         ConfigSource     `protobuf:"varint,4,opt,name=source,proto3,enum=redpanda.api.dataplane.v1alpha1.ConfigSource" json:"source,omitempty"`
	ReadOnly       bool             `protobuf:"varint,5,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	Sensitive      bool             `protobuf:"varint,6,opt,name=sensitive,proto3" json:"sensitive,omitempty"`
	ConfigSynonyms []*ConfigSynonym `protobuf:"bytes,7,rep,name=config_synonyms,json=configSynonyms,proto3" json:"config_synonyms,omitempty"`
	Documentation  *string          `protobuf:"bytes,8,opt,name=documentation,proto3,oneof" json:"documentation,omitempty"`
	// contains filtered or unexported fields
}

func (*Topic_Configuration) Descriptor deprecated 

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

Deprecated: Use Topic_Configuration.ProtoReflect.Descriptor instead.

func (*Topic_Configuration) GetConfigSynonyms 

func (x *Topic_Configuration) GetConfigSynonyms() []*ConfigSynonym

func (*Topic_Configuration) GetDocumentation 

func (x *Topic_Configuration) GetDocumentation() string

func (*Topic_Configuration) GetName 

func (x *Topic_Configuration) GetName() string

func (*Topic_Configuration) GetReadOnly added in v0.3.0 

func (x *Topic_Configuration) GetReadOnly() bool

func (*Topic_Configuration) GetSensitive added in v0.3.0 

func (x *Topic_Configuration) GetSensitive() bool

func (*Topic_Configuration) GetSource 

func (x *Topic_Configuration) GetSource() ConfigSource

func (*Topic_Configuration) GetType 

func (x *Topic_Configuration) GetType() ConfigType

func (*Topic_Configuration) GetValue 

func (x *Topic_Configuration) GetValue() string

func (*Topic_Configuration) ProtoMessage 

func (*Topic_Configuration) ProtoMessage()

func (*Topic_Configuration) ProtoReflect 

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

func (*Topic_Configuration) Reset 

func (x *Topic_Configuration) Reset()

func (*Topic_Configuration) String 

func (x *Topic_Configuration) String() string

type TransformMetadata added in v0.3.0 

type TransformMetadata struct {
	Name                 string                                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InputTopicName       string                                   `protobuf:"bytes,2,opt,name=input_topic_name,json=inputTopicName,proto3" json:"input_topic_name,omitempty"`
	OutputTopicNames     []string                                 `protobuf:"bytes,3,rep,name=output_topic_names,json=outputTopicNames,proto3" json:"output_topic_names,omitempty"`
	Statuses             []*PartitionTransformStatus              `protobuf:"bytes,4,rep,name=statuses,proto3" json:"statuses,omitempty"`
	EnvironmentVariables []*TransformMetadata_EnvironmentVariable `protobuf:"bytes,5,rep,name=environment_variables,json=environmentVariables,proto3" json:"environment_variables,omitempty"`
	// contains filtered or unexported fields
}

func (*TransformMetadata) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use TransformMetadata.ProtoReflect.Descriptor instead.

func (*TransformMetadata) GetEnvironmentVariables added in v0.3.0 

func (x *TransformMetadata) GetEnvironmentVariables() []*TransformMetadata_EnvironmentVariable

func (*TransformMetadata) GetInputTopicName added in v0.3.0 

func (x *TransformMetadata) GetInputTopicName() string

func (*TransformMetadata) GetName added in v0.3.0 

func (x *TransformMetadata) GetName() string

func (*TransformMetadata) GetOutputTopicNames added in v0.3.0 

func (x *TransformMetadata) GetOutputTopicNames() []string

func (*TransformMetadata) GetStatuses added in v0.3.0 

func (x *TransformMetadata) GetStatuses() []*PartitionTransformStatus

func (*TransformMetadata) ProtoMessage added in v0.3.0 

func (*TransformMetadata) ProtoMessage()

func (*TransformMetadata) ProtoReflect added in v0.3.0 

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

func (*TransformMetadata) Reset added in v0.3.0 

func (x *TransformMetadata) Reset()

func (*TransformMetadata) String added in v0.3.0 

func (x *TransformMetadata) String() string

type TransformMetadata_EnvironmentVariable added in v0.3.0 

type TransformMetadata_EnvironmentVariable struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TransformMetadata_EnvironmentVariable) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use TransformMetadata_EnvironmentVariable.ProtoReflect.Descriptor instead.

func (*TransformMetadata_EnvironmentVariable) GetKey added in v0.3.0 

func (x *TransformMetadata_EnvironmentVariable) GetKey() string

func (*TransformMetadata_EnvironmentVariable) GetValue added in v0.3.0 

func (x *TransformMetadata_EnvironmentVariable) GetValue() string

func (*TransformMetadata_EnvironmentVariable) ProtoMessage added in v0.3.0 

func (*TransformMetadata_EnvironmentVariable) ProtoMessage()

func (*TransformMetadata_EnvironmentVariable) ProtoReflect added in v0.3.0 

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

func (*TransformMetadata_EnvironmentVariable) Reset added in v0.3.0 

func (x *TransformMetadata_EnvironmentVariable) Reset()

func (*TransformMetadata_EnvironmentVariable) String added in v0.3.0 

func (x *TransformMetadata_EnvironmentVariable) String() string

type TransformServiceClient added in v0.3.0 

type TransformServiceClient interface {
	ListTransforms(ctx context.Context, in *ListTransformsRequest, opts ...grpc.CallOption) (*ListTransformsResponse, error)
	GetTransform(ctx context.Context, in *GetTransformRequest, opts ...grpc.CallOption) (*GetTransformResponse, error)
	DeleteTransform(ctx context.Context, in *DeleteTransformRequest, opts ...grpc.CallOption) (*DeleteTransformResponse, error)
}

TransformServiceClient is the client API for TransformService 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 NewTransformServiceClient added in v0.3.0 

func NewTransformServiceClient(cc grpc.ClientConnInterface) TransformServiceClient

type TransformServiceServer added in v0.3.0 

type TransformServiceServer interface {
	ListTransforms(context.Context, *ListTransformsRequest) (*ListTransformsResponse, error)
	GetTransform(context.Context, *GetTransformRequest) (*GetTransformResponse, error)
	DeleteTransform(context.Context, *DeleteTransformRequest) (*DeleteTransformResponse, error)
}

TransformServiceServer is the server API for TransformService service. All implementations should embed UnimplementedTransformServiceServer for forward compatibility

type UnimplementedACLServiceServer 

type UnimplementedACLServiceServer struct {
}

UnimplementedACLServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedACLServiceServer) CreateACL 

func (UnimplementedACLServiceServer) CreateACL(context.Context, *CreateACLRequest) (*CreateACLResponse, error)

func (UnimplementedACLServiceServer) DeleteACLs 

func (UnimplementedACLServiceServer) DeleteACLs(context.Context, *DeleteACLsRequest) (*DeleteACLsResponse, error)

func (UnimplementedACLServiceServer) ListACLs 

func (UnimplementedACLServiceServer) ListACLs(context.Context, *ListACLsRequest) (*ListACLsResponse, error)

type UnimplementedDummyServiceServer 

type UnimplementedDummyServiceServer struct {
}

UnimplementedDummyServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDummyServiceServer) DummyMethod 

func (UnimplementedDummyServiceServer) DummyMethod(context.Context, *emptypb.Empty) (*DummyMethodResponse, error)

type UnimplementedKafkaConnectServiceServer 

type UnimplementedKafkaConnectServiceServer struct {
}

UnimplementedKafkaConnectServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedKafkaConnectServiceServer) CreateConnector 

func (UnimplementedKafkaConnectServiceServer) CreateConnector(context.Context, *CreateConnectorRequest) (*CreateConnectorResponse, error)

func (UnimplementedKafkaConnectServiceServer) DeleteConnector 

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

func (UnimplementedKafkaConnectServiceServer) GetConnectCluster 

func (UnimplementedKafkaConnectServiceServer) GetConnectCluster(context.Context, *GetConnectClusterRequest) (*GetConnectClusterResponse, error)

func (UnimplementedKafkaConnectServiceServer) GetConnector 

func (UnimplementedKafkaConnectServiceServer) GetConnector(context.Context, *GetConnectorRequest) (*GetConnectorResponse, error)

func (UnimplementedKafkaConnectServiceServer) GetConnectorConfig 

func (UnimplementedKafkaConnectServiceServer) GetConnectorConfig(context.Context, *GetConnectorConfigRequest) (*GetConnectorConfigResponse, error)

func (UnimplementedKafkaConnectServiceServer) GetConnectorStatus 

func (UnimplementedKafkaConnectServiceServer) GetConnectorStatus(context.Context, *GetConnectorStatusRequest) (*GetConnectorStatusResponse, error)

func (UnimplementedKafkaConnectServiceServer) ListConnectClusters 

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

func (UnimplementedKafkaConnectServiceServer) ListConnectorTopics 

func (UnimplementedKafkaConnectServiceServer) ListConnectorTopics(context.Context, *ListConnectorTopicsRequest) (*ListConnectorTopicsResponse, error)

func (UnimplementedKafkaConnectServiceServer) ListConnectors 

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

func (UnimplementedKafkaConnectServiceServer) PauseConnector 

func (UnimplementedKafkaConnectServiceServer) PauseConnector(context.Context, *PauseConnectorRequest) (*emptypb.Empty, error)

func (UnimplementedKafkaConnectServiceServer) ResetConnectorTopics 

func (UnimplementedKafkaConnectServiceServer) ResetConnectorTopics(context.Context, *ResetConnectorTopicsRequest) (*emptypb.Empty, error)

func (UnimplementedKafkaConnectServiceServer) RestartConnector 

func (UnimplementedKafkaConnectServiceServer) RestartConnector(context.Context, *RestartConnectorRequest) (*emptypb.Empty, error)

func (UnimplementedKafkaConnectServiceServer) ResumeConnector 

func (UnimplementedKafkaConnectServiceServer) ResumeConnector(context.Context, *ResumeConnectorRequest) (*emptypb.Empty, error)

func (UnimplementedKafkaConnectServiceServer) StopConnector 

func (UnimplementedKafkaConnectServiceServer) StopConnector(context.Context, *StopConnectorRequest) (*emptypb.Empty, error)

func (UnimplementedKafkaConnectServiceServer) UpsertConnector 

func (UnimplementedKafkaConnectServiceServer) UpsertConnector(context.Context, *UpsertConnectorRequest) (*UpsertConnectorResponse, error)

type UnimplementedSecretServiceServer 

type UnimplementedSecretServiceServer struct {
}

UnimplementedSecretServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedSecretServiceServer) CreateConnectSecret added in v0.3.0 

func (UnimplementedSecretServiceServer) CreateConnectSecret(context.Context, *CreateConnectSecretRequest) (*CreateConnectSecretResponse, error)

func (UnimplementedSecretServiceServer) CreateSecret 

func (UnimplementedSecretServiceServer) CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)

func (UnimplementedSecretServiceServer) DeleteConnectSecret added in v0.3.0 

func (UnimplementedSecretServiceServer) DeleteConnectSecret(context.Context, *DeleteConnectSecretRequest) (*DeleteConnectSecretResponse, error)

func (UnimplementedSecretServiceServer) DeleteSecret 

func (UnimplementedSecretServiceServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)

func (UnimplementedSecretServiceServer) GetConnectSecret added in v0.3.0 

func (UnimplementedSecretServiceServer) GetConnectSecret(context.Context, *GetConnectSecretRequest) (*GetConnectSecretResponse, error)

func (UnimplementedSecretServiceServer) GetSecret added in v0.3.0 

func (UnimplementedSecretServiceServer) GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)

func (UnimplementedSecretServiceServer) ListConnectSecrets added in v0.3.0 

func (UnimplementedSecretServiceServer) ListConnectSecrets(context.Context, *ListConnectSecretsRequest) (*ListConnectSecretsResponse, error)

func (UnimplementedSecretServiceServer) ListSecrets 

func (UnimplementedSecretServiceServer) ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)

func (UnimplementedSecretServiceServer) UpdateConnectSecret added in v0.3.0 

func (UnimplementedSecretServiceServer) UpdateConnectSecret(context.Context, *UpdateConnectSecretRequest) (*UpdateConnectSecretResponse, error)

func (UnimplementedSecretServiceServer) UpdateSecret 

func (UnimplementedSecretServiceServer) UpdateSecret(context.Context, *UpdateSecretRequest) (*UpdateSecretResponse, error)

type UnimplementedTopicServiceServer 

type UnimplementedTopicServiceServer struct {
}

UnimplementedTopicServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTopicServiceServer) CreateTopic 

func (UnimplementedTopicServiceServer) CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)

func (UnimplementedTopicServiceServer) DeleteTopic 

func (UnimplementedTopicServiceServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*DeleteTopicResponse, error)

func (UnimplementedTopicServiceServer) GetTopicConfigurations 

func (UnimplementedTopicServiceServer) GetTopicConfigurations(context.Context, *GetTopicConfigurationsRequest) (*GetTopicConfigurationsResponse, error)

func (UnimplementedTopicServiceServer) ListTopics 

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

func (UnimplementedTopicServiceServer) SetTopicConfigurations 

func (UnimplementedTopicServiceServer) SetTopicConfigurations(context.Context, *SetTopicConfigurationsRequest) (*SetTopicConfigurationsResponse, error)

func (UnimplementedTopicServiceServer) UpdateTopicConfigurations 

func (UnimplementedTopicServiceServer) UpdateTopicConfigurations(context.Context, *UpdateTopicConfigurationsRequest) (*UpdateTopicConfigurationsResponse, error)

type UnimplementedTransformServiceServer added in v0.3.0 

type UnimplementedTransformServiceServer struct {
}

UnimplementedTransformServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTransformServiceServer) DeleteTransform added in v0.3.0 

func (UnimplementedTransformServiceServer) DeleteTransform(context.Context, *DeleteTransformRequest) (*DeleteTransformResponse, error)

func (UnimplementedTransformServiceServer) GetTransform added in v0.3.0 

func (UnimplementedTransformServiceServer) GetTransform(context.Context, *GetTransformRequest) (*GetTransformResponse, error)

func (UnimplementedTransformServiceServer) ListTransforms added in v0.3.0 

func (UnimplementedTransformServiceServer) ListTransforms(context.Context, *ListTransformsRequest) (*ListTransformsResponse, error)

type UnimplementedUserServiceServer 

type UnimplementedUserServiceServer struct {
}

UnimplementedUserServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUserServiceServer) CreateUser 

func (UnimplementedUserServiceServer) CreateUser(context.Context, *CreateUserRequest) (*CreateUserResponse, error)

func (UnimplementedUserServiceServer) DeleteUser 

func (UnimplementedUserServiceServer) DeleteUser(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error)

func (UnimplementedUserServiceServer) ListUsers 

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

func (UnimplementedUserServiceServer) UpdateUser 

func (UnimplementedUserServiceServer) UpdateUser(context.Context, *UpdateUserRequest) (*UpdateUserResponse, error)

type UnsafeACLServiceServer 

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

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

type UnsafeDummyServiceServer 

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

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

type UnsafeKafkaConnectServiceServer 

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

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

type UnsafeSecretServiceServer 

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

UnsafeSecretServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SecretServiceServer 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 UnsafeTransformServiceServer added in v0.3.0 

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

UnsafeTransformServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransformServiceServer 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 UpdateConnectSecretRequest added in v0.3.0 

type UpdateConnectSecretRequest struct {

	// The unique name of target connect cluster.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// The id of the secret to retrieve.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// The input for the secret to update.
	Secret *SecretInput `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

UpdateConnectSecretRequest is the request of UpdateConnectSecret.

func (*UpdateConnectSecretRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use UpdateConnectSecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectSecretRequest) GetClusterName added in v0.3.0 

func (x *UpdateConnectSecretRequest) GetClusterName() string

func (*UpdateConnectSecretRequest) GetId added in v0.3.0 

func (x *UpdateConnectSecretRequest) GetId() string

func (*UpdateConnectSecretRequest) GetSecret added in v0.3.0 

func (x *UpdateConnectSecretRequest) GetSecret() *SecretInput

func (*UpdateConnectSecretRequest) ProtoMessage added in v0.3.0 

func (*UpdateConnectSecretRequest) ProtoMessage()

func (*UpdateConnectSecretRequest) ProtoReflect added in v0.3.0 

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

func (*UpdateConnectSecretRequest) Reset added in v0.3.0 

func (x *UpdateConnectSecretRequest) Reset()

func (*UpdateConnectSecretRequest) String added in v0.3.0 

func (x *UpdateConnectSecretRequest) String() string

type UpdateConnectSecretResponse added in v0.3.0 

type UpdateConnectSecretResponse struct {

	// The updated secret.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

UpdateConnectSecretResponse is the response of UpdateConnectSecret.

func (*UpdateConnectSecretResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use UpdateConnectSecretResponse.ProtoReflect.Descriptor instead.

func (*UpdateConnectSecretResponse) GetSecret added in v0.3.0 

func (x *UpdateConnectSecretResponse) GetSecret() *Secret

func (*UpdateConnectSecretResponse) ProtoMessage added in v0.3.0 

func (*UpdateConnectSecretResponse) ProtoMessage()

func (*UpdateConnectSecretResponse) ProtoReflect added in v0.3.0 

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

func (*UpdateConnectSecretResponse) Reset added in v0.3.0 

func (x *UpdateConnectSecretResponse) Reset()

func (*UpdateConnectSecretResponse) String added in v0.3.0 

func (x *UpdateConnectSecretResponse) String() string

type UpdateSecretRequest 

type UpdateSecretRequest struct {

	// Secret identifier.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The input for the secret to update.
	Secret *SecretInput `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

UpdateSecretRequest is the request of UpdateSecret.

func (*UpdateSecretRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateSecretRequest) GetId added in v0.3.0 

func (x *UpdateSecretRequest) GetId() string

func (*UpdateSecretRequest) GetSecret 

func (x *UpdateSecretRequest) GetSecret() *SecretInput

func (*UpdateSecretRequest) ProtoMessage 

func (*UpdateSecretRequest) ProtoMessage()

func (*UpdateSecretRequest) ProtoReflect 

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

func (*UpdateSecretRequest) Reset 

func (x *UpdateSecretRequest) Reset()

func (*UpdateSecretRequest) String 

func (x *UpdateSecretRequest) String() string

type UpdateSecretResponse 

type UpdateSecretResponse struct {

	// The updated secret.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

UpdateSecretResponse is the response of UpdateSecret.

func (*UpdateSecretResponse) Descriptor deprecated 

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

Deprecated: Use UpdateSecretResponse.ProtoReflect.Descriptor instead.

func (*UpdateSecretResponse) GetSecret 

func (x *UpdateSecretResponse) GetSecret() *Secret

func (*UpdateSecretResponse) ProtoMessage 

func (*UpdateSecretResponse) ProtoMessage()

func (*UpdateSecretResponse) ProtoReflect 

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

func (*UpdateSecretResponse) Reset 

func (x *UpdateSecretResponse) Reset()

func (*UpdateSecretResponse) String 

func (x *UpdateSecretResponse) String() string

type UpdateTopicConfigurationsRequest 

type UpdateTopicConfigurationsRequest struct {
	TopicName      string                                                  `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Configurations []*UpdateTopicConfigurationsRequest_UpdateConfiguration `protobuf:"bytes,2,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTopicConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTopicConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*UpdateTopicConfigurationsRequest) GetConfigurations 

func (x *UpdateTopicConfigurationsRequest) GetConfigurations() []*UpdateTopicConfigurationsRequest_UpdateConfiguration

func (*UpdateTopicConfigurationsRequest) GetTopicName 

func (x *UpdateTopicConfigurationsRequest) GetTopicName() string

func (*UpdateTopicConfigurationsRequest) ProtoMessage 

func (*UpdateTopicConfigurationsRequest) ProtoMessage()

func (*UpdateTopicConfigurationsRequest) ProtoReflect 

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

func (*UpdateTopicConfigurationsRequest) Reset 

func (x *UpdateTopicConfigurationsRequest) Reset()

func (*UpdateTopicConfigurationsRequest) String 

func (x *UpdateTopicConfigurationsRequest) String() string

type UpdateTopicConfigurationsRequest_UpdateConfiguration 

type UpdateTopicConfigurationsRequest_UpdateConfiguration struct {
	Name      string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value     *string              `protobuf:"bytes,2,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Operation ConfigAlterOperation `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) Descriptor deprecated 

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

Deprecated: Use UpdateTopicConfigurationsRequest_UpdateConfiguration.ProtoReflect.Descriptor instead.

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) GetName added in v0.3.0 

func (x *UpdateTopicConfigurationsRequest_UpdateConfiguration) GetName() string

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) GetOperation 

func (x *UpdateTopicConfigurationsRequest_UpdateConfiguration) GetOperation() ConfigAlterOperation

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) GetValue 

func (x *UpdateTopicConfigurationsRequest_UpdateConfiguration) GetValue() string

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) ProtoMessage 

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) ProtoMessage()

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) ProtoReflect 

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

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) Reset 

func (x *UpdateTopicConfigurationsRequest_UpdateConfiguration) Reset()

func (*UpdateTopicConfigurationsRequest_UpdateConfiguration) String 

func (x *UpdateTopicConfigurationsRequest_UpdateConfiguration) String() string

type UpdateTopicConfigurationsResponse 

type UpdateTopicConfigurationsResponse struct {

	// Topic's complete set of configurations after this partial patch has been applied.
	Configurations []*Topic_Configuration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTopicConfigurationsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateTopicConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*UpdateTopicConfigurationsResponse) GetConfigurations 

func (x *UpdateTopicConfigurationsResponse) GetConfigurations() []*Topic_Configuration

func (*UpdateTopicConfigurationsResponse) ProtoMessage 

func (*UpdateTopicConfigurationsResponse) ProtoMessage()

func (*UpdateTopicConfigurationsResponse) ProtoReflect 

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

func (*UpdateTopicConfigurationsResponse) Reset 

func (x *UpdateTopicConfigurationsResponse) Reset()

func (*UpdateTopicConfigurationsResponse) String 

func (x *UpdateTopicConfigurationsResponse) String() string

type UpdateUserRequest 

type UpdateUserRequest struct {
	User *UpdateUserRequest_User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserRequest) Descriptor deprecated 

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

Deprecated: Use UpdateUserRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserRequest) GetUser 

func (x *UpdateUserRequest) GetUser() *UpdateUserRequest_User

func (*UpdateUserRequest) ProtoMessage 

func (*UpdateUserRequest) ProtoMessage()

func (*UpdateUserRequest) ProtoReflect 

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

func (*UpdateUserRequest) Reset 

func (x *UpdateUserRequest) Reset()

func (*UpdateUserRequest) String 

func (x *UpdateUserRequest) String() string

type UpdateUserRequest_User 

type UpdateUserRequest_User struct {
	Name      string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Password  string        `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Mechanism SASLMechanism `protobuf:"varint,3,opt,name=mechanism,proto3,enum=redpanda.api.dataplane.v1alpha1.SASLMechanism" json:"mechanism,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserRequest_User) Descriptor deprecated 

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

Deprecated: Use UpdateUserRequest_User.ProtoReflect.Descriptor instead.

func (*UpdateUserRequest_User) GetMechanism 

func (x *UpdateUserRequest_User) GetMechanism() SASLMechanism

func (*UpdateUserRequest_User) GetName 

func (x *UpdateUserRequest_User) GetName() string

func (*UpdateUserRequest_User) GetPassword 

func (x *UpdateUserRequest_User) GetPassword() string

func (*UpdateUserRequest_User) ProtoMessage 

func (*UpdateUserRequest_User) ProtoMessage()

func (*UpdateUserRequest_User) ProtoReflect 

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

func (*UpdateUserRequest_User) Reset 

func (x *UpdateUserRequest_User) Reset()

func (*UpdateUserRequest_User) String 

func (x *UpdateUserRequest_User) String() string

type UpdateUserResponse 

type UpdateUserResponse struct {
	User *UpdateUserResponse_User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserResponse) Descriptor deprecated 

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

Deprecated: Use UpdateUserResponse.ProtoReflect.Descriptor instead.

func (*UpdateUserResponse) GetUser 

func (x *UpdateUserResponse) GetUser() *UpdateUserResponse_User

func (*UpdateUserResponse) ProtoMessage 

func (*UpdateUserResponse) ProtoMessage()

func (*UpdateUserResponse) ProtoReflect 

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

func (*UpdateUserResponse) Reset 

func (x *UpdateUserResponse) Reset()

func (*UpdateUserResponse) String 

func (x *UpdateUserResponse) String() string

type UpdateUserResponse_User 

type UpdateUserResponse_User struct {
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mechanism *SASLMechanism `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateUserResponse_User) Descriptor deprecated 

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

Deprecated: Use UpdateUserResponse_User.ProtoReflect.Descriptor instead.

func (*UpdateUserResponse_User) GetMechanism 

func (x *UpdateUserResponse_User) GetMechanism() SASLMechanism

func (*UpdateUserResponse_User) GetName 

func (x *UpdateUserResponse_User) GetName() string

func (*UpdateUserResponse_User) ProtoMessage 

func (*UpdateUserResponse_User) ProtoMessage()

func (*UpdateUserResponse_User) ProtoReflect 

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

func (*UpdateUserResponse_User) Reset 

func (x *UpdateUserResponse_User) Reset()

func (*UpdateUserResponse_User) String 

func (x *UpdateUserResponse_User) String() string

type UpsertConnectorRequest 

type UpsertConnectorRequest struct {
	ClusterName string            `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Name        string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Config      map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpsertConnectorRequest) Descriptor deprecated 

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

Deprecated: Use UpsertConnectorRequest.ProtoReflect.Descriptor instead.

func (*UpsertConnectorRequest) GetClusterName 

func (x *UpsertConnectorRequest) GetClusterName() string

func (*UpsertConnectorRequest) GetConfig 

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

func (*UpsertConnectorRequest) GetName 

func (x *UpsertConnectorRequest) GetName() string

func (*UpsertConnectorRequest) ProtoMessage 

func (*UpsertConnectorRequest) ProtoMessage()

func (*UpsertConnectorRequest) ProtoReflect 

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

func (*UpsertConnectorRequest) Reset 

func (x *UpsertConnectorRequest) Reset()

func (*UpsertConnectorRequest) String 

func (x *UpsertConnectorRequest) String() string

type UpsertConnectorResponse 

type UpsertConnectorResponse struct {
	Connector *ConnectorSpec `protobuf:"bytes,1,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertConnectorResponse) Descriptor deprecated 

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

Deprecated: Use UpsertConnectorResponse.ProtoReflect.Descriptor instead.

func (*UpsertConnectorResponse) GetConnector 

func (x *UpsertConnectorResponse) GetConnector() *ConnectorSpec

func (*UpsertConnectorResponse) ProtoMessage 

func (*UpsertConnectorResponse) ProtoMessage()

func (*UpsertConnectorResponse) ProtoReflect 

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

func (*UpsertConnectorResponse) Reset 

func (x *UpsertConnectorResponse) Reset()

func (*UpsertConnectorResponse) String 

func (x *UpsertConnectorResponse) String() string

type UserServiceClient 

type UserServiceClient interface {
	CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*CreateUserResponse, error)
	UpdateUser(ctx context.Context, in *UpdateUserRequest, opts ...grpc.CallOption) (*UpdateUserResponse, error)
	ListUsers(ctx context.Context, in *ListUsersRequest, opts ...grpc.CallOption) (*ListUsersResponse, error)
	DeleteUser(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*DeleteUserResponse, 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 {
	CreateUser(context.Context, *CreateUserRequest) (*CreateUserResponse, error)
	UpdateUser(context.Context, *UpdateUserRequest) (*UpdateUserResponse, error)
	ListUsers(context.Context, *ListUsersRequest) (*ListUsersResponse, error)
	DeleteUser(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error)
}

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

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.