Documentation ¶
Index ¶
- func AlignToBigger(x uint64, align uint64) uint64
- func AlignToSmaller(x uint64, align uint64) uint64
- func BytesBeforeFirstSub(s []byte, subString []byte) (b []byte)
- func Clone(b []byte) []byte
- func CutToMaxLen(b []byte, l int) []byte
- func DecodeStringListLenUvarint(b []byte) ([]string, bool)
- func EncodeStringListLenUvarint(sList []string) (b []byte)
- func FillZero(b []byte)
- func GetUvarintOutputSize(x uint64) int
- func GetVarintOutputSize(x int64) int
- func IsAllZero(b []byte) bool
- func ReadCStringFromBuf(b []byte) string
- func ReadCStringFromBufToByte(b []byte) []byte
- func ReadUvarint(buf []byte) (uint64, int)
- func ReadableAlphaNumFromBinary(b []byte, originLen int) string
- func ReadableAlphaNumToBinaryOrOriginToSlice(id string) []byte
- func ReadableAlphaNumToBinaryOrOriginToWriter(id string, bufWriter *BufWriter)
- func SliceAddLittleEndianFixLen(b []byte, toAdd uint64)
- func SplitTwoBetweenFirst(s []byte, subString []byte) (before []byte, after []byte)
- func Uint64ToBigEndSlice(i uint64) []byte
- func WriteUvarint(buf []byte, x uint64) int
- type BufReader
- func (r *BufReader) AddPos(rel int)
- func (r *BufReader) Close() (err error)
- func (r *BufReader) GetBuf() []byte
- func (r *BufReader) GetNextLine() []byte
- func (r *BufReader) GetPos() int
- func (r *BufReader) GetRemainSize() int
- func (r *BufReader) IsEof() bool
- func (r *BufReader) IsMatchPrefix(toMatch []byte) bool
- func (r *BufReader) IsNextLineContains(toMatch []byte) bool
- func (r *BufReader) MustReadByte() (b byte)
- func (r *BufReader) MustReadByteSlice(num int) (s []byte)
- func (r *BufReader) MustReadLittleEndUint32() (x uint32)
- func (r *BufReader) PeekByte() (b byte, ok bool)
- func (r *BufReader) Read(inBuf []byte) (n int, err error)
- func (r *BufReader) ReadAt(inBuf []byte, off int64) (n int, err error)
- func (r *BufReader) ReadBigEndUint16() (x uint16, isOk bool)
- func (r *BufReader) ReadBigEndUint32() (x uint32, isOk bool)
- func (r *BufReader) ReadBigEndUint64() (x uint64, isOk bool)
- func (r *BufReader) ReadByte() (b byte, err error)
- func (r *BufReader) ReadByteOrEof() (b byte, isRead bool)
- func (r *BufReader) ReadByteSlice(num int) (s []byte, ok bool)
- func (r *BufReader) ReadCString() (s string)
- func (r *BufReader) ReadHttpHeaderWithCallback(fn func(name []byte, value []byte)) (errMsg string)
- func (r *BufReader) ReadLittleEndUint16() (x uint16, isOk bool)
- func (r *BufReader) ReadLittleEndUint32() (x uint32, isOk bool)
- func (r *BufReader) ReadLittleEndUint64() (x uint64, isOk bool)
- func (r *BufReader) ReadMaxByteNum(num int) []byte
- func (r *BufReader) ReadSpace() []byte
- func (r *BufReader) ReadString255() (s string, errMsg string)
- func (r *BufReader) ReadStringLenUint32() (s string, isOk bool)
- func (br *BufReader) ReadStringLenUvarint() (s string, isOk bool)
- func (br *BufReader) ReadStringListLenUvarint() (sList []string, isOk bool)
- func (r *BufReader) ReadToEof() []byte
- func (r *BufReader) ReadToLineEnd() []byte
- func (r *BufReader) ReadUtilFlag(flag []byte) []byte
- func (br *BufReader) ReadUvarint() (x uint64, isOk bool)
- func (br *BufReader) ReadVarint() (x int64, isOk bool)
- func (r *BufReader) ResetWithBuffer(buf []byte)
- func (r *BufReader) SetPos(pos int)
- type BufReaderWithOk
- func (buf *BufReaderWithOk) GetPos() int
- func (buf *BufReaderWithOk) GetRemainSize() int
- func (buf *BufReaderWithOk) IsEof() bool
- func (buf *BufReaderWithOk) IsOk() bool
- func (buf *BufReaderWithOk) ReadBigEndUint16() (x uint16)
- func (buf *BufReaderWithOk) ReadLittleEndUint16() (x uint16)
- func (buf *BufReaderWithOk) ReadLittleEndUint32() (x uint32)
- func (buf *BufReaderWithOk) ReadLittleEndUint64() (x uint64)
- func (buf *BufReaderWithOk) ReadSliceBySize(size int) []byte
- func (buf *BufReaderWithOk) ReadStringLenUvarint() string
- func (buf *BufReaderWithOk) ReadUvarint() (x uint64)
- type BufWriter
- func (w *BufWriter) AddPos(offset int)
- func (w *BufWriter) GetAllocNoUseBuf() []byte
- func (w *BufWriter) GetBytes() []byte
- func (w *BufWriter) GetBytesClone() []byte
- func (w *BufWriter) GetCap() int
- func (w *BufWriter) GetHeadBuffer(size int) []byte
- func (w BufWriter) GetLastByte() (b byte, ok bool)
- func (w *BufWriter) GetLen() int
- func (w *BufWriter) GetPos() int
- func (w *BufWriter) GetString() string
- func (w *BufWriter) MustWriteString255(s string)
- func (w *BufWriter) ReadFrom(r io.Reader) (n int64, err error)
- func (w *BufWriter) Reset()
- func (w *BufWriter) ResetWithBuffer(buf []byte)
- func (w *BufWriter) SetPos(pos int)
- func (w *BufWriter) TrimSuffixOneByte(b byte)
- func (w *BufWriter) TrimSuffixSpace()
- func (w *BufWriter) TryGrow(toWrite int)
- func (w *BufWriter) Write(p []byte) (n int, err error)
- func (w *BufWriter) WriteBigEndUint16(v uint16)
- func (w *BufWriter) WriteBigEndUint32(v uint32)
- func (w *BufWriter) WriteBigEndUint64(v uint64)
- func (w *BufWriter) WriteBool(b bool)
- func (w *BufWriter) WriteByte(b uint8) error
- func (w *BufWriter) WriteByteBySize(size int, b byte)
- func (w *BufWriter) WriteByte_(b uint8)
- func (w *BufWriter) WriteLittleEndFloat32(f float32)
- func (w *BufWriter) WriteLittleEndFloat64(f float64)
- func (w *BufWriter) WriteLittleEndUint16(v uint16)
- func (w *BufWriter) WriteLittleEndUint32(v uint32)
- func (w *BufWriter) WriteLittleEndUint64(v uint64)
- func (w *BufWriter) WriteString(p string) (n int, err error)
- func (bw *BufWriter) WriteStringLenUvarint(s string)
- func (bw *BufWriter) WriteStringListLenUvarint(sList []string)
- func (w *BufWriter) WriteString_(s string)
- func (bw *BufWriter) WriteUvarint(x uint64)
- func (bw *BufWriter) WriteVarint(x int64)
- func (w *BufWriter) WriteZeroByteBySize(size int)
- func (w *BufWriter) Write_(p []byte)
- type BufWriterPool
- type LimitedBuffer
- type LockerBufReadWriter
- type QueueByteSlice
- type QueueInt
- type ReadBufferWrap
- func (crb *ReadBufferWrap) ReadBySize(need int) (b []byte, errMsg string)
- func (crb *ReadBufferWrap) ReadByteErrMsg() (b byte, errMsg string)
- func (crb *ReadBufferWrap) ReadLittleEndUint64() (x uint64, errMsg string)
- func (crb *ReadBufferWrap) ReadStringLenUvarint() (s string, errMsg string)
- func (crb *ReadBufferWrap) ReadUvarint() (x uint64, errMsg string)
- type ReadCopyFromPosResponse
- type ReadUtilRequest
- type ReadUtilResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AlignToBigger ¶
func AlignToSmaller ¶
func BytesBeforeFirstSub ¶
func CutToMaxLen ¶
func GetUvarintOutputSize ¶
func GetVarintOutputSize ¶
func ReadCStringFromBuf ¶
func ReadUvarint ¶
func SplitTwoBetweenFirst ¶
func Uint64ToBigEndSlice ¶
func WriteUvarint ¶
Types ¶
type BufReader ¶
type BufReader struct {
// contains filtered or unexported fields
}
func NewBufReader ¶
func (*BufReader) GetNextLine ¶
func (*BufReader) GetRemainSize ¶
func (*BufReader) IsMatchPrefix ¶
func (*BufReader) IsNextLineContains ¶
func (*BufReader) MustReadByte ¶
func (*BufReader) MustReadByteSlice ¶
func (*BufReader) MustReadLittleEndUint32 ¶
func (*BufReader) ReadBigEndUint16 ¶
func (*BufReader) ReadBigEndUint32 ¶
func (*BufReader) ReadBigEndUint64 ¶
func (*BufReader) ReadByteOrEof ¶
func (*BufReader) ReadCString ¶
func (*BufReader) ReadHttpHeaderWithCallback ¶
func (*BufReader) ReadLittleEndUint16 ¶
func (*BufReader) ReadLittleEndUint32 ¶
func (*BufReader) ReadLittleEndUint64 ¶
func (*BufReader) ReadMaxByteNum ¶
func (*BufReader) ReadString255 ¶
func (*BufReader) ReadStringLenUint32 ¶
func (*BufReader) ReadStringLenUvarint ¶
func (*BufReader) ReadStringListLenUvarint ¶
func (*BufReader) ReadToLineEnd ¶
func (*BufReader) ReadUtilFlag ¶
func (*BufReader) ReadUvarint ¶
func (*BufReader) ReadVarint ¶
func (*BufReader) ResetWithBuffer ¶
type BufReaderWithOk ¶
type BufReaderWithOk struct {
// contains filtered or unexported fields
}
func NewBufReaderWithOk ¶
func NewBufReaderWithOk(buf []byte) *BufReaderWithOk
func (*BufReaderWithOk) GetPos ¶
func (buf *BufReaderWithOk) GetPos() int
func (*BufReaderWithOk) GetRemainSize ¶
func (buf *BufReaderWithOk) GetRemainSize() int
func (*BufReaderWithOk) IsEof ¶
func (buf *BufReaderWithOk) IsEof() bool
func (*BufReaderWithOk) IsOk ¶
func (buf *BufReaderWithOk) IsOk() bool
func (*BufReaderWithOk) ReadBigEndUint16 ¶
func (buf *BufReaderWithOk) ReadBigEndUint16() (x uint16)
func (*BufReaderWithOk) ReadLittleEndUint16 ¶
func (buf *BufReaderWithOk) ReadLittleEndUint16() (x uint16)
func (*BufReaderWithOk) ReadLittleEndUint32 ¶
func (buf *BufReaderWithOk) ReadLittleEndUint32() (x uint32)
func (*BufReaderWithOk) ReadLittleEndUint64 ¶
func (buf *BufReaderWithOk) ReadLittleEndUint64() (x uint64)
func (*BufReaderWithOk) ReadSliceBySize ¶
func (buf *BufReaderWithOk) ReadSliceBySize(size int) []byte
func (*BufReaderWithOk) ReadStringLenUvarint ¶
func (buf *BufReaderWithOk) ReadStringLenUvarint() string
func (*BufReaderWithOk) ReadUvarint ¶
func (buf *BufReaderWithOk) ReadUvarint() (x uint64)
type BufWriter ¶
type BufWriter struct {
// contains filtered or unexported fields
}
func NewBufWriter ¶
func NewBufWriterString ¶
func ResetBufWriter ¶
func (*BufWriter) GetAllocNoUseBuf ¶
func (*BufWriter) GetBytesClone ¶
func (*BufWriter) GetHeadBuffer ¶
func (BufWriter) GetLastByte ¶
func (*BufWriter) MustWriteString255 ¶
func (*BufWriter) ResetWithBuffer ¶
func (*BufWriter) TrimSuffixOneByte ¶
func (*BufWriter) TrimSuffixSpace ¶
func (w *BufWriter) TrimSuffixSpace()
func (*BufWriter) WriteBigEndUint16 ¶
func (*BufWriter) WriteBigEndUint32 ¶
func (*BufWriter) WriteBigEndUint64 ¶
func (*BufWriter) WriteByteBySize ¶
func (*BufWriter) WriteByte_ ¶
func (*BufWriter) WriteLittleEndFloat32 ¶
func (*BufWriter) WriteLittleEndFloat64 ¶
func (*BufWriter) WriteLittleEndUint16 ¶
func (*BufWriter) WriteLittleEndUint32 ¶
func (*BufWriter) WriteLittleEndUint64 ¶
func (*BufWriter) WriteStringLenUvarint ¶
func (*BufWriter) WriteStringListLenUvarint ¶
func (*BufWriter) WriteString_ ¶
func (*BufWriter) WriteUvarint ¶
func (*BufWriter) WriteVarint ¶
func (*BufWriter) WriteZeroByteBySize ¶
type BufWriterPool ¶
type BufWriterPool struct {
// contains filtered or unexported fields
}
func (*BufWriterPool) Get ¶
func (pool *BufWriterPool) Get() *BufWriter
func (*BufWriterPool) GetAndCloneFromByteSlice ¶
func (pool *BufWriterPool) GetAndCloneFromByteSlice(buf []byte) *BufWriter
func (*BufWriterPool) Put ¶
func (pool *BufWriterPool) Put(w *BufWriter)
type LimitedBuffer ¶
type LimitedBuffer struct {
// contains filtered or unexported fields
}
func NewLimitedBuffer ¶
func NewLimitedBuffer(maxSizeInBytes int) *LimitedBuffer
func (*LimitedBuffer) Add ¶
func (buffer *LimitedBuffer) Add(data string)
func (*LimitedBuffer) AddBytes ¶
func (buffer *LimitedBuffer) AddBytes(bytesData []byte)
func (*LimitedBuffer) AddLine ¶
func (buffer *LimitedBuffer) AddLine(data string)
func (*LimitedBuffer) Reset ¶
func (buffer *LimitedBuffer) Reset()
func (*LimitedBuffer) ToString ¶
func (buffer *LimitedBuffer) ToString() string
type LockerBufReadWriter ¶
type LockerBufReadWriter struct {
// contains filtered or unexported fields
}
func (*LockerBufReadWriter) SetReadPos ¶
func (buf *LockerBufReadWriter) SetReadPos(toCutReadPos int) (errMsg string)
func (*LockerBufReadWriter) TryReadCopyFromPos ¶
func (buf *LockerBufReadWriter) TryReadCopyFromPos(readPos int) (resp ReadCopyFromPosResponse)
type QueueByteSlice ¶
type QueueByteSlice struct {
// contains filtered or unexported fields
}
func (*QueueByteSlice) AddOne ¶
func (rb *QueueByteSlice) AddOne(b []byte)
func (*QueueByteSlice) GetOne ¶
func (rb *QueueByteSlice) GetOne() []byte
func (*QueueByteSlice) HasData ¶
func (rb *QueueByteSlice) HasData() bool
func (*QueueByteSlice) Init ¶
func (rb *QueueByteSlice) Init()
func (*QueueByteSlice) RemoveOne ¶
func (rb *QueueByteSlice) RemoveOne()
type ReadBufferWrap ¶
func (*ReadBufferWrap) ReadBySize ¶
func (crb *ReadBufferWrap) ReadBySize(need int) (b []byte, errMsg string)
func (*ReadBufferWrap) ReadByteErrMsg ¶
func (crb *ReadBufferWrap) ReadByteErrMsg() (b byte, errMsg string)
func (*ReadBufferWrap) ReadLittleEndUint64 ¶
func (crb *ReadBufferWrap) ReadLittleEndUint64() (x uint64, errMsg string)
func (*ReadBufferWrap) ReadStringLenUvarint ¶
func (crb *ReadBufferWrap) ReadStringLenUvarint() (s string, errMsg string)
func (*ReadBufferWrap) ReadUvarint ¶
func (crb *ReadBufferWrap) ReadUvarint() (x uint64, errMsg string)
type ReadCopyFromPosResponse ¶
type ReadUtilResponse ¶
func ReadUtil ¶
func ReadUtil(req ReadUtilRequest) (resp ReadUtilResponse)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.