messages

package

Go to main page

Versions in this module

v0

v0.11.1

Aug 21, 2024

v0.11.0

Aug 12, 2024

Changes in this version

+ const OidInterval

+ const OidIntervalArray

v0.10.0

Jul 2, 2024

v0.9.0

Jun 11, 2024

v0.8.0

Jun 4, 2024

v0.7.5

May 20, 2024

Changes in this version

+ func ReturnsRow(tag string) bool

type CommandComplete

+ Tag string

v0.7.4

May 14, 2024

v0.7.1

May 13, 2024

v0.7.0

May 13, 2024

v0.6.0

Apr 16, 2024

v0.5.0

Mar 28, 2024

v0.4.0

Feb 14, 2024

Changes in this version

+ const OidAbstime

+ const OidAclitem

+ const OidAclitemArray

+ const OidBool

+ const OidBox

+ const OidBytea

+ const OidByteaArray

+ const OidCash

+ const OidChar

+ const OidCid

+ const OidCidr

+ const OidCidrArray

+ const OidCircle

+ const OidDate

+ const OidDateArray

+ const OidFloat4

+ const OidFloat4Array

+ const OidFloat8

+ const OidFloat8Array

+ const OidIndexAm

+ const OidInet

+ const OidInetArray

+ const OidInt2

+ const OidInt2Array

+ const OidInt2Vector

+ const OidInt4

+ const OidInt4Array

+ const OidInt8

+ const OidInt8Array

+ const OidJson

+ const OidJsonArray

+ const OidLine

+ const OidLseg

+ const OidMacaddr

+ const OidName

+ const OidNumeric

+ const OidOid

+ const OidOidVector

+ const OidPath

+ const OidPgAttribute

+ const OidPgClass

+ const OidPgNodeTree

+ const OidPgNodeTreeArray

+ const OidPgProc

+ const OidPgType

+ const OidPoint

+ const OidPointArray

+ const OidPolygon

+ const OidRefcursor

+ const OidRegRoleArray

+ const OidRegclass

+ const OidRegclassArray

+ const OidRegnamespace

+ const OidRegnamespaceArray

+ const OidRegoper

+ const OidRegoperator

+ const OidRegproc

+ const OidRegprocedure

+ const OidRegrole

+ const OidRegtype

+ const OidReltime

+ const OidSmgr

+ const OidText

+ const OidTextArray

+ const OidTid

+ const OidTime

+ const OidTimeArray

+ const OidTimestamp

+ const OidTimestampArray

+ const OidTinterval

+ const OidUnknown

+ const OidVarchar

+ const OidVarcharArray

+ const OidXid

+ const OidXml

+ const OidXmlArray

+ func VitessTypeToObjectID(typ query.Type) (int32, error)

v0.3.1

Dec 28, 2023

v0.3.0

Dec 20, 2023

v0.2.0

Dec 11, 2023

Changes in this version

type Bind

+ func (m Bind) DebugString() string

type Describe

+ func (m Describe) DebugString() string

type Execute

+ func (m Execute) DebugString() string

type Parse

+ func (m Parse) DebugString() string

type Query

+ func (m Query) DebugString() string

type Sync

+ func (m Sync) DebugString() string

v0.1.0

Nov 1, 2023

Changes in this version

+ func VitessFieldToDataTypeModifier(field *query.Field) (int32, error)

+ func VitessFieldToDataTypeObjectID(field *query.Field) (int32, error)

+ func VitessFieldToDataTypeSize(field *query.Field) (int16, error)

+ type AuthenticationCleartextPassword struct

+ func (m AuthenticationCleartextPassword) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationCleartextPassword) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationCleartextPassword) Encode() (connection.MessageFormat, error)

+ type AuthenticationGSS struct

+ func (m AuthenticationGSS) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationGSS) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationGSS) Encode() (connection.MessageFormat, error)

+ type AuthenticationGSSContinue struct

+ Data []byte

+ func (m AuthenticationGSSContinue) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationGSSContinue) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationGSSContinue) Encode() (connection.MessageFormat, error)

+ type AuthenticationKerberosV5 struct

+ func (m AuthenticationKerberosV5) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationKerberosV5) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationKerberosV5) Encode() (connection.MessageFormat, error)

+ type AuthenticationMD5Password struct

+ Salt int32

