Versions in this module Expand all Collapse all v1 v1.0.0 Jan 25, 2023 Changes in this version + var File_contrib_envoy_extensions_filters_network_kafka_mesh_v3alpha_kafka_mesh_proto protoreflect.FileDescriptor + 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 + 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) 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 + 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) 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