postgresql

Dec 27, 2024

Changes in this version

+ type CertConfig interface

+ SetClientAuthType func(authType tls.ClientAuthType)

+ SetRootCertFiles func(files ...string) error

+ SetRootCerts func(certs ...[]byte)

+ SetServerCert func(cert []byte)

+ SetServerCertFile func(file string) error

+ SetServerKey func(key []byte)

+ SetServerKeyFile func(file string) error

+ SetTLSConfig func(tlsConfig *tls.Config)

+ TLSConfig func() (*tls.Config, error)

Dec 11, 2024

Changes in this version

+ func NewDefaultExQueryExecutorWith(executor QueryExecutor) *defaultExQueryExecutor

+ func NewPgxClient() *sqltest.PgxClient

+ func NewPqClient() *sqltest.PqClient

+ type Client = sqltest.Client

+ func NewDefaultClient() Client

+ type DDOExExecutor interface

+ CreateIndex func(Conn, query.CreateIndex) (protocol.Responses, error)

+ DropIndex func(Conn, query.DropIndex) (protocol.Responses, error)

+ type PgxClient = sqltest.PgxClient

+ type PqClient = sqltest.PqClient

type QueryExecutor

+ func NewDefaultQueryExecutor() QueryExecutor

+ type SQLExecutorSetter interface

+ SetSQLExecutor func(SQLExecutor)

type SystemQueryExecutor

+ func NewDefaultSystemQueryExecutor() SystemQueryExecutor

Nov 23, 2024

Changes in this version

+ func NewDefaultExtraQueryExecutorWith(executor DMOExecutor) *dmoExtraExecutor

type BulkQueryExecutor

+ func NewNullBulkExecutor() BulkQueryExecutor

type ErrorHandler

+ func NewNullErrorHandler() ErrorHandler

type QueryExecutor

+ func NewNullQueryExecutor() QueryExecutor

+ type SQLQueryExecutor interface

+ SetSQLExecutor func(SQLExecutor)

+ func NewDefaultSQLQueryExecutor() SQLQueryExecutor

+ type SQLSystemQueryExecutor interface

+ SetSQLExecutor func(SQLExecutor)

+ func NewDefaultSQLSystemQueryExecutor() SQLSystemQueryExecutor

type Server

+ BulkQueryExecutor func() BulkQueryExecutor

+ ErrorHandler func() ErrorHandler

+ ExQueryExecutor func() ExQueryExecutor

+ QueryExecutor func() QueryExecutor

+ SQLExecutor func() SQLExecutor

+ SetBulkQueryExecutor func(BulkQueryExecutor)

+ SetErrorHandler func(ErrorHandler)

+ SetExQueryExecutor func(ExQueryExecutor)

+ SetQueryExecutor func(QueryExecutor)

+ SetSQLExecutor func(SQLExecutor)

+ SetSystemQueryExecutor func(SystemQueryExecutor)

+ SystemQueryExecutor func() SystemQueryExecutor

type SystemQueryExecutor

+ func NewNullSystemQueryExecutor() SystemQueryExecutor

Nov 16, 2024

Changes in this version

type BaseExecutor

+ func (executor *BaseExecutor) SetBulkQueryExecutor(be BulkQueryExecutor)

+ func (executor *BaseExecutor) SetExQueryExecutor(qe ExQueryExecutor)

type BaseQueryExecutor

+ func (executor *BaseQueryExecutor) Begin(Conn, query.Begin) (protocol.Responses, error)

+ func (executor *BaseQueryExecutor) Commit(Conn, query.Commit) (protocol.Responses, error)

+ func (executor *BaseQueryExecutor) Rollback(Conn, query.Rollback) (protocol.Responses, error)

+ type BulkQueryExecutor interface

+ Copy func(Conn, query.Copy) (protocol.Responses, error)

+ CopyData func(Conn, query.Copy, *CopyStream) (protocol.Responses, error)

+ type DMOExExecutor interface

+ Truncate func(Conn, query.Truncate) (protocol.Responses, error)