+ func (m AuthenticationMD5Password) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationMD5Password) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationMD5Password) Encode() (connection.MessageFormat, error)

+ type AuthenticationOk struct

+ func (m AuthenticationOk) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationOk) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationOk) Encode() (connection.MessageFormat, error)

+ type AuthenticationSASL struct

+ Mechanisms []string

+ func (m AuthenticationSASL) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationSASL) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationSASL) Encode() (connection.MessageFormat, error)

+ type AuthenticationSASLContinue struct

+ Data []byte

+ func (m AuthenticationSASLContinue) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationSASLContinue) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationSASLContinue) Encode() (connection.MessageFormat, error)

+ type AuthenticationSASLFinal struct

+ AdditionalData []byte

+ func (m AuthenticationSASLFinal) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationSASLFinal) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationSASLFinal) Encode() (connection.MessageFormat, error)

+ type AuthenticationSCMCredential struct

+ func (m AuthenticationSCMCredential) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationSCMCredential) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationSCMCredential) Encode() (connection.MessageFormat, error)

+ type AuthenticationSSPI struct

+ func (m AuthenticationSSPI) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m AuthenticationSSPI) DefaultMessage() *connection.MessageFormat

+ func (m AuthenticationSSPI) Encode() (connection.MessageFormat, error)

+ type BackendKeyData struct

+ ProcessID int32

+ SecretKey int32

+ func (m BackendKeyData) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m BackendKeyData) DefaultMessage() *connection.MessageFormat

+ func (m BackendKeyData) Encode() (connection.MessageFormat, error)

+ type Bind struct

+ DestinationPortal string

+ ParameterFormatCodes []int32

+ ParameterValues []BindParameterValue

+ ResultFormatCodes []int32

+ SourcePreparedStatement string

+ func (m Bind) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Bind) DefaultMessage() *connection.MessageFormat

+ func (m Bind) Encode() (connection.MessageFormat, error)

+ type BindComplete struct

+ func (m BindComplete) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m BindComplete) DefaultMessage() *connection.MessageFormat

+ func (m BindComplete) Encode() (connection.MessageFormat, error)

+ type BindParameterValue struct

+ Data []byte

+ IsNull bool

+ type CancelRequest struct

+ ProcessID int32

+ SecretKey int32

+ func (m CancelRequest) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CancelRequest) DefaultMessage() *connection.MessageFormat

+ func (m CancelRequest) Encode() (connection.MessageFormat, error)

+ type Close struct

+ ClosingPreparedStatement bool

+ Target string

+ func (m Close) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Close) DefaultMessage() *connection.MessageFormat

+ func (m Close) Encode() (connection.MessageFormat, error)

+ type CloseComplete struct

+ func (m CloseComplete) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CloseComplete) DefaultMessage() *connection.MessageFormat

+ func (m CloseComplete) Encode() (connection.MessageFormat, error)

+ type CommandComplete struct

+ Query string

+ Rows int32

+ func (m CommandComplete) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CommandComplete) DefaultMessage() *connection.MessageFormat

+ func (m CommandComplete) Encode() (connection.MessageFormat, error)

+ func (m CommandComplete) IsIUD() bool

+ type CopyBothResponse struct

+ FormatCodes []int32

+ IsTextual bool

+ func (m CopyBothResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CopyBothResponse) DefaultMessage() *connection.MessageFormat

+ func (m CopyBothResponse) Encode() (connection.MessageFormat, error)

+ type CopyData struct

+ Data []byte

+ func (m CopyData) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CopyData) DefaultMessage() *connection.MessageFormat

+ func (m CopyData) Encode() (connection.MessageFormat, error)

+ type CopyDone struct

+ func (m CopyDone) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CopyDone) DefaultMessage() *connection.MessageFormat

+ func (m CopyDone) Encode() (connection.MessageFormat, error)

+ type CopyFail struct

+ ErrorMessage string

+ func (m CopyFail) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CopyFail) DefaultMessage() *connection.MessageFormat

+ func (m CopyFail) Encode() (connection.MessageFormat, error)

+ type CopyInResponse struct

+ FormatCodes []int32

+ IsTextual bool

+ func (m CopyInResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CopyInResponse) DefaultMessage() *connection.MessageFormat

+ func (m CopyInResponse) Encode() (connection.MessageFormat, error)

+ type CopyOutResponse struct

+ FormatCodes []int32

+ IsTextual bool

