envoy_extensions_filters_network_tcp_proxy_v3

package
v1.5.5 Latest Latest
Warning

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

Go to latest
Published: Jun 30, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTcpProxy        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTcpProxy          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTcpProxy = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type TcpProxy

type TcpProxy struct {
	// The prefix to use when emitting :ref:`statistics
	// <config_network_filters_tcp_proxy_stats>`.
	StatPrefix string `protobuf:"bytes,1,opt,name=stat_prefix,json=statPrefix,proto3" json:"stat_prefix,omitempty"`
	// Types that are valid to be assigned to ClusterSpecifier:
	//	*TcpProxy_Cluster
	//	*TcpProxy_WeightedClusters
	ClusterSpecifier isTcpProxy_ClusterSpecifier `protobuf_oneof:"cluster_specifier"`
	// Optional endpoint metadata match criteria. Only endpoints in the upstream
	// cluster with metadata matching that set in metadata_match will be
	// considered. The filter name should be specified as *envoy.lb*.
	MetadataMatch *v3.Metadata `protobuf:"bytes,9,opt,name=metadata_match,json=metadataMatch,proto3" json:"metadata_match,omitempty"`
	// The idle timeout for connections managed by the TCP proxy filter. The idle timeout
	// is defined as the period in which there are no bytes sent or received on either
	// the upstream or downstream connection. If not set, the default idle timeout is 1 hour. If set
	// to 0s, the timeout will be disabled.
	//
	// .. warning::
	//   Disabling this timeout has a highly likelihood of yielding connection leaks due to lost TCP
	//   FIN packets, etc.
	IdleTimeout *types.Duration `protobuf:"bytes,8,opt,name=idle_timeout,json=idleTimeout,proto3" json:"idle_timeout,omitempty"`
	// [#not-implemented-hide:] The idle timeout for connections managed by the TCP proxy
	// filter. The idle timeout is defined as the period in which there is no
	// active traffic. If not set, there is no idle timeout. When the idle timeout
	// is reached the connection will be closed. The distinction between
	// downstream_idle_timeout/upstream_idle_timeout provides a means to set
	// timeout based on the last byte sent on the downstream/upstream connection.
	DownstreamIdleTimeout *types.Duration `` /* 126-byte string literal not displayed */
	// [#not-implemented-hide:]
	UpstreamIdleTimeout *types.Duration `protobuf:"bytes,4,opt,name=upstream_idle_timeout,json=upstreamIdleTimeout,proto3" json:"upstream_idle_timeout,omitempty"`
	// Configuration for :ref:`access logs <arch_overview_access_logs>`
	// emitted by the this tcp_proxy.
	AccessLog []*v31.AccessLog `protobuf:"bytes,5,rep,name=access_log,json=accessLog,proto3" json:"access_log,omitempty"`
	// The maximum number of unsuccessful connection attempts that will be made before
	// giving up. If the parameter is not specified, 1 connection attempt will be made.
	MaxConnectAttempts *types.UInt32Value `protobuf:"bytes,7,opt,name=max_connect_attempts,json=maxConnectAttempts,proto3" json:"max_connect_attempts,omitempty"`
	// Optional configuration for TCP proxy hash policy. If hash_policy is not set, the hash-based
	// load balancing algorithms will select a host randomly. Currently the number of hash policies is
	// limited to 1.
	HashPolicy []*v32.HashPolicy `protobuf:"bytes,11,rep,name=hash_policy,json=hashPolicy,proto3" json:"hash_policy,omitempty"`
	// [#not-implemented-hide:] feature in progress
	// If set, this configures tunneling, e.g. configuration options to tunnel multiple TCP
	// payloads over a shared HTTP/2 tunnel. If this message is absent, the payload
	// will be proxied upstream as per usual.
	TunnelingConfig      *TcpProxy_TunnelingConfig `protobuf:"bytes,12,opt,name=tunneling_config,json=tunnelingConfig,proto3" json:"tunneling_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

[#next-free-field: 13]

func (*TcpProxy) Descriptor

func (*TcpProxy) Descriptor() ([]byte, []int)

func (*TcpProxy) GetAccessLog

func (m *TcpProxy) GetAccessLog() []*v31.AccessLog

func (*TcpProxy) GetCluster

func (m *TcpProxy) GetCluster() string

func (*TcpProxy) GetClusterSpecifier

func (m *TcpProxy) GetClusterSpecifier() isTcpProxy_ClusterSpecifier

func (*TcpProxy) GetDownstreamIdleTimeout

func (m *TcpProxy) GetDownstreamIdleTimeout() *types.Duration

func (*TcpProxy) GetHashPolicy

func (m *TcpProxy) GetHashPolicy() []*v32.HashPolicy

func (*TcpProxy) GetIdleTimeout

func (m *TcpProxy) GetIdleTimeout() *types.Duration

func (*TcpProxy) GetMaxConnectAttempts

func (m *TcpProxy) GetMaxConnectAttempts() *types.UInt32Value

func (*TcpProxy) GetMetadataMatch

func (m *TcpProxy) GetMetadataMatch() *v3.Metadata

func (*TcpProxy) GetStatPrefix

func (m *TcpProxy) GetStatPrefix() string

func (*TcpProxy) GetTunnelingConfig

func (m *TcpProxy) GetTunnelingConfig() *TcpProxy_TunnelingConfig

func (*TcpProxy) GetUpstreamIdleTimeout

func (m *TcpProxy) GetUpstreamIdleTimeout() *types.Duration

func (*TcpProxy) GetWeightedClusters

func (m *TcpProxy) GetWeightedClusters() *TcpProxy_WeightedCluster

func (*TcpProxy) Marshal

func (m *TcpProxy) Marshal() (dAtA []byte, err error)

func (*TcpProxy) MarshalTo

func (m *TcpProxy) MarshalTo(dAtA []byte) (int, error)

func (*TcpProxy) MarshalToSizedBuffer

func (m *TcpProxy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TcpProxy) ProtoMessage

func (*TcpProxy) ProtoMessage()

func (*TcpProxy) Reset

func (m *TcpProxy) Reset()

func (*TcpProxy) Size

func (m *TcpProxy) Size() (n int)

func (*TcpProxy) String

func (m *TcpProxy) String() string

func (*TcpProxy) Unmarshal

func (m *TcpProxy) Unmarshal(dAtA []byte) error

func (*TcpProxy) Validate

func (m *TcpProxy) Validate() error

Validate checks the field values on TcpProxy with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TcpProxy) XXX_DiscardUnknown

func (m *TcpProxy) XXX_DiscardUnknown()

func (*TcpProxy) XXX_Marshal

func (m *TcpProxy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcpProxy) XXX_Merge

func (m *TcpProxy) XXX_Merge(src proto.Message)

func (*TcpProxy) XXX_OneofWrappers

func (*TcpProxy) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TcpProxy) XXX_Size

func (m *TcpProxy) XXX_Size() int

func (*TcpProxy) XXX_Unmarshal

func (m *TcpProxy) XXX_Unmarshal(b []byte) error

type TcpProxyValidationError

type TcpProxyValidationError struct {
	// contains filtered or unexported fields
}

TcpProxyValidationError is the validation error returned by TcpProxy.Validate if the designated constraints aren't met.

func (TcpProxyValidationError) Cause

func (e TcpProxyValidationError) Cause() error

Cause function returns cause value.

func (TcpProxyValidationError) Error

func (e TcpProxyValidationError) Error() string

Error satisfies the builtin error interface

func (TcpProxyValidationError) ErrorName

func (e TcpProxyValidationError) ErrorName() string

ErrorName returns error name.

func (TcpProxyValidationError) Field

func (e TcpProxyValidationError) Field() string

Field function returns field value.

func (TcpProxyValidationError) Key

func (e TcpProxyValidationError) Key() bool

Key function returns key value.

func (TcpProxyValidationError) Reason

func (e TcpProxyValidationError) Reason() string

Reason function returns reason value.

type TcpProxy_Cluster

type TcpProxy_Cluster struct {
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3,oneof" json:"cluster,omitempty"`
}