+ Vacuum func(Conn, query.Vacuum) (protocol.Responses, error)

+ type ExQueryExecutor interface

+ type PreparedManager struct

+ func NewPreparedManager() *PreparedManager

+ func (mgr *PreparedManager) PreparedPortal(conn Conn, name string) (*PreparedPortal, error)

+ func (mgr *PreparedManager) PreparedStatement(conn Conn, name string) (*PreparedStatement, error)

+ func (mgr *PreparedManager) RemovePreparedPortal(conn Conn, name string) error

+ func (mgr *PreparedManager) RemovePreparedStatement(conn Conn, name string) error

+ func (mgr *PreparedManager) SetPreparedPortal(conn Conn, name string, query *PreparedPortal) error

+ func (mgr *PreparedManager) SetPreparedStatement(conn Conn, msg *protocol.Parse) error

+ type ProtocolMessageExecutor interface

+ SetBulkQueryExecutor func(BulkQueryExecutor)

+ SetErrorHandler func(ErrorHandler)

+ SetExQueryExecutor func(ExQueryExecutor)

+ SetQueryExecutor func(QueryExecutor)

+ SetSystemQueryExecutor func(SystemQueryExecutor)

+ type ProtocolQueryHandler interface

+ type ProtocolStartupHander interface

+ type SQLExecutor = query.SQLExecutor

+ type SystemDMOExecutor interface

+ SystemSelect func(Conn, query.Select) (protocol.Responses, error)

+ type TCOExecutor interface

+ Begin func(Conn, query.Begin) (protocol.Responses, error)

+ Commit func(Conn, query.Commit) (protocol.Responses, error)

+ Rollback func(Conn, query.Rollback) (protocol.Responses, error)

type TLSConfig

+ func NewTLSConfig() TLSConfig

Nov 11, 2024

Changes in this version

+ type AuthManager interface

+ AddAuthenticator func(authenticator auth.Authenticator)

+ ClearAuthenticators func()

type BaseAuthExecutor

+ func (executor *BaseAuthExecutor) AddAuthenticator(authenticator auth.Authenticator)

+ func (executor *BaseAuthExecutor) ClearAuthenticators()

+ type SystemExecutor interface

+ type SystemExecutorHandler interface

+ SetStartupHandler func(StartupHandler)

+ type TLSConfig interface

+ IsTLSEnabled func() bool

+ SetClientAuthType func(authType tls.ClientAuthType)

+ SetRootCertFiles func(files ...string) error

+ SetRootCerts func(certs ...[]byte)

+ SetServerCert func(cert []byte)

+ SetServerCertFile func(file string) error

+ SetServerKey func(key []byte)

+ SetServerKeyFile func(file string) error

+ SetTLSConfig func(tlsConfig *tls.Config)

+ SetTLSEnabled func(enabled bool)

+ TLSConfig func() (*tls.Config, error)

+ type UserExecutor interface

+ type UserExecutorHandler interface

+ SetBulkExecutor func(BulkExecutor)

+ SetErrorHandler func(ErrorHandler)

+ SetQueryExecutor func(QueryExecutor)

+ SetQueryExtraExecutor func(QueryExtraExecutor)

+ SetSystemQueryExecutor func(SystemQueryExecutor)

+ SetTransactionExecutor func(TCLExecutor)

Oct 12, 2024

Changes in this version

+ func WithconnDatabase(name string) func(*conn)

+ func WithconnStartupMessage(msg *protocol.Startup) func(*conn)

+ func WithconnTracer(t tracer.Context) func(*conn)

+ type ConnID = sql.ConnID

+ type MessageConn interface

+ MessageReader func() *protocol.MessageReader

+ ReadyForMessage func(status protocol.TransactionStatus) error

+ ResponseError func(err error) error

+ ResponseMessage func(resMsg protocol.Response) error

+ ResponseMessages func(resMsgs protocol.Responses) error

+ SetStartupMessage func(msg *protocol.Startup)

+ SkipMessage func() error

+ StartupMessage func() (*protocol.Startup, bool)

+ type PreparedConn interface

