pgproto3

package
v3.6.3+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2020 License: MIT Imports: 11 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	AuthTypeOk                = 0
	AuthTypeCleartextPassword = 3
	AuthTypeMD5Password       = 5
)
View Source 
const (
	TextFormat   = 0
	BinaryFormat = 1
)
View Source 
const (
	ProtocolVersionNumber = 196608 // 3.0

)

Variables

This section is empty.

Functions

This section is empty.

Types

type Authentication 

type Authentication struct {
	Type uint32

	// MD5Password fields
	Salt [4]byte
}

func (*Authentication) Backend 

func (*Authentication) Backend()

func (*Authentication) Decode 

func (dst *Authentication) Decode(src []byte) error

func (*Authentication) Encode 

func (src *Authentication) Encode(dst []byte) []byte

type Backend 

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

func NewBackend 

func NewBackend(r io.Reader, w io.Writer) (*Backend, error)

func (*Backend) Receive 

func (b *Backend) Receive() (FrontendMessage, error)

func (*Backend) ReceiveStartupMessage 

func (b *Backend) ReceiveStartupMessage() (*StartupMessage, error)

func (*Backend) Send 

func (b *Backend) Send(msg BackendMessage) error

type BackendKeyData 

type BackendKeyData struct {
	ProcessID uint32
	SecretKey uint32
}

func (*BackendKeyData) Backend 

func (*BackendKeyData) Backend()

func (*BackendKeyData) Decode 

func (dst *BackendKeyData) Decode(src []byte) error

func (*BackendKeyData) Encode 

func (src *BackendKeyData) Encode(dst []byte) []byte

func (*BackendKeyData) MarshalJSON 

func (src *BackendKeyData) MarshalJSON() ([]byte, error)

type BackendMessage 

type BackendMessage interface {
	Message
	Backend() // no-op method to distinguish frontend from backend methods
}

type BigEndianBuf 

type BigEndianBuf [8]byte

func (BigEndianBuf) Int16 

func (b BigEndianBuf) Int16(n int16) []byte

func (BigEndianBuf) Int32 

func (b BigEndianBuf) Int32(n int32) []byte

func (BigEndianBuf) Int64 

func (b BigEndianBuf) Int64(n int64) []byte

func (BigEndianBuf) Uint16 

func (b BigEndianBuf) Uint16(n uint16) []byte

func (BigEndianBuf) Uint32 

func (b BigEndianBuf) Uint32(n uint32) []byte

type Bind 

type Bind struct {
	DestinationPortal    string
	PreparedStatement    string
	ParameterFormatCodes []int16
	Parameters           [][]byte
	ResultFormatCodes    []int16
}

func (*Bind) Decode 

func (dst *Bind) Decode(src []byte) error

func (*Bind) Encode 

func (src *Bind) Encode(dst []byte) []byte

func (*Bind) Frontend 

func (*Bind) Frontend()

func (*Bind) MarshalJSON 

func (src *Bind) MarshalJSON() ([]byte, error)

type BindComplete 

type BindComplete struct{}

func (*BindComplete) Backend 

func (*BindComplete) Backend()

func (*BindComplete) Decode 

func (dst *BindComplete) Decode(src []byte) error

func (*BindComplete) Encode 

func (src *BindComplete) Encode(dst []byte) []byte

func (*BindComplete) MarshalJSON 

func (src *BindComplete) MarshalJSON() ([]byte, error)

type Close 

type Close struct {
	ObjectType byte // 'S' = prepared statement, 'P' = portal
	Name       string
}

func (*Close) Decode 

func (dst *Close) Decode(src []byte) error

func (*Close) Encode 

func (src *Close) Encode(dst []byte) []byte

func (*Close) Frontend 

func (*Close) Frontend()

func (*Close) MarshalJSON 

func (src *Close) MarshalJSON() ([]byte, error)

type CloseComplete 

type CloseComplete struct{}