func (*TcpProxy_Cluster) MarshalTo

func (m *TcpProxy_Cluster) MarshalTo(dAtA []byte) (int, error)

func (*TcpProxy_Cluster) MarshalToSizedBuffer

func (m *TcpProxy_Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TcpProxy_Cluster) Size

func (m *TcpProxy_Cluster) Size() (n int)

type TcpProxy_TunnelingConfig

type TcpProxy_TunnelingConfig struct {
	// The hostname to send in the synthesized CONNECT headers to the upstream proxy.
	Hostname             string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Configuration for tunneling TCP over other transports or application layers. Currently, only HTTP/2 is supported. When other options exist, HTTP/2 will remain the default.

func (*TcpProxy_TunnelingConfig) Descriptor

func (*TcpProxy_TunnelingConfig) Descriptor() ([]byte, []int)

func (*TcpProxy_TunnelingConfig) GetHostname

func (m *TcpProxy_TunnelingConfig) GetHostname() string

func (*TcpProxy_TunnelingConfig) Marshal

func (m *TcpProxy_TunnelingConfig) Marshal() (dAtA []byte, err error)

func (*TcpProxy_TunnelingConfig) MarshalTo

func (m *TcpProxy_TunnelingConfig) MarshalTo(dAtA []byte) (int, error)

func (*TcpProxy_TunnelingConfig) MarshalToSizedBuffer

func (m *TcpProxy_TunnelingConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TcpProxy_TunnelingConfig) ProtoMessage

func (*TcpProxy_TunnelingConfig) ProtoMessage()

func (*TcpProxy_TunnelingConfig) Reset

func (m *TcpProxy_TunnelingConfig) Reset()

func (*TcpProxy_TunnelingConfig) Size

func (m *TcpProxy_TunnelingConfig) Size() (n int)

func (*TcpProxy_TunnelingConfig) String

func (m *TcpProxy_TunnelingConfig) String() string

func (*TcpProxy_TunnelingConfig) Unmarshal

func (m *TcpProxy_TunnelingConfig) Unmarshal(dAtA []byte) error

func (*TcpProxy_TunnelingConfig) Validate

func (m *TcpProxy_TunnelingConfig) Validate() error

Validate checks the field values on TcpProxy_TunnelingConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TcpProxy_TunnelingConfig) XXX_DiscardUnknown