+ PreparedPortal func(name string) (*PreparedPortal, error)

+ PreparedStatement func(name string) (*PreparedStatement, error)

+ RemovePreparedPortal func(name string) error

+ RemovePreparedStatement func(name string) error

+ SetPreparedPortal func(name string, query *PreparedPortal) error

+ SetPreparedStatement func(msg *protocol.Parse) error

+ type TLSConn interface

+ IsTLSConnection func() bool

+ TLSConnectionState func() (*tls.ConnectionState, bool)

Jun 28, 2024

Changes in this version

type Conn

+ func (conn *Conn) Close() error

+ type ConnManager struct

+ func NewConnManager() *ConnManager

+ func (mgr *ConnManager) AddConn(c *Conn)

+ func (mgr *ConnManager) Close() error

+ func (mgr *ConnManager) ConnByUUID(uuid uuid.UUID) (*Conn, bool)

+ func (mgr *ConnManager) Conns() []*Conn

+ func (mgr *ConnManager) RemoveConn(conn *Conn) error

+ func (mgr *ConnManager) Start() error

+ func (mgr *ConnManager) Stop() error

May 25, 2024

Changes in this version

+ func WithConnStartupMessage(msg *message.Startup) func(*Conn)

+ func WithTLSConnectionState(s *tls.ConnectionState) func(*Conn)

type Conn

+ func (conn *Conn) IsTLSConnection() bool

+ func (conn *Conn) SetStartupMessage(msg *message.Startup)

+ func (conn *Conn) StartupMessage() (*message.Startup, bool)

+ func (conn *Conn) TLSConnectionState() (*tls.ConnectionState, bool)

May 18, 2024

Changes in this version

type TLSConf

+ RootCerts [][]byte

+ ServerCert []byte

+ ServerKey []byte

+ func (config *TLSConf) SetRootCerts(certs ...[]byte)

+ func (config *TLSConf) SetServerCert(cert []byte)

+ func (config *TLSConf) SetServerKey(key []byte)

+ func (config *TLSConf) SetTLSConfig(tlsConfig *tls.Config)

May 15, 2024

Changes in this version

type TLSConf

+ func (config *TLSConf) IsTLSEnabled() bool

+ func (config *TLSConf) SetTLSEnabled(enabled bool)

May 12, 2024

Changes in this version

+ type TLSConf struct

+ ClientAuthType tls.ClientAuthType

+ RootCertFiles []string

+ ServerCertFile string

+ ServerKeyFile string

+ func NewTLSConf() *TLSConf

+ func (config *TLSConf) SetClientAuthType(authType tls.ClientAuthType)

+ func (config *TLSConf) SetRootCertFiles(files ...string)

+ func (config *TLSConf) SetServerCertFile(file string)

+ func (config *TLSConf) SetServerKeyFile(file string)

+ func (config *TLSConf) TLSConfig() (*tls.Config, error)

Dec 3, 2023

Changes in this version

+ type BaseAuthExecutor struct

+ func NewBaseAuthExecutor() *BaseAuthExecutor

+ func (executor *BaseAuthExecutor) Authenticate(conn *Conn, msg *message.Startup) (message.Response, error)

+ type BaseStartupExecutor struct

+ func (executor *BaseStartupExecutor) BackendKeyData(*Conn) (message.Response, error)

+ func (executor *BaseStartupExecutor) ParameterStatuses(*Conn) (message.Responses, error)

type Conn

+ func (conn *Conn) MessageReader() *message.MessageReader

+ type StartupAuthHandler interface

+ AddAuthenticator func(auth.Authenticator)

+ Authenticate func(*Conn, *message.Startup) (message.Response, error)

+ ClearAuthenticators func()

type StartupHandler

+ BackendKeyData func(*Conn) (message.Response, error)

+ ParameterStatuses func(*Conn) (message.Responses, error)

Oct 27, 2023

Changes in this version

type Conn

+ func (conn *Conn) SetReadDeadline(t time.Time) error

+ func (conn *Conn) SetWriteDeadline(t time.Time) error

