v2alpha1

package
v0.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 2, 2024 License: Apache-2.0 Imports: 18 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.