func (m *TcpProxy_TunnelingConfig) XXX_DiscardUnknown()

func (*TcpProxy_TunnelingConfig) XXX_Marshal

func (m *TcpProxy_TunnelingConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcpProxy_TunnelingConfig) XXX_Merge

func (m *TcpProxy_TunnelingConfig) XXX_Merge(src proto.Message)

func (*TcpProxy_TunnelingConfig) XXX_Size

func (m *TcpProxy_TunnelingConfig) XXX_Size() int

func (*TcpProxy_TunnelingConfig) XXX_Unmarshal

func (m *TcpProxy_TunnelingConfig) XXX_Unmarshal(b []byte) error

type TcpProxy_TunnelingConfigValidationError

type TcpProxy_TunnelingConfigValidationError struct {
	// contains filtered or unexported fields
}

TcpProxy_TunnelingConfigValidationError is the validation error returned by TcpProxy_TunnelingConfig.Validate if the designated constraints aren't met.

func (TcpProxy_TunnelingConfigValidationError) Cause

Cause function returns cause value.

func (TcpProxy_TunnelingConfigValidationError) Error

Error satisfies the builtin error interface

func (TcpProxy_TunnelingConfigValidationError) ErrorName

ErrorName returns error name.

func (TcpProxy_TunnelingConfigValidationError) Field

Field function returns field value.

func (TcpProxy_TunnelingConfigValidationError) Key

Key function returns key value.

func (TcpProxy_TunnelingConfigValidationError) Reason

Reason function returns reason value.

type TcpProxy_WeightedCluster

