tcpproxy

Documentation

Index

• func CreateTCPProxyFactory(conf map[string]interface{}) (types.NetworkFilterChainFactory, error)
• type DownstreamCallbacks
• type IpRangeList
  • func (ipList *IpRangeList) Contains(address net.Addr) bool
• type LbContext
  • func (c *LbContext) DownstreamConnection() net.Conn
  • func (c *LbContext) DownstreamContext() context.Context
  • func (c *LbContext) DownstreamHeaders() types.HeaderMap
  • func (c *LbContext) MetadataMatchCriteria() types.MetadataMatchCriteria
• type PortRange
• type PortRangeList
  • func ParsePortRangeList(ports string) PortRangeList
  • func (pr *PortRangeList) Contains(address net.Addr) bool
• type Proxy
  • func NewProxy(ctx context.Context, config *v2.TCPProxy, clusterManager types.ClusterManager) Proxy
• type ProxyConfig
  • func NewProxyConfig(config *v2.TCPProxy) ProxyConfig
• type UpstreamCallbacks
• type UpstreamFailureReason

Functions

func CreateTCPProxyFactory

func CreateTCPProxyFactory(conf map[string]interface{}) (types.NetworkFilterChainFactory, error)

Types

type DownstreamCallbacks

type DownstreamCallbacks interface {
	types.ConnectionEventListener
}

DownstreamCallbacks for downstream's callbacks

type IpRangeList

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

func (*IpRangeList) Contains

func (ipList *IpRangeList) Contains(address net.Addr) bool

type LbContext

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

LbContext is a types.LoadBalancerContext implementation

func (*LbContext) DownstreamConnection

func (c *LbContext) DownstreamConnection() net.Conn

func (*LbContext) DownstreamContext

func (c *LbContext) DownstreamContext() context.Context

func (*LbContext) DownstreamHeaders

func (c *LbContext) DownstreamHeaders() types.HeaderMap

TCP Proxy have no header

func (*LbContext) MetadataMatchCriteria

func (c *LbContext) MetadataMatchCriteria() types.MetadataMatchCriteria

type PortRange

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

type PortRangeList

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

func ParsePortRangeList

func ParsePortRangeList(ports string) PortRangeList

func (*PortRangeList) Contains

func (pr *PortRangeList) Contains(address net.Addr) bool

type Proxy

type Proxy interface {
	types.ReadFilter

	ReadDisableUpstream(disable bool)

	ReadDisableDownstream(disable bool)
}

Proxy

func NewProxy

func NewProxy(ctx context.Context, config *v2.TCPProxy, clusterManager types.ClusterManager) Proxy

type ProxyConfig

type ProxyConfig interface {
	GetRouteFromEntries(connection types.Connection) string
}

ProxyConfig

func NewProxyConfig

func NewProxyConfig(config *v2.TCPProxy) ProxyConfig

type UpstreamCallbacks

type UpstreamCallbacks interface {
	types.ReadFilter
	types.ConnectionEventListener
}

UpstreamCallbacks for upstream's callbacks

type UpstreamFailureReason

type UpstreamFailureReason string

UpstreamFailureReason used to define Upstream Failure Reason

const (
	ConnectFailed         UpstreamFailureReason = "ConnectFailed"
	NoHealthyUpstream     UpstreamFailureReason = "NoHealthyUpstream"
	ResourceLimitExceeded UpstreamFailureReason = "ResourceLimitExceeded"
	NoRoute               UpstreamFailureReason = "NoRoute"
)

Upstream Failure Reason const