bfe_server

type BfeListener struct {
	// Listener is the underlying tcp listener
	Listener net.Listener

	// BalancerType is the type of Layer4 load balancer
	BalancerType string

	// ProxyHeaderTimeout Optionally specifies the timeout value to
	// receive the Proxy Protocol Header. Zero means no timeout.
	ProxyHeaderTimeout time.Duration

	// ProxyHeaderLimit Optionally specifies the maximum bytes to
	// receive the Proxy Protocol Header. Zero means default value.
	ProxyHeaderLimit int64
}

type BfeMonitor struct {
	WebServer   *web_monitor.MonitorServer
	WebHandlers *web_monitor.WebHandlers
	// contains filtered or unexported fields
}

type BfeServer struct {
	bfe_http.Server

	HttpListener  net.Listener   // listener for http
	HttpsListener *HttpsListener // listener for https

	// for http server
	ReverseProxy *ReverseProxy // reverse proxy

	// TLS session cache
	SessionCache *ServerSessionCache

	// TLS certificates
	MultiCert *MultiCertMap

	// TLS server rule
	TLSServerRule *TLSServerRuleMap

	// server config
	Config   bfe_conf.BfeConfig
	ConfRoot string

	// module and callback
	CallBacks *bfe_module.BfeCallbacks // call back functions
	Modules   *bfe_module.BfeModules   // bfe modules

	// web server for bfe monitor and reload
	Monitor *BfeMonitor

	// bufio cache
	BufioCache *BufioCache

	// signal table
	SignalTable *signal_table.SignalTable

	ServerConf *bfe_route.ServerDataConf // cluster_conf and host table conf

	Version string // version of bfe server
	// contains filtered or unexported fields
}

type BufferFiller interface {
	FillBuffer() error
}

type BufioCache struct {
}

type CloseNotifier interface {
	// CloseNotify returns a channel that receives a single value
	// when the client connection has gone away.
	CloseNotify() <-chan bool
}

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

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

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

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

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

type ProxyState struct {
	// panic
	PanicClientConnServe *metrics.Counter // panic when accept from client
	PanicBackendWrite    *metrics.Counter // panic when write to backend
	PanicBackendRead     *metrics.Counter // panic when read from backend

	// client side errors
	ErrClientLongUrl        *metrics.Counter
	ErrClientLongHeader     *metrics.Counter
	ErrClientClose          *metrics.Counter
	ErrClientTimeout        *metrics.Counter
	ErrClientBadRequest     *metrics.Counter
	ErrClientZeroContentlen *metrics.Counter
	ErrClientExpectFail     *metrics.Counter
	ErrClientConnAccept     *metrics.Counter
	ErrClientWrite          *metrics.Counter
	ErrClientReset          *metrics.Counter

	// route config errors
	ErrBkFindProduct  *metrics.Counter
	ErrBkFindLocation *metrics.Counter
	ErrBkNoBalance    *metrics.Counter
	ErrBkNoCluster    *metrics.Counter
	ErrBkBodyProcess  *metrics.Counter

	// backend side errors
	ErrBkConnectBackend    *metrics.Counter
	ErrBkRequestBackend    *metrics.Counter
	ErrBkWriteRequest      *metrics.Counter
	ErrBkReadRespHeader    *metrics.Counter
	ErrBkRespHeaderTimeout *metrics.Counter
	ErrBkTransportBroken   *metrics.Counter

	// tls handshake
	TlsHandshakeAll  *metrics.Counter
	TlsHandshakeSucc *metrics.Counter

	// tls session cache
	SessionCacheConn         *metrics.Counter
	SessionCacheConnFail     *metrics.Counter
	SessionCacheSet          *metrics.Counter
	SessionCacheSetFail      *metrics.Counter
	SessionCacheGet          *metrics.Counter
	SessionCacheGetFail      *metrics.Counter
	SessionCacheTypeNotBytes *metrics.Counter
	SessionCacheMiss         *metrics.Counter
	SessionCacheHit          *metrics.Counter
	SessionCacheNoInstance   *metrics.Counter

	// tls multiply certificates
	TlsMultiCertGet            *metrics.Counter
	TlsMultiCertConnWithoutVip *metrics.Counter
	TlsMultiCertConnVipUnknown *metrics.Counter
	TlsMultiCertConnWithoutSni *metrics.Counter
	TlsMultiCertUseDefault     *metrics.Counter
	TlsMultiCertUpdate         *metrics.Counter
	TlsMultiCertUpdateErr      *metrics.Counter

	// client side
	ClientReqWithRetry       *metrics.Counter // req served with retry
	ClientReqWithCrossRetry  *metrics.Counter // req served with cross cluster retry
	ClientReqFail            *metrics.Counter // req with ErrCode != nil
	ClientReqFailWithNoRetry *metrics.Counter // req fail with no retry
	ClientConnUse100Continue *metrics.Counter // connection used Expect 100 Continue
	ClientConnUnfinishedReq  *metrics.Counter // connection closed with unfinished request

	// request successful received
	ClientReqServed      *metrics.Counter
	HttpClientReqServed  *metrics.Counter
	HttpsClientReqServed *metrics.Counter
	Http2ClientReqServed *metrics.Counter
	SpdyClientReqServed  *metrics.Counter

	// active request
	ClientReqActive      *metrics.Gauge
	HttpClientReqActive  *metrics.Gauge
	HttpsClientReqActive *metrics.Gauge
	Http2ClientReqActive *metrics.Gauge
	SpdyClientReqActive  *metrics.Gauge

	// connection successful accepted
	ClientConnServed       *metrics.Counter
	HttpClientConnServed   *metrics.Counter
	HttpsClientConnServed  *metrics.Counter
	Http2ClientConnServed  *metrics.Counter
	SpdyClientConnServed   *metrics.Counter
	StreamClientConnServed *metrics.Counter
	WsClientConnServed     *metrics.Counter
	WssClientConnServed    *metrics.Counter

	// active connection
	ClientConnActive       *metrics.Gauge
	HttpClientConnActive   *metrics.Gauge
	HttpsClientConnActive  *metrics.Gauge
	Http2ClientConnActive  *metrics.Gauge
	SpdyClientConnActive   *metrics.Gauge
	StreamClientConnActive *metrics.Gauge
	WsClientConnActive     *metrics.Gauge
	WssClientConnActive    *metrics.Gauge
}

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

