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 BaseExecutor struct {
	Authenticator
	ProtocolHandler
	QueryExecutor
}

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

type BaseQueryExecutor struct {
}

type BindHandler interface {
	// Parse returns the parse response.
	Parse(*Conn, *message.Parse) (message.Response, error)
	// Bind returns the bind response.
	Bind(*Conn, *message.Parse, *message.Bind) (message.Response, error)
}

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

type Conn struct {
	tracer.Context
	// contains filtered or unexported fields
}

type ConnOption = func(*Conn)

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 Executor interface {
	Authenticator
	ProtocolHandler
	QueryExecutor
	// SetAuthenticator sets a user authenticator.
	SetAuthenticator(Authenticator)
	// SetProtocolHandler sets a user protocol executor.
	SetProtocolHandler(ProtocolHandler)
	// SetQueryExecutor sets a user query executor.
	SetQueryExecutor(QueryExecutor)
}

type ProtocolHandler interface {
	StatusHandler
	BindHandler
}

type QueryExecutor interface {
	DDOExecutor
	DMOExecutor
}

type Server struct {
	*Config
	tracer.Tracer

	Executor
	// contains filtered or unexported fields
}

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