postgresql

type BaseAuthExecutor struct {
	*auth.AuthManager
}

type BaseBulkExecutor struct {
}

type BaseErrorHandler struct {
}

type BaseExecutor struct {
	StartupHandler
	QueryExecutor
	QueryExtraExecutor
	TCLExecutor
	ExtendedQueryExecutor
	BulkExecutor
	ErrorHandler
	SystemQueryExecutor
}

type BaseExtendedQueryExecutor struct {
	*BaseExecutor
}

type BaseQueryExecutor struct {
}

type BaseStartupExecutor struct {
	*BaseAuthExecutor
	// contains filtered or unexported fields
}

type BaseSugarExecutor struct {
	*BaseExecutor
}

type BaseSystemQueryExecutor struct {
}

type BaseTransactionExecutor struct {
}

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

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

type Conn struct {
	net.Conn

	tracer.Context
	PreparedStatementMap
	PreparedPortalMap
	// 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)
	// AlterDatabase handles a ALTER DATABASE query.
	AlterDatabase(*Conn, *query.AlterDatabase) (message.Responses, error)
	// AlterTable handles a ALTER TABLE query.
	AlterTable(*Conn, *query.AlterTable) (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 DMOExtraExecutor interface {
	// Vacuum handles a VACUUM query.
	Vacuum(*Conn, *query.Vacuum) (message.Responses, error)
	// Truncate handles a TRUNCATE query.
	Truncate(*Conn, *query.Truncate) (message.Responses, error)
}

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

type Executor interface {
	StartupHandler
	QueryExecutor
	QueryExtraExecutor
	TCLExecutor
	ExtendedQueryExecutor
	SystemQueryExecutor
	BulkExecutor
	ErrorHandler
	// SetStartupHandler sets a user startup handler.
	SetStartupHandler(StartupHandler)
	// SetQueryExecutor sets a user query executor.
	SetQueryExecutor(QueryExecutor)
	// SetQueryExecutor sets a user query executor.
	SetQueryExtraExecutor(QueryExtraExecutor)
	// SetTransactionExecutor sets a user transaction executor.
	SetTransactionExecutor(TCLExecutor)
	// SetSystemQueryExecutor sets a system query executor.
	SetSystemQueryExecutor(SystemQueryExecutor)
	// SetBulkExecutor sets a user bulk executor.
	SetBulkExecutor(BulkExecutor)
	// SetErrorHandler sets a user error handler.
	SetErrorHandler(ErrorHandler)
}

type ExtendedQueryExecutor interface {
	// Query handles a query message.
	Query(*Conn, *message.Query) (message.Responses, error)
	// Prepare handles a parse message.
	Parse(*Conn, *message.Parse) (message.Responses, error)
	// Bind handles a bind message.
	Bind(*Conn, *message.Bind) (message.Responses, error)
	// Describe handles a describe message.
	Describe(*Conn, *message.Describe) (message.Responses, error)
	// Execute handles a execute message.
	Execute(*Conn, *message.Execute) (message.Responses, error)
	// Close handles a close message.
	Close(*Conn, *message.Close) (message.Responses, error)
	// Sync handles a sync message.
	Sync(*Conn, *message.Sync) (message.Responses, error)
	// Flush handles a flush message.
	Flush(*Conn, *message.Flush) (message.Responses, error)
}

type PreparedPortal = message.Query

type PreparedPortalMap map[string]PreparedPortal

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

type PreparedStatementMap map[string]*PreparedStatement

type QueryExecutor interface {
	DDOExecutor
	DMOExecutor
}

type QueryExtraExecutor interface {
	DMOExtraExecutor
}

type Server struct {
	*Config
	tracer.Tracer

	Executor
	// contains filtered or unexported fields
}

type StartupAuthHandler interface {
	// Authenticate handles the Start-up message and returns an Authentication or ErrorResponse message.
	Authenticate(*Conn, *message.Startup) (message.Response, error)
	// AddAuthenticator adds a new authenticator.
	AddAuthenticator(auth.Authenticator)
	// ClearAuthenticators clears all authenticators.
	ClearAuthenticators()
}

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

type SystemQueryExecutor interface {
	// SystemSelect handles a SELECT query for system tables.
	SystemSelect(*Conn, *query.Select) (message.Responses, error)
}

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

type TLSConf struct {
	ClientAuthType tls.ClientAuthType
	ServerCert     []byte
	ServerKey      []byte
	RootCerts      [][]byte
	// contains filtered or unexported fields
}