message

package

Go to main page

Versions in this module

v1

v1.5.4

Jun 28, 2024

v1.5.3

May 25, 2024

v1.5.2

May 18, 2024

v1.5.1

May 15, 2024

v1.5.0

May 12, 2024

Changes in this version

+ const SSLRequestCode

v1.4.1

May 8, 2024

v1.4.0

Dec 3, 2023

Changes in this version

+ const AuthenticationCleartextPasswordRequired

+ const AuthenticationGSSContinueRequired

+ const AuthenticationGSSRequired

+ const AuthenticationKerberosV5Required

+ const AuthenticationMD5PasswordRequired

+ const AuthenticationOk

+ const AuthenticationSASLContinueRequired

+ const AuthenticationSASLFinalRequired

+ const AuthenticationSASLRequired

+ const AuthenticationSCMCredentialRequired

+ const AuthenticationSSPIRequired

+ const StartUpPassword

type CommandComplete

+ func NewEmptyComplete() (*CommandComplete, error)

+ type Password struct

+ Password string

+ func NewPasswordWithReader(reader *MessageReader) (*Password, error)

type ResponseMessage

+ func NewAuthenticationCleartextPassword() (*ResponseMessage, error)

+ func NewAuthenticationMD5Password(salt []byte) (*ResponseMessage, error)

type Responses

+ func NewEmptyCompleteResponses() (Responses, error)

type Startup

+ func (msg *Startup) Password() (string, bool)

v1.3.5

Nov 2, 2023

v1.3.4

Oct 27, 2023

v1.3.3

Oct 3, 2023

v1.3.2

Sep 29, 2023

v1.3.1

Sep 28, 2023

v1.3.0

Sep 27, 2023

Changes in this version

+ const PreparedPortalByte

+ const PreparedStatementByte

type Bind

+ PortalName string

+ StatementName string

type BindParam

+ FormatCode int16

+ type Close struct

+ Name string

+ Type PreparedType

+ func NewCloseWithReader(reader *MessageReader) (*Close, error)

+ type CloseComplete struct

+ func NewCloseComplete() *CloseComplete

+ type Describe struct

+ Name string

+ Type PreparedType

+ func NewDescribeWithReader(reader *MessageReader) (*Describe, error)

+ type Execute struct

+ MaxRows int32

+ PortalName string

+ func NewExecuteWithReader(reader *MessageReader) (*Execute, error)

+ type Flush struct

+ func NewFlushWithReader(reader *MessageReader) (*Flush, error)

+ type FormatCode = system.FormatCode

+ const BinaryFormat

+ const TextFormat

type MessageReader

+ func (reader *MessageReader) IsPeekType(t Type) (bool, error)

+ type ParameterDescription struct

+ func NewParameterDescription() *ParameterDescription

+ func NewParameterDescriptionWith(objectIDs ...ObjectID) (*ParameterDescription, error)

+ type PreparedType int

+ const PreparedPortal

+ const PreparedStatement

+ func NewPreparedTypeWithByte(bt byte) (PreparedType, error)

type Reader

+ func (reader *Reader) PeekBytes(n int) ([]byte, error)

+ func (reader *Reader) ReadByte() (byte, error)

+ func (reader *Reader) ReadBytesUntil(delim byte) ([]byte, error)

type Responses

+ func (responses Responses) HasErrorResponse() bool

+ type Sync struct

+ func NewSyncWithReader(reader *MessageReader) (*Sync, error)

v1.2.1

Sep 18, 2023

v1.2.0

Sep 17, 2023

Changes in this version

+ func WithRowFieldDataType(dt *DataType) func(*RowField)

+ func WithRowFieldFormatCode(formatCode int16) func(*RowField)

+ func WithRowFieldModifier(typeModifier int32) func(*RowField)

+ func WithRowFieldNumber(number int16) func(*RowField)

+ func WithRowFieldObjectID(dataTypeID int32) func(*RowField)

