streamproxy

package
v1.6.1 Latest Latest
Warning

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

Go to latest
Published: Aug 1, 2024 License: Apache-2.0 Imports: 16 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateTCPProxyFactory

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

func CreateUDPProxyFactory

func CreateUDPProxyFactory(conf map[string]interface{}) (api.NetworkFilterChainFactory, error)

func ParseStreamProxy

func ParseStreamProxy(cfg map[string]interface{}) (*v2.StreamProxy, error)

ParseStreamProxy

Types

type DownstreamCallbacks

type DownstreamCallbacks interface {
	api.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) DownstreamCluster

func (c *LbContext) DownstreamCluster() types.ClusterInfo

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() api.HeaderMap

Stream Proxy have no header

func (*LbContext) DownstreamRoute

func (c *LbContext) DownstreamRoute() api.Route

func (*LbContext) MetadataMatchCriteria

func (c *LbContext) MetadataMatchCriteria() api.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 {
	api.ReadFilter

	ReadDisableUpstream(disable bool)

	ReadDisableDownstream(disable bool)
}

Proxy

func NewProxy

func NewProxy(ctx context.Context, config *v2.StreamProxy, net string) Proxy

type ProxyConfig

type ProxyConfig interface {
	GetRouteFromEntries(connection api.Connection) string

	GetIdleTimeout(network string) time.Duration

	GetReadTimeout(network string) time.Duration
}

ProxyConfig

func NewProxyConfig

func NewProxyConfig(config *v2.StreamProxy) ProxyConfig

type UpstreamCallbacks

type UpstreamCallbacks interface {
	api.ReadFilter
	api.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

Jump to

Keyboard shortcuts

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