tex

package
v0.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 19, 2021 License: MIT Imports: 17 Imported by: 3

README

tex

  • 基本扩展
  • 扩展一些数据类型，能适配SQL/JSON
  • 提供基本的二进制读写数据
  • 提供高效的JSON算法和压缩算法
  • 提供位图数据
  • 提供interface到基本数据类型的转化

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrByteBufferEmpty = errors.New("byte.buffer.empty")
	ErrReadWrongNum    = errors.New("byte.buffer.wrong.num")
	ErrSizeLimit       = errors.New("byte.buffer.size.limit")
)
View Source 
var (
	JSONMarshal   = jsonStd.Marshal
	JSONUnmarshal = jsonStd.Unmarshal
)

标准jsoniter json库 100%兼容

View Source 
var (
	JSONFastMarshal   = jsonFast.Marshal
	JSONFastUnmarshal = jsonFast.Unmarshal

	JSONFastMarshalSnappy   = fastMarshalSnappy
	JSONFastUnmarshalSnappy = fastUnmarshalSnappy

	TrySnappyCompress = compressJSON
)

快速jsoniter json库 -- 浮点数会丢失精度，小数点最多后6位

View Source 
var (
	ErrInvalidByteJs = errors.New(`byte.invalid.string`)
)
View Source 
var (
	ErrInvalidDurationJs = errors.New(`duration invalid string`)
)
View Source 
var (
	ErrInvalidInt64Js = errors.New(`int64 invalid string`)
)
View Source 
var (
	ErrInvalidUInt64Js = errors.New(`uint64 invalid string`)
)
View Source 
var (
	Snappy = &_Snappy{}
)

Functions

func KeyInMap 

func KeyInMap(m map[string]interface{}, k string) bool

KeyInMap : Map中是否包含了key

func LoadJSONFile2Obj 

func LoadJSONFile2Obj(fileName string, v interface{}) error

LoadJSONFile2Obj 读取json文件并序列化到传入的指针中

func MapVal2Bool 

func MapVal2Bool(m map[string]interface{}, k string) bool

MapVal2Bool : 将map中的value转换为bool

func MapVal2Bytes 

func MapVal2Bytes(m map[string]interface{}, k string) []byte

MapVal2Bytes : 将map中的value转换为[]byte

func MapVal2Duration added in v0.0.3 

func MapVal2Duration(m map[string]interface{}, k string) (time.Duration, bool)

MapVal2Duration : 将map中的value转换为Duration

func MapVal2Float64 

func MapVal2Float64(m map[string]interface{}, k string) float64

MapVal2Float64 : 将map中的value转换为float64

func MapVal2Int 

func MapVal2Int(m map[string]interface{}, k string) int

MapVal2Int : 将map中的value转换为int

func MapVal2Int32 

func MapVal2Int32(m map[string]interface{}, k string) int32

MapVal2Int32 : 将map中的value转换为int32

func MapVal2Int64 

func MapVal2Int64(m map[string]interface{}, k string) int64

MapVal2Int64 : 将map中的value转换为int64

func MapVal2String 

func MapVal2String(m map[string]interface{}, k string) string

MapVal2String : 将map中的value转换为string

func MapVal2StringList 

func MapVal2StringList(m map[string]interface{}, k string) []string

MapVal2StringList : 将map中的value转换为string list

func MapVal2Time 

func MapVal2Time(m map[string]interface{}, k string) (time.Time, bool)

MapVal2Time : 将map中的value转换为time

func ToBool 

func ToBool(v interface{}) bool

ToBool 将基本类型转换为bool

func ToBytes 

func ToBytes(v interface{}) []byte

ToBytes 将基本类型转换为[]byte

func ToDuration added in v0.0.3 

func ToDuration(v interface{}) (time.Duration, bool)

ToDuration 转换为time.Duration

func ToFloat64 

func ToFloat64(v interface{}) float64

ToFloat64 将基本类型转换为浮点型

func ToInt 

func ToInt(v interface{}) int

ToInt 将基本类型转换为整型

func ToInt32 

func ToInt32(v interface{}) int32

ToInt32 将基本类型转换为32位整型

func ToInt64 

func ToInt64(v interface{}) int64

ToInt64 将基本类型转换为64位整型

func ToString 