func (*CloseComplete) Backend 

func (*CloseComplete) Backend()

func (*CloseComplete) Decode 

func (dst *CloseComplete) Decode(src []byte) error

func (*CloseComplete) Encode 

func (src *CloseComplete) Encode(dst []byte) []byte

func (*CloseComplete) MarshalJSON 

func (src *CloseComplete) MarshalJSON() ([]byte, error)

type CommandComplete 

type CommandComplete struct {
	CommandTag string
}

func (*CommandComplete) Backend 

func (*CommandComplete) Backend()

func (*CommandComplete) Decode 

func (dst *CommandComplete) Decode(src []byte) error

func (*CommandComplete) Encode 

func (src *CommandComplete) Encode(dst []byte) []byte

func (*CommandComplete) MarshalJSON 

func (src *CommandComplete) MarshalJSON() ([]byte, error)

type CopyBothResponse 

type CopyBothResponse struct {
	OverallFormat     byte
	ColumnFormatCodes []uint16
}

func (*CopyBothResponse) Backend 

func (*CopyBothResponse) Backend()

func (*CopyBothResponse) Decode 

func (dst *CopyBothResponse) Decode(src []byte) error

func (*CopyBothResponse) Encode 

func (src *CopyBothResponse) Encode(dst []byte) []byte

func (*CopyBothResponse) MarshalJSON 

func (src *CopyBothResponse) MarshalJSON() ([]byte, error)

type CopyData 

type CopyData struct {
	Data []byte
}

func (*CopyData) Backend 

func (*CopyData) Backend()

func (*CopyData) Decode 

func (dst *CopyData) Decode(src []byte) error

func (*CopyData) Encode 

func (src *CopyData) Encode(dst []byte) []byte

func (*CopyData) Frontend 

func (*CopyData) Frontend()

func (*CopyData) MarshalJSON 

func (src *CopyData) MarshalJSON() ([]byte, error)

type CopyInResponse 

type CopyInResponse struct {
	OverallFormat     byte
	ColumnFormatCodes []uint16
}

func (*CopyInResponse) Backend 

func (*CopyInResponse) Backend()

func (*CopyInResponse) Decode 

func (dst *CopyInResponse) Decode(src []byte) error

func (*CopyInResponse) Encode 

func (src *CopyInResponse) Encode(dst []byte) []byte

func (*CopyInResponse) MarshalJSON 

func (src *CopyInResponse) MarshalJSON() ([]byte, error)

type CopyOutResponse 

type CopyOutResponse struct {
	OverallFormat     byte
	ColumnFormatCodes []uint16
}

func (*CopyOutResponse) Backend 

func (*CopyOutResponse) Backend()

func (*CopyOutResponse) Decode 

func (dst *CopyOutResponse) Decode(src []byte) error

func (*CopyOutResponse) Encode 

func (src *CopyOutResponse) Encode(dst []byte) []byte

func (*CopyOutResponse) MarshalJSON 

func (src *CopyOutResponse) MarshalJSON() ([]byte, error)

type DataRow 

type DataRow struct {
	Values [][]byte
}

func (*DataRow) Backend 

func (*DataRow) Backend()

func (*DataRow) Decode 

func (dst *DataRow) Decode(src []byte) error

func (*DataRow) Encode 

func (src *DataRow) Encode(dst []byte) []byte

func (*DataRow) MarshalJSON 

func (src *DataRow) MarshalJSON() ([]byte, error)

type Describe 

type Describe struct {
	ObjectType byte // 'S' = prepared statement, 'P' = portal
	Name       string
}

func (*Describe) Decode 

func (dst *Describe) Decode(src []byte) error

func (*Describe) Encode 

func (src *Describe) Encode(dst []byte) []byte

func (*Describe) Frontend 

func (*Describe) Frontend()

func (*Describe) MarshalJSON 

func (src *Describe) MarshalJSON() ([]byte, error)

