Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JsonReverseProxy ¶
type JsonReverseProxy struct {
// Optional callbacks for connection events
OnConnect func(id string, conn *ProxyConn)
OnDisconnect func(id string, conn *ProxyConn)
OnRequest func(id string, conn *ProxyConn, data []byte)
OnResponse func(id string, conn *ProxyConn, data []byte)
ActiveConnectionsCount int64
// contains filtered or unexported fields
}
func (*JsonReverseProxy) AddUnixSocketListener ¶
func (j *JsonReverseProxy) AddUnixSocketListener(context context.Context, path string) error
func (*JsonReverseProxy) DumpDebugInfo ¶
func (j *JsonReverseProxy) DumpDebugInfo()
DumpDebugInfo returns debug information about active connections and decoders
func (*JsonReverseProxy) Listen ¶
func (j *JsonReverseProxy) Listen()
func (*JsonReverseProxy) Shutdown ¶
func (j *JsonReverseProxy) Shutdown()
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
func NewSession ¶
func NewSession() *Session
type Upstream ¶
type Upstream struct {
// contains filtered or unexported fields
}
func (*Upstream) PooledConn ¶
Return a random upstream from pool
func (*Upstream) RefillPool ¶
Source Files
Click to show internal directories.
Click to hide internal directories.