Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

net

package

Go to main page

Versions in this module

v1

v1.0.0

Mar 20, 2024

Changes in this version

+ func ParseQueryPacket(data []byte) string

type PacketIO

+ func (p *PacketIO) InPackets() uint64

+ func (p *PacketIO) OutPackets() uint64

v0

v0.2.0

Jan 16, 2024

Changes in this version

+ const ServerMoreResultsExists

+ const ServerPSOutParams

+ const ServerStatusAutocommit

+ const ServerStatusCursorExists

+ const ServerStatusDBDropped

+ const ServerStatusInTrans

+ const ServerStatusLastRowSend

+ const ServerStatusMetadataChanged

+ const ServerStatusNoBackslashEscaped

+ const ServerStatusNoGoodIndexUsed

+ const ServerStatusNoIndexUsed

+ const ServerStatusWasSlow

+ func IsMySQLError(err error) bool

v0.1.2

Nov 8, 2023

Changes in this version

+ const AttrNameClientName1

+ const AttrNameClientName2

+ const AttrNameClientVersion

+ const AttrNameProgramName

+ const AuthCachingSha2Password

+ const AuthMySQLClearPassword

+ const AuthNativePassword

+ const AuthSocket

+ const AuthTiDBAuthToken

+ const AuthTiDBSM3Password

+ const AuthTiDBSessionToken

+ const DefaultConnBufferSize

+ const FastAuthFail

+ const MaxPayloadLen

+ const ShaCommand

+ var Collation = uint8(mysql.DefaultCollationID)

+ var ErrCloseConn = errors.New("failed to close the connection")

+ var ErrFlushConn = errors.New("failed to flush the connection")

+ var ErrHandshakeTLS = errors.New("failed to complete tls handshake")

+ var ErrInvalidSequence = dbterror.ClassServer.NewStd(errno.ErrInvalidSequence)

+ var ErrReadConn = errors.New("failed to read the connection")

+ var ErrRelayConn = errors.New("failed to relay the connection")

+ var ErrSaltNotLongEnough = errors.New("salt is not long enough")

+ var ErrWriteConn = errors.New("failed to write the connection")

+ var ServerVersion = mysql.ServerVersion

+ var Status = mysql.ServerStatusAutocommit

+ func Attr2ZapFields(attrs map[string]string) []zap.Field

+ func DumpLengthEncodedInt(buffer []byte, n uint64) []byte

+ func DumpLengthEncodedString(buffer []byte, bytes []byte) []byte

+ func DumpUint16(buffer []byte, n uint16) []byte

+ func DumpUint32(buffer []byte, n uint32) []byte

+ func IsDisconnectError(err error) bool

+ func IsEOFPacket(firstByte byte, length int) bool

+ func IsErrorPacket(firstByte byte) bool

+ func IsOKPacket(firstByte byte) bool

+ func IsResultSetOKPacket(firstByte byte, length int) bool

+ func MakeChangeUser(req *ChangeUserReq, capability Capability) []byte

+ func MakeHandshakeResponse(resp *HandshakeResp) []byte

+ func ParseErrorPacket(data []byte) error

+ func ParseLengthEncodedBytes(b []byte) ([]byte, bool, int, error)

+ func ParseLengthEncodedInt(b []byte) (num uint64, isNull bool, n int)

+ func ParseNullTermString(b []byte) (str []byte, remain []byte)

+ func ParseOKPacket(data []byte) uint16

+ func ReadFull(prw packetReadWriter, b []byte) error

+ func ReadServerVersion(conn net.Conn) (string, error)

+ func SkipLengthEncodedInt(b []byte) int

+ func WithProxy(pi *PacketIO)

+ func WithRemoteAddr(readdr string, addr net.Addr) func(pi *PacketIO)

+ func WithWrapError(err error) func(pi *PacketIO)

+ func WriteServerVersion(conn net.Conn, serverVersion string) error

+ type Capability uint32

+ const ClientCanHandleExpiredPasswords

+ const ClientCapabilityExtension

+ const ClientCompress

+ const ClientConnectAttrs

+ const ClientConnectWithDB

+ const ClientDeprecateEOF

+ const ClientFoundRows

+ const ClientIgnoreSigpipe

+ const ClientIgnoreSpace

+ const ClientInteractive

+ const ClientLocalFiles

+ const ClientLongFlag

+ const ClientLongPassword

+ const ClientMultiResults

+ const ClientMultiStatements

+ const ClientNoSchema

+ const ClientODBC

+ const ClientOptionalResultsetMetadata

+ const ClientPSMultiResults

+ const ClientPluginAuth

+ const ClientPluginAuthLenencClientData

+ const ClientProtocol41

+ const ClientQueryAttributes

+ const ClientRememberOptions

+ const ClientReserved

+ const ClientSSL

+ const ClientSSLVerifyServerCert

+ const ClientSecureConnection

+ const ClientSessionTrack

+ const ClientTransactions

+ const ClientZstdCompressionAlgorithm

+ const MultiFactorAuthentication

+ func ParseInitialHandshake(data []byte) (Capability, uint64, string)

