Documentation ¶
Index ¶
- Variables
- type IdBasedBrokerRewriteRule
- func (*IdBasedBrokerRewriteRule) Descriptor() ([]byte, []int)deprecated
- func (x *IdBasedBrokerRewriteRule) GetHost() string
- func (x *IdBasedBrokerRewriteRule) GetId() uint32
- func (x *IdBasedBrokerRewriteRule) GetPort() uint32
- func (*IdBasedBrokerRewriteRule) ProtoMessage()
- func (x *IdBasedBrokerRewriteRule) ProtoReflect() protoreflect.Message
- func (x *IdBasedBrokerRewriteRule) Reset()
- func (x *IdBasedBrokerRewriteRule) String() string
- type IdBasedBrokerRewriteSpec
- func (*IdBasedBrokerRewriteSpec) Descriptor() ([]byte, []int)deprecated
- func (x *IdBasedBrokerRewriteSpec) GetRules() []*IdBasedBrokerRewriteRule
- func (*IdBasedBrokerRewriteSpec) ProtoMessage()
- func (x *IdBasedBrokerRewriteSpec) ProtoReflect() protoreflect.Message
- func (x *IdBasedBrokerRewriteSpec) Reset()
- func (x *IdBasedBrokerRewriteSpec) String() string
- type KafkaBroker
- func (*KafkaBroker) Descriptor() ([]byte, []int)deprecated
- func (m *KafkaBroker) GetBrokerAddressRewriteSpec() isKafkaBroker_BrokerAddressRewriteSpec
- func (x *KafkaBroker) GetForceResponseRewrite() bool
- func (x *KafkaBroker) GetIdBasedBrokerAddressRewriteSpec() *IdBasedBrokerRewriteSpec
- func (x *KafkaBroker) GetStatPrefix() string
- func (*KafkaBroker) ProtoMessage()
- func (x *KafkaBroker) ProtoReflect() protoreflect.Message
- func (x *KafkaBroker) Reset()
- func (x *KafkaBroker) String() string
- type KafkaBroker_IdBasedBrokerAddressRewriteSpec
Constants ¶
This section is empty.
Variables ¶
View Source
var File_contrib_envoy_extensions_filters_network_kafka_broker_v3_kafka_broker_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type IdBasedBrokerRewriteRule ¶
type IdBasedBrokerRewriteRule struct { // Broker ID to match. Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // The host value to use (resembling the host part of Kafka's advertised.listeners). // The value should point to the Envoy (not Kafka) listener, so that all client traffic goes // through Envoy. Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // The port value to use (resembling the port part of Kafka's advertised.listeners). // The value should point to the Envoy (not Kafka) listener, so that all client traffic goes // through Envoy. Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
Defines a rule to rewrite broker address data.
func (*IdBasedBrokerRewriteRule) Descriptor
deprecated
func (*IdBasedBrokerRewriteRule) Descriptor() ([]byte, []int)
Deprecated: Use IdBasedBrokerRewriteRule.ProtoReflect.Descriptor instead.
func (*IdBasedBrokerRewriteRule) GetHost ¶
func (x *IdBasedBrokerRewriteRule) GetHost() string
func (*IdBasedBrokerRewriteRule) GetId ¶
func (x *IdBasedBrokerRewriteRule) GetId() uint32
func (*IdBasedBrokerRewriteRule) GetPort ¶
func (x *IdBasedBrokerRewriteRule) GetPort() uint32
func (*IdBasedBrokerRewriteRule) ProtoMessage ¶
func (*IdBasedBrokerRewriteRule) ProtoMessage()
func (*IdBasedBrokerRewriteRule) ProtoReflect ¶
func (x *IdBasedBrokerRewriteRule) ProtoReflect() protoreflect.Message
func (*IdBasedBrokerRewriteRule) Reset ¶
func (x *IdBasedBrokerRewriteRule) Reset()
func (*IdBasedBrokerRewriteRule) String ¶
func (x *IdBasedBrokerRewriteRule) String() string
type IdBasedBrokerRewriteSpec ¶
type IdBasedBrokerRewriteSpec struct { Rules []*IdBasedBrokerRewriteRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"` // contains filtered or unexported fields }
Collection of rules matching by broker ID.
func (*IdBasedBrokerRewriteSpec) Descriptor
deprecated
func (*IdBasedBrokerRewriteSpec) Descriptor() ([]byte, []int)
Deprecated: Use IdBasedBrokerRewriteSpec.ProtoReflect.Descriptor instead.
func (*IdBasedBrokerRewriteSpec) GetRules ¶
func (x *IdBasedBrokerRewriteSpec) GetRules() []*IdBasedBrokerRewriteRule
func (*IdBasedBrokerRewriteSpec) ProtoMessage ¶
func (*IdBasedBrokerRewriteSpec) ProtoMessage()
func (*IdBasedBrokerRewriteSpec) ProtoReflect ¶
func (x *IdBasedBrokerRewriteSpec) ProtoReflect() protoreflect.Message
func (*IdBasedBrokerRewriteSpec) Reset ¶
func (x *IdBasedBrokerRewriteSpec) Reset()
func (*IdBasedBrokerRewriteSpec) String ¶
func (x *IdBasedBrokerRewriteSpec) String() string
type KafkaBroker ¶
type KafkaBroker struct { // The prefix to use when emitting :ref:`statistics <config_network_filters_kafka_broker_stats>`. StatPrefix string `protobuf:"bytes,1,opt,name=stat_prefix,json=statPrefix,proto3" json:"stat_prefix,omitempty"` // Set to true if broker filter should attempt to serialize the received responses from the // upstream broker instead of passing received bytes as is. // Disabled by default. ForceResponseRewrite bool `protobuf:"varint,2,opt,name=force_response_rewrite,json=forceResponseRewrite,proto3" json:"force_response_rewrite,omitempty"` // Optional broker address rewrite specification. // Allows the broker filter to rewrite Kafka responses so that all connections established by // the Kafka clients point to Envoy. // This allows Kafka cluster not to configure its 'advertised.listeners' property // (as the necessary re-pointing will be done by this filter). // This collection of rules should cover all brokers in the cluster that is being proxied, // otherwise some nodes' addresses might leak to the downstream clients. // // Types that are assignable to BrokerAddressRewriteSpec: // // *KafkaBroker_IdBasedBrokerAddressRewriteSpec BrokerAddressRewriteSpec isKafkaBroker_BrokerAddressRewriteSpec `protobuf_oneof:"broker_address_rewrite_spec"` // contains filtered or unexported fields }
func (*KafkaBroker) Descriptor
deprecated
func (*KafkaBroker) Descriptor() ([]byte, []int)
Deprecated: Use KafkaBroker.ProtoReflect.Descriptor instead.
func (*KafkaBroker) GetBrokerAddressRewriteSpec ¶
func (m *KafkaBroker) GetBrokerAddressRewriteSpec() isKafkaBroker_BrokerAddressRewriteSpec
func (*KafkaBroker) GetForceResponseRewrite ¶
func (x *KafkaBroker) GetForceResponseRewrite() bool
func (*KafkaBroker) GetIdBasedBrokerAddressRewriteSpec ¶
func (x *KafkaBroker) GetIdBasedBrokerAddressRewriteSpec() *IdBasedBrokerRewriteSpec
func (*KafkaBroker) GetStatPrefix ¶
func (x *KafkaBroker) GetStatPrefix() string
func (*KafkaBroker) ProtoMessage ¶
func (*KafkaBroker) ProtoMessage()
func (*KafkaBroker) ProtoReflect ¶
func (x *KafkaBroker) ProtoReflect() protoreflect.Message
func (*KafkaBroker) Reset ¶
func (x *KafkaBroker) Reset()
func (*KafkaBroker) String ¶
func (x *KafkaBroker) String() string
type KafkaBroker_IdBasedBrokerAddressRewriteSpec ¶
type KafkaBroker_IdBasedBrokerAddressRewriteSpec struct { // Broker address rewrite rules that match by broker ID. IdBasedBrokerAddressRewriteSpec *IdBasedBrokerRewriteSpec `protobuf:"bytes,3,opt,name=id_based_broker_address_rewrite_spec,json=idBasedBrokerAddressRewriteSpec,proto3,oneof"` }
Click to show internal directories.
Click to hide internal directories.