pointsdecoder

func (*DecoderWork) DecodeDBPT ¶

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

DecodeDBPT decodes the data for [db, rp, ptId]

func (*DecoderWork) DecodePoints ¶

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

DecodePoints decodes the network data reqBuf to Points. DecoderWork is a reuse object.

func (*DecoderWork) DecodeShardAndRows ¶

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

DecodeShardAndRows decodes the tail from [shardId] to [...rows]

func (*DecoderWork) GetLogger ¶

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

func (*DecoderWork) GetRows ¶

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

func (*DecoderWork) PutWritePointsWork ¶

func (ww *DecoderWork) PutWritePointsWork()

func (*DecoderWork) SetReqBuf ¶

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

func (*DecoderWork) SetRows ¶

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

func (*DecoderWork) SetStreamVars ¶

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