mirror-seaweedfs/weed/storage/needle/needle_write_v3.go

package needle

import (
	"bytes"

	. "github.com/seaweedfs/seaweedfs/weed/storage/types"
	"github.com/seaweedfs/seaweedfs/weed/util"
)

func writeNeedleV3(n *Needle, offset uint64, bytesBuffer *bytes.Buffer) (size Size, actualSize int64, err error) {
	return writeNeedleCommon(n, offset, bytesBuffer, Version3, func(n *Needle, header []byte, bytesBuffer *bytes.Buffer, padding int) {
		util.Uint32toBytes(header[0:NeedleChecksumSize], uint32(n.Checksum))
		util.Uint64toBytes(header[NeedleChecksumSize:NeedleChecksumSize+TimestampSize], n.AppendAtNs)
		bytesBuffer.Write(header[0 : NeedleChecksumSize+TimestampSize+padding])
	})
}