func ToString(v interface{}) string

ToString 将基本类型转换为字符串

func ToStringList 

func ToStringList(v interface{}) []string

ToStringList 将基本类型转换为字符串list

func ToTime 

func ToTime(v interface{}) (time.Time, bool)

ToTime 转换为time.Time

func ToUInt added in v0.0.3 

func ToUInt(v interface{}) uint

func ToUInt32 added in v0.0.3 

func ToUInt32(v interface{}) uint32

ToInt32 将基本类型转换为32位无符号整型

func ToUInt64 added in v0.0.3 

func ToUInt64(v interface{}) uint64

Types

type Base64Bytes 

type Base64Bytes []byte

func (*Base64Bytes) Scan 

func (i *Base64Bytes) Scan(value interface{}) error

func (Base64Bytes) Value 

func (i Base64Bytes) Value() (driver.Value, error)

type BufferX 

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

BufferX buffer implement

func NewBuffer 

func NewBuffer() *BufferX

NewBuffer new buffer with a default size as unpack

func NewReadableBuffer added in v0.2.3 

func NewReadableBuffer(data []byte) *BufferX

NewReadableBuffer new buffer from existed bytes to read. Use existed bytes to fill buffer, the buffer is always used as read stream.

func NewSizedBuffer added in v0.2.3 

func NewSizedBuffer(size int) *BufferX

NewSizedBuffer : new buffer with specific size

func (*BufferX) Bytes 

func (b *BufferX) Bytes() []byte

Bytes all buffer bytes

func (*BufferX) Len 

func (b *BufferX) Len() int

Len : buffer len

func (*BufferX) ReWrite 

func (b *BufferX) ReWrite(pos int, p []byte)

ReWrite buffer

func (*BufferX) ReWriteU32 

func (b *BufferX) ReWriteU32(pos int, v uint32)

ReWriteU32 rewrite uint32

func (*BufferX) Read 

func (b *BufferX) Read(p []byte) error

read to a buffer

func (*BufferX) ReadBool 

func (b *BufferX) ReadBool() (bool, error)

ReadBool read a bool

func (*BufferX) ReadF64 

func (b *BufferX) ReadF64() (float64, error)

ReadF64 read float64

func (*BufferX) ReadI16 

func (b *BufferX) ReadI16() (int16, error)

ReadI16 read int16

func (*BufferX) ReadI32 

func (b *BufferX) ReadI32() (int32, error)

ReadI32 read int32

func (*BufferX) ReadI64 

func (b *BufferX) ReadI64() (int64, error)

ReadI64 read int64

func (*BufferX) ReadLimitString 

func (b *BufferX) ReadLimitString(limit uint32) (string, error)

ReadLimitString read limit size string

func (*BufferX) ReadN 

func (b *BufferX) ReadN(n int) ([]byte, error)

ReadN read n length buffer

func (*BufferX) ReadString 

func (b *BufferX) ReadString() (string, error)

ReadString read string

func (*BufferX) ReadU8 

func (b *BufferX) ReadU8() (byte, error)

ReadU8 read a byte

func (*BufferX) ReadU16 

func (b *BufferX) ReadU16() (uint16, error)

ReadU16 read uint16

func (*BufferX) ReadU32 

func (b *BufferX) ReadU32() (uint32, error)

ReadU32 read uint32

func (*BufferX) ReadU64 

func (b *BufferX) ReadU64() (uint64, error)

ReadU64 read uint64

func (*BufferX) ReadVarI32 added in v0.1.6 

func (b *BufferX) ReadVarI32() (int32, error)

ReadVarI32 read variant int32

func (*BufferX) ReadVarI64 added in v0.1.6 

func (b *BufferX) ReadVarI64() (int64, error)

ReadVarI64 read variant int64

func (*BufferX) ReadVarU32 added in v0.1.6 

func (b *BufferX) ReadVarU32() (uint32, error)

ReadVarU32 read variant uint32

func (*BufferX) ReadVarU64 added in v0.1.6 

func (b *BufferX) ReadVarU64() (uint64, error)

ReadVarU64 read variant uint64

func (*BufferX) Reset 

func (b *BufferX) Reset()

Reset clear all buffer bytes

func (*BufferX) Write 

func (b *BufferX) Write(p []byte)

write to a buffer