+ type TCLExecutor interface

+ Begin func(*Conn, *query.Begin) (message.Responses, error)

+ Commit func(*Conn, *query.Commit) (message.Responses, error)

+ Rollback func(*Conn, *query.Rollback) (message.Responses, error)

Oct 3, 2023

Changes in this version

type Conn

+ func (conn *Conn) UUID() uuid.UUID

Sep 27, 2023

Changes in this version

+ func IsMatchQuery(q string, prefix string) bool

+ func IsPgbenchGetPartitionQuery(q string) bool

+ func NewCopyCompleteResponsesFrom(q *query.Copy, stream *CopyStream, conn *Conn, schema *sql.Schema, ...) (message.Responses, error)

+ func NewCopyInResponsesFrom(q *query.Copy, schema *sql.Schema) (message.Responses, error)

+ func NewCopyQueryFrom(schema *query.Schema, copyColumns sql.ColumnList, copyData *message.CopyData) (*query.Insert, error)

+ func NewGetPartitionResponseForPgbench() (message.Responses, error)

type BaseBulkExecutor

+ func (executor *BaseBulkExecutor) CopyData(*Conn, *query.Copy, *CopyStream) (message.Responses, error)

type BaseExecutor

+ func (executor *BaseExecutor) SetExtendedQueryExecutor(eqe ExtendedQueryExecutor)

+ func (executor *BaseExecutor) SetSystemQueryExecutor(sq SystemQueryExecutor)

+ type BaseExtendedQueryExecutor struct

+ func NewBaseExtendedQueryExecutorWith(executor *BaseExecutor) *BaseExtendedQueryExecutor

+ func (executor *BaseExtendedQueryExecutor) Bind(conn *Conn, msg *message.Bind) (message.Responses, error)

+ func (executor *BaseExtendedQueryExecutor) Close(conn *Conn, msg *message.Close) (message.Responses, error)

+ func (executor *BaseExtendedQueryExecutor) Describe(conn *Conn, msg *message.Describe) (message.Responses, error)

+ func (executor *BaseExtendedQueryExecutor) Execute(conn *Conn, msg *message.Execute) (message.Responses, error)

+ func (executor *BaseExtendedQueryExecutor) Flush(conn *Conn, msg *message.Flush) (message.Responses, error)

+ func (executor *BaseExtendedQueryExecutor) Parse(conn *Conn, msg *message.Parse) (message.Responses, error)

+ func (executor *BaseExtendedQueryExecutor) Query(conn *Conn, msg *message.Query) (message.Responses, error)

+ func (executor *BaseExtendedQueryExecutor) Sync(conn *Conn, msg *message.Sync) (message.Responses, error)

+ type BaseSystemQueryExecutor struct

+ func NewBaseSystemQueryExecutor() *BaseSystemQueryExecutor

+ func (executor *BaseSystemQueryExecutor) SystemSelect(*Conn, *query.Select) (message.Responses, error)

type BulkExecutor

+ CopyData func(*Conn, *query.Copy, *CopyStream) (message.Responses, error)

type Conn

+ func (conn *Conn) ReadyForMessage(status message.TransactionStatus) error

+ func (conn *Conn) ResponseError(err error) error

+ func (conn *Conn) ResponseMessage(resMsg message.Response) error

+ func (conn *Conn) ResponseMessages(resMsgs message.Responses) error

+ func (conn *Conn) SetDeadline(t time.Time) error

+ func (conn *Conn) SetSpanContext(ctx tracer.Context)

+ func (conn *Conn) SkipMessage() error

type Executor

+ SetBulkExecutor func(BulkExecutor)

+ SetSystemQueryExecutor func(SystemQueryExecutor)

+ type ExtendedQueryExecutor interface

+ Bind func(*Conn, *message.Bind) (message.Responses, error)

+ Close func(*Conn, *message.Close) (message.Responses, error)

+ Describe func(*Conn, *message.Describe) (message.Responses, error)

+ Execute func(*Conn, *message.Execute) (message.Responses, error)