type TcpProxy_WeightedCluster struct {
	// Specifies one or more upstream clusters associated with the route.
	Clusters             []*TcpProxy_WeightedCluster_ClusterWeight `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

Allows for specification of multiple upstream clusters along with weights that indicate the percentage of traffic to be forwarded to each cluster. The router selects an upstream cluster based on these weights.

func (*TcpProxy_WeightedCluster) Descriptor

func (*TcpProxy_WeightedCluster) Descriptor() ([]byte, []int)

func (*TcpProxy_WeightedCluster) GetClusters

func (*TcpProxy_WeightedCluster) Marshal

func (m *TcpProxy_WeightedCluster) Marshal() (dAtA []byte, err error)

func (*TcpProxy_WeightedCluster) MarshalTo

func (m *TcpProxy_WeightedCluster) MarshalTo(dAtA []byte) (int, error)

func (*TcpProxy_WeightedCluster) MarshalToSizedBuffer

func (m *TcpProxy_WeightedCluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TcpProxy_WeightedCluster) ProtoMessage

func (*TcpProxy_WeightedCluster) ProtoMessage()

func (*TcpProxy_WeightedCluster) Reset

func (m *TcpProxy_WeightedCluster) Reset()

func (*TcpProxy_WeightedCluster) Size

func (m *TcpProxy_WeightedCluster) Size() (n int)

func (*TcpProxy_WeightedCluster) String

func (m *TcpProxy_WeightedCluster) String() string

func (*TcpProxy_WeightedCluster) Unmarshal

func (m *TcpProxy_WeightedCluster) Unmarshal(dAtA []byte) error

func (*TcpProxy_WeightedCluster) Validate

func (m *TcpProxy_WeightedCluster) Validate() error

Validate checks the field values on TcpProxy_WeightedCluster with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TcpProxy_WeightedCluster) XXX_DiscardUnknown

func (m *TcpProxy_WeightedCluster) XXX_DiscardUnknown()

func (*TcpProxy_WeightedCluster) XXX_Marshal

func (m *TcpProxy_WeightedCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcpProxy_WeightedCluster) XXX_Merge

func (m *TcpProxy_WeightedCluster) XXX_Merge(src proto.Message)

func (*TcpProxy_WeightedCluster) XXX_Size

func (m *TcpProxy_WeightedCluster) XXX_Size() int

func (*TcpProxy_WeightedCluster) XXX_Unmarshal

func (m *TcpProxy_WeightedCluster) XXX_Unmarshal(b []byte) error

type TcpProxy_WeightedClusterValidationError

type TcpProxy_WeightedClusterValidationError struct {
	// contains filtered or unexported fields
}

TcpProxy_WeightedClusterValidationError is the validation error returned by TcpProxy_WeightedCluster.Validate if the designated constraints aren't met.

func (TcpProxy_WeightedClusterValidationError) Cause

Cause function returns cause value.

func (TcpProxy_WeightedClusterValidationError) Error

Error satisfies the builtin error interface

func (TcpProxy_WeightedClusterValidationError) ErrorName

ErrorName returns error name.

func (TcpProxy_WeightedClusterValidationError) Field

Field function returns field value.

func (TcpProxy_WeightedClusterValidationError) Key

Key function returns key value.

func (TcpProxy_WeightedClusterValidationError) Reason

Reason function returns reason value.

type TcpProxy_WeightedCluster_ClusterWeight

type TcpProxy_WeightedCluster_ClusterWeight struct {
	// Name of the upstream cluster.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// When a request matches the route, the choice of an upstream cluster is
	// determined by its weight. The sum of weights across all entries in the
	// clusters array determines the total weight.
	Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// Optional endpoint metadata match criteria used by the subset load balancer. Only endpoints
	// in the upstream cluster with metadata matching what is set in this field will be considered
	// for load balancing. Note that this will be merged with what's provided in
	// :ref:`TcpProxy.metadata_match
	// <envoy_api_field_extensions.filters.network.tcp_proxy.v3.TcpProxy.metadata_match>`, with values
	// here taking precedence. The filter name should be specified as *envoy.lb*.
	MetadataMatch        *v3.Metadata `protobuf:"bytes,3,opt,name=metadata_match,json=metadataMatch,proto3" json:"metadata_match,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*TcpProxy_WeightedCluster_ClusterWeight) Descriptor

func (*TcpProxy_WeightedCluster_ClusterWeight) Descriptor() ([]byte, []int)

func (*TcpProxy_WeightedCluster_ClusterWeight) GetMetadataMatch

func (m *TcpProxy_WeightedCluster_ClusterWeight) GetMetadataMatch() *v3.Metadata

func (*TcpProxy_WeightedCluster_ClusterWeight) GetName

func (*TcpProxy_WeightedCluster_ClusterWeight) GetWeight

func (*TcpProxy_WeightedCluster_ClusterWeight) Marshal

func (m *TcpProxy_WeightedCluster_ClusterWeight) Marshal() (dAtA []byte, err error)

func (*TcpProxy_WeightedCluster_ClusterWeight) MarshalTo

func (m *TcpProxy_WeightedCluster_ClusterWeight) MarshalTo(dAtA []byte) (int, error)

func (*TcpProxy_WeightedCluster_ClusterWeight) MarshalToSizedBuffer

func (m *TcpProxy_WeightedCluster_ClusterWeight) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TcpProxy_WeightedCluster_ClusterWeight) ProtoMessage

func (*TcpProxy_WeightedCluster_ClusterWeight) Reset

func (*TcpProxy_WeightedCluster_ClusterWeight) Size

func (*TcpProxy_WeightedCluster_ClusterWeight) String

func (*TcpProxy_WeightedCluster_ClusterWeight) Unmarshal

func (m *TcpProxy_WeightedCluster_ClusterWeight) Unmarshal(dAtA []byte) error

func (*TcpProxy_WeightedCluster_ClusterWeight) Validate

Validate checks the field values on TcpProxy_WeightedCluster_ClusterWeight with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TcpProxy_WeightedCluster_ClusterWeight) XXX_DiscardUnknown

func (m *TcpProxy_WeightedCluster_ClusterWeight) XXX_DiscardUnknown()

func (*TcpProxy_WeightedCluster_ClusterWeight) XXX_Marshal

func (m *TcpProxy_WeightedCluster_ClusterWeight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcpProxy_WeightedCluster_ClusterWeight) XXX_Merge

func (*TcpProxy_WeightedCluster_ClusterWeight) XXX_Size

func (*TcpProxy_WeightedCluster_ClusterWeight) XXX_Unmarshal

func (m *TcpProxy_WeightedCluster_ClusterWeight) XXX_Unmarshal(b []byte) error

type TcpProxy_WeightedCluster_ClusterWeightValidationError

type TcpProxy_WeightedCluster_ClusterWeightValidationError struct {
	// contains filtered or unexported fields
}

TcpProxy_WeightedCluster_ClusterWeightValidationError is the validation error returned by TcpProxy_WeightedCluster_ClusterWeight.Validate if the designated constraints aren't met.

func (TcpProxy_WeightedCluster_ClusterWeightValidationError) Cause

Cause function returns cause value.

func (TcpProxy_WeightedCluster_ClusterWeightValidationError) Error

Error satisfies the builtin error interface

func (TcpProxy_WeightedCluster_ClusterWeightValidationError) ErrorName

ErrorName returns error name.

func (TcpProxy_WeightedCluster_ClusterWeightValidationError) Field

Field function returns field value.

func (TcpProxy_WeightedCluster_ClusterWeightValidationError) Key

Key function returns key value.

func (TcpProxy_WeightedCluster_ClusterWeightValidationError) Reason

Reason function returns reason value.

type TcpProxy_WeightedClusters

type TcpProxy_WeightedClusters struct {
	WeightedClusters *TcpProxy_WeightedCluster `protobuf:"bytes,10,opt,name=weighted_clusters,json=weightedClusters,proto3,oneof" json:"weighted_clusters,omitempty"`
}

func (*TcpProxy_WeightedClusters) MarshalTo

func (m *TcpProxy_WeightedClusters) MarshalTo(dAtA []byte) (int, error)

func (*TcpProxy_WeightedClusters) MarshalToSizedBuffer

func (m *TcpProxy_WeightedClusters) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TcpProxy_WeightedClusters) Size

func (m *TcpProxy_WeightedClusters) Size() (n int)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL