postgresql

type Authenticator interface {
	// Authenticate handles the Start-up message and returns an Authentication or ErrorResponse message.
	Authenticate(*Conn, *message.Startup) (message.Response, error)
}

type BaseAuthenticator struct {
}

type BaseBulkExecutor struct {
}

type BaseErrorHandler struct {
}

type BaseExecutor struct {
	Authenticator
	StartupHandler
	QueryExecutor
	BulkExecutor
	ErrorHandler
}

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

type BaseQueryExecutor struct {
}

type BulkExecutor interface {
	// Copy handles a COPY query.
	Copy(*Conn, *query.Copy, *CopyStream) (message.Responses, error)
}

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

type Conn struct {
	tracer.Context

	PreparedQueryMap
	// contains filtered or unexported fields
}

type ConnOption = func(*Conn)

type CopyStream struct {
	*message.MessageReader
}

type DDOExecutor interface {
	// CreateDatabase handles a CREATE DATABASE query.
	CreateDatabase(*Conn, *query.CreateDatabase) (message.Responses, error)
	// CreateTable handles a CREATE TABLE query.
	CreateTable(*Conn, *query.CreateTable) (message.Responses, error)
	// CreateIndex handles a CREATE INDEX query.
	CreateIndex(*Conn, *query.CreateIndex) (message.Responses, error)
	// DropDatabase handles a DROP DATABASE query.
	DropDatabase(*Conn, *query.DropDatabase) (message.Responses, error)
	// DropIndex handles a DROP INDEX query.
	DropTable(*Conn, *query.DropTable) (message.Responses, error)
}

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

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

type Executor interface {
	Authenticator
	StartupHandler
	QueryExecutor
	ErrorHandler
	// SetAuthenticator sets a user authenticator.
	SetAuthenticator(Authenticator)
	// SetStartupHandler sets a user startup handler.
	SetStartupHandler(StartupHandler)
	// SetQueryExecutor sets a user query executor.
	SetQueryExecutor(QueryExecutor)
	// SetQueryExecutor sets a user query executor.
	SetErrorHandler(ErrorHandler)
}

type PreparedQuery = message.Parse

type PreparedQueryMap map[string]*PreparedQuery

type QueryExecutor interface {
	DDOExecutor
	DMOExecutor
}

type Server struct {
	*Config
	tracer.Tracer

	Executor
	// contains filtered or unexported fields
}

type StartupHandler interface {
	StatusHandler
}

type StatusHandler interface {
	// ParameterStatuses returns the parameter statuses.
	ParameterStatuses(*Conn) (message.Responses, error)
	// BackendKeyData returns the backend key data.
	BackendKeyData(*Conn) (message.Response, error)
}