pgserver

Documentation

Index

• Constants
• Variables
• type Backend
  • func NewBackend(ctx context.Context, clientConn io.ReadWriteCloser) (*Backend, error)
  • func (be *Backend) Close() error
  • func (be *Backend) Fatal(ctx context.Context, msg string)
  • func (be *Backend) Fatalf(ctx context.Context, msg string, args ...any)
  • func (be *Backend) Passthrough(ctx context.Context, frontend *pgproto3.Frontend) error
  • func (be *Backend) SendReady() error
• type StartupData

Constants

const TxStatusIdle = 'I'

Variables

var ErrTerminate = fmt.Errorf("terminate")

Types

type Backend

type Backend struct {
	Data StartupData
	// contains filtered or unexported fields
}

func NewBackend

func NewBackend(ctx context.Context, clientConn io.ReadWriteCloser) (*Backend, error)

func (*Backend) Close

func (be *Backend) Close() error

func (*Backend) Fatal

func (be *Backend) Fatal(ctx context.Context, msg string)

func (*Backend) Fatalf

func (be *Backend) Fatalf(ctx context.Context, msg string, args ...any)

func (*Backend) Passthrough

func (be *Backend) Passthrough(ctx context.Context, frontend *pgproto3.Frontend) error

func (*Backend) SendReady

func (be *Backend) SendReady() error

type StartupData

type StartupData struct {
	User            string
	Database        string
	ProtocolVersion uint32
}