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
- func (m *IdBasedBrokerRewriteRule) Validate() error
- func (m *IdBasedBrokerRewriteRule) ValidateAll() error
- type IdBasedBrokerRewriteRuleMultiError
- type IdBasedBrokerRewriteRuleValidationError
- func (e IdBasedBrokerRewriteRuleValidationError) Cause() error
- func (e IdBasedBrokerRewriteRuleValidationError) Error() string
- func (e IdBasedBrokerRewriteRuleValidationError) ErrorName() string
- func (e IdBasedBrokerRewriteRuleValidationError) Field() string
- func (e IdBasedBrokerRewriteRuleValidationError) Key() bool
- func (e IdBasedBrokerRewriteRuleValidationError) Reason() 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
- func (m *IdBasedBrokerRewriteSpec) Validate() error
- func (m *IdBasedBrokerRewriteSpec) ValidateAll() error
- type IdBasedBrokerRewriteSpecMultiError
- type IdBasedBrokerRewriteSpecValidationError
- func (e IdBasedBrokerRewriteSpecValidationError) Cause() error
- func (e IdBasedBrokerRewriteSpecValidationError) Error() string
- func (e IdBasedBrokerRewriteSpecValidationError) ErrorName() string
- func (e IdBasedBrokerRewriteSpecValidationError) Field() string
- func (e IdBasedBrokerRewriteSpecValidationError) Key() bool
- func (e IdBasedBrokerRewriteSpecValidationError) Reason() 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_envoy_config_filter_network_kafka_broker_v2alpha1_kafka_broker_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type IdBasedBrokerRewriteRule ¶ added in v0.12.0
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
added in
v0.12.0
func (*IdBasedBrokerRewriteRule) Descriptor() ([]byte, []int)
Deprecated: Use IdBasedBrokerRewriteRule.ProtoReflect.Descriptor instead.
func (*IdBasedBrokerRewriteRule) GetHost ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteRule) GetHost() string
func (*IdBasedBrokerRewriteRule) GetId ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteRule) GetId() uint32
func (*IdBasedBrokerRewriteRule) GetPort ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteRule) GetPort() uint32
func (*IdBasedBrokerRewriteRule) ProtoMessage ¶ added in v0.12.0
func (*IdBasedBrokerRewriteRule) ProtoMessage()
func (*IdBasedBrokerRewriteRule) ProtoReflect ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteRule) ProtoReflect() protoreflect.Message
func (*IdBasedBrokerRewriteRule) Reset ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteRule) Reset()
func (*IdBasedBrokerRewriteRule) String ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteRule) String() string
func (*IdBasedBrokerRewriteRule) Validate ¶ added in v0.12.0
func (m *IdBasedBrokerRewriteRule) Validate() error
Validate checks the field values on IdBasedBrokerRewriteRule 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 (*IdBasedBrokerRewriteRule) ValidateAll ¶ added in v0.12.0
func (m *IdBasedBrokerRewriteRule) ValidateAll() error
ValidateAll checks the field values on IdBasedBrokerRewriteRule 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 IdBasedBrokerRewriteRuleMultiError, or nil if none found.
type IdBasedBrokerRewriteRuleMultiError ¶ added in v0.12.0
type IdBasedBrokerRewriteRuleMultiError []error
IdBasedBrokerRewriteRuleMultiError is an error wrapping multiple validation errors returned by IdBasedBrokerRewriteRule.ValidateAll() if the designated constraints aren't met.
func (IdBasedBrokerRewriteRuleMultiError) AllErrors ¶ added in v0.12.0
func (m IdBasedBrokerRewriteRuleMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (IdBasedBrokerRewriteRuleMultiError) Error ¶ added in v0.12.0
func (m IdBasedBrokerRewriteRuleMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type IdBasedBrokerRewriteRuleValidationError ¶ added in v0.12.0
type IdBasedBrokerRewriteRuleValidationError struct {
// contains filtered or unexported fields
}
IdBasedBrokerRewriteRuleValidationError is the validation error returned by IdBasedBrokerRewriteRule.Validate if the designated constraints aren't met.
func (IdBasedBrokerRewriteRuleValidationError) Cause ¶ added in v0.12.0
func (e IdBasedBrokerRewriteRuleValidationError) Cause() error
Cause function returns cause value.
func (IdBasedBrokerRewriteRuleValidationError) Error ¶ added in v0.12.0
func (e IdBasedBrokerRewriteRuleValidationError) Error() string
Error satisfies the builtin error interface
func (IdBasedBrokerRewriteRuleValidationError) ErrorName ¶ added in v0.12.0
func (e IdBasedBrokerRewriteRuleValidationError) ErrorName() string
ErrorName returns error name.
func (IdBasedBrokerRewriteRuleValidationError) Field ¶ added in v0.12.0
func (e IdBasedBrokerRewriteRuleValidationError) Field() string
Field function returns field value.
func (IdBasedBrokerRewriteRuleValidationError) Key ¶ added in v0.12.0
func (e IdBasedBrokerRewriteRuleValidationError) Key() bool
Key function returns key value.
func (IdBasedBrokerRewriteRuleValidationError) Reason ¶ added in v0.12.0
func (e IdBasedBrokerRewriteRuleValidationError) Reason() string
Reason function returns reason value.
type IdBasedBrokerRewriteSpec ¶ added in v0.12.0
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
added in
v0.12.0
func (*IdBasedBrokerRewriteSpec) Descriptor() ([]byte, []int)
Deprecated: Use IdBasedBrokerRewriteSpec.ProtoReflect.Descriptor instead.
func (*IdBasedBrokerRewriteSpec) GetRules ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteSpec) GetRules() []*IdBasedBrokerRewriteRule
func (*IdBasedBrokerRewriteSpec) ProtoMessage ¶ added in v0.12.0
func (*IdBasedBrokerRewriteSpec) ProtoMessage()
func (*IdBasedBrokerRewriteSpec) ProtoReflect ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteSpec) ProtoReflect() protoreflect.Message
func (*IdBasedBrokerRewriteSpec) Reset ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteSpec) Reset()
func (*IdBasedBrokerRewriteSpec) String ¶ added in v0.12.0
func (x *IdBasedBrokerRewriteSpec) String() string
func (*IdBasedBrokerRewriteSpec) Validate ¶ added in v0.12.0
func (m *IdBasedBrokerRewriteSpec) Validate() error
Validate checks the field values on IdBasedBrokerRewriteSpec 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 (*IdBasedBrokerRewriteSpec) ValidateAll ¶ added in v0.12.0
func (m *IdBasedBrokerRewriteSpec) ValidateAll() error
ValidateAll checks the field values on IdBasedBrokerRewriteSpec 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 IdBasedBrokerRewriteSpecMultiError, or nil if none found.
type IdBasedBrokerRewriteSpecMultiError ¶ added in v0.12.0
type IdBasedBrokerRewriteSpecMultiError []error
IdBasedBrokerRewriteSpecMultiError is an error wrapping multiple validation errors returned by IdBasedBrokerRewriteSpec.ValidateAll() if the designated constraints aren't met.
func (IdBasedBrokerRewriteSpecMultiError) AllErrors ¶ added in v0.12.0
func (m IdBasedBrokerRewriteSpecMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (IdBasedBrokerRewriteSpecMultiError) Error ¶ added in v0.12.0
func (m IdBasedBrokerRewriteSpecMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type IdBasedBrokerRewriteSpecValidationError ¶ added in v0.12.0
type IdBasedBrokerRewriteSpecValidationError struct {
// contains filtered or unexported fields
}
IdBasedBrokerRewriteSpecValidationError is the validation error returned by IdBasedBrokerRewriteSpec.Validate if the designated constraints aren't met.
func (IdBasedBrokerRewriteSpecValidationError) Cause ¶ added in v0.12.0
func (e IdBasedBrokerRewriteSpecValidationError) Cause() error
Cause function returns cause value.
func (IdBasedBrokerRewriteSpecValidationError) Error ¶ added in v0.12.0
func (e IdBasedBrokerRewriteSpecValidationError) Error() string
Error satisfies the builtin error interface
func (IdBasedBrokerRewriteSpecValidationError) ErrorName ¶ added in v0.12.0
func (e IdBasedBrokerRewriteSpecValidationError) ErrorName() string
ErrorName returns error name.
func (IdBasedBrokerRewriteSpecValidationError) Field ¶ added in v0.12.0
func (e IdBasedBrokerRewriteSpecValidationError) Field() string
Field function returns field value.
func (IdBasedBrokerRewriteSpecValidationError) Key ¶ added in v0.12.0
func (e IdBasedBrokerRewriteSpecValidationError) Key() bool
Key function returns key value.
func (IdBasedBrokerRewriteSpecValidationError) Reason ¶ added in v0.12.0
func (e IdBasedBrokerRewriteSpecValidationError) Reason() string
Reason function returns reason value.
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 ¶ added in v0.12.0
func (m *KafkaBroker) GetBrokerAddressRewriteSpec() isKafkaBroker_BrokerAddressRewriteSpec
func (*KafkaBroker) GetForceResponseRewrite ¶ added in v0.12.0
func (x *KafkaBroker) GetForceResponseRewrite() bool
func (*KafkaBroker) GetIdBasedBrokerAddressRewriteSpec ¶ added in v0.12.0
func (x *KafkaBroker) GetIdBasedBrokerAddressRewriteSpec() *IdBasedBrokerRewriteSpec
func (*KafkaBroker) GetStatPrefix ¶
func (x *KafkaBroker) GetStatPrefix() string
func (*KafkaBroker) ProtoMessage ¶
func (*KafkaBroker) ProtoMessage()
func (*KafkaBroker) ProtoReflect ¶ added in v0.9.6
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 ¶ added in v0.10.0
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 ¶ added in v0.10.0
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 ¶ added in v0.10.0
func (m KafkaBrokerMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (KafkaBrokerMultiError) Error ¶ added in v0.10.0
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 ¶ added in v0.12.0
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"` }