Documentation ¶
Index ¶
- Variables
- type ForwardingRule
- func (*ForwardingRule) Descriptor() ([]byte, []int)deprecated
- func (x *ForwardingRule) GetTargetCluster() string
- func (x *ForwardingRule) GetTopicPrefix() string
- func (m *ForwardingRule) GetTrigger() isForwardingRule_Trigger
- func (*ForwardingRule) ProtoMessage()
- func (x *ForwardingRule) ProtoReflect() protoreflect.Message
- func (x *ForwardingRule) Reset()
- func (x *ForwardingRule) String() string
- func (m *ForwardingRule) Validate() error
- func (m *ForwardingRule) ValidateAll() error
- type ForwardingRuleMultiError
- type ForwardingRuleValidationError
- func (e ForwardingRuleValidationError) Cause() error
- func (e ForwardingRuleValidationError) Error() string
- func (e ForwardingRuleValidationError) ErrorName() string
- func (e ForwardingRuleValidationError) Field() string
- func (e ForwardingRuleValidationError) Key() bool
- func (e ForwardingRuleValidationError) Reason() string
- type ForwardingRule_TopicPrefix
- type KafkaClusterDefinition
- func (*KafkaClusterDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaClusterDefinition) GetBootstrapServers() string
- func (x *KafkaClusterDefinition) GetClusterName() string
- func (x *KafkaClusterDefinition) GetPartitionCount() int32
- func (x *KafkaClusterDefinition) GetProducerConfig() map[string]string
- func (*KafkaClusterDefinition) ProtoMessage()
- func (x *KafkaClusterDefinition) ProtoReflect() protoreflect.Message
- func (x *KafkaClusterDefinition) Reset()
- func (x *KafkaClusterDefinition) String() string
- func (m *KafkaClusterDefinition) Validate() error
- func (m *KafkaClusterDefinition) ValidateAll() error
- type KafkaClusterDefinitionMultiError
- type KafkaClusterDefinitionValidationError
- func (e KafkaClusterDefinitionValidationError) Cause() error
- func (e KafkaClusterDefinitionValidationError) Error() string
- func (e KafkaClusterDefinitionValidationError) ErrorName() string
- func (e KafkaClusterDefinitionValidationError) Field() string
- func (e KafkaClusterDefinitionValidationError) Key() bool
- func (e KafkaClusterDefinitionValidationError) Reason() string
- type KafkaMesh
- func (*KafkaMesh) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaMesh) GetAdvertisedHost() string
- func (x *KafkaMesh) GetAdvertisedPort() int32
- func (x *KafkaMesh) GetForwardingRules() []*ForwardingRule
- func (x *KafkaMesh) GetUpstreamClusters() []*KafkaClusterDefinition
- func (*KafkaMesh) ProtoMessage()
- func (x *KafkaMesh) ProtoReflect() protoreflect.Message
- func (x *KafkaMesh) Reset()
- func (x *KafkaMesh) String() string
- func (m *KafkaMesh) Validate() error
- func (m *KafkaMesh) ValidateAll() error
- type KafkaMeshMultiError
- type KafkaMeshValidationError
Constants ¶
This section is empty.
Variables ¶
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. 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 */ // contains filtered or unexported fields }
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) 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"` // contains filtered or unexported fields }
func (*KafkaMesh) Descriptor
deprecated
func (*KafkaMesh) GetAdvertisedHost ¶
func (*KafkaMesh) GetAdvertisedPort ¶
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) Validate ¶
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 ¶
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.