type EmptyQueryResponse 

type EmptyQueryResponse struct{}

func (*EmptyQueryResponse) Backend 

func (*EmptyQueryResponse) Backend()

func (*EmptyQueryResponse) Decode 

func (dst *EmptyQueryResponse) Decode(src []byte) error

func (*EmptyQueryResponse) Encode 

func (src *EmptyQueryResponse) Encode(dst []byte) []byte

func (*EmptyQueryResponse) MarshalJSON 

func (src *EmptyQueryResponse) MarshalJSON() ([]byte, error)

type ErrorResponse 

type ErrorResponse struct {
	Severity         string
	Code             string
	Message          string
	Detail           string
	Hint             string
	Position         int32
	InternalPosition int32
	InternalQuery    string
	Where            string
	SchemaName       string
	TableName        string
	ColumnName       string
	DataTypeName     string
	ConstraintName   string
	File             string
	Line             int32
	Routine          string

	UnknownFields map[byte]string
}

func (*ErrorResponse) Backend 

func (*ErrorResponse) Backend()

func (*ErrorResponse) Decode 

func (dst *ErrorResponse) Decode(src []byte) error

func (*ErrorResponse) Encode 

func (src *ErrorResponse) Encode(dst []byte) []byte

type Execute 

type Execute struct {
	Portal  string
	MaxRows uint32
}

func (*Execute) Decode 

func (dst *Execute) Decode(src []byte) error

func (*Execute) Encode 

func (src *Execute) Encode(dst []byte) []byte

func (*Execute) Frontend 

func (*Execute) Frontend()

func (*Execute) MarshalJSON 

func (src *Execute) MarshalJSON() ([]byte, error)

type FieldDescription 

type FieldDescription struct {
	Name                 string
	TableOID             uint32
	TableAttributeNumber uint16
	DataTypeOID          uint32
	DataTypeSize         int16
	TypeModifier         uint32
	Format               int16
}

type Flush 

type Flush struct{}

func (*Flush) Decode 

func (dst *Flush) Decode(src []byte) error

func (*Flush) Encode 

func (src *Flush) Encode(dst []byte) []byte

func (*Flush) Frontend 

func (*Flush) Frontend()

func (*Flush) MarshalJSON 

func (src *Flush) MarshalJSON() ([]byte, error)

type Frontend 

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

func NewFrontend 

func NewFrontend(r io.Reader, w io.Writer) (*Frontend, error)

func (*Frontend) Receive 

func (b *Frontend) Receive(rmsgs *ReceivedMessages) error

function to batch receive backend message and write to given ReceivedMessages this will make sure ReceivedMessages have at least 1 BackendMessage

func (*Frontend) Send 

func (b *Frontend) Send(msg FrontendMessage) error

type FrontendMessage 

type FrontendMessage interface {
	Message
	Frontend() // no-op method to distinguish frontend from backend methods
}

type FunctionCallResponse 

type FunctionCallResponse struct {
	Result []byte
}

func (*FunctionCallResponse) Backend 

func (*FunctionCallResponse) Backend()

func (*FunctionCallResponse) Decode 

func (dst *FunctionCallResponse) Decode(src []byte) error

func (*FunctionCallResponse) Encode 

func (src *FunctionCallResponse) Encode(dst []byte) []byte

func (*FunctionCallResponse) MarshalJSON 

func (src *FunctionCallResponse) MarshalJSON() ([]byte, error)

type Message 

type Message interface {
	// Decode is allowed and expected to retain a reference to data after
	// returning (unlike encoding.BinaryUnmarshaler).
	Decode(data []byte) error

	// Encode appends itself to dst and returns the new buffer.
	Encode(dst []byte) []byte
}

Message is the interface implemented by an object that can decode and encode a particular PostgreSQL message.

type NoData 

type NoData struct{}

func (*NoData) Backend 

func (*NoData) Backend()

