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
- func (m *KafkaBroker) Validate() error
- func (m *KafkaBroker) ValidateAll() error
- type KafkaBrokerMultiError
- type KafkaBrokerValidationError
- func (e KafkaBrokerValidationError) Cause() error
- func (e KafkaBrokerValidationError) Error() string
- func (e KafkaBrokerValidationError) ErrorName() string
- func (e KafkaBrokerValidationError) Field() string
- func (e KafkaBrokerValidationError) Key() bool
- func (e KafkaBrokerValidationError) Reason() string
- type KafkaBroker_IdBasedBrokerAddressRewriteSpec
Constants ¶
This section is empty.
Variables ¶
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
func (*KafkaBroker) Validate ¶
func (m *KafkaBroker) Validate() error
Validate checks the field values on KafkaBroker 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 (*KafkaBroker) ValidateAll ¶
func (m *KafkaBroker) ValidateAll() error
ValidateAll checks the field values on KafkaBroker 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 KafkaBrokerMultiError, or nil if none found.
type KafkaBrokerMultiError ¶
type KafkaBrokerMultiError []error
KafkaBrokerMultiError is an error wrapping multiple validation errors returned by KafkaBroker.ValidateAll() if the designated constraints aren't met.
func (KafkaBrokerMultiError) AllErrors ¶
func (m KafkaBrokerMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (KafkaBrokerMultiError) Error ¶
func (m KafkaBrokerMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type KafkaBrokerValidationError ¶
type KafkaBrokerValidationError struct {
// contains filtered or unexported fields
}
KafkaBrokerValidationError is the validation error returned by KafkaBroker.Validate if the designated constraints aren't met.
func (KafkaBrokerValidationError) Cause ¶
func (e KafkaBrokerValidationError) Cause() error
Cause function returns cause value.
func (KafkaBrokerValidationError) Error ¶
func (e KafkaBrokerValidationError) Error() string
Error satisfies the builtin error interface
func (KafkaBrokerValidationError) ErrorName ¶
func (e KafkaBrokerValidationError) ErrorName() string
ErrorName returns error name.
func (KafkaBrokerValidationError) Field ¶
func (e KafkaBrokerValidationError) Field() string
Field function returns field value.
func (KafkaBrokerValidationError) Key ¶
func (e KafkaBrokerValidationError) Key() bool
Key function returns key value.
func (KafkaBrokerValidationError) Reason ¶
func (e KafkaBrokerValidationError) Reason() string
Reason function returns reason value.
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"` }