wire

type AuthStrategy func(ctx context.Context, writer *buffer.Writer, reader *buffer.Reader) (err error)

type CloseFn func(ctx context.Context) error

type Column struct {
	Table        int32  // table id
	Name         string // column name
	AttrNo       int16  // column attribute no (optional)
	Oid          oid.Oid
	Width        int16
	TypeModifier int32
	Format       FormatCode
}

type Columns []Column

type DataWriter interface {
	// Define writes the column headers containing their type definitions, width
	// type oid, etc. to the underlaying Postgres client. The column headers
	// could only be written once. An error will be returned whenever this
	// method is called twice.
	Define(Columns) error
	// Row writes a single data row containing the values inside the given slice to
	// the underlaying Postgres client. The column headers have to be written before
	// sending rows. Each item inside the slice represents a single column value.
	// The slice length needs to be the same length as the defined columns. Nil
	// values are encoded as NULL values.
	Row([]interface{}) error

	// Empty announces to the client a empty response and that no data rows should
	// be expected.
	Empty() error

	// Complete announces to the client that the command has been completed and
	// no further data should be expected.
	Complete(description string) error
}

type FormatCode int16

type FormatEncoder func(ci *pgtype.ConnInfo, buf []byte) (newBuf []byte, err error)

type OptionFn func(*Server)

type ParameterStatus string

type Parameters map[ParameterStatus]string

type Server struct {
	Auth            AuthStrategy
	BufferedMsgSize int
	Parameters      Parameters
	Certificates    []tls.Certificate
	ClientCAs       *x509.CertPool
	ClientAuth      tls.ClientAuthType
	SimpleQuery     SimpleQueryFn
	SQLBackend      sqlbackend.ISQLBackend
	CloseConn       CloseFn
	TerminateConn   CloseFn
	// contains filtered or unexported fields
}

type SimpleQueryFn func(ctx context.Context, query string, writer DataWriter) error