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

package needle

import (
	"bytes"
	"fmt"

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

func writeNeedleByVersion(version Version, n *Needle, offset uint64, bytesBuffer *bytes.Buffer) (size Size, actualSize int64, err error) {
	// Switch logic moved from needle_write.go
	switch version {
	case Version1:
		size, actualSize, err = writeNeedleV1(n, offset, bytesBuffer)
	case Version2:
		size, actualSize, err = writeNeedleV2(n, offset, bytesBuffer)
	case Version3:
		size, actualSize, err = writeNeedleV3(n, offset, bytesBuffer)
	default:
		err = fmt.Errorf("unsupported version: %d", version)
	}
	return
}