+ Flush func(*Conn, *message.Flush) (message.Responses, error)

+ Parse func(*Conn, *message.Parse) (message.Responses, error)

+ Query func(*Conn, *message.Query) (message.Responses, error)

+ Sync func(*Conn, *message.Sync) (message.Responses, error)

+ type PreparedPortal = message.Query

+ type PreparedPortalMap map[string]PreparedPortal

+ func NewPreparedPortalMap() PreparedPortalMap

+ func (portalMap PreparedPortalMap) PreparedPortal(name string) (*PreparedPortal, error)

+ func (portalMap PreparedPortalMap) RemovePreparedPortal(name string) error

+ func (portalMap PreparedPortalMap) SetPreparedPortal(name string, query *PreparedPortal) error

+ type PreparedStatement struct

+ ParsedStatement *query.Statement

+ func (stmt *PreparedStatement) Name() string

+ type PreparedStatementMap map[string]*PreparedStatement

+ func NewPreparedStatementMap() PreparedStatementMap

+ func (stmtMap PreparedStatementMap) PreparedStatement(name string) (*PreparedStatement, error)

+ func (stmtMap PreparedStatementMap) RemovePreparedStatement(name string) error

+ func (stmtMap PreparedStatementMap) SetPreparedStatement(msg *message.Parse) error

+ type SystemQueryExecutor interface

+ SystemSelect func(*Conn, *query.Select) (message.Responses, error)

Sep 18, 2023

Changes in this version

+ type BaseSugarExecutor struct

+ func NewBaseSugarExecutorWith(executor *BaseExecutor) *BaseSugarExecutor

+ func (executor *BaseSugarExecutor) Truncate(conn *Conn, stmt *query.Truncate) (message.Responses, error)

+ func (executor *BaseSugarExecutor) Vacuum(conn *Conn, stmt *query.Vacuum) (message.Responses, error)

Sep 17, 2023

Changes in this version

type BaseExecutor

+ func (executor *BaseExecutor) SetQueryExtraExecutor(qe QueryExtraExecutor)

+ func (executor *BaseExecutor) SetTransactionExecutor(te TransactionExecutor)

type BaseQueryExecutor

+ func (executor *BaseQueryExecutor) AlterDatabase(*Conn, *query.AlterDatabase) (message.Responses, error)

+ func (executor *BaseQueryExecutor) AlterTable(*Conn, *query.AlterTable) (message.Responses, error)

+ type BaseTransactionExecutor struct

+ func NewBaseTransactionExecutor() *BaseTransactionExecutor

+ func (executor *BaseTransactionExecutor) Begin(*Conn, *query.Begin) (message.Responses, error)

+ func (executor *BaseTransactionExecutor) Commit(*Conn, *query.Commit) (message.Responses, error)

+ func (executor *BaseTransactionExecutor) Rollback(*Conn, *query.Rollback) (message.Responses, error)

type DDOExecutor

+ AlterDatabase func(*Conn, *query.AlterDatabase) (message.Responses, error)

+ AlterTable func(*Conn, *query.AlterTable) (message.Responses, error)

+ type DMOExtraExecutor interface

+ Truncate func(*Conn, *query.Truncate) (message.Responses, error)

+ Vacuum func(*Conn, *query.Vacuum) (message.Responses, error)

type Executor

+ SetQueryExtraExecutor func(QueryExtraExecutor)

+ SetTransactionExecutor func(TransactionExecutor)

+ type QueryExtraExecutor interface

+ type TransactionExecutor interface

+ Begin func(*Conn, *query.Begin) (message.Responses, error)

+ Commit func(*Conn, *query.Commit) (message.Responses, error)

+ Rollback func(*Conn, *query.Rollback) (message.Responses, error)

Sep 9, 2023

Changes in this version

+ type BaseErrorHandler struct

+ func NewBaseErrorHandler() *BaseErrorHandler

+ func (executor *BaseErrorHandler) ParserError(conn *Conn, q string, err error) (message.Responses, error)

type BaseExecutor

+ func (executor *BaseExecutor) SetErrorHandler(eh ErrorHandler)

