Documentation ¶
Index ¶
- func NewGrpcLoadBalanceHandler(lb loadbalance.LoadBalance) grpc.StreamHandler
- func NewLoadBalanceReverseProxy(c *middleware.SliceRouterContext, lb loadbalance.LoadBalance) *httputil.ReverseProxy
- func NewMultipleHostsReverseProxy(c *middleware.SliceRouterContext, targets []*url.URL) *httputil.ReverseProxy
- type TCPReverseProxy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGrpcLoadBalanceHandler ¶
func NewGrpcLoadBalanceHandler(lb loadbalance.LoadBalance) grpc.StreamHandler
NewGrpcLoadBalanceHandler 创建 Grpc 负载均衡代理 Handler
func NewLoadBalanceReverseProxy ¶
func NewLoadBalanceReverseProxy(c *middleware.SliceRouterContext, lb loadbalance.LoadBalance) *httputil.ReverseProxy
NewLoadBalanceReverseProxy 创建负载均衡反向代理器
func NewMultipleHostsReverseProxy ¶
func NewMultipleHostsReverseProxy(c *middleware.SliceRouterContext, targets []*url.URL) *httputil.ReverseProxy
NewMultipleHostsReverseProxy 反向代理负载均衡 func NewMultipleHostsReverseProxy(lb loadbalance.LoadBalance) *httputil.ReverseProxy {
Types ¶
type TCPReverseProxy ¶
type TCPReverseProxy struct { Addr string KeepAlivePeriod time.Duration // 长连接设置 DialTimeout time.Duration // 拨号超时时间 // 拨号的上下文 DialContext func(ctx context.Context, network, address string) (net.Conn, error) // 拨号的错误 OnDialError func(src net.Conn, dstDialErr error) ProxyProtocolVersion int // contains filtered or unexported fields }
TCPReverseProxy TCP 反向代理配置
func NewTCPLoadBalanceReverseProxy ¶
func NewTCPLoadBalanceReverseProxy(c *tcpmiddleware.TCPSliceRouterContext, lb loadbalance.LoadBalance) *TCPReverseProxy
NewTCPLoadBalanceReverseProxy 创建TCP代理负载均衡器
Click to show internal directories.
Click to hide internal directories.