func (*BufferX) WriteBool 

func (b *BufferX) WriteBool(v bool)

WriteBool write a bool

func (*BufferX) WriteF64 

func (b *BufferX) WriteF64(v float64)

WriteF64 write float64

func (*BufferX) WriteI16 

func (b *BufferX) WriteI16(v int16)

WriteI16 write int16

func (*BufferX) WriteI32 

func (b *BufferX) WriteI32(v int32)

WriteI32 write int32

func (*BufferX) WriteI64 

func (b *BufferX) WriteI64(v int64)

WriteI64 write int64

func (*BufferX) WriteLimitString 

func (b *BufferX) WriteLimitString(limit uint32, val string) error

WriteLimitString write limit size string

func (*BufferX) WriteString 

func (b *BufferX) WriteString(val string)

WriteString write string

func (*BufferX) WriteU8 

func (b *BufferX) WriteU8(v byte)

WriteU8 write a byte

func (*BufferX) WriteU16 

func (b *BufferX) WriteU16(v uint16)

WriteU16 write uint16

func (*BufferX) WriteU32 

func (b *BufferX) WriteU32(v uint32)

WriteU32 write uint32

func (*BufferX) WriteU64 

func (b *BufferX) WriteU64(v uint64)

WriteU64 write uint64

func (*BufferX) WriteVarI32 added in v0.1.6 

func (b *BufferX) WriteVarI32(v int32)

WriteVarI32 write variant int32

func (*BufferX) WriteVarI64 added in v0.1.6 

func (b *BufferX) WriteVarI64(v int64)

WriteVarI64 write variant int64

func (*BufferX) WriteVarU32 added in v0.1.6 

func (b *BufferX) WriteVarU32(v uint32)

WriteVarU32 write variant uint32

func (*BufferX) WriteVarU64 added in v0.1.6 

func (b *BufferX) WriteVarU64(v uint64)

WriteVarU64 write variant uint64

func (*BufferX) ZReadN 

func (b *BufferX) ZReadN(n int) ([]byte, error)

ZReadN read n length buffer - no copy

type CompressType 

type CompressType byte
const (
	CompressThreshHold              = 256
	CompressSnappy     CompressType = 128
)

type IBufferX 

type IBufferX interface {
	//Len : length
	Len() int
	//Read specific p, if length is not enough, return error
	Read(p []byte) error
	//ReadN n bytes, if length is not enough, return error
	ReadN(n int) ([]byte, error)
	//Write to buffer
	Write(p []byte)
	//Bytes left bytes
	Bytes() []byte
	//Reset reset cursor
	Reset()

	//ReWrite a buffer
	ReWrite(pos int, p []byte)
	//ReWriteU32 rewrite with a specific pos
	ReWriteU32(pos int, v uint32)

	//ReadU8 read byte
	ReadU8() (byte, error)
	//WriteU8 write byte
	WriteU8(byte)

	//ReadBool read bool
	ReadBool() (bool, error)
	//WriteBool write bool
	WriteBool(bool)

	//ReadLimitString read string
	ReadLimitString(limit uint32) (string, error)
	//WriteLimitString write string
	WriteLimitString(limit uint32, val string) error

	//ReadString read string
	ReadString() (string, error)
	//WriteString write string
	WriteString(val string)

	//ReadU16 read uint16
	ReadU16() (uint16, error)
	//WriteU16 write uint16
	WriteU16(uint16)

	//ReadI16 read int16
	ReadI16() (int16, error)
	//WriteI16 write int16
	WriteI16(int16)

	//ReadU32 read uint32
	ReadU32() (uint32, error)
	//WriteU32 write uint32
	WriteU32(uint32)

	//ReadI32 read int32
	ReadI32() (int32, error)
	//WriteI32 write int32
	WriteI32(int32)

	//ReadU64 read uint64
	ReadU64() (uint64, error)
	//WriteU64 write uint64
	WriteU64(uint64)

	//ReadI64 read int64
	ReadI64() (int64, error)
	//WriteI64 write int64
	WriteI64(int64)

	//ReadF64 read float64
	ReadF64() (float64, error)
	//WriteF64 write float64
	WriteF64(float64)
}

IBufferX buffer interface

type IReaderX 