+ func WithRowFieldSize(dataTypeSize int16) func(*RowField)

+ func WithRowFieldTableID(tableID int32) func(*RowField)

+ type ObjectID = system.ObjectID

type RowField

+ ObjectID int32

v1.1.1

Sep 13, 2023

v1.1.0

Sep 9, 2023

v1.0.2

Sep 5, 2023

Changes in this version

+ type OID = system.OID

v1.0.1

Aug 30, 2023

Changes in this version

+ const SSLDisabled

+ const SSLEnabled

type Reader

+ func (reader *Reader) PeekInt32() (int32, error)

type Responses

+ func NewParameterStatusesWith(m map[string]string) (Responses, error)

+ type SSLRequest struct

+ RequestCode int32

+ func NewSSLRequestWithReader(reader *MessageReader) (*SSLRequest, error)

+ type SSLResponse struct

+ Enabled byte

+ func NewSSLResponseWith(enabled rune) *SSLResponse

+ func (msg *SSLResponse) Bytes() ([]byte, error)

+ func (msg *SSLResponse) Type() Type

type Type

+ const SSLResponseMessage

v1.0.0

Aug 27, 2023

Changes in this version

+ type DataType int32

+ const AbstimeType

+ const AnyType

+ const AnyarrayType

+ const AnyelementType

+ const AnynonarrayType

+ const BitType

+ const BoolType

+ const BoxType

+ const BpcharType

+ const ByteaType

+ const CharType

+ const CidType

+ const CidrArrayType

+ const CidrType

+ const CircleArrayType

+ const CircleType

+ const CstringType

+ const DateType

+ const Float4Type

+ const Float8Type

+ const GeograpyType

+ const GeometryType

+ const InetArrayType

+ const InetType

+ const Int2Type

+ const Int2VectorType

+ const Int4Type

+ const Int8Type

+ const InternalType

+ const IntervalType

+ const LanguageHandlerType

+ const LineArrayType

+ const LineType

+ const LsegType

+ const Macaddr8Type

+ const MacaddrType

+ const NameType

+ const NumericType

+ const OidType

+ const OidvectorType

+ const OpaqueType

+ const PathType

+ const PointType

+ const PolygonArrayType

+ const PolygonType

+ const RecordType

+ const RefcursorType

+ const RegProcType

+ const RegclassType

+ const RegoperType

+ const RegoperatorType

+ const RegprocedureType

+ const RegtypeType

+ const ReltimeType

+ const TextType

+ const TidType

+ const TimeType

+ const TimeTzType

+ const TimestampType

+ const TimestampTzType

+ const TintervalType

+ const TriggerType

+ const UnknownType

+ const VarbitType

+ const VarcharType

+ const VoidType

+ const XMLType

+ const XidType

type RowDescription

+ func (msg *RowDescription) Field(n int) *RowField

v0

v0.9.1

Aug 18, 2023

Changes in this version

+ const BinaryCopy

+ const MessageHeaderSize

+ const MessageLengthSize

+ const MessageTypeSize

+ const TextCopy

+ var ErrInvalid = errors.New("invalid")

+ func NewErrInvalidMessage(t Type) error

type Bind

+ func NewBindWithReader(reader *MessageReader) (*Bind, error)

type CommandComplete

+ func NewCommitComplete() (*CommandComplete, error)

+ func NewCopyCompleteWith(n int) (*CommandComplete, error)

+ type CopyData struct

+ Data []string

+ func NewCopyDataWithReader(reader *MessageReader) (*CopyData, error)

+ type CopyDone struct

+ func NewCopyDoneWithReader(reader *MessageReader) (*CopyDone, error)

+ type CopyFail struct

+ Message string

+ MessageLength int32

+ func NewCopyFailWithReader(reader *Reader) (*CopyFail, error)

+ type CopyFormat = int8

+ type CopyInResponse struct

+ func NewCopyInResponseWith(fmt CopyFormat) *CopyInResponse

