netmanager

type ConnManager interface {
	ConnectTask(job.Job) (job.Init, job.Run, job.Finalize)
	AcceptTask(job.Job) (job.Init, job.Run, job.Finalize)
	GetBytesSent() uint64
	GetBytesReceived() uint64
	GetNetworkManager() NetManager
	GetConnTotalCount(state StreamState, typ ConnType) int
	GetInboundLimit() int
}

type ConnManagerOptions struct {
	InboundLimit int
	ReadbufLen   int
}

type ConnType int

type DataKind int

type NetManager interface {
}

type ProxyConn interface {
	Upstream() *stream
	Downstream() *stream
	ProxyReadUpstreamTask(j job.Job) (job.Init, job.Run, job.Finalize)
	ProxyReadDownstreamTask(j job.Job) (job.Init, job.Run, job.Finalize)
	ProxyWriteUpstreamTask(j job.Job) (job.Init, job.Run, job.Finalize)
	ProxyWriteDownstreamTask(j job.Job) (job.Init, job.Run, job.Finalize)
}

type Server struct {
	Host     string
	Weight   uint8
	MaxConns uint16
}

type ServerNet struct {
	Server  *Server
	TcpAddr *net.TCPAddr
}

type Stream interface {
	//Read() <-chan interface{}
	Write() chan<- interface{}
	WriteSync() int
	RecvDataFrame() <-chan netdataframe.DataFrame
	RecvDataFrameSync()
	RecvRaw() <-chan []byte
	RecvRawSync()
	NewConn() <-chan struct{}

	GetConnManager() ConnManager
	Key() string
	String() string
	GetState() StreamState
	CanBeReused() bool
	IsConnected() bool
	Refresh()
	CloseWithReuse()
	Close()
}

type StreamOptions struct {
	DataKind DataKind
}

type StreamState int