v3alpha

package
v0.11.3 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	KafkaMesh_ConsumerProxyMode_name = map[int32]string{
		0: "StatefulConsumerProxy",
	}
	KafkaMesh_ConsumerProxyMode_value = map[string]int32{
		"StatefulConsumerProxy": 0,
	}
)

Enum value maps for KafkaMesh_ConsumerProxyMode.

View Source 
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 

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) Descriptor() ([]byte, []int)

Deprecated: Use KafkaMesh.ProtoReflect.Descriptor instead.

func (*KafkaMesh) GetAdvertisedHost 

func (x *KafkaMesh) GetAdvertisedHost() string

func (*KafkaMesh) GetAdvertisedPort 

func (x *KafkaMesh) GetAdvertisedPort() int32

func (*KafkaMesh) GetConsumerProxyMode 

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) Reset 

func (x *KafkaMesh) Reset()

func (*KafkaMesh) String 

func (x *KafkaMesh) String() string

func (*KafkaMesh) Validate 

func (m *KafkaMesh) Validate() error

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 

func (m *KafkaMesh) ValidateAll() error

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 

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 

func (KafkaMesh_ConsumerProxyMode) Descriptor() protoreflect.EnumDescriptor

func (KafkaMesh_ConsumerProxyMode) Enum 

func (x KafkaMesh_ConsumerProxyMode) Enum() *KafkaMesh_ConsumerProxyMode

func (KafkaMesh_ConsumerProxyMode) EnumDescriptor deprecated 

func (KafkaMesh_ConsumerProxyMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use KafkaMesh_ConsumerProxyMode.Descriptor instead.

func (KafkaMesh_ConsumerProxyMode) Number 

func (x KafkaMesh_ConsumerProxyMode) Number() protoreflect.EnumNumber

func (KafkaMesh_ConsumerProxyMode) String 

func (x KafkaMesh_ConsumerProxyMode) String() string

func (KafkaMesh_ConsumerProxyMode) Type 

func (KafkaMesh_ConsumerProxyMode) Type() protoreflect.EnumType

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.