Documentation ¶
Index ¶
- Variables
- type ForwardingRule
- func (*ForwardingRule) Descriptor() ([]byte, []int)deprecated
- func (x *ForwardingRule) GetTargetCluster() string
- func (x *ForwardingRule) GetTopicPrefix() string
- func (m *ForwardingRule) GetTrigger() isForwardingRule_Trigger
- func (*ForwardingRule) ProtoMessage()
- func (x *ForwardingRule) ProtoReflect() protoreflect.Message
- func (x *ForwardingRule) Reset()
- func (x *ForwardingRule) String() string
- func (m *ForwardingRule) Validate() error
- func (m *ForwardingRule) ValidateAll() error
- type ForwardingRuleMultiError
- type ForwardingRuleValidationError
- 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
- type KafkaClusterDefinition
- func (*KafkaClusterDefinition) Descriptor() ([]byte, []int)deprecated
- 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 (*KafkaClusterDefinition) ProtoMessage()
- func (x *KafkaClusterDefinition) ProtoReflect() protoreflect.Message
- func (x *KafkaClusterDefinition) Reset()
- func (x *KafkaClusterDefinition) String() string
- func (m *KafkaClusterDefinition) Validate() error
- func (m *KafkaClusterDefinition) ValidateAll() error
- type KafkaClusterDefinitionMultiError
- type KafkaClusterDefinitionValidationError
- 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
- func (*KafkaMesh) Descriptor() ([]byte, []int)deprecated
- 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 (*KafkaMesh) ProtoMessage()
- func (x *KafkaMesh) ProtoReflect() protoreflect.Message
- func (x *KafkaMesh) Reset()
- func (x *KafkaMesh) String() string
- func (m *KafkaMesh) Validate() error
- func (m *KafkaMesh) ValidateAll() error
- type KafkaMeshMultiError
- type KafkaMeshValidationError
- type KafkaMesh_ConsumerProxyMode
- func (KafkaMesh_ConsumerProxyMode) Descriptor() protoreflect.EnumDescriptor
- func (x KafkaMesh_ConsumerProxyMode) Enum() *KafkaMesh_ConsumerProxyMode
- func (KafkaMesh_ConsumerProxyMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x KafkaMesh_ConsumerProxyMode) Number() protoreflect.EnumNumber
- func (x KafkaMesh_ConsumerProxyMode) String() string
- func (KafkaMesh_ConsumerProxyMode) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( KafkaMesh_ConsumerProxyMode_name = map[int32]string{ 0: "StatefulConsumerProxy", } KafkaMesh_ConsumerProxyMode_value = map[string]int32{ "StatefulConsumerProxy": 0, } )
Enum value maps for KafkaMesh_ConsumerProxyMode.
var File_contrib_envoy_extensions_filters_network_kafka_mesh_v3alpha_kafka_mesh_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ForwardingRule ¶
type ForwardingRule struct { // Cluster name. TargetCluster string `protobuf:"bytes,1,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"` // Types that are assignable to Trigger: // // *ForwardingRule_TopicPrefix Trigger isForwardingRule_Trigger `protobuf_oneof:"trigger"` // contains filtered or unexported fields }
func (*ForwardingRule) Descriptor
deprecated
func (*ForwardingRule) Descriptor() ([]byte, []int)
Deprecated: Use ForwardingRule.ProtoReflect.Descriptor instead.
func (*ForwardingRule) GetTargetCluster ¶
func (x *ForwardingRule) GetTargetCluster() string
func (*ForwardingRule) GetTopicPrefix ¶
func (x *ForwardingRule) GetTopicPrefix() string
func (*ForwardingRule) GetTrigger ¶
func (m *ForwardingRule) GetTrigger() isForwardingRule_Trigger
func (*ForwardingRule) ProtoMessage ¶
func (*ForwardingRule) ProtoMessage()
func (*ForwardingRule) ProtoReflect ¶
func (x *ForwardingRule) ProtoReflect() protoreflect.Message
func (*ForwardingRule) Reset ¶
func (x *ForwardingRule) Reset()
func (*ForwardingRule) String ¶
func (x *ForwardingRule) String() string
func (*ForwardingRule) Validate ¶
func (m *ForwardingRule) Validate() error
Validate checks the field values on ForwardingRule with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ForwardingRule) ValidateAll ¶
func (m *ForwardingRule) ValidateAll() error
ValidateAll checks the field values on ForwardingRule with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ForwardingRuleMultiError, or nil if none found.
type ForwardingRuleMultiError ¶
type ForwardingRuleMultiError []error
ForwardingRuleMultiError is an error wrapping multiple validation errors returned by ForwardingRule.ValidateAll() if the designated constraints aren't met.
func (ForwardingRuleMultiError) AllErrors ¶
func (m ForwardingRuleMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ForwardingRuleMultiError) Error ¶
func (m ForwardingRuleMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ForwardingRuleValidationError ¶
type ForwardingRuleValidationError struct {
// contains filtered or unexported fields
}
ForwardingRuleValidationError is the validation error returned by ForwardingRule.Validate if the designated constraints aren't met.
func (ForwardingRuleValidationError) Cause ¶
func (e ForwardingRuleValidationError) Cause() error
Cause function returns cause value.
func (ForwardingRuleValidationError) Error ¶
func (e ForwardingRuleValidationError) Error() string
Error satisfies the builtin error interface
func (ForwardingRuleValidationError) ErrorName ¶
func (e ForwardingRuleValidationError) ErrorName() string
ErrorName returns error name.
func (ForwardingRuleValidationError) Field ¶
func (e ForwardingRuleValidationError) Field() string
Field function returns field value.
func (ForwardingRuleValidationError) Key ¶
func (e ForwardingRuleValidationError) Key() bool
Key function returns key value.
func (ForwardingRuleValidationError) Reason ¶
func (e ForwardingRuleValidationError) Reason() string
Reason function returns reason value.
type ForwardingRule_TopicPrefix ¶
type ForwardingRule_TopicPrefix struct { // Intended place for future types of forwarding rules. TopicPrefix string `protobuf:"bytes,2,opt,name=topic_prefix,json=topicPrefix,proto3,oneof"` }
type KafkaClusterDefinition ¶
type KafkaClusterDefinition struct { // Cluster name. ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` // Kafka cluster address. BootstrapServers string `protobuf:"bytes,2,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"` // Default number of partitions present in this cluster. // This is especially important for clients that do not specify partition in their payloads and depend on this value for hashing. // The same number of partitions is going to be used by upstream-pointing Kafka consumers for consumer proxying scenarios. PartitionCount int32 `protobuf:"varint,3,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"` // Custom configuration passed to Kafka producer. ProducerConfig map[string]string `` /* 191-byte string literal not displayed */ // Custom configuration passed to Kafka consumer. ConsumerConfig map[string]string `` /* 191-byte string literal not displayed */ // contains filtered or unexported fields }
[#next-free-field: 6]
func (*KafkaClusterDefinition) Descriptor
deprecated
func (*KafkaClusterDefinition) Descriptor() ([]byte, []int)
Deprecated: Use KafkaClusterDefinition.ProtoReflect.Descriptor instead.
func (*KafkaClusterDefinition) GetBootstrapServers ¶
func (x *KafkaClusterDefinition) GetBootstrapServers() string
func (*KafkaClusterDefinition) GetClusterName ¶
func (x *KafkaClusterDefinition) GetClusterName() string
func (*KafkaClusterDefinition) GetConsumerConfig ¶ added in v0.11.1
func (x *KafkaClusterDefinition) GetConsumerConfig() map[string]string
func (*KafkaClusterDefinition) GetPartitionCount ¶
func (x *KafkaClusterDefinition) GetPartitionCount() int32
func (*KafkaClusterDefinition) GetProducerConfig ¶
func (x *KafkaClusterDefinition) GetProducerConfig() map[string]string
func (*KafkaClusterDefinition) ProtoMessage ¶
func (*KafkaClusterDefinition) ProtoMessage()
func (*KafkaClusterDefinition) ProtoReflect ¶
func (x *KafkaClusterDefinition) ProtoReflect() protoreflect.Message
func (*KafkaClusterDefinition) Reset ¶
func (x *KafkaClusterDefinition) Reset()
func (*KafkaClusterDefinition) String ¶
func (x *KafkaClusterDefinition) String() string
func (*KafkaClusterDefinition) Validate ¶
func (m *KafkaClusterDefinition) Validate() error
Validate checks the field values on KafkaClusterDefinition with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*KafkaClusterDefinition) ValidateAll ¶
func (m *KafkaClusterDefinition) ValidateAll() error
ValidateAll checks the field values on KafkaClusterDefinition with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KafkaClusterDefinitionMultiError, or nil if none found.
type KafkaClusterDefinitionMultiError ¶
type KafkaClusterDefinitionMultiError []error
KafkaClusterDefinitionMultiError is an error wrapping multiple validation errors returned by KafkaClusterDefinition.ValidateAll() if the designated constraints aren't met.
func (KafkaClusterDefinitionMultiError) AllErrors ¶
func (m KafkaClusterDefinitionMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (KafkaClusterDefinitionMultiError) Error ¶
func (m KafkaClusterDefinitionMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type KafkaClusterDefinitionValidationError ¶
type KafkaClusterDefinitionValidationError struct {
// contains filtered or unexported fields
}
KafkaClusterDefinitionValidationError is the validation error returned by KafkaClusterDefinition.Validate if the designated constraints aren't met.
func (KafkaClusterDefinitionValidationError) Cause ¶
func (e KafkaClusterDefinitionValidationError) Cause() error
Cause function returns cause value.
func (KafkaClusterDefinitionValidationError) Error ¶
func (e KafkaClusterDefinitionValidationError) Error() string
Error satisfies the builtin error interface
func (KafkaClusterDefinitionValidationError) ErrorName ¶
func (e KafkaClusterDefinitionValidationError) ErrorName() string
ErrorName returns error name.
func (KafkaClusterDefinitionValidationError) Field ¶
func (e KafkaClusterDefinitionValidationError) Field() string
Field function returns field value.
func (KafkaClusterDefinitionValidationError) Key ¶
func (e KafkaClusterDefinitionValidationError) Key() bool
Key function returns key value.
func (KafkaClusterDefinitionValidationError) Reason ¶
func (e KafkaClusterDefinitionValidationError) Reason() string
Reason function returns reason value.
type KafkaMesh ¶
type KafkaMesh struct { // Envoy's host that's advertised to clients. // Has the same meaning as corresponding Kafka broker properties. // Usually equal to filter chain's listener config, but needs to be reachable by clients // (so 0.0.0.0 will not work). AdvertisedHost string `protobuf:"bytes,1,opt,name=advertised_host,json=advertisedHost,proto3" json:"advertised_host,omitempty"` // Envoy's port that's advertised to clients. AdvertisedPort int32 `protobuf:"varint,2,opt,name=advertised_port,json=advertisedPort,proto3" json:"advertised_port,omitempty"` // Upstream clusters this filter will connect to. UpstreamClusters []*KafkaClusterDefinition `protobuf:"bytes,3,rep,name=upstream_clusters,json=upstreamClusters,proto3" json:"upstream_clusters,omitempty"` // Rules that will decide which cluster gets which request. ForwardingRules []*ForwardingRule `protobuf:"bytes,4,rep,name=forwarding_rules,json=forwardingRules,proto3" json:"forwarding_rules,omitempty"` // How the consumer proxying should behave - this relates mostly to Fetch request handling. ConsumerProxyMode KafkaMesh_ConsumerProxyMode `` /* 200-byte string literal not displayed */ // contains filtered or unexported fields }
[#next-free-field: 6]
func (*KafkaMesh) Descriptor
deprecated
func (*KafkaMesh) GetAdvertisedHost ¶
func (*KafkaMesh) GetAdvertisedPort ¶
func (*KafkaMesh) GetConsumerProxyMode ¶ added in v0.11.1
func (x *KafkaMesh) GetConsumerProxyMode() KafkaMesh_ConsumerProxyMode
func (*KafkaMesh) GetForwardingRules ¶
func (x *KafkaMesh) GetForwardingRules() []*ForwardingRule
func (*KafkaMesh) GetUpstreamClusters ¶
func (x *KafkaMesh) GetUpstreamClusters() []*KafkaClusterDefinition
func (*KafkaMesh) ProtoMessage ¶
func (*KafkaMesh) ProtoMessage()
func (*KafkaMesh) ProtoReflect ¶
func (x *KafkaMesh) ProtoReflect() protoreflect.Message
func (*KafkaMesh) Validate ¶
Validate checks the field values on KafkaMesh with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*KafkaMesh) ValidateAll ¶
ValidateAll checks the field values on KafkaMesh with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KafkaMeshMultiError, or nil if none found.
type KafkaMeshMultiError ¶
type KafkaMeshMultiError []error
KafkaMeshMultiError is an error wrapping multiple validation errors returned by KafkaMesh.ValidateAll() if the designated constraints aren't met.
func (KafkaMeshMultiError) AllErrors ¶
func (m KafkaMeshMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (KafkaMeshMultiError) Error ¶
func (m KafkaMeshMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type KafkaMeshValidationError ¶
type KafkaMeshValidationError struct {
// contains filtered or unexported fields
}
KafkaMeshValidationError is the validation error returned by KafkaMesh.Validate if the designated constraints aren't met.
func (KafkaMeshValidationError) Cause ¶
func (e KafkaMeshValidationError) Cause() error
Cause function returns cause value.
func (KafkaMeshValidationError) Error ¶
func (e KafkaMeshValidationError) Error() string
Error satisfies the builtin error interface
func (KafkaMeshValidationError) ErrorName ¶
func (e KafkaMeshValidationError) ErrorName() string
ErrorName returns error name.
func (KafkaMeshValidationError) Field ¶
func (e KafkaMeshValidationError) Field() string
Field function returns field value.
func (KafkaMeshValidationError) Key ¶
func (e KafkaMeshValidationError) Key() bool
Key function returns key value.
func (KafkaMeshValidationError) Reason ¶
func (e KafkaMeshValidationError) Reason() string
Reason function returns reason value.
type KafkaMesh_ConsumerProxyMode ¶ added in v0.11.1
type KafkaMesh_ConsumerProxyMode int32
const ( // Records received are going to be distributed amongst downstream consumer connections. // In this mode Envoy uses librdkafka consumers pointing at upstream Kafka clusters, what means that these // consumers' position is meaningful and affects what records are received from upstream. // Users might want to take a look into these consumers' custom configuration to manage their auto-committing // capabilities, as it will impact Envoy's behaviour in case of restarts. KafkaMesh_StatefulConsumerProxy KafkaMesh_ConsumerProxyMode = 0 )
func (KafkaMesh_ConsumerProxyMode) Descriptor ¶ added in v0.11.1
func (KafkaMesh_ConsumerProxyMode) Descriptor() protoreflect.EnumDescriptor
func (KafkaMesh_ConsumerProxyMode) Enum ¶ added in v0.11.1
func (x KafkaMesh_ConsumerProxyMode) Enum() *KafkaMesh_ConsumerProxyMode
func (KafkaMesh_ConsumerProxyMode) EnumDescriptor
deprecated
added in
v0.11.1
func (KafkaMesh_ConsumerProxyMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use KafkaMesh_ConsumerProxyMode.Descriptor instead.
func (KafkaMesh_ConsumerProxyMode) Number ¶ added in v0.11.1
func (x KafkaMesh_ConsumerProxyMode) Number() protoreflect.EnumNumber
func (KafkaMesh_ConsumerProxyMode) String ¶ added in v0.11.1
func (x KafkaMesh_ConsumerProxyMode) String() string
func (KafkaMesh_ConsumerProxyMode) Type ¶ added in v0.11.1
func (KafkaMesh_ConsumerProxyMode) Type() protoreflect.EnumType