+ type ErrorHandler interface

+ ParserError func(*Conn, string, error) (message.Responses, error)

type Executor

+ SetErrorHandler func(ErrorHandler)

Aug 30, 2023

Changes in this version

type BaseProtocolExecutor

+ func (executor *BaseProtocolExecutor) ParameterStatuses(*Conn) (message.Responses, error)

type StatusHandler

+ ParameterStatuses func(*Conn) (message.Responses, error)

Aug 27, 2023

Changes in this version

+ type BaseBulkExecutor struct

+ func NewBaseBulkExecutor() *BaseBulkExecutor

+ func (executor *BaseBulkExecutor) Copy(*Conn, *query.Copy, *CopyStream) (message.Responses, error)

type BaseExecutor

+ func (executor *BaseExecutor) SetBulkExecutor(be BulkExecutor)

+ func (executor *BaseExecutor) SetStartupHandler(sh StartupHandler)

type Config

+ func (config *Config) Address() string

+ func (config *Config) SetAddress(addr string)

type Conn

+ func (conn *Conn) Database() string

+ func (conn *Conn) SetDatabase(db string)

type Executor

+ SetStartupHandler func(StartupHandler)

+ type StartupHandler interface

Aug 18, 2023

Changes in this version

+ var ErrNotEqual = errors.New("not equal")

+ func NewErrColumnNotExist(v any) error

+ func NewErrColumnsNotEqual(v1, v2 int) error

+ func NewErrNotEqual(v1, v2 any) error

+ func NewErrPreparedQueryNotExist(name string) error

type BaseQueryExecutor

+ func (executor *BaseQueryExecutor) Copy(*Conn, *query.Copy, *CopyStream) (message.Responses, error)

+ type BulkExecutor interface

+ Copy func(*Conn, *query.Copy, *CopyStream) (message.Responses, error)

+ type CopyStream struct

+ func NewCopyStreamWithReader(reader *message.MessageReader) *CopyStream

+ func (stream *CopyStream) CopyData() (*message.CopyData, error)

+ func (stream *CopyStream) Next() (bool, error)

+ type PreparedQuery = message.Parse

+ type PreparedQueryMap map[string]*PreparedQuery

+ func NewPreparedQueryMap() PreparedQueryMap

+ func (queries PreparedQueryMap) PreparedQuery(name string) (*PreparedQuery, error)

+ func (queries PreparedQueryMap) SetPreparedQuery(query *PreparedQuery) error

Jul 27, 2023

Changes in this version

+ const DefaultPort

+ const PackageName

+ const Version

+ var ErrExist = errors.New("exist")

+ var ErrNotExist = errors.New("not exist")

+ var ErrNotImplemented = errors.New("not implemented")

+ var ErrNotSupported = errors.New("not supported")

+ func NewErrDatabaseExist(v string) error

+ func NewErrDatabaseNotExist(v string) error

+ func NewErrExist(v any) error

+ func NewErrNotExist(v any) error

+ func NewErrNotImplemented(msg string) error

+ func NewErrNotSupported(msg string) error

+ func NewErrTableExist(v string) error

+ func NewErrTableNotExist(v string) error

+ func WithConnDatabase(name string) func(*Conn)

+ func WithConnTracer(t tracer.Context) func(*Conn)

+ type Authenticator interface

+ Authenticate func(*Conn, *message.Startup) (message.Response, error)

+ type BaseAuthenticator struct

+ func NewBaseAuthenticator() *BaseAuthenticator

+ func (executor *BaseAuthenticator) Authenticate(*Conn, *message.Startup) (message.Response, error)

+ type BaseExecutor struct

+ func NewBaseExecutor() *BaseExecutor

+ func (executor *BaseExecutor) SetAuthenticator(at Authenticator)

+ func (executor *BaseExecutor) SetProtocolHandler(pe ProtocolHandler)

+ func (executor *BaseExecutor) SetQueryExecutor(qe QueryExecutor)

+ type BaseProtocolExecutor struct

