msgs

package

Go to main page

Versions in this module

v1

v1.0.1

Apr 10, 2020

Changes in this version

type BEDataRowMsg

+ func (b *BEDataRowMsg) Columns() ColumnExtractor

+ type ColumnExtractor struct

+ NumCols uint16

+ func (c *ColumnExtractor) Chunk() []byte

+ type FECancelMsg struct

+ Key uint32

+ PID uint32

+ func (m *FECancelMsg) Flatten() ([]byte, byte)

+ func (m *FECancelMsg) String() string

v0

v0.1.7

Jan 16, 2020

Changes in this version

+ func NewMsgBufferFromBytes(b []byte) *msgBuffer

type BEDataRowMsg

+ func (b *BEDataRowMsg) RevertToBytes() []byte

v0.1.6

Nov 15, 2019

v0.1.5

Oct 3, 2019

v0.1.4

Sep 18, 2019

Changes in this version

+ type BEInitSTDINLoadMsg struct

+ ColumnFormats []int16

+ IsBinary bool

+ func (b *BEInitSTDINLoadMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (b *BEInitSTDINLoadMsg) String() string

+ type BELoadNewFileMsg struct

+ FileName string

+ func (m *BELoadNewFileMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BELoadNewFileMsg) String() string

+ type BEVerifyLoadFilesMsg struct

+ ExceptionsPath string

+ FileList []string

+ RejectedPath string

+ func (m *BEVerifyLoadFilesMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEVerifyLoadFilesMsg) String() string

+ type BEWriteFileMsg struct

+ Data []byte

+ FileName string

+ func (m *BEWriteFileMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEWriteFileMsg) String() string

+ type FEErrorMsg struct

+ ErrorMsg string

+ FileName string

+ LineNumber int

+ Method string

+ func (m *FEErrorMsg) Flatten() ([]byte, byte)

+ func (m *FEErrorMsg) String() string

+ type FELoadDataMsg struct

+ Data []byte

+ UsedBytes int

+ func (m *FELoadDataMsg) Flatten() ([]byte, byte)

+ func (m *FELoadDataMsg) String() string

+ type FELoadDoneMsg struct

+ func (m *FELoadDoneMsg) Flatten() ([]byte, byte)

+ func (m *FELoadDoneMsg) String() string

+ type FELoadFailMsg struct

+ Message string

+ func (m *FELoadFailMsg) Flatten() ([]byte, byte)

+ func (m *FELoadFailMsg) String() string

+ type FEVerifyLoadFiles struct

+ FileNames []string

+ FileSizes []uint64

+ func (m *FEVerifyLoadFiles) Flatten() ([]byte, byte)

+ func (m *FEVerifyLoadFiles) String() string

v0.1.3

Aug 20, 2019

v0.1.2

Aug 5, 2019

v0.1.1

Jul 25, 2019

v0.1.0

Jun 25, 2019

Changes in this version

+ type BEAuthenticationMsg struct

+ ExtraAuthData []byte

+ Response int32

+ func (b *BEAuthenticationMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (b *BEAuthenticationMsg) String() string

+ type BEBindCompleteMsg struct

+ func (m *BEBindCompleteMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEBindCompleteMsg) String() string

+ type BECloseCompleteMsg struct

+ func (m *BECloseCompleteMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BECloseCompleteMsg) String() string

+ type BECmdCompleteMsg struct

+ Tag string

+ func (b *BECmdCompleteMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (b *BECmdCompleteMsg) String() string

+ type BECmdDescriptionMsg struct

+ CommandTag string

+ CopyRewrite string

+ HasCopyRewrite bool

+ func (m *BECmdDescriptionMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BECmdDescriptionMsg) String() string

+ type BEDataRowMsg struct

+ RowData [][]byte

+ func (b *BEDataRowMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (b *BEDataRowMsg) String() string

+ type BEEmptyQueryResponseMsg struct

+ func (m *BEEmptyQueryResponseMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEEmptyQueryResponseMsg) String() string

+ type BEErrorMsg struct

+ File string

+ Line string

+ Message string

+ Routine string

+ SQLCode string

+ Severity string

+ func (b *BEErrorMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (b *BEErrorMsg) String() string

+ func (b *BEErrorMsg) ToErrorType() error

+ type BEKeyDataMsg struct

+ BackendPID uint32

+ CancelKey uint32

+ func (m *BEKeyDataMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEKeyDataMsg) String() string

+ type BENoDataMsg struct

+ func (m *BENoDataMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BENoDataMsg) String() string

+ type BENoticeMsg struct

+ NoticeCodes []byte

+ NoticeValues []string

+ func (b *BENoticeMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (b *BENoticeMsg) String() string

+ type BEParamStatusMsg struct

+ ParamName string

+ ParamValue string

+ func (m *BEParamStatusMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEParamStatusMsg) String() string

+ type BEParameterDescMsg struct

+ ParameterTypes []common.ParameterType

+ func (m *BEParameterDescMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEParameterDescMsg) String() string

+ type BEParseCompleteMsg struct

+ func (m *BEParseCompleteMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEParseCompleteMsg) String() string

+ type BEPortalSuspendedMsg struct

+ TransactionState byte

+ func (m *BEPortalSuspendedMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEPortalSuspendedMsg) String() string

+ type BEReadyForQueryMsg struct

+ TransactionState byte

+ func (m *BEReadyForQueryMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BEReadyForQueryMsg) String() string

+ type BERowDescColumnDef struct

+ AttribNum int16

+ DataTypeMod int32

+ DataTypeName string

+ DataTypeOID uint32

+ FieldName string

+ FormatCode uint16

+ IsIdentity bool

+ Length int16

+ Nullable bool

+ SchemaName string

+ TableName string

+ TableOID int64

+ type BERowDescMsg struct

+ Columns []*BERowDescColumnDef

+ func (m *BERowDescMsg) CreateFromMsgBody(buf *msgBuffer) (BackEndMsg, error)

+ func (m *BERowDescMsg) String() string

+ type BackEndMsg interface

+ CreateFromMsgBody func(*msgBuffer) (BackEndMsg, error)

+ String func() string

+ func CreateBackEndMsg(msgType byte, body []byte) (BackEndMsg, error)

+ type CmdTargetType byte

+ var CmdTargetTypePortal CmdTargetType = 'P'

+ var CmdTargetTypeStatement CmdTargetType = 'S'

+ type FEBindMsg struct

+ NamedArgs []driver.NamedValue

+ OIDTypes []int32

+ Portal string

+ Statement string

+ func (m *FEBindMsg) Flatten() ([]byte, byte)

+ func (m *FEBindMsg) String() string

+ type FECloseMsg struct

+ TargetName string

+ TargetType CmdTargetType

+ func (m *FECloseMsg) Flatten() ([]byte, byte)

+ func (m *FECloseMsg) String() string

+ type FEDescribeMsg struct

+ TargetName string

+ TargetType CmdTargetType

+ func (m *FEDescribeMsg) Flatten() ([]byte, byte)

+ func (m *FEDescribeMsg) String() string

+ type FEExecuteMsg struct

+ Portal string

+ RowLimit uint32

+ func (m *FEExecuteMsg) Flatten() ([]byte, byte)

+ func (m *FEExecuteMsg) String() string

+ type FEFlushMsg struct

+ func (m *FEFlushMsg) Flatten() ([]byte, byte)

+ func (m *FEFlushMsg) String() string

+ type FEParseMsg struct

+ Command string

+ NumArgs uint16

+ PreparedName string

+ func (m *FEParseMsg) Flatten() ([]byte, byte)

+ func (m *FEParseMsg) String() string

+ type FEPasswordMsg struct

+ PasswordData string

+ func (m *FEPasswordMsg) Flatten() ([]byte, byte)

+ func (m *FEPasswordMsg) String() string

+ type FEQueryMsg struct

+ Query string

+ func (m *FEQueryMsg) Flatten() ([]byte, byte)

+ func (m *FEQueryMsg) String() string

+ type FESSLMsg struct

+ func (m *FESSLMsg) Flatten() ([]byte, byte)

+ func (m *FESSLMsg) String() string

+ type FEStartupMsg struct

+ ClientPID int

+ Database string

+ DriverName string

+ DriverVersion string

+ ProtocolVersion uint32

+ SessionID string

+ Username string

+ func (m *FEStartupMsg) Flatten() ([]byte, byte)

+ func (m *FEStartupMsg) String() string

+ type FESyncMsg struct

+ func (m *FESyncMsg) Flatten() ([]byte, byte)

+ func (m *FESyncMsg) String() string

+ type FrontEndMsg interface

+ Flatten func() ([]byte, byte)

+ String func() string

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