+ func (f *Capability) MarshalText() ([]byte, error)

+ func (f *Capability) UnmarshalText(o []byte) error

+ func (f Capability) String() string

+ func (f Capability) Uint32() uint32

+ type ChangeUserReq struct

+ Attrs map[string]string

+ AuthData []byte

+ AuthPlugin string

+ Charset []byte

+ DB string

+ User string

+ func ParseChangeUser(data []byte, capability Capability) (*ChangeUserReq, error)

+ type Command byte

+ const ComBinlogDump

+ const ComBinlogDumpGtid

+ const ComChangeUser

+ const ComConnect

+ const ComConnectOut

+ const ComCreateDB

+ const ComDaemon

+ const ComDebug

+ const ComDelayedInsert

+ const ComDeprecated1

+ const ComDropDB

+ const ComEnd

+ const ComFieldList

+ const ComInitDB

+ const ComPing

+ const ComProcessInfo

+ const ComProcessKill

+ const ComQuery

+ const ComQuit

+ const ComRefresh

+ const ComRegisterSlave

+ const ComResetConnection

+ const ComSetOption

+ const ComSleep

+ const ComStatistics

+ const ComStmtClose

+ const ComStmtExecute

+ const ComStmtFetch

+ const ComStmtPrepare

+ const ComStmtReset

+ const ComStmtSendLongData

+ const ComTableDump

+ const ComTime

+ func (f *Command) MarshalText() ([]byte, error)

+ func (f *Command) UnmarshalText(o []byte) error

+ func (f Command) Byte() byte

+ func (f Command) String() string

+ type CompressAlgorithm int

+ const CompressionNone

+ const CompressionZlib

+ const CompressionZstd

+ type HandshakeResp struct

+ Attrs map[string]string

+ AuthData []byte

+ AuthPlugin string

+ Capability Capability

+ Collation uint8

+ DB string

+ User string

+ ZstdLevel int

+ func ParseHandshakeResponse(data []byte) (*HandshakeResp, error)

+ type Header byte

+ const AuthSwitchHeader

+ const EOFHeader

+ const ErrHeader

+ const LocalInFileHeader

+ const OKHeader

+ func (f Header) Byte() byte

+ func (f Header) String() string

+ type PacketIO struct

+ func NewPacketIO(conn net.Conn, lg *zap.Logger, bufferSize int, opts ...PacketIOption) *PacketIO

+ func (p *PacketIO) ApplyOpts(opts ...PacketIOption)

+ func (p *PacketIO) ClientTLSHandshake(tlsConfig *tls.Config) error

+ func (p *PacketIO) Close() error

+ func (p *PacketIO) EnableProxyClient(proxy *proxyprotocol.Proxy)

+ func (p *PacketIO) EnableProxyServer()

+ func (p *PacketIO) Flush() error

+ func (p *PacketIO) ForwardUntil(dest *PacketIO, ...) error

+ func (p *PacketIO) GetSequence() uint8

+ func (p *PacketIO) GracefulClose() error

+ func (p *PacketIO) InBytes() uint64

+ func (p *PacketIO) IsPeerActive() bool

+ func (p *PacketIO) LastKeepAlive() config.KeepAlive

+ func (p *PacketIO) LocalAddr() net.Addr

+ func (p *PacketIO) OutBytes() uint64

+ func (p *PacketIO) Proxy() *proxyprotocol.Proxy

+ func (p *PacketIO) ReadPacket() (data []byte, err error)

+ func (p *PacketIO) ReadSSLRequestOrHandshakeResp() (pkt []byte, isSSL bool, err error)

+ func (p *PacketIO) RemoteAddr() net.Addr

+ func (p *PacketIO) ResetSequence()

+ func (p *PacketIO) ServerTLSHandshake(tlsConfig *tls.Config) (tls.ConnectionState, error)

+ func (p *PacketIO) SetCompressionAlgorithm(algorithm CompressAlgorithm, zstdLevel int) error

+ func (p *PacketIO) SetKeepalive(cfg config.KeepAlive) error

+ func (p *PacketIO) TLSConnectionState() tls.ConnectionState

+ func (p *PacketIO) WriteEOFPacket(status uint16) error

+ func (p *PacketIO) WriteErrPacket(merr *mysql.MyError) error

+ func (p *PacketIO) WriteInitialHandshake(capability Capability, salt []byte, authPlugin string, serverVersion string, ...) error

+ func (p *PacketIO) WriteOKPacket(status uint16, header Header) error

+ func (p *PacketIO) WritePacket(data []byte, flush bool) (err error)

+ func (p *PacketIO) WriteShaCommand() error

+ func (p *PacketIO) WriteSwitchRequest(authPlugin string, salt []byte) error

+ func (p *PacketIO) WriteUserError(err error)

+ type PacketIOption = func(*PacketIO)

+ type UserError struct

+ func WrapUserError(err error, userMsg string) *UserError

+ func (ue *UserError) Error() string

+ func (ue *UserError) Unwrap() error

+ func (ue *UserError) UserMsg() string

v0.1.2-alpha.2

Nov 6, 2023

v0.1.2-alpha.1

Oct 20, 2023