package msgs

import "github.com/vertica/vertica-sql-go/msgs"

Index

Types

type BEAuthenticationMsg 

type BEAuthenticationMsg struct {
	Response      int32
	ExtraAuthData []byte
}

BEAuthenticationMsg docs

func (*BEAuthenticationMsg) CreateFromMsgBody 

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

CreateFromMsgBody docs

func (*BEAuthenticationMsg) String 

func (b *BEAuthenticationMsg) String() string

type BEBindCompleteMsg 

type BEBindCompleteMsg struct {
}

func (*BEBindCompleteMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEBindCompleteMsg) String 

func (m *BEBindCompleteMsg) String() string

type BECloseCompleteMsg 

type BECloseCompleteMsg struct {
}

func (*BECloseCompleteMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BECloseCompleteMsg) String 

func (m *BECloseCompleteMsg) String() string

type BECmdCompleteMsg 

type BECmdCompleteMsg struct {
	Tag string
}

BECmdCompleteMsg docs

func (*BECmdCompleteMsg) CreateFromMsgBody 

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

CreateFromMsgBody docs

func (*BECmdCompleteMsg) String 

func (b *BECmdCompleteMsg) String() string

type BECmdDescriptionMsg 

type BECmdDescriptionMsg struct {
	CommandTag     string
	HasCopyRewrite bool
	CopyRewrite    string
}

func (*BECmdDescriptionMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BECmdDescriptionMsg) String 

func (m *BECmdDescriptionMsg) String() string

type BEDataRowMsg 

type BEDataRowMsg struct {
	RowData [][]byte
}

BEDataRowMsg docs

func (*BEDataRowMsg) CreateFromMsgBody 

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

CreateFromMsgBody docs

func (*BEDataRowMsg) String 

func (b *BEDataRowMsg) String() string

type BEEmptyQueryResponseMsg 

type BEEmptyQueryResponseMsg struct {
}

func (*BEEmptyQueryResponseMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEEmptyQueryResponseMsg) String 

func (m *BEEmptyQueryResponseMsg) String() string

type BEErrorMsg 

type BEErrorMsg struct {
	Severity string
	SQLCode  string
	Message  string
	File     string
	Line     string
	Routine  string
}

BEErrorMsg docs

func (*BEErrorMsg) CreateFromMsgBody 

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

InitFromMsgBody docs

func (*BEErrorMsg) String 

func (b *BEErrorMsg) String() string

func (*BEErrorMsg) ToErrorType 

func (b *BEErrorMsg) ToErrorType() error

type BEInitSTDINLoadMsg 

type BEInitSTDINLoadMsg struct {
	IsBinary      bool
	ColumnFormats []int16
}

BEInitSTDINLoadMsg docs

func (*BEInitSTDINLoadMsg) CreateFromMsgBody 

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

InitFromMsgBody docs

func (*BEInitSTDINLoadMsg) String 

func (b *BEInitSTDINLoadMsg) String() string

type BEKeyDataMsg 

type BEKeyDataMsg struct {
	BackendPID uint32
	CancelKey  uint32
}

func (*BEKeyDataMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEKeyDataMsg) String 

func (m *BEKeyDataMsg) String() string

type BELoadNewFileMsg 

type BELoadNewFileMsg struct {
	FileName string
}

func (*BELoadNewFileMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BELoadNewFileMsg) String 

func (m *BELoadNewFileMsg) String() string

type BENoDataMsg 

type BENoDataMsg struct {
}

func (*BENoDataMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BENoDataMsg) String 

func (m *BENoDataMsg) String() string

type BENoticeMsg 

type BENoticeMsg struct {
	NoticeCodes  []byte
	NoticeValues []string
}

BENoticeMsg docs

func (*BENoticeMsg) CreateFromMsgBody 

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

CreateFromMsgBody docs

func (*BENoticeMsg) String 

func (b *BENoticeMsg) String() string

type BEParamStatusMsg 

type BEParamStatusMsg struct {
	ParamName  string
	ParamValue string
}

func (*BEParamStatusMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEParamStatusMsg) String 

func (m *BEParamStatusMsg) String() string

type BEParameterDescMsg 

type BEParameterDescMsg struct {
	ParameterTypes []common.ParameterType
}

