Versions in this module Expand all Collapse all v0 v0.11.3 Jun 6, 2023 v0.11.2 Jun 6, 2023 Changes in this version + var File_contrib_envoy_extensions_filters_network_kafka_mesh_v3alpha_kafka_mesh_proto protoreflect.FileDescriptor + var KafkaMesh_ConsumerProxyMode_name = map[int32]string + var KafkaMesh_ConsumerProxyMode_value = map[string]int32 + type ForwardingRule struct + TargetCluster string + Trigger isForwardingRule_Trigger + func (*ForwardingRule) Descriptor() ([]byte, []int) + func (*ForwardingRule) ProtoMessage() + func (m *ForwardingRule) GetTrigger() isForwardingRule_Trigger + func (m *ForwardingRule) Validate() error + func (m *ForwardingRule) ValidateAll() error + func (x *ForwardingRule) GetTargetCluster() string + func (x *ForwardingRule) GetTopicPrefix() string + func (x *ForwardingRule) ProtoReflect() protoreflect.Message + func (x *ForwardingRule) Reset() + func (x *ForwardingRule) String() string + type ForwardingRuleMultiError []error + func (m ForwardingRuleMultiError) AllErrors() []error + func (m ForwardingRuleMultiError) Error() string + type ForwardingRuleValidationError struct + func (e ForwardingRuleValidationError) Cause() error + func (e ForwardingRuleValidationError) Error() string + func (e ForwardingRuleValidationError) ErrorName() string + func (e ForwardingRuleValidationError) Field() string + func (e ForwardingRuleValidationError) Key() bool + func (e ForwardingRuleValidationError) Reason() string + type ForwardingRule_TopicPrefix struct + TopicPrefix string + type KafkaClusterDefinition struct + BootstrapServers string + ClusterName string + ConsumerConfig map[string]string + PartitionCount int32 + ProducerConfig map[string]string + func (*KafkaClusterDefinition) Descriptor() ([]byte, []int) + func (*KafkaClusterDefinition) ProtoMessage() + func (m *KafkaClusterDefinition) Validate() error + func (m *KafkaClusterDefinition) ValidateAll() error + func (x *KafkaClusterDefinition) GetBootstrapServers() string + func (x *KafkaClusterDefinition) GetClusterName() string + func (x *KafkaClusterDefinition) GetConsumerConfig() map[string]string + func (x *KafkaClusterDefinition) GetPartitionCount() int32 + func (x *KafkaClusterDefinition) GetProducerConfig() map[string]string + func (x *KafkaClusterDefinition) ProtoReflect() protoreflect.Message + func (x *KafkaClusterDefinition) Reset() + func (x *KafkaClusterDefinition) String() string + type KafkaClusterDefinitionMultiError []error + func (m KafkaClusterDefinitionMultiError) AllErrors() []error + func (m KafkaClusterDefinitionMultiError) Error() string + type KafkaClusterDefinitionValidationError struct + func (e KafkaClusterDefinitionValidationError) Cause() error + func (e KafkaClusterDefinitionValidationError) Error() string + func (e KafkaClusterDefinitionValidationError) ErrorName() string + func (e KafkaClusterDefinitionValidationError) Field() string + func (e KafkaClusterDefinitionValidationError) Key() bool + func (e KafkaClusterDefinitionValidationError) Reason() string + type KafkaMesh struct + AdvertisedHost string + AdvertisedPort int32 + ConsumerProxyMode KafkaMesh_ConsumerProxyMode + ForwardingRules []*ForwardingRule + UpstreamClusters []*KafkaClusterDefinition + func (*KafkaMesh) Descriptor() ([]byte, []int) + func (*KafkaMesh) ProtoMessage() + func (m *KafkaMesh) Validate() error + func (m *KafkaMesh) ValidateAll() error + func (x *KafkaMesh) GetAdvertisedHost() string + func (x *KafkaMesh) GetAdvertisedPort() int32 + func (x *KafkaMesh) GetConsumerProxyMode() KafkaMesh_ConsumerProxyMode + func (x *KafkaMesh) GetForwardingRules() []*ForwardingRule + func (x *KafkaMesh) GetUpstreamClusters() []*KafkaClusterDefinition + func (x *KafkaMesh) ProtoReflect() protoreflect.Message + func (x *KafkaMesh) Reset() + func (x *KafkaMesh) String() string + type KafkaMeshMultiError []error + func (m KafkaMeshMultiError) AllErrors() []error + func (m KafkaMeshMultiError) Error() string + type KafkaMeshValidationError struct + func (e KafkaMeshValidationError) Cause() error + func (e KafkaMeshValidationError) Error() string + func (e KafkaMeshValidationError) ErrorName() string + func (e KafkaMeshValidationError) Field() string + func (e KafkaMeshValidationError) Key() bool + func (e KafkaMeshValidationError) Reason() string + type KafkaMesh_ConsumerProxyMode int32 + const KafkaMesh_StatefulConsumerProxy + func (KafkaMesh_ConsumerProxyMode) Descriptor() protoreflect.EnumDescriptor + func (KafkaMesh_ConsumerProxyMode) EnumDescriptor() ([]byte, []int) + func (KafkaMesh_ConsumerProxyMode) Type() protoreflect.EnumType + func (x KafkaMesh_ConsumerProxyMode) Enum() *KafkaMesh_ConsumerProxyMode + func (x KafkaMesh_ConsumerProxyMode) Number() protoreflect.EnumNumber + func (x KafkaMesh_ConsumerProxyMode) String() string