pointsdecoder

Apr 12, 2025

Changes in this version

type DecoderWork

+ func (ww *DecoderWork) Ref()

+ func (ww *DecoderWork) UnRef() int64

Nov 12, 2024

Changes in this version

+ func PutDecoderWork(ww *DecoderWork)

+ type DecoderWork struct

+ func GetDecoderWork() *DecoderWork

+ func (ww *DecoderWork) DecodeDBPT() (db string, rp string, ptId uint32, tail []byte, err error)

+ func (ww *DecoderWork) DecodePoints() (db string, rp string, ptId uint32, shard uint64, streamShardIdList []uint64, ...)

+ func (ww *DecoderWork) DecodeShardAndRows(db string, rp string, ptId uint32, tail []byte) (shard uint64, streamShardIdList []uint64, binaryRows []byte, err error)

+ func (ww *DecoderWork) GetLogger() *logger.Logger

+ func (ww *DecoderWork) GetRows() []influx.Row

+ func (ww *DecoderWork) PutWritePointsWork()

+ func (ww *DecoderWork) SetReqBuf(buff []byte)

+ func (ww *DecoderWork) SetRows(rows []influx.Row)

+ func (ww *DecoderWork) SetStreamVars(vars []*netstorage.StreamVar)