util

Documentation

Index

• Constants
• func AppendFormatFloat(in []byte, fVal float64, prec, bitSize int) []byte
• func LengthEncodedIntSize(n uint64) int
• func NewCorsHandler(handler http.Handler, cfg *config.Config) http.Handler
• func NewTestConfig() *config.Config
• 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)
• type BufferedReadConn
  • func NewBufferedReadConn(conn net.Conn) *BufferedReadConn
  • func (conn BufferedReadConn) Read(b []byte) (n int, err error)
• type CorsHandler
  • func (h CorsHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type InputDecoder
  • func NewInputDecoder(chs string) *InputDecoder
  • func (i *InputDecoder) DecodeInput(src []byte) []byte

Constants

const DefaultReaderSize = 16 * 1024

DefaultReaderSize is the default size of bufio.Reader.

Functions

func AppendFormatFloat

func AppendFormatFloat(in []byte, fVal float64, prec, bitSize int) []byte

AppendFormatFloat appends a float64 to dst in MySQL format.

func LengthEncodedIntSize

func LengthEncodedIntSize(n uint64) int

LengthEncodedIntSize returns the size of length encoded integer.

func NewCorsHandler

func NewCorsHandler(handler http.Handler, cfg *config.Config) http.Handler

NewCorsHandler creates a new CorsHandler.

func NewTestConfig

func NewTestConfig() *config.Config

NewTestConfig creates a new config for test.

func ParseLengthEncodedBytes

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

ParseLengthEncodedBytes parses a length encoded byte slice.

func ParseLengthEncodedInt

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

ParseLengthEncodedInt parses a length encoded integer.

func ParseNullTermString

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

ParseNullTermString parses a null terminated string.

Types

type BufferedReadConn

type BufferedReadConn struct {
	net.Conn
	// contains filtered or unexported fields
}

BufferedReadConn is a net.Conn compatible structure that reads from bufio.Reader.

func NewBufferedReadConn

func NewBufferedReadConn(conn net.Conn) *BufferedReadConn

NewBufferedReadConn creates a BufferedReadConn.

func (BufferedReadConn) Read

func (conn BufferedReadConn) Read(b []byte) (n int, err error)

Read reads data from the connection.

type CorsHandler

type CorsHandler struct {
	// contains filtered or unexported fields
}

CorsHandler adds Cors Header if `cors` config is set.

func (CorsHandler) ServeHTTP

func (h CorsHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP implements http.Handler interface.

type InputDecoder

type InputDecoder struct {
	// contains filtered or unexported fields
}

InputDecoder is used to decode input.

func NewInputDecoder

func NewInputDecoder(chs string) *InputDecoder

NewInputDecoder creates a new InputDecoder.

func (*InputDecoder) DecodeInput

func (i *InputDecoder) DecodeInput(src []byte) []byte

DecodeInput decodes input.