streamproxy

Documentation

Index

• func CreateTCPProxyFactory(conf map[string]interface{}) (api.NetworkFilterChainFactory, error)
• func CreateUDPProxyFactory(conf map[string]interface{}) (api.NetworkFilterChainFactory, error)
• func ParseStreamProxy(cfg map[string]interface{}) (*v2.StreamProxy, error)
• type DownstreamCallbacks
• type IpRangeList
  • func (ipList *IpRangeList) Contains(address net.Addr) bool
• type LbContext
  • func (c *LbContext) DownstreamCluster() types.ClusterInfo
  • func (c *LbContext) DownstreamConnection() net.Conn
  • func (c *LbContext) DownstreamContext() context.Context
  • func (c *LbContext) DownstreamHeaders() api.HeaderMap
  • func (c *LbContext) DownstreamRoute() api.Route
  • func (c *LbContext) MetadataMatchCriteria() api.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.StreamProxy, net string) Proxy
• type ProxyConfig
  • func NewProxyConfig(config *v2.StreamProxy) ProxyConfig
• type UpstreamCallbacks
• type UpstreamFailureReason

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