func (*NoData) Decode 

func (dst *NoData) Decode(src []byte) error

func (*NoData) Encode 

func (src *NoData) Encode(dst []byte) []byte

func (*NoData) MarshalJSON 

func (src *NoData) MarshalJSON() ([]byte, error)

type NoticeResponse 

type NoticeResponse ErrorResponse

func (*NoticeResponse) Backend 

func (*NoticeResponse) Backend()

func (*NoticeResponse) Decode 

func (dst *NoticeResponse) Decode(src []byte) error

func (*NoticeResponse) Encode 

func (src *NoticeResponse) Encode(dst []byte) []byte

type NotificationResponse 

type NotificationResponse struct {
	PID     uint32
	Channel string
	Payload string
}

func (*NotificationResponse) Backend 

func (*NotificationResponse) Backend()

func (*NotificationResponse) Decode 

func (dst *NotificationResponse) Decode(src []byte) error

func (*NotificationResponse) Encode 

func (src *NotificationResponse) Encode(dst []byte) []byte

func (*NotificationResponse) MarshalJSON 

func (src *NotificationResponse) MarshalJSON() ([]byte, error)

type ParameterDescription 

type ParameterDescription struct {
	ParameterOIDs []uint32
}

func (*ParameterDescription) Backend 

func (*ParameterDescription) Backend()

func (*ParameterDescription) Decode 

func (dst *ParameterDescription) Decode(src []byte) error

func (*ParameterDescription) Encode 

func (src *ParameterDescription) Encode(dst []byte) []byte

func (*ParameterDescription) MarshalJSON 

func (src *ParameterDescription) MarshalJSON() ([]byte, error)

type ParameterStatus 

type ParameterStatus struct {
	Name  string
	Value string
}

func (*ParameterStatus) Backend 

func (*ParameterStatus) Backend()

func (*ParameterStatus) Decode 

func (dst *ParameterStatus) Decode(src []byte) error

func (*ParameterStatus) Encode 

func (src *ParameterStatus) Encode(dst []byte) []byte

func (*ParameterStatus) MarshalJSON 

func (ps *ParameterStatus) MarshalJSON() ([]byte, error)

type Parse 

type Parse struct {
	Name          string
	Query         string
	ParameterOIDs []uint32
}

func (*Parse) Decode 

func (dst *Parse) Decode(src []byte) error

func (*Parse) Encode 

func (src *Parse) Encode(dst []byte) []byte

func (*Parse) Frontend 

func (*Parse) Frontend()

func (*Parse) MarshalJSON 

func (src *Parse) MarshalJSON() ([]byte, error)

type ParseComplete 

type ParseComplete struct{}

func (*ParseComplete) Backend 

func (*ParseComplete) Backend()

func (*ParseComplete) Decode 

func (dst *ParseComplete) Decode(src []byte) error

func (*ParseComplete) Encode 

func (src *ParseComplete) Encode(dst []byte) []byte

func (*ParseComplete) MarshalJSON 

func (src *ParseComplete) MarshalJSON() ([]byte, error)

type PasswordMessage 

type PasswordMessage struct {
	Password string
}

func (*PasswordMessage) Decode 

func (dst *PasswordMessage) Decode(src []byte) error

func (*PasswordMessage) Encode 

func (src *PasswordMessage) Encode(dst []byte) []byte

func (*PasswordMessage) Frontend 

func (*PasswordMessage) Frontend()

func (*PasswordMessage) MarshalJSON 

func (src *PasswordMessage) MarshalJSON() ([]byte, error)

type Query 

type Query struct {
	String string
}

func (*Query) Decode 

func (dst *Query) Decode(src []byte) error

func (*Query) Encode 

func (src *Query) Encode(dst []byte) []byte

func (*Query) Frontend 

func (*Query) Frontend()

func (*Query) MarshalJSON 

func (src *Query) MarshalJSON() ([]byte, error)