+ func (msg *CopyInResponse) AppendFormatCode(formatCode int16)

+ func (msg *CopyInResponse) Bytes() ([]byte, error)

+ type Message struct

+ Length int32

+ Type Type

+ func NewMessageWithReader(reader *MessageReader) (*Message, error)

+ func (msg *Message) MessageDataLength() int32

+ func (msg *Message) MessageLength() int32

+ func (msg *Message) MessageType() Type

+ func (msg *Message) ReadMessageData() ([]byte, error)

+ type MessageReader struct

+ Length int32

+ Type Type

+ func NewMessageReaderWith(reader *bufio.Reader) *MessageReader

+ func (reader *MessageReader) PeekType() (Type, error)

+ func (reader *MessageReader) ReadLength() (int32, error)

+ func (reader *MessageReader) ReadType() (Type, error)

type Reader

+ func (reader *Reader) ReadBytes(buf []byte) (int, error)

type RequestMessage

+ func NewRequestMessageWithReader(reader *MessageReader) (*RequestMessage, error)

type Responses

+ func NewCopyCompleteResponsesWith(n int) (Responses, error)

+ type Terminate struct

+ func NewTerminateWithReader(reader *MessageReader) (*Terminate, error)

type Type

+ func (t Type) String() string

v0.9.0

Jul 27, 2023

Changes in this version

+ const ApplicationName

+ const ClientEncoding

+ const DateStyle

+ const DateStyleISO

+ const DefaultTransactiOnReadOnly

+ const EncodingUTF8

+ const InHotStandby

+ const IntervalStyle

+ const IsSuperuser

+ const NoneMessage

+ const OntegerDatetimes

+ const ServerEncoding

+ const ServerVersion

+ const StandardConformingStrings

+ const StartUpApplicationName

+ const StartUpClientEncoding

+ const StartUpDatabase

+ const StartUpUser

+ const TimeZone

+ const TransactionBlock

+ const TransactionFailed

+ const TransactionIdle

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

+ var ErrInvalidLength = errors.New("invalid length")

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

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

+ var ErrShortMessage = errors.New("short message")

+ func NewErrExist(v any) error

+ func NewErrMessageNotSuppoted(t Type) error

+ func NewErrNotExist(v any) error

+ func WithDataTypeID(dataTypeID int32) func(*RowField)

+ func WithDataTypeSize(dataTypeSize int16) func(*RowField)

+ func WithFormatCode(formatCode int16) func(*RowField)

+ func WithNumber(number int16) func(*RowField)

+ func WithTableID(tableID int32) func(*RowField)

+ func WithTypeModifier(typeModifier int32) func(*RowField)

+ type BackendKeyData struct

+ func NewBackendKeyData() *BackendKeyData

+ func NewBackendKeyDataWith(processID int32, secretKey int32) (*BackendKeyData, error)

+ type Bind struct

+ MessageLength int32

+ Name string

+ NumParams int16

+ Params BindParams

+ Portal string

+ func NewBindWith(reader *Reader, parse *Parse) (*Bind, error)

+ type BindComplete struct

+ func NewBindComplete() *BindComplete

+ type BindParam struct

+ Type BindParamType

+ Value any

+ type BindParamType int16

+ const BindParamTypeBinary

+ const BindParamTypeString

+ type BindParams []*BindParam

+ func (params BindParams) FindBindParam(id string) (*BindParam, error)

+ type CommandComplete struct

+ func NewCommandComplete() *CommandComplete

+ func NewCommandCompleteWith(tag string) (*CommandComplete, error)

+ func NewDeleteCompleteWith(n int) (*CommandComplete, error)

+ func NewInsertCompleteWith(n int) (*CommandComplete, error)

+ func NewSelectCompleteWith(n int) (*CommandComplete, error)

+ func NewUpdateCompleteWith(n int) (*CommandComplete, error)

+ type DataRow struct

+ Data []any