+ func NewBaseProtocolExecutor() *BaseProtocolExecutor

+ func (executor *BaseProtocolExecutor) Authenticate(*Conn, *message.Startup) (message.Response, error)

+ func (executor *BaseProtocolExecutor) BackendKeyData(*Conn) (message.Response, error)

+ func (executor *BaseProtocolExecutor) Bind(*Conn, *message.Parse, *message.Bind) (message.Response, error)

+ func (executor *BaseProtocolExecutor) ParameterStatus(*Conn) (message.Response, error)

+ func (executor *BaseProtocolExecutor) Parse(*Conn, *message.Parse) (message.Response, error)

+ type BaseQueryExecutor struct

+ func NewBaseQueryExecutor() *BaseQueryExecutor

+ func (executor *BaseQueryExecutor) CreateDatabase(*Conn, *query.CreateDatabase) (message.Responses, error)

+ func (executor *BaseQueryExecutor) CreateIndex(*Conn, *query.CreateIndex) (message.Responses, error)

+ func (executor *BaseQueryExecutor) CreateTable(*Conn, *query.CreateTable) (message.Responses, error)

+ func (executor *BaseQueryExecutor) Delete(*Conn, *query.Delete) (message.Responses, error)

+ func (executor *BaseQueryExecutor) DropDatabase(*Conn, *query.DropDatabase) (message.Responses, error)

+ func (executor *BaseQueryExecutor) DropTable(*Conn, *query.DropTable) (message.Responses, error)

+ func (executor *BaseQueryExecutor) Insert(*Conn, *query.Insert) (message.Responses, error)

+ func (executor *BaseQueryExecutor) Select(*Conn, *query.Select) (message.Responses, error)

+ func (executor *BaseQueryExecutor) Update(*Conn, *query.Update) (message.Responses, error)

+ type BindHandler interface

+ Bind func(*Conn, *message.Parse, *message.Bind) (message.Response, error)

+ Parse func(*Conn, *message.Parse) (message.Response, error)

+ type Config struct

+ func NewDefaultConfig() *Config

+ func (config *Config) Host() string

+ func (config *Config) Port() int

+ func (config *Config) SetHost(host string)

+ func (config *Config) SetPort(port int)

+ type Conn struct

+ func NewConnWith(c net.Conn, opts ...ConnOption) *Conn

+ func (conn *Conn) Conn() net.Conn

+ func (conn *Conn) DatabaseName() string

+ func (conn *Conn) SetDatabaseName(db string)

+ func (conn *Conn) SpanContext() tracer.Context

+ func (conn *Conn) Timestamp() time.Time

+ type ConnOption = func(*Conn)

+ type DDOExecutor interface

+ CreateDatabase func(*Conn, *query.CreateDatabase) (message.Responses, error)

+ CreateIndex func(*Conn, *query.CreateIndex) (message.Responses, error)

+ CreateTable func(*Conn, *query.CreateTable) (message.Responses, error)

+ DropDatabase func(*Conn, *query.DropDatabase) (message.Responses, error)

+ DropTable func(*Conn, *query.DropTable) (message.Responses, error)

+ type DMOExecutor interface

+ Delete func(*Conn, *query.Delete) (message.Responses, error)

+ Insert func(*Conn, *query.Insert) (message.Responses, error)

+ Select func(*Conn, *query.Select) (message.Responses, error)

+ Update func(*Conn, *query.Update) (message.Responses, error)

+ type Executor interface

+ SetAuthenticator func(Authenticator)

+ SetProtocolHandler func(ProtocolHandler)

+ SetQueryExecutor func(QueryExecutor)

+ type ProtocolHandler interface

+ type QueryExecutor interface

+ type Server struct

+ func NewServer() *Server

+ func (server *Server) Restart() error

+ func (server *Server) SetTracer(t tracer.Tracer)

+ func (server *Server) Start() error

+ func (server *Server) Stop() error

+ type StatusHandler interface

+ BackendKeyData func(*Conn) (message.Response, error)

+ ParameterStatus func(*Conn) (message.Response, error)