type ReadyForQuery 

type ReadyForQuery struct {
	TxStatus byte
}

func (*ReadyForQuery) Backend 

func (*ReadyForQuery) Backend()

func (*ReadyForQuery) Decode 

func (dst *ReadyForQuery) Decode(src []byte) error

func (*ReadyForQuery) Encode 

func (src *ReadyForQuery) Encode(dst []byte) []byte

func (*ReadyForQuery) MarshalJSON 

func (src *ReadyForQuery) MarshalJSON() ([]byte, error)

type ReceivedMessages 

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

ring buffer structure to store non-decoded backend messages and its body

func NewReceivedMessages 

func NewReceivedMessages(n int) *ReceivedMessages

func (*ReceivedMessages) Backward 

func (r *ReceivedMessages) Backward()

moved 1 read message backward, it will not backward if all messages are not yet read

func (*ReceivedMessages) Forward 

func (r *ReceivedMessages) Forward()

skip 1 message which is not yet read, it will not forward if no readable messages

func (*ReceivedMessages) Kth 

func (r *ReceivedMessages) Kth(k int) (BackendMessage, []byte)

function to BackendMessage and its body by index (k) the start point is (r.rp + k) % r.Len() this function will not move message read position forward

func (ReceivedMessages) Len 

func (r ReceivedMessages) Len() int

return the length of messages array

func (*ReceivedMessages) Read 

func (r *ReceivedMessages) Read() (BackendMessage, []byte, error)

function to get BackendMessage and its body

func (ReceivedMessages) Readable 

func (r ReceivedMessages) Readable() int

return the count of message that is not yet read

func (*ReceivedMessages) SetCapacity 

func (r *ReceivedMessages) SetCapacity(capacity int)

update ReceivedMessages capacity, it will copy existing BackendMessage and message body to new array if they are not yet read

func (*ReceivedMessages) Write 

func (r *ReceivedMessages) Write(msg BackendMessage, msgBody []byte) error

function to store BackendMessage and its body this function would not overwrite the messages which are not yet read

func (ReceivedMessages) WriteCapacity 

func (r ReceivedMessages) WriteCapacity() int

return the count of space that allow to be written

type RowDescription 

type RowDescription struct {
	Fields []FieldDescription
}

func (*RowDescription) Backend 

func (*RowDescription) Backend()

func (*RowDescription) Decode 

func (dst *RowDescription) Decode(src []byte) error

func (*RowDescription) Encode 

func (src *RowDescription) Encode(dst []byte) []byte

func (*RowDescription) MarshalJSON 

func (src *RowDescription) MarshalJSON() ([]byte, error)

type StartupMessage 

type StartupMessage struct {
	ProtocolVersion uint32
	Parameters      map[string]string
}

func (*StartupMessage) Decode 

func (dst *StartupMessage) Decode(src []byte) error

func (*StartupMessage) Encode 

func (src *StartupMessage) Encode(dst []byte) []byte

func (*StartupMessage) Frontend 

func (*StartupMessage) Frontend()

func (*StartupMessage) MarshalJSON 

func (src *StartupMessage) MarshalJSON() ([]byte, error)

type Sync 

type Sync struct{}

func (*Sync) Decode 

func (dst *Sync) Decode(src []byte) error

func (*Sync) Encode 

func (src *Sync) Encode(dst []byte) []byte

func (*Sync) Frontend 

func (*Sync) Frontend()

func (*Sync) MarshalJSON 

func (src *Sync) MarshalJSON() ([]byte, error)

type Terminate 

type Terminate struct{}

func (*Terminate) Decode 

func (dst *Terminate) Decode(src []byte) error

func (*Terminate) Encode 

func (src *Terminate) Encode(dst []byte) []byte

func (*Terminate) Frontend 

func (*Terminate) Frontend()

func (*Terminate) MarshalJSON 

func (src *Terminate) MarshalJSON() ([]byte, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.