server

Documentation

Index

• type Server
  • func NewServer() *Server
  • func (server *Server) Authenticate(*postgresql.Conn, *protocol.Startup) (protocol.Response, error)
  • func (server *Server) Copy(conn postgresql.Conn, q query.Copy) (protocol.Responses, error)
  • func (server *Server) CopyData(conn postgresql.Conn, q query.Copy, stream *postgresql.CopyStream) (protocol.Responses, error)
  • func (server *Server) ParserError(conn postgresql.Conn, q string, err error) (protocol.Responses, error)

Types

type Server

type Server struct {
	postgresql.Server
	*store.Store
}

Server represents a test server.

func NewServer

func NewServer() *Server

NewServer returns a test server instance.

func (*Server) Authenticate

func (server *Server) Authenticate(*postgresql.Conn, *protocol.Startup) (protocol.Response, error)

Authenticate authenticates the connection with the startup protocol.

func (*Server) Copy

func (server *Server) Copy(conn postgresql.Conn, q query.Copy) (protocol.Responses, error)

Copy handles a COPY query.

func (*Server) CopyData

func (server *Server) CopyData(conn postgresql.Conn, q query.Copy, stream *postgresql.CopyStream) (protocol.Responses, error)

Copy handles a COPY DATA protocol.

func (*Server) ParserError

func (server *Server) ParserError(conn postgresql.Conn, q string, err error) (protocol.Responses, error)

ParserError handles a parser error.