func (*BEParameterDescMsg) CreateFromMsgBody 

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

CreateFromMsgBody docs

func (*BEParameterDescMsg) String 

func (m *BEParameterDescMsg) String() string

type BEParseCompleteMsg 

type BEParseCompleteMsg struct {
}

func (*BEParseCompleteMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEParseCompleteMsg) String 

func (m *BEParseCompleteMsg) String() string

type BEPortalSuspendedMsg 

type BEPortalSuspendedMsg struct {
	TransactionState byte
}

func (*BEPortalSuspendedMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEPortalSuspendedMsg) String 

func (m *BEPortalSuspendedMsg) String() string

type BEReadyForQueryMsg 

type BEReadyForQueryMsg struct {
	TransactionState byte
}

func (*BEReadyForQueryMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEReadyForQueryMsg) String 

func (m *BEReadyForQueryMsg) String() string

type BERowDescColumnDef 

type BERowDescColumnDef struct {
	FieldName    string
	SchemaName   string
	TableName    string
	TableOID     int64
	Nullable     bool
	IsIdentity   bool
	AttribNum    int16
	DataTypeOID  uint32
	DataTypeName string
	Length       int16
	DataTypeMod  int32
	FormatCode   uint16
}

BERowDescColumnDef docs

type BERowDescMsg 

type BERowDescMsg struct {
	Columns []*BERowDescColumnDef
}

BERowDescMsg docs

func (*BERowDescMsg) CreateFromMsgBody 

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

CreateFromMsgBody docs

func (*BERowDescMsg) String 

func (m *BERowDescMsg) String() string

type BEVerifyLoadFilesMsg 

type BEVerifyLoadFilesMsg struct {
	FileList       []string
	RejectedPath   string
	ExceptionsPath string
}

func (*BEVerifyLoadFilesMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEVerifyLoadFilesMsg) String 

func (m *BEVerifyLoadFilesMsg) String() string

type BEWriteFileMsg 

type BEWriteFileMsg struct {
	FileName string
	Data     []byte
}

func (*BEWriteFileMsg) CreateFromMsgBody 

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

CreateFromMsgBody

func (*BEWriteFileMsg) String 

func (m *BEWriteFileMsg) String() string

type BackEndMsg 

type BackEndMsg interface {
	CreateFromMsgBody(*msgBuffer) (BackEndMsg, error)
	String() string
}

BackEndMsg docs

func CreateBackEndMsg 

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

CreateBackEndMsg docs

type CmdTargetType 

type CmdTargetType byte
var (
	CmdTargetTypePortal    CmdTargetType = 'P'
	CmdTargetTypeStatement CmdTargetType = 'S'
)

type FEBindMsg 

type FEBindMsg struct {
	Portal    string
	Statement string
	NamedArgs []driver.NamedValue
	OIDTypes  []int32
}

FEPBindMsg docs

func (*FEBindMsg) Flatten 

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

Flatten docs

func (*FEBindMsg) String 

func (m *FEBindMsg) String() string

type FECloseMsg 

type FECloseMsg struct {
	TargetType CmdTargetType
	TargetName string
}

func (*FECloseMsg) Flatten 

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

Flatten docs

func (*FECloseMsg) String 

func (m *FECloseMsg) String() string

type FEDescribeMsg 

type FEDescribeMsg struct {
	TargetType CmdTargetType
	TargetName string
}

FEDescribeMsg docs

func (*FEDescribeMsg) Flatten 

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

Flatten docs

func (*FEDescribeMsg) String 

func (m *FEDescribeMsg) String() string

type FEErrorMsg 

type FEErrorMsg struct {
	FileName   string
	LineNumber int
	Method     string
	ErrorMsg   string
}

FEErrorMsg docs

func (*FEErrorMsg) Flatten 

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

Flatten docs

func (*FEErrorMsg) String 

func (m *FEErrorMsg) String() string

type FEExecuteMsg 

type FEExecuteMsg struct {
	Portal   string
	RowLimit uint32
}

FEExecuteMsg docs

func (*FEExecuteMsg) Flatten 

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

Flatten docs

func (*FEExecuteMsg) String 

func (m *FEExecuteMsg) String() string

type FEFlushMsg 

type FEFlushMsg struct {
}