type IReaderX interface {
	//Read : read specific p, if length is not enough, return error
	Read(p []byte) error
	//ReadN : read n bytes, if length is not enough, return error
	ReadN(n int) ([]byte, error)

	ZReadN(n int) ([]byte, error)

	//ReadByte : read byte
	ReadByte() (byte, error)
	//ReadBool : read bool
	ReadBool() (bool, error)

	//ReadLimitString : read string
	ReadLimitString(limit uint32) (string, error)

	//ReadString : read string
	ReadString() (string, error)

	//ReadU16 : read uint16
	ReadU16() (uint16, error)

	//ReadI16 : read int16
	ReadI16() (int16, error)

	//ReadU32 : read uint32
	ReadU32() (uint32, error)

	//ReadI32 : read int32
	ReadI32() (int32, error)

	//ReadU64 : read uint64
	ReadU64() (uint64, error)

	//ReadI64 : read int64
	ReadI64() (int64, error)

	//ReadF64 : read float64
	ReadF64() (float64, error)
}

IReaderX reader interface

type JsByte 

type JsByte []byte

JsByte json could not support readable []byte use string to replace the byte array

func (*JsByte) FromString 

func (i *JsByte) FromString(strBuf string) error

FromString from string

func (JsByte) MarshalJSON 

func (i JsByte) MarshalJSON() ([]byte, error)

MarshalJSON marshal json

func (JsByte) ToJS 

func (i JsByte) ToJS() []byte

ToJS split byte to string use '/' split

func (JsByte) ToString 

func (i JsByte) ToString() string

ToString split byte to byte use '/' split

func (*JsByte) UnmarshalJSON 

func (i *JsByte) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshal json

type JsDuration added in v0.0.3 

type JsDuration struct {
	time.Duration
}

func NewJsDuration added in v0.0.3 

func NewJsDuration(d time.Duration) JsDuration

func (*JsDuration) From added in v0.0.3 

func (i *JsDuration) From(d time.Duration)

From : from duration

func (JsDuration) MarshalJSON added in v0.0.3 

func (i JsDuration) MarshalJSON() ([]byte, error)

MarshalJSON marshal json

func (*JsDuration) UnmarshalJSON added in v0.0.3 

func (i *JsDuration) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshal json

func (*JsDuration) UnmarshalTOML added in v0.0.3 

func (i *JsDuration) UnmarshalTOML(v interface{}) error

UnmarshalTOML unmarshal toml

type JsInt64 

type JsInt64 int64

JsInt64 json could not support large number use string to replace the number if a field is int64

func MapVal2JsInt64 

func MapVal2JsInt64(m map[string]interface{}, k string) JsInt64

MapVal2JsInt64 : 将map中的value转换为 json int64

func ToJsInt64 

func ToJsInt64(v interface{}) JsInt64

ToJsInt64 将基本类型转换为json int64整型

func (JsInt64) MarshalJSON 

func (i JsInt64) MarshalJSON() ([]byte, error)

MarshalJSON marshal json

func (*JsInt64) UnmarshalJSON 

func (i *JsInt64) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshal json

type JsUInt64 

type JsUInt64 uint64

JsUInt64 json could not support large number use string to replace the number if a field is uint64

func ToJsUInt64 added in v0.0.3 

func ToJsUInt64(v interface{}) JsUInt64

ToJsUInt64 将基本类型转换为json uint64整型

func (JsUInt64) MarshalJSON 

func (i JsUInt64) MarshalJSON() ([]byte, error)

MarshalJSON marshal json

func (*JsUInt64) UnmarshalJSON 

func (i *JsUInt64) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshal json

type ReaderX 

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

ReaderX buffer implement

func NewReaderX 

func NewReaderX(reader io.Reader) *ReaderX

NewReaderX new with io.reader

func (*ReaderX) Read 

func (b *ReaderX) Read(p []byte) error

Read : read to a buffer

func (*ReaderX) ReadBool 

func (b *ReaderX) ReadBool() (bool, error)

ReadBool read a bool

func (*ReaderX) ReadByte 

func (b *ReaderX) ReadByte() (byte, error)

ReadByte read a byte

func (*ReaderX) ReadF64 

func (b *ReaderX) ReadF64() (float64, error)

ReadF64 read float64

func (*ReaderX) ReadI16 

