server

type MessageReader interface {
	ReadRawMessage() (*rawMessage, error)
	Write(msg []byte) (int, error)
	Read(data []byte) (int, error)
	UpgradeConnection(conn net.Conn)
	CloseConnection() error
	Connection() net.Conn
}

type Option func(s *srv)

type Server interface {
	Initialize() error
	Serve() error
	Stop() error
	GetPort() int
}

type Session interface {
	InitializeSession() error
	HandleStartup(dbList database.DatabaseList) error
	QueriesMachine(ctx context.Context) (err error)
	ErrorHandle(err error)
}

type SessionFactory interface {
	NewSession(conn net.Conn, log logger.Logger, sysDb database.DB, tlsConfig *tls.Config) Session
}