+ func (m CopyOutResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m CopyOutResponse) DefaultMessage() *connection.MessageFormat

+ func (m CopyOutResponse) Encode() (connection.MessageFormat, error)

+ type DataRow struct

+ Values []sqltypes.Value

+ func (m DataRow) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m DataRow) DefaultMessage() *connection.MessageFormat

+ func (m DataRow) Encode() (connection.MessageFormat, error)

+ type Describe struct

+ IsPrepared bool

+ Target string

+ func (m Describe) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Describe) DefaultMessage() *connection.MessageFormat

+ func (m Describe) Encode() (connection.MessageFormat, error)

+ type EmptyQueryResponse struct

+ func (m EmptyQueryResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m EmptyQueryResponse) DefaultMessage() *connection.MessageFormat

+ func (m EmptyQueryResponse) Encode() (connection.MessageFormat, error)

+ type ErrorResponse struct

+ Message string

+ Optional ErrorResponseOptionalFields

+ Severity ErrorResponseSeverity

+ SqlStateCode string

+ func (m ErrorResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m ErrorResponse) DefaultMessage() *connection.MessageFormat

+ func (m ErrorResponse) Encode() (connection.MessageFormat, error)

+ type ErrorResponseOptionalFields struct

+ Column string

+ Constraint string

+ Routine string

+ Schema string

+ Table string

+ type ErrorResponseSeverity string

+ const ErrorResponseSeverity_Debug

+ const ErrorResponseSeverity_Error

+ const ErrorResponseSeverity_Fatal

+ const ErrorResponseSeverity_Info

+ const ErrorResponseSeverity_Log

+ const ErrorResponseSeverity_Notice

+ const ErrorResponseSeverity_Panic

+ const ErrorResponseSeverity_Warning

+ type Execute struct

+ Portal string

+ RowMax int32

+ func (m Execute) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Execute) DefaultMessage() *connection.MessageFormat

+ func (m Execute) Encode() (connection.MessageFormat, error)

+ type Flush struct

+ func (m Flush) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Flush) DefaultMessage() *connection.MessageFormat

+ func (m Flush) Encode() (connection.MessageFormat, error)

+ type FunctionCall struct

+ ArgumentFormatCodes []int32

+ Arguments []FunctionCallArgument

+ ObjectID int32

+ ResultFormatCode int32

+ func (m FunctionCall) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m FunctionCall) DefaultMessage() *connection.MessageFormat

+ func (m FunctionCall) Encode() (connection.MessageFormat, error)

+ type FunctionCallArgument struct

+ Data []byte

+ IsNull bool

+ type FunctionCallResponse struct

+ IsResultNull bool

+ ResultValue []byte

+ func (m FunctionCallResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m FunctionCallResponse) DefaultMessage() *connection.MessageFormat

+ func (m FunctionCallResponse) Encode() (connection.MessageFormat, error)

+ type GSSENCRequest struct

+ func (m GSSENCRequest) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m GSSENCRequest) DefaultMessage() *connection.MessageFormat

+ func (m GSSENCRequest) Encode() (connection.MessageFormat, error)

+ type GSSENCResponse struct

+ SupportsGSSAPI bool

+ func (m GSSENCResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m GSSENCResponse) DefaultMessage() *connection.MessageFormat

+ func (m GSSENCResponse) Encode() (connection.MessageFormat, error)

+ type GSSResponse struct

+ Data []byte

+ func (m GSSResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m GSSResponse) DefaultMessage() *connection.MessageFormat

+ func (m GSSResponse) Encode() (connection.MessageFormat, error)

+ type NegotiateProtocolVersion struct

+ NewestMinorProtocol int32

+ UnrecognizedOptions []string

+ func (m NegotiateProtocolVersion) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m NegotiateProtocolVersion) DefaultMessage() *connection.MessageFormat

+ func (m NegotiateProtocolVersion) Encode() (connection.MessageFormat, error)

+ type NoData struct

+ func (m NoData) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m NoData) DefaultMessage() *connection.MessageFormat

+ func (m NoData) Encode() (connection.MessageFormat, error)

+ type NoticeResponse struct

+ Fields []NoticeResponseField

+ func (m NoticeResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m NoticeResponse) DefaultMessage() *connection.MessageFormat

+ func (m NoticeResponse) Encode() (connection.MessageFormat, error)

+ type NoticeResponseField struct