func (b *ReaderX) ReadI16() (int16, error)

ReadI16 read int16

func (*ReaderX) ReadI32 

func (b *ReaderX) ReadI32() (int32, error)

ReadI32 read int32

func (*ReaderX) ReadI64 

func (b *ReaderX) ReadI64() (int64, error)

ReadI64 read int64

func (*ReaderX) ReadLimitString 

func (b *ReaderX) ReadLimitString(limit uint32) (string, error)

ReadLimitString read limit size string

func (*ReaderX) ReadN 

func (b *ReaderX) ReadN(n int) ([]byte, error)

ReadN read n length buffer

func (*ReaderX) ReadString 

func (b *ReaderX) ReadString() (string, error)

ReadString read string

func (*ReaderX) ReadU16 

func (b *ReaderX) ReadU16() (uint16, error)

ReadU16 read uint16

func (*ReaderX) ReadU32 

func (b *ReaderX) ReadU32() (uint32, error)

ReadU32 read uint32

func (*ReaderX) ReadU64 

func (b *ReaderX) ReadU64() (uint64, error)

ReadU64 read uint64

func (*ReaderX) ZReadN 

func (b *ReaderX) ZReadN(n int) ([]byte, error)

ZReadN read n length buffer - no copy

type U64BitMap 

type U64BitMap uint64

func (U64BitMap) Bytes 

func (b U64BitMap) Bytes() []byte

func (*U64BitMap) FromBytes 

func (b *U64BitMap) FromBytes(buf []byte)

func (U64BitMap) Full 

func (b U64BitMap) Full() bool

func (U64BitMap) Left 

func (b U64BitMap) Left() []byte

func (U64BitMap) LeftX 

func (b U64BitMap) LeftX(plus byte) []byte

func (U64BitMap) Len 

func (b U64BitMap) Len() int

func (U64BitMap) ReverseLen 

func (b U64BitMap) ReverseLen() int

func (*U64BitMap) Set 

func (b *U64BitMap) Set(i byte)

func (U64BitMap) Values 

func (b U64BitMap) Values() []byte

func (U64BitMap) ValuesX 

func (b U64BitMap) ValuesX(plus byte) []byte

type U128BitMap 

type U128BitMap struct {
	Low  U64BitMap
	High U64BitMap
}

U128BitMap use 2 uint64 Low and High

func (*U128BitMap) Bytes 

func (u *U128BitMap) Bytes() []byte

func (*U128BitMap) FromBytes 

func (u *U128BitMap) FromBytes(buf []byte)

func (*U128BitMap) Full 

func (u *U128BitMap) Full() bool

func (*U128BitMap) Left 

func (u *U128BitMap) Left() []byte

func (*U128BitMap) Len 

func (u *U128BitMap) Len() int

func (*U128BitMap) ReverseLen 

func (u *U128BitMap) ReverseLen() int

func (*U128BitMap) Set 

func (u *U128BitMap) Set(i byte)

func (*U128BitMap) Values 

func (u *U128BitMap) Values() []byte

type Unix2Time 

type Unix2Time time.Time

Unix2Time 秒时间戳时间

func (*Unix2Time) Scan 

func (s *Unix2Time) Scan(value interface{}) error

Scan : sql scan

func (Unix2Time) Value 

func (s Unix2Time) Value() (driver.Value, error)

Value : sql value

type UnixNano2Time 

type UnixNano2Time time.Time

UnixNano2Time 纳秒时间戳时间

func (*UnixNano2Time) Scan 

func (s *UnixNano2Time) Scan(value interface{}) error

Scan : sql scan

func (UnixNano2Time) Value 

func (s UnixNano2Time) Value() (driver.Value, error)

Value : sql value

type UnixStamp 

type UnixStamp int64

UnixStamp 时间转成秒(只需要秒/Database中的datetime)

func (UnixStamp) MarshalJSON 

func (i UnixStamp) MarshalJSON() ([]byte, error)

MarshalJSON marshal json

func (*UnixStamp) Scan 

func (i *UnixStamp) Scan(value interface{}) error

Scan : sql scan

func (*UnixStamp) UnmarshalJSON 

func (i *UnixStamp) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshal json

func (UnixStamp) Value 

func (i UnixStamp) Value() (driver.Value, error)

Value : sql value

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.