type RoundTripperMap map[string]bfe_http.RoundTripper

type ServerRule struct {
	TlsRule    bfe_tls.Rule    // server rule for tls
	H2Rule     bfe_http2.Rule  // server rule for h2
	StreamRule bfe_stream.Rule // server rule for stream
}

type ServerSessionCache struct {
	Servers []string // tcp address for redis servers

	ConnectTimeout time.Duration // connect timeout (ms)
	ReadTimeout    time.Duration // read timeout (ms)
	WriteTimeout   time.Duration // write timeout (ms)
	KeyPrefix      string        // prefix for cache key

	SessionExpire int // expire time for tls session state (s)
	MaxIdle       int // max idle connections in pool
	// contains filtered or unexported fields
}

type ServerStatus struct {
	// for proxy protocol
	ProxyProtocolState   *bfe_proxy.ProxyState
	ProxyProtocolMetrics metrics.Metrics

	// for tls protocol
	TlsState   *bfe_tls.TlsState
	TlsMetrics metrics.Metrics

	// for spdy protocol
	SpdyState   *bfe_spdy.SpdyState
	SpdyMetrics metrics.Metrics

	// for http2 protocol
	Http2State   *bfe_http2.Http2State
	Http2Metrics metrics.Metrics

	// for http protocol
	HttpState   *bfe_http.HttpState
	HttpMetrics metrics.Metrics

	// for stream protocol (tls proxy)
	StreamState   *bfe_stream.StreamState
	StreamMetrics metrics.Metrics

	// for websocket protocol (websocket proxy)
	WebSocketState   *bfe_websocket.WebSocketState
	WebSocketMetrics metrics.Metrics

	// for balance
	BalState   *bal.BalErrState
	BalMetrics metrics.Metrics

	// for proxy
	ProxyState   *ProxyState
	ProxyMetrics metrics.Metrics

	// for monitor "internal delay"
	ProxyDelay *delay_counter.DelayRecent

	// for monitor "internal delay" of post/put request
	ProxyPostDelay *delay_counter.DelayRecent

	// for monitor "internal delay" of tls handshake
	ProxyHandshakeDelay       *delay_counter.DelayRecent
	ProxyHandshakeFullDelay   *delay_counter.DelayRecent
	ProxyHandshakeResumeDelay *delay_counter.DelayRecent
}

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

type Version struct {
	TlsRuleConfVersion string
}