Method put

tx.go:602–629

put sets the value for a key in the bucket. Returns an error if tx is closed, if performing a write operation on a read-only transaction, if the key is empty.

(bucket string, key, value []byte, ttl uint32, flag uint16, timestamp uint64, ds uint16)

// put sets the value for a key in the bucket.
// Returns an error if tx is closed, if performing a write operation on a read-only transaction, if the key is empty.
func (tx *Tx) put(bucket string, key, value []byte, ttl uint32, flag uint16, timestamp uint64, ds uint16) (err error) {
	if err := tx.checkTxIsClosed(); err != nil {
		return err
	}

	bucketStatus, b := tx.getBucketAndItsStatus(ds, bucket)
	if isBucketNotFoundStatus(bucketStatus) {
		return ErrBucketNotFound
	}

	if !tx.writable {
		return ErrTxNotWritable
	}
	bucketId := b.Id

	meta := core.NewMetaData().WithTimeStamp(timestamp).WithKeySize(uint32(len(key))).WithValueSize(uint32(len(value))).WithFlag(flag).
		WithTTL(ttl).WithStatus(UnCommitted).WithDs(ds).WithTxID(tx.id).WithBucketId(bucketId)

	e := core.NewEntry().WithKey(key).WithMeta(meta).WithValue(value)

	err = e.Valid()
	if err != nil {
		return err
	}
	tx.submitEntry(ds, bucket, e)
	tx.size += e.Size()
	return nil
}

// setStatusCommitting will change the tx status to txStatusCommitting
func (tx *Tx) setStatusCommitting() {