+ Code int32

+ Value string

+ type NotificationResponse struct

+ Channel string

+ Payload string

+ ProcessID int32

+ func (m NotificationResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m NotificationResponse) DefaultMessage() *connection.MessageFormat

+ func (m NotificationResponse) Encode() (connection.MessageFormat, error)

+ type ParameterDescription struct

+ ObjectIDs []int32

+ func (m ParameterDescription) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m ParameterDescription) DefaultMessage() *connection.MessageFormat

+ func (m ParameterDescription) Encode() (connection.MessageFormat, error)

+ type ParameterStatus struct

+ Name string

+ Value string

+ func (m ParameterStatus) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m ParameterStatus) DefaultMessage() *connection.MessageFormat

+ func (m ParameterStatus) Encode() (connection.MessageFormat, error)

+ type Parse struct

+ Name string

+ ParameterObjectIDs []int32

+ Query string

+ func (m Parse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Parse) DefaultMessage() *connection.MessageFormat

+ func (m Parse) Encode() (connection.MessageFormat, error)

+ type ParseComplete struct

+ func (m ParseComplete) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m ParseComplete) DefaultMessage() *connection.MessageFormat

+ func (m ParseComplete) Encode() (connection.MessageFormat, error)

+ type PasswordMessage struct

+ Password string

+ func (m PasswordMessage) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m PasswordMessage) DefaultMessage() *connection.MessageFormat

+ func (m PasswordMessage) Encode() (connection.MessageFormat, error)

+ type PortalSuspended struct

+ Integer int32

+ String string

+ func (m PortalSuspended) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m PortalSuspended) DefaultMessage() *connection.MessageFormat

+ func (m PortalSuspended) Encode() (connection.MessageFormat, error)

+ type Query struct

+ String string

+ func (m Query) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Query) DefaultMessage() *connection.MessageFormat

+ func (m Query) Encode() (connection.MessageFormat, error)

+ type ReadyForQuery struct

+ Indicator ReadyForQueryTransactionIndicator

+ func (m ReadyForQuery) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m ReadyForQuery) DefaultMessage() *connection.MessageFormat

+ func (m ReadyForQuery) Encode() (connection.MessageFormat, error)

+ type ReadyForQueryTransactionIndicator byte

+ const ReadyForQueryTransactionIndicator_FailedTransactionBlock

+ const ReadyForQueryTransactionIndicator_Idle

+ const ReadyForQueryTransactionIndicator_TransactionBlock

+ type RowDescription struct

+ Fields []*query.Field

+ func (m RowDescription) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m RowDescription) DefaultMessage() *connection.MessageFormat

+ func (m RowDescription) Encode() (connection.MessageFormat, error)

+ type SASLInitialResponse struct

+ Name string

+ Response []byte

+ func (m SASLInitialResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m SASLInitialResponse) DefaultMessage() *connection.MessageFormat

+ func (m SASLInitialResponse) Encode() (connection.MessageFormat, error)

+ type SASLResponse struct

+ Data []byte

+ func (m SASLResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m SASLResponse) DefaultMessage() *connection.MessageFormat

+ func (m SASLResponse) Encode() (connection.MessageFormat, error)

+ type SSLRequest struct

+ func (m SSLRequest) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m SSLRequest) DefaultMessage() *connection.MessageFormat

+ func (m SSLRequest) Encode() (connection.MessageFormat, error)

+ type SSLResponse struct

+ SupportsSSL bool

+ func (m SSLResponse) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m SSLResponse) DefaultMessage() *connection.MessageFormat

+ func (m SSLResponse) Encode() (connection.MessageFormat, error)

+ type StartupMessage struct

+ Parameters map[string]string

+ ProtocolMajorVersion int

+ ProtocolMinorVersion int

+ func (m StartupMessage) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m StartupMessage) DefaultMessage() *connection.MessageFormat

+ func (m StartupMessage) Encode() (connection.MessageFormat, error)

+ type Sync struct

+ func (m Sync) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Sync) DefaultMessage() *connection.MessageFormat

+ func (m Sync) Encode() (connection.MessageFormat, error)

+ type Terminate struct

+ func (m Terminate) Decode(s connection.MessageFormat) (connection.Message, error)

+ func (m Terminate) DefaultMessage() *connection.MessageFormat

+ func (m Terminate) Encode() (connection.MessageFormat, error)

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