func (*FEFlushMsg) Flatten 

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

Flatten docs

func (*FEFlushMsg) String 

func (m *FEFlushMsg) String() string

type FELoadDataMsg 

type FELoadDataMsg struct {
	Data      []byte
	UsedBytes int
}

FELoadDataMsg docs

func (*FELoadDataMsg) Flatten 

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

Flatten docs

func (*FELoadDataMsg) String 

func (m *FELoadDataMsg) String() string

type FELoadDoneMsg 

type FELoadDoneMsg struct {
}

FELoadDoneMsg docs

func (*FELoadDoneMsg) Flatten 

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

Flatten docs

func (*FELoadDoneMsg) String 

func (m *FELoadDoneMsg) String() string

type FELoadFailMsg 

type FELoadFailMsg struct {
	Message string
}

FELoadDoneMsg docs

func (*FELoadFailMsg) Flatten 

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

Flatten docs

func (*FELoadFailMsg) String 

func (m *FELoadFailMsg) String() string

type FEParseMsg 

type FEParseMsg struct {
	PreparedName string
	Command      string
	NumArgs      uint16
}

FEParseMsg docs

func (*FEParseMsg) Flatten 

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

Flatten docs

func (*FEParseMsg) String 

func (m *FEParseMsg) String() string

type FEPasswordMsg 

type FEPasswordMsg struct {
	PasswordData string
}

func (*FEPasswordMsg) Flatten 

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

Flatten docs

func (*FEPasswordMsg) String 

func (m *FEPasswordMsg) String() string

type FEQueryMsg 

type FEQueryMsg struct {
	Query string
}

FEQueyMsg docs

func (*FEQueryMsg) Flatten 

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

Flatten docs

func (*FEQueryMsg) String 

func (m *FEQueryMsg) String() string

type FESSLMsg 

type FESSLMsg struct {
}

FESSLMsg docs

func (*FESSLMsg) Flatten 

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

Flatten docs

func (*FESSLMsg) String 

func (m *FESSLMsg) String() string

type FEStartupMsg 

type FEStartupMsg struct {
	ProtocolVersion uint32
	DriverName      string
	DriverVersion   string
	Username        string
	Database        string
	SessionID       string
	ClientPID       int
}

FEStartupMsg docs

func (*FEStartupMsg) Flatten 

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

Flatten docs

func (*FEStartupMsg) String 

func (m *FEStartupMsg) String() string

type FESyncMsg 

type FESyncMsg struct {
}

FEParseMsg docs

func (*FESyncMsg) Flatten 

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

Flatten docs

func (*FESyncMsg) String 

func (m *FESyncMsg) String() string

type FEVerifyLoadFiles 

type FEVerifyLoadFiles struct {
	FileNames []string
	FileSizes []uint64
}

FEVerifyLoadFiles docs

func (*FEVerifyLoadFiles) Flatten 

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

Flatten docs

func (*FEVerifyLoadFiles) String 

func (m *FEVerifyLoadFiles) String() string

type FrontEndMsg 

type FrontEndMsg interface {
	Flatten() ([]byte, byte)
	String() string
}

FrontEndMsg docs

Source Files

beauthenticationmsg.go bebindcompletemsg.go beclosecompletemsg.go becmdcompletemsg.go becmddescriptionmsg.go bedatarowmsg.go beemptyqueryrespmsg.go beerrormsg.go beinitstdinloadmsg.go bekeydatamsg.go beloadnewfilemsg.go benodatamsg.go benoticemsg.go beparameterdescmsg.go beparamstatusmsg.go beparsecomplete.go beportalsuspendedmsg.go bereadyforquerymsg.go berowdescmsg.go beverifyloadfilesmsg.go bewritefilemsg.go febindmsg.go feclosemsg.go fedescribemsg.go feerrormsg.go feexecutemsg.go feflush.go feloaddatamsg.go feloaddonemsg.go feloadfailmsg.go feparsemsg.go fepasswordmsg.go fequerymsg.go fesslmsg.go festartupmsg.go fesyncmsg.go feverifyloadfiles.go msg.go msgbuffer.go

Version
v0.1.5
Published
Oct 3, 2019
Platform
js/wasm
Imports
6 packages
Last checked
7 hours ago –

Tools for package owners.