goetty

type AppOption[IN any, OUT any] func(*server[IN, OUT])

type BufferedIOSession interface {
	// BufferedConn returns a wrapped net.Conn that read from IOSession's in-buffer first
	BufferedConn() net.Conn
}

type IOSession[IN any, OUT any] interface {
	// ID session id
	ID() uint64
	// Connect connect to address, only used at client-side
	Connect(addr string, timeout time.Duration) error
	// Connected returns true if connection is ok
	Connected() bool
	// Disconnect disconnect the connection
	Disconnect() error
	// Close close the session, the read and write buffer will closed, and cannot Connect
	// again. IOSession reference count minus 1.
	Close() error
	// Ref for IOSessions, held by several goroutines, several references are needed. Each
	// concurrent process holding an IOSession can Close the IOSession and release the resource
	// when the reference count reaches 0.
	Ref()
	// Read read packet from connection
	Read(option ReadOptions) (IN, error)
	// Write encodes the msg into a []byte into the buffer according to the codec.Encode.
	// If flush is set to false, the data will not be written to the underlying socket.
	Write(msg OUT, options WriteOptions) error
	// Flush flush the out buffer
	Flush(timeout time.Duration) error
	// RemoteAddress returns remote address, include ip and port
	RemoteAddress() string
	// RawConn return raw tcp conn, RawConn should only be used to access the underlying
	// attributes of the tcp conn, e.g. set keepalive attributes. Read from RawConn directly
	// may lose data since the bytes might have been copied to the InBuf.
	// To perform read/write operation on the underlying tcp conn, use BufferedConn instead.
	RawConn() net.Conn
	// UseConn use the specified conn to handle reads and writes. Note that conn reads and
	// writes cannot be handled in other goroutines until UseConn is called.
	UseConn(net.Conn)
	// OutBuf returns byte buffer which used to encode message into bytes
	OutBuf() *buf.ByteBuf
	// InBuf returns input buffer which used to decode bytes to message
	InBuf() *buf.ByteBuf
}

type IOSessionAware[IN any, OUT any] interface {
	// Created session created
	Created(IOSession[IN, OUT])
	//Closed session closed
	Closed(IOSession[IN, OUT])
}

type NetApplication[IN any, OUT any] interface {
	// Start start the transport server
	Start() error
	// Stop stop the transport server
	Stop() error
	// GetSession get session
	GetSession(uint64) (IOSession[IN, OUT], error)
}

type Option[IN any, OUT any] func(*baseIO[IN, OUT])

type Proxy interface {
	// Start start the proxy
	Start() error
	// Stop stop the proxy
	Stop() error
	// AddUpStream add upstream
	AddUpStream(address string, connectTimeout time.Duration)
}

type ReadOptions struct {
	// Timeout deadline for read
	Timeout time.Duration
}

type WriteOptions struct {
	// Timeout deadline for write
	Timeout time.Duration
	// Flush flush data to net.Conn
	Flush bool
}