+ func NewDataRow() *DataRow

+ func (msg *DataRow) AppendData(v any) error

+ func (msg *DataRow) Bytes() ([]byte, error)

+ type EmptyQueryResponse struct

+ func NewEmptyQueryResponse() *EmptyQueryResponse

+ type ErrorResponse struct

+ func NewErrorResponse() *ErrorResponse

+ func NewErrorResponseWith(err error) (*ErrorResponse, error)

+ func (msg *ErrorResponse) AddCode(code int32) error

+ func (msg *ErrorResponse) AddError(err error) error

+ func (msg *ErrorResponse) AppendField(t ErrorType, v string) error

+ func (msg *ErrorResponse) Bytes() ([]byte, error)

+ type ErrorType byte

+ const CodeError

+ const ColumnError

+ const ConstraintError

+ const DataTypeNameError

+ const DetailError

+ const FileError

+ const HintError

+ const InternalPositionError

+ const InternalQueryError

+ const LineError

+ const MessageError

+ const PositionError

+ const RoutineError

+ const SchemaError

+ const SeverityError

+ const TableError

+ const WhereError

+ type NoData struct

+ func NewNoData() *NoData

+ type ParameterStatus struct

+ func NewParameterStatus() *ParameterStatus

+ func NewParameterStatusWith(m map[string]string) (*ParameterStatus, error)

+ func (msg *ParameterStatus) AppendParameter(s ...string) error

+ func (msg *ParameterStatus) AppendParameters(m map[string]string) error

+ type Parse struct

+ DataTypes []int32

+ MessageLength int32

+ Name string

+ NumDataTypes int16

+ Query string

+ func NewParseWithReader(reader *Reader) (*Parse, error)

+ type ParseComplete struct

+ func NewParseComplete() *ParseComplete

+ type Query struct

+ MessageLength int32

+ Query string

+ func NewQueryWith(parseMsg *Parse, bindMsg *Bind) (*Query, error)

+ func NewQueryWithReader(reader *Reader) (*Query, error)

+ type Reader struct

+ func NewReaderWith(reader *bufio.Reader) *Reader

+ func (reader *Reader) ReadInt16() (int16, error)

+ func (reader *Reader) ReadInt32() (int32, error)

+ func (reader *Reader) ReadLength() (int32, error)

+ func (reader *Reader) ReadString() (string, error)

+ func (reader *Reader) ReadType() (Type, error)

+ type ReadyForQuery struct

+ func NewReadyForQuery() *ReadyForQuery

+ func NewReadyForQueryWith(s TransactionStatus) (*ReadyForQuery, error)

+ type RequestMessage struct

+ Length int32

+ Type Type

+ func NewRequestMessageWith(reader *bufio.Reader) *RequestMessage

+ func (msg *RequestMessage) ParseBindMessageWith(p *Parse) (*Bind, error)

+ func (msg *RequestMessage) ParseParseMessage() (*Parse, error)

+ func (msg *RequestMessage) ParseQueryMessage() (*Query, error)

+ func (msg *RequestMessage) ParseStartupMessage() (*Startup, error)

+ func (msg *RequestMessage) ReadLength() (int32, error)

+ func (msg *RequestMessage) ReadType() (Type, error)

+ type Response interface

+ Bytes func() ([]byte, error)

+ Type func() Type

+ type ResponseMessage struct

+ func NewAuthenticationOk() (*ResponseMessage, error)

+ func NewResponseMessage() *ResponseMessage

+ func NewResponseMessageWith(t Type) *ResponseMessage

+ func (msg *ResponseMessage) Bytes() ([]byte, error)

+ func (msg *ResponseMessage) SetType(t Type)

+ func (msg *ResponseMessage) Type() Type

+ type Responses []Response

+ func NewCommandCompleteResponsesWith(msg string) (Responses, error)

+ func NewDeleteCompleteResponsesWith(n int) (Responses, error)

