Versions in this module Expand all Collapse all v0 v0.0.4 Jun 14, 2023 v0.0.3 Jun 14, 2023 v0.0.2 Jun 14, 2023 Changes in this version + const AuthSwitchRequestPacket + const BaseShowTables + const BinlogChecksumAlgCRC32 + const BinlogChecksumAlgOff + const BinlogChecksumAlgUndef + const CRCantReadCharset + const CRCommandsOutOfSync + const CRConnHostError + const CRConnectionError + const CRMalformedPacket + const CRNamedPipeStateError + const CRSSLConnectionError + const CRServerGone + const CRServerHandshakeErr + const CRServerLost + const CRUnknownError + const CRVersionError + const CapabilityClientConnAttr + const CapabilityClientConnectWithDB + const CapabilityClientDeprecateEOF + const CapabilityClientFoundRows + const CapabilityClientLocalFiles + const CapabilityClientLongFlag + const CapabilityClientLongPassword + const CapabilityClientMultiResults + const CapabilityClientMultiStatements + const CapabilityClientPluginAuth + const CapabilityClientPluginAuthLenencClientData + const CapabilityClientProtocol41 + const CapabilityClientSSL + const CapabilityClientSecureConnection + const CapabilityClientTransactions + const CharacterSetBinary + const CharacterSetUtf8 + const ComBinlogDump + const ComBinlogDumpGTID + const ComFieldList + const ComInitDB + const ComPing + const ComPrepare + const ComQuery + const ComQuit + const ComResetConnection + const ComSetOption + const ComStmtClose + const ComStmtExecute + const ComStmtFetch + const ComStmtReset + const ComStmtSendLongData + const DefaultConnBufferSize + const DefaultServerVersion + const EOFPacket + const ERAbortingConnection + const ERAccessDeniedError + const ERBadDb + const ERBadFTColumn + const ERBadFieldError + const ERBadNullError + const ERBadTable + const ERBlobCantHaveDefault + const ERBlobKeyWithoutLength + const ERBlobUsedAsKey + const ERBlobsAndNoTerminated + const ERCannotAddForeign + const ERCantAggregate2Collations + const ERCantAggregate3Collations + const ERCantAggregateNCollations + const ERCantCreateThread + const ERCantDoThisDuringAnTransaction + const ERCantDropFieldOrKey + const ERCantFindUDF + const ERCantRemoveAllFields + const ERCantUpdateWithReadLock + const ERCantUseOptionHere + const ERCollationCharsetMismatch + const ERConCount + const ERCyclicReference + const ERDBAccessDenied + const ERDataOutOfRange + const ERDataTooLong + const ERDbCreateExists + const ERDbDropExists + const ERDelayedInsertTableLocked + const ERDerivedMustHaveAlias + const ERDiskFull + const ERDupArgument + const ERDupEntry + const ERDupFieldName + const ERDupKeyName + const ERDupUnique + const ERDuplicatedValueInType + const EREmptyQuery + const ERFeatureDisabled + const ERFieldSpecifiedTwice + const ERFileExists + const ERForcingClose + const ERFormNotFound + const ERFunctionNotDefined + const ERGlobalVariable + const ERGotSignal + const ERHostIsBlocked + const ERIllegalGrantForTable + const ERIllegalReference + const ERIncorrectGlobalLocalVar + const ERInvalidCharacterString + const ERInvalidDefault + const ERInvalidGroupFuncUse + const ERInvalidOnUpdate + const ERInvalidUseOfNull + const ERKeyColumnDoesNotExist + const ERKeyDoesNotExist + const ERKeyNotFound + const ERKeyRefDoNotMatchTableRef + const ERKillDenied + const ERLocalVariable + const ERLockDeadlock + const ERLockTableFull + const ERLockWaitTimeout + const ERMixOfGroupFuncAndFields + const ERMultiplePriKey + const ERNetPacketTooLarge + const ERNoDb + const ERNoDefault + const ERNoPermissionToCreateUsers + const ERNoReferencedRow + const ERNoSuchIndex + const ERNoSuchTable + const ERNoSuchThread + const ERNoTablesUsed + const ERNonExistingGrant + const ERNonExistingTableGrant + const ERNonUniq + const ERNonUniqTable + const ERNonUpdateableTable + const ERNotAllowedCommand + const ERNotSupportedYet + const ERNullColumnInIndex + const EROperandColumns + const EROptionPreventsStatement + const EROutOfMemory + const EROutOfResources + const EROutOfSortMemory + const ERParseError + const ERPrimaryCantHaveNull + const ERQueryInterrupted + const ERReadOnlyTransaction + const ERRecordFileFull + const ERRegexpError + const ERRequiresPrimaryKey + const ERRowIsReferenced + const ERRowIsReferenced2 + const ERServerShutdown + const ERSetConstantsOnly + const ERSpecifiedAccessDenied + const ERSubqueryNo1Row + const ERSyntaxError + const ERTableExists + const ERTableMustHaveColumns + const ERTableNameNotAllowedHere + const ERTableNotLocked + const ERTableNotLockedForWrite + const ERTextFileNotReadable + const ERTooBigFieldLength + const ERTooBigRowSize + const ERTooBigSelect + const ERTooBigSet + const ERTooLongIdent + const ERTooLongKey + const ERTooLongString + const ERTooManyDelayedThreads + const ERTooManyFields + const ERTooManyKeyParts + const ERTooManyKeys + const ERTooManyRows + const ERTooManyTables + const ERTooManyUserConnections + const ERTooMuchAutoTimestampCols + const ERTruncatedWrongValue + const ERTruncatedWrongValueForField + const ERUDFExists + const ERUnknownCharacterSet + const ERUnknownCollation + const ERUnknownComError + const ERUnknownError + const ERUnknownProcedure + const ERUnknownSystemVariable + const ERUnknownTable + const ERUnknownTimeZone + const ERUpdateTableUsed + const ERUserLimitReached + const ERVarCantBeRead + const ERVariableIsNotStruct + const ERVitessMaxRowsExceeded + const ERWrongArguments + const ERWrongAutoKey + const ERWrongColumnName + const ERWrongDbName + const ERWrongFKDef + const ERWrongFieldSpec + const ERWrongFieldTerminators + const ERWrongFieldWithGroup + const ERWrongGroupField + const ERWrongKeyColumn + const ERWrongNameForCatalog + const ERWrongNameForIndex + const ERWrongNumberOfColumnsInSelect + const ERWrongOuterJoin + const ERWrongParamCountToProcedure + const ERWrongParametersToProcedure + const ERWrongSubKey + const ERWrongSumSelect + const ERWrongTableName + const ERWrongTypeForVar + const ERWrongUsage + const ERWrongValueCount + const ERWrongValueCountOnRow + const ERWrongValueForVar + const ErNoReferencedRow2 + const ErrPacket + const IntVarInsertID + const IntVarInvalidInt + const IntVarLastInsertID + const LocalInfilePacket + const MaxPacketSize + const MaximumPositionSize + const MysqlClearPassword + const MysqlDialog + const MysqlNativePassword + const NullValue + const OKPacket + const QAutoIncrement + const QCatalog + const QCatalogNZCode + const QCharsetCode + const QFlags2Code + const QSQLModeCode + const QTimeZoneCode + const SSAccessDeniedError + const SSBadFieldError + const SSBadNullError + const SSCantDoThisDuringAnTransaction + const SSDataOutOfRange + const SSDataTooLong + const SSDupKey + const SSHandshakeError + const SSLockDeadlock + const SSServerShutdown + const SSUnknownComError + const SSUnknownSQLState + const ServerInTransaction + const ServerMoreResultsExists + const ServerStatusAutocommit + const TypeBit + const TypeBlob + const TypeDate + const TypeDateTime + const TypeDateTime2 + const TypeDecimal + const TypeDouble + const TypeEnum + const TypeFloat + const TypeGeometry + const TypeInt24 + const TypeJSON + const TypeLong + const TypeLongBlob + const TypeLongLong + const TypeMediumBlob + const TypeNewDate + const TypeNewDecimal + const TypeNull + const TypeSet + const TypeShort + const TypeString + const TypeTime + const TypeTime2 + const TypeTimestamp + const TypeTimestamp2 + const TypeTiny + const TypeTinyBlob + const TypeVarString + const TypeVarchar + const TypeYear + var BaseShowTablesFields = []*querypb.Field + var CharacterSetMap = map[string]uint8 + var DescribeTableFields = []*querypb.Field + var ErrNotSlave = errors.New("no slave status") + var IntVarNames = map[byte]string + var ShowIndexFromTableFields = []*querypb.Field + var ZeroTimestamp = []byte("0000-00-00 00:00:00") + func AuthServerNegotiateClearOrDialog(c *Conn, method string) (string, error) + func AuthServerReadPacketString(c *Conn) (string, error) + func BaseShowTablesForTable(table string) string + func BaseShowTablesRow(tableName string, isView bool, comment string) []sqltypes.Value + func CellValue(data []byte, pos int, typ byte, metadata uint16, styp querypb.Type) (sqltypes.Value, int, error) + func DescribeTableRow(name string, typ string, null bool, key string, def string) []sqltypes.Value + func EncodeGTID(gtid GTID) string + func EncodePosition(rp Position) string + func ExecuteFetchMap(conn *Conn, query string) (map[string]string, error) + func GetCharset(conn *Conn) (*binlogdatapb.Charset, error) + func InitAuthServerClientCert() + func InitAuthServerStatic() + func IsConnErr(err error) bool + func IsNum(typ uint8) bool + func NewSQLErrorFromError(err error) error + func NewSalt() ([]byte, error) + func ParseErrorPacket(data []byte) error + func RegisterAuthServerImpl(name string, authServer AuthServer) + func RegisterAuthServerStaticFromParams(file, str string) + func ScramblePassword(salt, password []byte) []byte + func SetCharset(conn *Conn, cs *binlogdatapb.Charset) error + func ShowIndexFromTableRow(table string, unique bool, keyName string, seqInIndex int, columnName string, ...) []sqltypes.Value + func SlaveStatusToProto(s SlaveStatus) *replicationdatapb.Status + type AuthServer interface + AuthMethod func(user string) (string, error) + Negotiate func(c *Conn, user string, remoteAddr net.Addr) (Getter, error) + Salt func() ([]byte, error) + ValidateHash func(salt []byte, user string, authResponse []byte, remoteAddr net.Addr) (Getter, error) + func GetAuthServer(name string) AuthServer + type AuthServerClientCert struct + Method string + func (ascc *AuthServerClientCert) AuthMethod(user string) (string, error) + func (ascc *AuthServerClientCert) Negotiate(c *Conn, user string, remoteAddr net.Addr) (Getter, error) + func (ascc *AuthServerClientCert) Salt() ([]byte, error) + func (ascc *AuthServerClientCert) ValidateHash(salt []byte, user string, authResponse []byte, remoteAddr net.Addr) (Getter, error) + type AuthServerNone struct + func (a *AuthServerNone) AuthMethod(user string) (string, error) + func (a *AuthServerNone) Negotiate(c *Conn, user string, remotAddr net.Addr) (Getter, error) + func (a *AuthServerNone) Salt() ([]byte, error) + func (a *AuthServerNone) ValidateHash(salt []byte, user string, authResponse []byte, remoteAddr net.Addr) (Getter, error) + type AuthServerStatic struct + Entries map[string][]*AuthServerStaticEntry + Method string + func NewAuthServerStatic() *AuthServerStatic + func (a *AuthServerStatic) AuthMethod(user string) (string, error) + func (a *AuthServerStatic) Negotiate(c *Conn, user string, remoteAddr net.Addr) (Getter, error) + func (a *AuthServerStatic) Salt() ([]byte, error) + func (a *AuthServerStatic) ValidateHash(salt []byte, user string, authResponse []byte, remoteAddr net.Addr) (Getter, error) + type AuthServerStaticEntry struct + Groups []string + MysqlNativePassword string + Password string + SourceHost string + UserData string + type BinlogEvent interface + Format func() (BinlogFormat, error) + GTID func(BinlogFormat) (GTID, bool, error) + IntVar func(BinlogFormat) (byte, uint64, error) + IsDeleteRows func() bool + IsFormatDescription func() bool + IsGTID func() bool + IsIntVar func() bool + IsPreviousGTIDs func() bool + IsPseudo func() bool + IsQuery func() bool + IsRand func() bool + IsRotate func() bool + IsTableMap func() bool + IsUpdateRows func() bool + IsValid func() bool + IsWriteRows func() bool + IsXID func() bool + PreviousGTIDs func(BinlogFormat) (Position, error) + Query func(BinlogFormat) (Query, error) + Rand func(BinlogFormat) (uint64, uint64, error) + Rows func(BinlogFormat, *TableMap) (Rows, error) + StripChecksum func(BinlogFormat) (ev BinlogEvent, checksum []byte, err error) + TableID func(BinlogFormat) uint64 + TableMap func(BinlogFormat) (*TableMap, error) + Timestamp func() uint32 + func NewDeleteRowsEvent(f BinlogFormat, s *FakeBinlogStream, tableID uint64, rows Rows) BinlogEvent + func NewFormatDescriptionEvent(f BinlogFormat, s *FakeBinlogStream) BinlogEvent + func NewIntVarEvent(f BinlogFormat, s *FakeBinlogStream, typ byte, value uint64) BinlogEvent + func NewInvalidEvent() BinlogEvent + func NewInvalidFormatDescriptionEvent(f BinlogFormat, s *FakeBinlogStream) BinlogEvent + func NewInvalidQueryEvent(f BinlogFormat, s *FakeBinlogStream) BinlogEvent + func NewMariaDBGTIDEvent(f BinlogFormat, s *FakeBinlogStream, gtid MariadbGTID, hasBegin bool) BinlogEvent + func NewMariadbBinlogEvent(buf []byte) BinlogEvent + func NewMysql56BinlogEvent(buf []byte) BinlogEvent + func NewQueryEvent(f BinlogFormat, s *FakeBinlogStream, q Query) BinlogEvent + func NewRotateEvent(f BinlogFormat, s *FakeBinlogStream, position uint64, filename string) BinlogEvent + func NewTableMapEvent(f BinlogFormat, s *FakeBinlogStream, tableID uint64, tm *TableMap) BinlogEvent + func NewUpdateRowsEvent(f BinlogFormat, s *FakeBinlogStream, tableID uint64, rows Rows) BinlogEvent + func NewWriteRowsEvent(f BinlogFormat, s *FakeBinlogStream, tableID uint64, rows Rows) BinlogEvent + func NewXIDEvent(f BinlogFormat, s *FakeBinlogStream) BinlogEvent + type BinlogFormat struct + ChecksumAlgorithm byte + FormatVersion uint16 + HeaderLength byte + HeaderSizes []byte + ServerVersion string + func NewMariaDBBinlogFormat() BinlogFormat + func NewMySQL56BinlogFormat() BinlogFormat + func (f BinlogFormat) HeaderSize(typ byte) byte + func (f BinlogFormat) IsZero() bool + type Bitmap struct + func NewServerBitmap(count int) Bitmap + func (b *Bitmap) Bit(index int) bool + func (b *Bitmap) BitCount() int + func (b *Bitmap) Count() int + func (b *Bitmap) Set(index int, value bool) + type Conn struct + Capabilities uint32 + CharacterSet uint8 + ClientData interface{} + Conn net.Conn + ConnectionID uint32 + PrepareData map[uint32]*PrepareData + ServerVersion string + StatementID uint32 + StatusFlags uint16 + User string + UserData Getter + func Connect(ctx context.Context, params *ConnParams) (*Conn, error) + func (c *Conn) Close() + func (c *Conn) CloseResult() + func (c *Conn) DisableBinlogPlaybackCommand() string + func (c *Conn) EnableBinlogPlaybackCommand() string + func (c *Conn) ExecuteFetch(query string, maxrows int, wantfields bool) (result *sqltypes.Result, err error) + func (c *Conn) ExecuteFetchMulti(query string, maxrows int, wantfields bool) (result *sqltypes.Result, more bool, err error) + func (c *Conn) ExecuteFetchWithWarningCount(query string, maxrows int, wantfields bool) (result *sqltypes.Result, warnings uint16, err error) + func (c *Conn) ExecuteStreamFetch(query string) (err error) + func (c *Conn) FetchNext() ([]sqltypes.Value, error) + func (c *Conn) Fields() ([]*querypb.Field, error) + func (c *Conn) GetTLSClientCerts() []*x509.Certificate + func (c *Conn) HandleLoadDataLocalQuery(tmpdir string, tmpfileName string, file string) error + func (c *Conn) ID() int64 + func (c *Conn) IsClosed() bool + func (c *Conn) IsMariaDB() bool + func (c *Conn) MasterPosition() (Position, error) + func (c *Conn) Ping() error + func (c *Conn) ReadBinlogEvent() (BinlogEvent, error) + func (c *Conn) ReadPacket() ([]byte, error) + func (c *Conn) ReadQueryResult(maxrows int, wantfields bool) (result *sqltypes.Result, more bool, warnings uint16, err error) + func (c *Conn) RemoteAddr() net.Addr + func (c *Conn) ResetReplicationCommands() []string + func (c *Conn) SemiSyncExtensionLoaded() bool + func (c *Conn) SendBinlogDumpCommand(slaveID uint32, startPos Position) error + func (c *Conn) SetMasterCommand(params *ConnParams, masterHost string, masterPort int, masterConnectRetry int) string + func (c *Conn) SetSlavePositionCommands(pos Position) []string + func (c *Conn) ShowSlaveStatus() (SlaveStatus, error) + func (c *Conn) StartSlaveCommand() string + func (c *Conn) StartSlaveUntilAfterCommand(pos Position) string + func (c *Conn) StopSlaveCommand() string + func (c *Conn) String() string + func (c *Conn) WaitUntilPositionCommand(ctx context.Context, pos Position) (string, error) + func (c *Conn) WriteComBinlogDump(serverID uint32, binlogFilename string, binlogPos uint32, flags uint16) error + func (c *Conn) WriteComBinlogDumpGTID(serverID uint32, binlogFilename string, binlogPos uint64, flags uint16, ...) error + func (c *Conn) WriteComQuery(query string) error + type ConnParams struct + Charset string + DbName string + DeprecatedDBName string + DisableClientDeprecateEOF bool + Flags uint64 + Flavor string + Host string + Pass string + Port int + ServerName string + SslCa string + SslCaPath string + SslCert string + SslKey string + Uname string + UnixSocket string + func (cp *ConnParams) EnableClientFoundRows() + func (cp *ConnParams) EnableSSL() + func (cp *ConnParams) SslEnabled() bool + type FakeBinlogStream struct + LogPosition uint32 + ServerID uint32 + Timestamp uint32 + func NewFakeBinlogStream() *FakeBinlogStream + func (s *FakeBinlogStream) Packetize(f BinlogFormat, typ byte, flags uint16, data []byte) []byte + type GTID interface + Flavor func() string + GTIDSet func() GTIDSet + SequenceDomain func() interface{} + SequenceNumber func() interface{} + SourceServer func() interface{} + String func() string + func DecodeGTID(s string) (GTID, error) + func MustDecodeGTID(s string) GTID + func MustParseGTID(flavor, value string) GTID + func ParseGTID(flavor, value string) (GTID, error) + type GTIDSet interface + AddGTID func(GTID) GTIDSet + Contains func(GTIDSet) bool + ContainsGTID func(GTID) bool + Equal func(GTIDSet) bool + Flavor func() string + String func() string + type Getter interface + Get func() *querypb.VTGateCallerID + type Handler interface + ComInitDB func(c *Conn, schemaName string) error + ComPrepare func(c *Conn, query string) ([]*querypb.Field, error) + ComQuery func(c *Conn, query string, callback func(*sqltypes.Result) error) error + ComResetConnection func(c *Conn) + ComStmtExecute func(c *Conn, prepare *PrepareData, callback func(*sqltypes.Result) error) error + ConnectionClosed func(c *Conn) + NewConnection func(c *Conn) + WarningCount func(c *Conn) uint16 + type Listener struct + AllowClearTextWithoutTLS bool + RequireSecureTransport bool + ServerVersion string + SlowConnectWarnThreshold time.Duration + TLSConfig *tls.Config + func NewFromListener(l net.Listener, authServer AuthServer, handler Handler, ...) (*Listener, error) + func NewListener(protocol, address string, authServer AuthServer, handler Handler, ...) (*Listener, error) + func NewListenerWithConfig(cfg ListenerConfig) (*Listener, error) + func (l *Listener) Accept() + func (l *Listener) Addr() net.Addr + func (l *Listener) Close() + func (l *Listener) Handler(conn net.Conn) + func (l *Listener) Shutdown() + type ListenerConfig struct + Address string + AuthServer AuthServer + ConnReadBufferSize int + ConnReadTimeout time.Duration + ConnWriteTimeout time.Duration + Handler Handler + Listener net.Listener + MaxConns uint64 + Protocol string + type MariadbGTID struct + Domain uint32 + Sequence uint64 + Server uint32 + func (gtid MariadbGTID) Flavor() string + func (gtid MariadbGTID) GTIDSet() GTIDSet + func (gtid MariadbGTID) SequenceDomain() interface{} + func (gtid MariadbGTID) SequenceNumber() interface{} + func (gtid MariadbGTID) SourceServer() interface{} + func (gtid MariadbGTID) String() string + type MariadbGTIDSet []MariadbGTID + func (gtidSet MariadbGTIDSet) AddGTID(other GTID) GTIDSet + func (gtidSet MariadbGTIDSet) Contains(other GTIDSet) bool + func (gtidSet MariadbGTIDSet) ContainsGTID(other GTID) bool + func (gtidSet MariadbGTIDSet) Equal(other GTIDSet) bool + func (gtidSet MariadbGTIDSet) Flavor() string + func (gtidSet MariadbGTIDSet) String() string + type Mysql56GTID struct + Sequence int64 + Server SID + func (gtid Mysql56GTID) Flavor() string + func (gtid Mysql56GTID) GTIDSet() GTIDSet + func (gtid Mysql56GTID) SequenceDomain() interface{} + func (gtid Mysql56GTID) SequenceNumber() interface{} + func (gtid Mysql56GTID) SourceServer() interface{} + func (gtid Mysql56GTID) String() string + type Mysql56GTIDSet map[SID][]interval + func NewMysql56GTIDSetFromSIDBlock(data []byte) (Mysql56GTIDSet, error) + func (Mysql56GTIDSet) Flavor() string + func (set Mysql56GTIDSet) AddGTID(gtid GTID) GTIDSet + func (set Mysql56GTIDSet) Contains(other GTIDSet) bool + func (set Mysql56GTIDSet) ContainsGTID(gtid GTID) bool + func (set Mysql56GTIDSet) Equal(other GTIDSet) bool + func (set Mysql56GTIDSet) SIDBlock() []byte + func (set Mysql56GTIDSet) SIDs() []SID + func (set Mysql56GTIDSet) String() string + type NoneGetter struct + func (ng *NoneGetter) Get() *querypb.VTGateCallerID + type Position struct + GTIDSet GTIDSet + func AppendGTID(rp Position, gtid GTID) Position + func DecodePosition(s string) (rp Position, err error) + func MustParsePosition(flavor, value string) Position + func ParsePosition(flavor, value string) (rp Position, err error) + func (rp *Position) UnmarshalJSON(buf []byte) error + func (rp Position) AtLeast(other Position) bool + func (rp Position) Equal(other Position) bool + func (rp Position) IsZero() bool + func (rp Position) MarshalJSON() ([]byte, error) + func (rp Position) String() string + type PrepareData struct + BindVars map[string]*querypb.BindVariable + ColumnNames []string + ParamsCount uint16 + ParamsType []int32 + PrepareStmt string + StatementID uint32 + type Query struct + Charset *binlogdatapb.Charset + Database string + SQL string + func (q Query) String() string + type Row struct + Data []byte + Identify []byte + NullColumns Bitmap + NullIdentifyColumns Bitmap + type Rows struct + DataColumns Bitmap + Flags uint16 + IdentifyColumns Bitmap + Rows []Row + func (rs *Rows) StringIdentifiesForTests(tm *TableMap, rowIndex int) ([]string, error) + func (rs *Rows) StringValuesForTests(tm *TableMap, rowIndex int) ([]string, error) + type SID [16]byte + func ParseSID(s string) (sid SID, err error) + func (sid SID) String() string + type SQLError struct + Message string + Num int + Query string + State string + func NewSQLError(number int, sqlState string, format string, args ...interface{}) *SQLError + func (se *SQLError) Error() string + func (se *SQLError) Number() int + func (se *SQLError) SQLState() string + type SlaveStatus struct + MasterConnectRetry int + MasterHost string + MasterPort int + Position Position + SecondsBehindMaster uint + SlaveIORunning bool + SlaveSQLRunning bool + func ProtoToSlaveStatus(s *replicationdatapb.Status) SlaveStatus + func (s *SlaveStatus) SlaveRunning() bool + type StaticUserData struct + func (sud *StaticUserData) Get() *querypb.VTGateCallerID + type TableMap struct + CanBeNull Bitmap + Database string + Flags uint16 + Metadata []uint16 + Name string + Types []byte
Go to main page