postgresql

type AuthManager interface {
	// AddAuthenticator adds a new authenticator.
	AddAuthenticator(authenticator auth.Authenticator)
	// ClearAuthenticators clears all authenticators.
	ClearAuthenticators()
}

type BaseBulkExecutor struct {
}

type BaseErrorHandler struct {
}

type BaseExecutor struct {
	ProtocolStartupHander
	ProtocolQueryHandler
	QueryExecutor
	ExQueryExecutor
	BulkQueryExecutor
	ErrorHandler
	SystemQueryExecutor
}

type BaseQueryExecutor struct {
}

type BaseSystemQueryExecutor struct {
}

type BulkQueryExecutor interface {
	// Copy handles a COPY query.
	Copy(Conn, query.Copy) (protocol.Responses, error)
	// CopyData handles a COPY data protocol.
	CopyData(Conn, query.Copy, *CopyStream) (protocol.Responses, error)
}

type Config interface {
	TLSConfig
	// SetAddress sets a listen address to the configuration.
	SetAddress(addr string)
	// SetPort sets a listen port to the configuration.
	SetPort(port int)
	// Address returns a listen address from the configuration.
	Address() string
	// Port returns a listen port from the configuration.
	Port() int
}

type Conn = protocol.Conn

type ConnID = net.ConnID

type CopyStream struct {
	*protocol.MessageReader
}

type DDOExecutor interface {
	// CreateDatabase handles a CREATE DATABASE query.
	CreateDatabase(Conn, query.CreateDatabase) (protocol.Responses, error)
	// CreateTable handles a CREATE TABLE query.
	CreateTable(Conn, query.CreateTable) (protocol.Responses, error)
	// AlterDatabase handles a ALTER DATABASE query.
	AlterDatabase(Conn, query.AlterDatabase) (protocol.Responses, error)
	// AlterTable handles a ALTER TABLE query.
	AlterTable(Conn, query.AlterTable) (protocol.Responses, error)
	// DropDatabase handles a DROP DATABASE query.
	DropDatabase(Conn, query.DropDatabase) (protocol.Responses, error)
	// DropIndex handles a DROP INDEX query.
	DropTable(Conn, query.DropTable) (protocol.Responses, error)
}

type DMOExExecutor interface {
	// Vacuum handles a VACUUM query.
	Vacuum(Conn, query.Vacuum) (protocol.Responses, error)
	// Truncate handles a TRUNCATE query.
	Truncate(Conn, query.Truncate) (protocol.Responses, error)
}

type DMOExecutor interface {
	// Insert handles a INSERT query.
	Insert(Conn, query.Insert) (protocol.Responses, error)
	// Select handles a SELECT query.
	Select(Conn, query.Select) (protocol.Responses, error)
	// Update handles a UPDATE query.
	Update(Conn, query.Update) (protocol.Responses, error)
	// Delete handles a DELETE query.
	Delete(Conn, query.Delete) (protocol.Responses, error)
}

type ErrorHandler interface {
	ParserError(Conn, string, error) (protocol.Responses, error)
}

type ExQueryExecutor interface {
	DMOExExecutor
}

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

type PreparedPortal = protocol.Query

type PreparedPortalMap map[string]PreparedPortal

type PreparedStatement struct {
	*protocol.Parse
	ParsedStatement *query.Statement
}

type PreparedStatementMap map[string]*PreparedStatement

type ProtocolMessageExecutor interface {
	// SetQueryExecutor sets a user query executor.
	SetQueryExecutor(QueryExecutor)
	// SetExQueryExecutor sets a user query executor.
	SetExQueryExecutor(ExQueryExecutor)
	// SetSystemQueryExecutor sets a system query executor.
	SetSystemQueryExecutor(SystemQueryExecutor)
	// SetBulkQueryExecutor sets a user bulk executor.
	SetBulkQueryExecutor(BulkQueryExecutor)
	// SetErrorHandler sets a user error handler.
	SetErrorHandler(ErrorHandler)
}

type ProtocolQueryHandler interface {
	protocol.QueryHandler
}

type ProtocolStartupHander interface {
	AuthManager
	protocol.StartupHandler
}

type QueryExecutor interface {
	TCOExecutor
	DDOExecutor
	DMOExecutor
}

type SQLExecutor = query.SQLExecutor

type Server interface {
	tracer.Tracer
	Config
	AuthManager
	ProtocolMessageExecutor
	SetTracer(tracer.Tracer)
	Start() error
	Stop() error
	Restart() error
}

type SystemDMOExecutor interface {
	// Select handles a SELECT query.
	SystemSelect(Conn, query.Select) (protocol.Responses, error)
}

type SystemQueryExecutor interface {
	SystemDMOExecutor
}

type TCOExecutor interface {
	// Begin handles a BEGIN query.
	Begin(Conn, query.Begin) (protocol.Responses, error)
	// Commit handles a COMMIT query.
	Commit(Conn, query.Commit) (protocol.Responses, error)
	// Rollback handles a ROLLBACK query.
	Rollback(Conn, query.Rollback) (protocol.Responses, error)
}

type TLSConfig = protocol.TLSConfig