+ func NewInsertCompleteResponsesWith(n int) (Responses, error)

+ func NewResponses() Responses

+ func NewResponsesWith(responses ...Response) Responses

+ func NewSelectCompleteResponsesWith(n int) (Responses, error)

+ func NewUpdateCompleteResponsesWith(n int) (Responses, error)

+ func (responses Responses) Append(res Response) Responses

+ type RowDescription struct

+ func NewRowDescription() *RowDescription

+ func (msg *RowDescription) AppendField(field *RowField)

+ func (msg *RowDescription) Bytes() ([]byte, error)

+ type RowField struct

+ DataTypeID int32

+ DataTypeSize int16

+ FormatCode int16

+ Name string

+ Number int16

+ TableID int32

+ TypeModifier int32

+ func NewRowFieldWith(name string, opts ...RowFieldOption) *RowField

+ func (field *RowField) WirteBytes(w *Writer) error

+ type RowFieldOption = func(*RowField)

+ type Startup struct

+ MajorVersion int

+ MessageLength int32

+ MinorVersion int

+ Parameters map[string]string

+ func NewStartupWithReader(reader *Reader) (*Startup, error)

+ func (msg *Startup) ApplicationName() (string, bool)

+ func (msg *Startup) ClientEncoding() (string, bool)

+ func (msg *Startup) Database() (string, bool)

+ func (msg *Startup) User() (string, bool)

+ type TransactionStatus = byte

+ type Type byte

+ const AuthenticationCleartextPasswordMessage

+ const AuthenticationGSSMessage

+ const AuthenticationKerberosV5Message

+ const AuthenticationMD5PasswordMessage

+ const AuthenticationOkMessage

+ const AuthenticationSASLContinueMessage

+ const AuthenticationSASLFinalMessage

+ const AuthenticationSASLMessage

+ const AuthenticationSSPIMessage

+ const BackendKeyDataMessage

+ const BindCompleteMessage

+ const BindMessage

+ const CancelRequestMessage

+ const CloseCompleteMessage

+ const CloseMessage

+ const CommandCompleteMessage

+ const CopyBothResponseMessage

+ const CopyDataMessage

+ const CopyDoneMessage

+ const CopyFailMessage

+ const CopyInResponseMessage

+ const CopyOutResponseMessage

+ const DataRowMessage

+ const DescribeMessage

+ const EmptyQueryResponseMessage

+ const ErrorResponseMessage

+ const ExecuteMessage

+ const FlushMessage

+ const FunctionCallMessage

+ const FunctionCallResponseMessage

+ const GSSENCRequestMessage

+ const GSSResponseMessage

+ const NegotiateProtocolVersionMessage

+ const NoDataMessage

+ const NoticeResponseMessage

+ const NotificationResponseMessage

+ const ParameterDescriptionMessage

+ const ParameterStatusMessage

+ const ParseCompleteMessage

+ const ParseMessage

+ const PasswordMessage

+ const PortalSuspendedMessage

+ const QueryMessage

+ const ReadyForQueryMessage

+ const RowDescriptionMessage

+ const SASLInitialResponseMessage

+ const SASLResponseMessage

+ const SSLRequestMessage

+ const StartupMessage

+ const SyncMessage

+ const TerminateMessage

+ type Writer struct

+ func NewWriter() *Writer

+ func (writer *Writer) AppendByte(c byte) error

+ func (writer *Writer) AppendBytes(p []byte) error

+ func (writer *Writer) AppendFloat32(v float32) error

+ func (writer *Writer) AppendFloat64(v float64) error

+ func (writer *Writer) AppendInt16(v int16) error

+ func (writer *Writer) AppendInt32(v int32) error

+ func (writer *Writer) AppendInt64(v int64) error

+ func (writer *Writer) AppendInt8(v int8) error

+ func (writer *Writer) AppendString(s string) error

+ func (writer *Writer) AppendTerminator() error

+ func (writer *Writer) Bytes() ([]byte, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL