bfe_stream

type BalanceHandler func(c interface{}) (*backend.BfeBackend, error)

type FindProductHandler func(c net.Conn) string

type ProxyHandler func(s *Server, c net.Conn, b net.Conn, errCh chan error)

type Rule struct {
	ProxyProtocol int
}

type Server struct {
	// ConnectTimeout optionally specifies the timeout value (ms) to
	// connect backend. If zero, a default value is used.
	ConnectTimeout int

	// ConnectRetryMax optionally specifies the upper limit of connect
	// retris. If zero, a default value is used
	ConnectRetryMax int

	// BalanceHandler optionally specifies the handler for backends balance
	// BalanceHandler should not be nil.
	BalanceHandler BalanceHandler

	// FindProductHandler finds product name for stream proxy
	FindProductHandler FindProductHandler

	// ProxyHandler optionally specifies the handler for process client conn
	// and backend conn. If nil, a default value is used.
	ProxyHandler ProxyHandler

	// ProxyConfig optionally specifies the config for ProxyHandler
	ProxyConfig interface{}
}

type ServerRule interface {
	GetStreamRule(conn *tls.Conn) *Rule
}

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

type StreamState struct {
	StreamErrBalance  *metrics.Counter
	StreamErrConnect  *metrics.Counter
	StreamErrProxy    *metrics.Counter
	StreamErrTransfer *metrics.Counter
	StreamPanicConn   *metrics.Counter
	StreamBytesRecv   *metrics.Counter
	StreamBytesSent   *metrics.Counter
}