Documentation ¶
Overview ¶
Package reedsolomon 提供Go语言的纠删码功能
使用方法和示例请参考 https://github.com/klauspost/reedsolomon
Package reedsolomon 实现了Reed-Solomon编码算法
Index ¶
- Variables
- func AllocAligned(shards, each int) [][]byte
- func StreamDecodeFile(originalFilePath string, dataShards, parityShards int) (string, error)
- func StreamEncodeWithFiles(r io.Reader, dataShards, parityShards int, size int64) (dataFiles, parityFiles []*os.File, err error)
- type Encoder
- type Extensions
- type FileEncoder
- type Option
- func WithAVX2(enabled bool) Option
- func WithAVX512(enabled bool) Option
- func WithAVXGFNI(enabled bool) Option
- func WithAutoGoroutines(shardSize int) Option
- func WithCauchyMatrix() Option
- func WithConcurrentStreamReads(enabled bool) Option
- func WithConcurrentStreamWrites(enabled bool) Option
- func WithConcurrentStreams(enabled bool) Option
- func WithCustomMatrix(customMatrix [][]byte) Option
- func WithFastOneParityMatrix() Option
- func WithGFNI(enabled bool) Option
- func WithInversionCache(enabled bool) Option
- func WithJerasureMatrix() Option
- func WithLeopardGF(enabled bool) Option
- func WithLeopardGF16(enabled bool) Option
- func WithMaxGoroutines(n int) Option
- func WithMinSplitSize(n int) Option
- func WithPAR1Matrix() Option
- func WithSSE2(enabled bool) Option
- func WithSSSE3(enabled bool) Option
- func WithStreamBlockSize(n int) Option
- type StreamEncoder
- type StreamReadError
- type StreamWriteError
Examples ¶
Constants ¶
This section is empty.
Variables ¶
var ErrInvShardNum = errors.New("cannot create Encoder with less than one data shard or less than zero parity shards")
ErrInvShardNum 在以下情况下由 New() 函数返回: - 尝试创建数据分片数小于1的编码器 - 尝试创建奇偶校验分片数小于0的编码器 说明: - 数据分片数必须大于等于1,因为至少需要1个数据分片来存储原始数据 - 奇偶校验分片数必须大于等于0,表示可以不使用纠错功能
var ErrInvalidInput = errors.New("invalid input")
ErrInvalidInput 当Update函数的输入参数无效时返回此错误
var ErrInvalidShardSize = errors.New("分片大小无效")
ErrInvalidShardSize 在分片长度不满足要求时返回, 通常要求分片长度是N的倍数
var ErrMaxShardNum = errors.New("cannot create Encoder with more than 256 data+parity shards")
ErrMaxShardNum 在以下情况下由 New() 函数返回: - 尝试创建数据分片数+奇偶校验分片数超过256的编码器 说明: - 由于使用GF(2^8)有限域,分片总数不能超过2^8=256 - 这是Reed-Solomon编码的数学特性决定的限制
var ErrNotSupported = errors.New("operation not supported")
ErrNotSupported 在操作不被支持时返回 说明: - 当尝试执行编码器不支持的操作时返回此错误 - 例如在不支持的平台上使用特定的SIMD优化
var ErrReconstructMismatch = errors.New("valid shards and fill shards are mutually exclusive")
ErrReconstructMismatch 当在同一个索引位置同时提供了"valid"和"fill"流时返回此错误 这种情况下无法判断是将该分片视为有效还是需要重建
var ErrReconstructRequired = errors.New("需要重建,因为一个或多个必需的数据分片为空")
ErrReconstructRequired 在数据分片不完整需要重建时返回 当一个或多个必需的数据分片为空时,需要先进行重建才能成功合并分片
var ErrShardNoData = errors.New("没有分片数据")
ErrShardNoData 在以下情况下返回: - 没有分片数据 - 所有分片的长度都为0
var ErrShardSize = errors.New("分片大小不一致")
ErrShardSize 在分片长度不一致时返回
var ErrShortData = errors.New("数据不足以填充请求的分片数量")
ErrShortData 当数据不足以填充所需分片数量时,Split()函数将返回此错误
var ErrTooFewShards = errors.New("too few shards given")
ErrTooFewShards 在以下情况下返回: - 传入Encode/Verify/Reconstruct/Update的分片数量不足 - 在Reconstruct中,可用分片数量不足以重建丢失的数据
Functions ¶
func AllocAligned ¶
AllocAligned allocates 'shards' slices, with 'each' bytes. Each slice will start on a 64 byte aligned boundary.
func StreamDecodeFile ¶
StreamDecodeFile 从分片文件中解码并恢复原始文件 参数:
- originalFilePath: 原始文件路径
- dataShards: 数据分片数量
- parityShards: 校验分片数量
返回值:
- string: 解码后的文件路径
- error: 错误信息
func StreamEncodeWithFiles ¶
func StreamEncodeWithFiles(r io.Reader, dataShards, parityShards int, size int64) (dataFiles, parityFiles []*os.File, err error)
StreamEncodeWithFiles 对输入流进行Reed-Solomon编码,并将结果写入临时文件 参数:
- r: 输入数据的读取器
- dataShards: 数据分片的数量
- parityShards: 奇偶校验分片的数量
- size: 输入数据的总大小
返回值:
- dataFiles: 数据分片的临时文件切片
- parityFiles: 奇偶校验分片的临时文件切片
- err: 编码过程中的错误,如果成功则为nil
Types ¶
type Encoder ¶
type Encoder interface { // Encode 为一组数据分片生成奇偶校验 // 参数: // - shards: 包含数据分片和奇偶校验分片的切片数组 // 返回值: // - error: 编码过程中的错误信息 // 说明: // - 分片数量必须与New()函数指定的数量匹配 // - 每个分片都是字节数组,且大小必须相同 // - 奇偶校验分片会被覆盖,数据分片保持不变 // - 在编码过程中可以安全地读取数据分片 Encode(shards [][]byte) error // EncodeIdx 为单个数据分片添加奇偶校验 // 参数: // - dataShard: 数据分片 // - idx: 分片索引 // - parity: 奇偶校验分片数组 // 返回值: // - error: 编码过程中的错误信息 // 说明: // - 奇偶校验分片初始值应为0,调用者必须将其置零 // - 数据分片必须只传递一次,不会对此进行检查 // - 奇偶校验分片会被更新,数据分片保持不变 EncodeIdx(dataShard []byte, idx int, parity [][]byte) error // Verify 验证奇偶校验分片是否包含正确的数据 // 参数: // - shards: 包含数据分片和奇偶校验分片的切片数组 // 返回值: // - bool: 验证是否通过 // - error: 验证过程中的错误信息 // 说明: // - 数据格式与Encode相同 // - 不会修改任何数据,可以在验证过程中安全读取 Verify(shards [][]byte) (bool, error) // Reconstruct 尝试重建丢失的分片 // 参数: // - shards: 包含部分数据的分片数组 // 返回值: // - error: 重建过程中的错误信息 // 说明: // - 数组长度必须等于分片总数 // - 通过将分片设置为nil或零长度来表示丢失的分片 // - 如果分片容量足够,将使用现有内存,否则分配新内存 // - 如果可用分片太少,将返回ErrTooFewShards错误 // - 重建后的分片集合是完整的,但未验证完整性 Reconstruct(shards [][]byte) error // ReconstructData 仅重建丢失的数据分片 // 参数: // - shards: 包含部分数据的分片数组 // 返回值: // - error: 重建过程中的错误信息 // 说明: // - 数组长度必须等于分片数 // - 通过将分片设置为nil或零长度来表示丢失的分片 // - 如果分片容量足够,将使用现有内存,否则分配新内存 // - 如果可用分片太少,将返回ErrTooFewShards错误 // - 由于重建后可能缺少奇偶校验分片,验证可能会失败 ReconstructData(shards [][]byte) error // ReconstructSome 仅重建指定的分片 // 参数: // - shards: 包含部分数据的分片数组 // - required: 指示需要重建的分片的布尔数组 // 返回值: // - error: 重建过程中的错误信息 // 说明: // - required数组长度必须等于分片总数或数据分片数 // - 如果长度等于数据分片数,将忽略奇偶校验分片的重建 // - shards数组长度必须等于分片总数 ReconstructSome(shards [][]byte, required []bool) error // Update 用于更新部分数据分片并重新计算奇偶校验 // 参数: // - shards: 包含旧数据分片和旧奇偶校验分片的数组 // - newDatashards: 更改后的数据分片数组 // 返回值: // - error: 更新过程中的错误信息 // 说明: // - 新的奇偶校验分片将存储在shards[DataShards:]中 // - 当数据分片远多于奇偶校验分片且变更较少时,此方法比Encode更快 Update(shards [][]byte, newDatashards [][]byte) error // Split 将数据切片分割成指定数量的分片 // 参数: // - data: 要分割的数据 // 返回值: // - [][]byte: 分割后的分片数组 // - error: 分割过程中的错误信息 // 说明: // - 数据将被均匀分割 // - 如果数据大小不能被分片数整除,最后一个分片将补零 // - 如果提供的数据切片有额外容量,将用于分配奇偶校验分片 Split(data []byte) ([][]byte, error) // Join 将分片合并并写入目标 // 参数: // - dst: 写入目标 // - shards: 分片数组 // - outSize: 期望的输出大小 // 返回值: // - error: 合并过程中的错误信息 // 说明: // - 仅考虑数据分片 // - 必须提供准确的输出大小 // - 如果分片数量不足,将返回ErrTooFewShards错误 // - 如果总数据大小小于outSize,将返回ErrShortData错误 Join(dst io.Writer, shards [][]byte, outSize int) error }
Encoder 是用于对数据进行Reed-Solomon奇偶校验编码的接口
Example ¶
ExampleEncoder 演示了如何使用编码器的所有功能 注意:为了保持简洁,所有错误检查都已被移除
package main import ( "fmt" "math/rand" "github.com/bpfs/defs/v2/reedsolomon" ) // fillRandom 用随机数据填充字节切片 // 参数: // - p: 要填充的字节切片 func fillRandom(p []byte) { for i := 0; i < len(p); i += 7 { val := rand.Int63() for j := 0; i+j < len(p) && j < 7; j++ { p[i+j] = byte(val) val >>= 8 } } } func main() { // 创建一些示例数据 var data = make([]byte, 250000) fillRandom(data) // 创建一个具有17个数据分片和3个奇偶校验分片的编码器 enc, _ := reedsolomon.New(17, 3) // 将数据分割成分片 shards, _ := enc.Split(data) // 编码奇偶校验集 _ = enc.Encode(shards) // 验证奇偶校验集 ok, _ := enc.Verify(shards) if ok { fmt.Println("ok") } // 删除两个分片 shards[10], shards[11] = nil, nil // 重建分片 _ = enc.Reconstruct(shards) // 验证数据集 ok, _ = enc.Verify(shards) if ok { fmt.Println("ok") } }
Output: ok ok
Example (Slicing) ¶
ExampleEncoder_slicing 演示了分片可以被任意切片和合并,并且仍然保持有效
package main import ( "fmt" "math/rand" "github.com/bpfs/defs/v2/reedsolomon" ) // fillRandom 用随机数据填充字节切片 // 参数: // - p: 要填充的字节切片 func fillRandom(p []byte) { for i := 0; i < len(p); i += 7 { val := rand.Int63() for j := 0; i+j < len(p) && j < 7; j++ { p[i+j] = byte(val) val >>= 8 } } } func main() { // 创建一些示例数据 var data = make([]byte, 250000) fillRandom(data) // 创建5个各包含50000个元素的数据分片 enc, _ := reedsolomon.New(5, 3) shards, _ := enc.Split(data) err := enc.Encode(shards) if err != nil { panic(err) } // 检查是否验证通过 ok, err := enc.Verify(shards) if ok && err == nil { fmt.Println("encode ok") } // 将50000个元素的数据集分割成两个25000个元素的集合 splitA := make([][]byte, 8) splitB := make([][]byte, 8) // 合并成一个100000个元素的集合 merged := make([][]byte, 8) // 分割/合并分片 for i := range shards { splitA[i] = shards[i][:25000] splitB[i] = shards[i][25000:] // 将其与自身连接 merged[i] = append(make([]byte, 0, len(shards[i])*2), shards[i]...) merged[i] = append(merged[i], shards[i]...) } // 每个部分应该仍然验证为ok ok, err = enc.Verify(shards) if ok && err == nil { fmt.Println("splitA ok") } ok, err = enc.Verify(splitB) if ok && err == nil { fmt.Println("splitB ok") } ok, err = enc.Verify(merged) if ok && err == nil { fmt.Println("merge ok") } }
Output: encode ok splitA ok splitB ok merge ok
Example (Xor) ¶
ExampleEncoder_xor 演示了分片可以进行异或操作并且仍然保持有效集合
每个分片中的第'n'个元素的异或值必须相同, 除非你与类似大小的编码分片集进行异或
package main import ( "fmt" "math/rand" "github.com/bpfs/defs/v2/reedsolomon" ) // fillRandom 用随机数据填充字节切片 // 参数: // - p: 要填充的字节切片 func fillRandom(p []byte) { for i := 0; i < len(p); i += 7 { val := rand.Int63() for j := 0; i+j < len(p) && j < 7; j++ { p[i+j] = byte(val) val >>= 8 } } } func main() { // 创建一些示例数据 var data = make([]byte, 25000) fillRandom(data) // 创建5个各包含5000个元素的数据分片 enc, _ := reedsolomon.New(5, 3) shards, _ := enc.Split(data) err := enc.Encode(shards) if err != nil { panic(err) } // 检查是否验证通过 ok, err := enc.Verify(shards) if !ok || err != nil { fmt.Println("falied initial verify", err) } // 创建一个异或后的集合 xored := make([][]byte, 8) // 我们按索引进行异或,所以你可以看到异或可以改变, // 但是它应该在你的分片中垂直保持恒定 for i := range shards { xored[i] = make([]byte, len(shards[i])) for j := range xored[i] { xored[i][j] = shards[i][j] ^ byte(j&0xff) } } // 每个部分应该仍然验证为ok ok, err = enc.Verify(xored) if ok && err == nil { fmt.Println("verified ok after xor") } }
Output: verified ok after xor
type Extensions ¶
type Extensions interface { // ShardSizeMultiple 返回分片大小必须是其倍数的值 ShardSizeMultiple() int // DataShards 返回数据分片的数量 DataShards() int // ParityShards 返回奇偶校验分片的数量 ParityShards() int // TotalShards 返回分片总数 TotalShards() int // AllocAligned 分配TotalShards数量的对齐内存切片 // 参数: // - each: 每个分片的大小 // 返回值: // - [][]byte: 分配的内存切片数组 AllocAligned(each int) [][]byte }
Extensions 是一个可选接口 所有返回的实例都将支持此接口
type FileEncoder ¶
type FileEncoder interface { // EncodeFile 对输入文件数组进行编码,生成校验分片文件 // 参数: // - shards: 输入文件数组,包含数据分片和校验分片 // 返回值: // - error: 编码失败时返回相应错误,成功返回nil // 说明: // - 分片数量必须与New()函数指定的数量匹配 // - 每个分片文件大小必须相同 // - 校验分片文件会被覆盖,数据分片文件保持不变 EncodeFile(shards []*os.File) error // VerifyFile 验证文件分片数据的完整性 // 参数: // - shards: 文件分片数组,包含数据分片和校验分片 // 返回值: // - bool: 验证通过返回true,否则返回false // - error: 验证过程中出现错误时返回相应错误,成功返回nil // 说明: // - 分片数量必须与New()函数指定的数量匹配 // - 每个分片件大小必须相同 // - 不会修改何数据 VerifyFile(shards []*os.File) (bool, error) // ReconstructFile 重建所有丢失的文件分片 // 参数: // - shards: 文件分片数组,包含数据分片和校验分片 // 返回值: // - error: 重建失败时返回相应错误,成功返回nil // 说明: // - 分片数量必须等于总分片数 // - 通过将分片设置为nil表示丢失的分片 // - 如果可用分片太少,将返回ErrTooFewShards错误 // - 重建后的分片集合是完整的,但未验证完整性 ReconstructFile(shards []*os.File) error // ReconstructDataFile 仅重建丢失的数据文件分片 // 参数: // - shards: 文件分片数组,包含数据分片和校验分片 // 返回值: // - error: 重建失败时返回相应错误,成功返回nil // 说明: // - 只重建数据分片,不重建校验分片 // - 其他说明同ReconstructFile ReconstructDataFile(shards []*os.File) error // SplitFile 将输入文件分割成编码器指定数量的临时文件 // 参数: // - dataFile: 需要分割的输入文件 // 返回值: // - []*os.File: 分割后的临时文件数组 // - error: 分割失败时返回相应错误,成功返回nil // 说明: // - 文件将被分割成大小相等的分片 // - 如果文件大小不能被分片数整除,最后一个分片将补零 // - 使用系统临时目录存储分片文件 SplitFile(dataFile *os.File) ([]*os.File, error) // JoinFile 将文件分片合并到一个输出文件中 // 参数: // - dst: 输出文件 // - shards: 文件分片数组,包含数据分片和校验分片 // - outSize: 输出文件的大小 // 返回值: // - error: 合并失败时返回相应错误,成功返回nil // 说明: // - 只考虑数据分片 // - 必须提供准确的输出大小 // - 如果分片数量不足,将返回ErrTooFewShards错误 // - 如果总数据大小小于outSize,将返回ErrShortData错误 JoinFile(dst *os.File, shards []*os.File, outSize int) error }
FileEncoder 提供基于文件的Reed-Solomon编解码功能 用于处理大文件的流式编码和解码
type Option ¶
type Option func(*options)
Option allows to override processing parameters.
func WithAVX2 ¶
WithAVX2 allows to enable/disable AVX2 instructions. If not set, AVX will be turned on or off automatically based on CPU ID information. This will also disable AVX GFNI instructions.
func WithAVX512 ¶
WithAVX512 allows to enable/disable AVX512 (and GFNI) instructions.
func WithAVXGFNI ¶
WithAVXGFNI allows to enable/disable GFNI with AVX instructions. If not set, GFNI will be turned on or off automatically based on CPU ID information.
func WithAutoGoroutines ¶
WithAutoGoroutines will adjust the number of goroutines for optimal speed with a specific shard size. Send in the shard size you expect to send. Other shard sizes will work, but may not run at the optimal speed. Overwrites WithMaxGoroutines. If shardSize <= 0, it is ignored.
func WithCauchyMatrix ¶
func WithCauchyMatrix() Option
WithCauchyMatrix will make the encoder build a Cauchy style matrix. The output of this is not compatible with the standard output. A Cauchy matrix is faster to generate. This does not affect data throughput, but will result in slightly faster start-up time.
func WithConcurrentStreamReads ¶
WithConcurrentStreamReads will enable concurrent reads from the input streams. Default: Disabled, meaning only one stream will be read at the time. Ignored if not used on a stream input.
func WithConcurrentStreamWrites ¶
WithConcurrentStreamWrites will enable concurrent writes to the the output streams. Default: Disabled, meaning only one stream will be written at the time. Ignored if not used on a stream input.
func WithConcurrentStreams ¶
WithConcurrentStreams will enable concurrent reads and writes on the streams. Default: Disabled, meaning only one stream will be read/written at the time. Ignored if not used on a stream input.
func WithCustomMatrix ¶
WithCustomMatrix causes the encoder to use the manually specified matrix. customMatrix represents only the parity chunks. customMatrix must have at least ParityShards rows and DataShards columns. It can be used for interoperability with libraries which generate the matrix differently or to implement more complex coding schemes like LRC (locally reconstructible codes).
func WithFastOneParityMatrix ¶
func WithFastOneParityMatrix() Option
WithFastOneParityMatrix will switch the matrix to a simple xor if there is only one parity shard. The PAR1 matrix already has this property so it has little effect there.
func WithGFNI ¶
WithGFNI allows to enable/disable AVX512+GFNI instructions. If not set, GFNI will be turned on or off automatically based on CPU ID information.
func WithInversionCache ¶
WithInversionCache allows to control the inversion cache. This will cache reconstruction matrices so they can be reused. Enabled by default, or <= 64 shards for Leopard encoding.
func WithJerasureMatrix ¶
func WithJerasureMatrix() Option
WithJerasureMatrix causes the encoder to build the Reed-Solomon-Vandermonde matrix in the same way as done by the Jerasure library. The first row and column of the coding matrix only contains 1's in this method so the first parity chunk is always equal to XOR of all data chunks.
func WithLeopardGF ¶
WithLeopardGF will use leopard GF for encoding, even when there are fewer than 256 shards. This will likely improve reconstruction time for some setups. Note that Leopard places certain restrictions on use see other documentation.
func WithLeopardGF16 ¶
WithLeopardGF16 will always use leopard GF16 for encoding, even when there is less than 256 shards. This will likely improve reconstruction time for some setups. This is not compatible with Leopard output for <= 256 shards. Note that Leopard places certain restrictions on use see other documentation.
func WithMaxGoroutines ¶
WithMaxGoroutines is the maximum number of goroutines number for encoding & decoding. Jobs will be split into this many parts, unless each goroutine would have to process less than minSplitSize bytes (set with WithMinSplitSize). For the best speed, keep this well above the GOMAXPROCS number for more fine grained scheduling. If n <= 0, it is ignored.
func WithMinSplitSize ¶
WithMinSplitSize is the minimum encoding size in bytes per goroutine. By default this parameter is determined by CPU cache characteristics. See WithMaxGoroutines on how jobs are split. If n <= 0, it is ignored.
func WithPAR1Matrix ¶
func WithPAR1Matrix() Option
WithPAR1Matrix causes the encoder to build the matrix how PARv1 does. Note that the method they use is buggy, and may lead to cases where recovery is impossible, even if there are enough parity shards.
func WithSSE2 ¶
WithSSE2 allows to enable/disable SSE2 instructions. If not set, SSE2 will be turned on or off automatically based on CPU ID information.
func WithSSSE3 ¶
WithSSSE3 allows to enable/disable SSSE3 instructions. If not set, SSSE3 will be turned on or off automatically based on CPU ID information.
func WithStreamBlockSize ¶
WithStreamBlockSize allows to set a custom block size per round of reads/writes. If not set, any shard size set with WithAutoGoroutines will be used. If WithAutoGoroutines is also unset, 4MB will be used. Ignored if not used on stream.
type StreamEncoder ¶
type StreamEncoder interface { // Encode 为一组数据分片编码奇偶校验分片。 // // 参数: // - data: 包含数据分片的读取器切片 // - parity: 用于写入奇偶校验分片的写入器切片 // // 返回值: // - error: 如果编码过程中出现错误则返回,否则返回nil // // 注意: // - 分片数量必须与NewStream()中给定的数量匹配 // - 每个读取器必须提供相同数量的字节 // - 如果数据流返回错误,将返回StreamReadError类型的错误 // - 如果奇偶校验写入器返回错误,将返回StreamWriteError Encode(data []io.Reader, parity []io.Writer) error // Verify 验证奇偶校验分片是否包含正确的数据。 // // 参数: // - shards: 包含所有数据和奇偶校验分片的读取器切片 // // 返回值: // - bool: 如果奇偶校验正确则返回true,否则返回false // - error: 如果验证过程中出现错误则返回,否则返回nil // // 注意: // - 分片数量必须与NewStream()中给定的总数据+奇偶校验分片数量匹配 // - 每个读取器必须提供相同数量的字节 // - 如果分片流返回错误,将返回StreamReadError类型的错误 Verify(shards []io.Reader) (bool, error) // Reconstruct 尝试重建丢失的分片。 // // 参数: // - valid: 有效分片的读取器切片,丢失的分片用nil表示 // - fill: 用于写入重建分片的写入器切片,不需要重建的分片用nil表示 // // 返回值: // - error: 如果重建过程中出现错误则返回,否则返回nil // // 注意: // - 如果分片太少而无法重建丢失的分片,将返回ErrTooFewShards // - 重建的分片集是完整的,但未验证完整性 // - 使用Verify函数检查数据集是否正常 Reconstruct(valid []io.Reader, fill []io.Writer) error // Split 将输入流分割为给定编码器的分片数。 // // 参数: // - data: 输入数据流 // - dst: 用于写入分割后分片的写入器切片 // - size: 输入数据的总大小 // // 返回值: // - error: 如果分割过程中出现错误则返回,否则返回nil // // 注意: // - 如果数据大小不能被分片数整除,最后一个分片将包含额外的零 // - 如果无法检索指定的字节数,将返回'ErrShortData' Split(data io.Reader, dst []io.Writer, size int64) (err error) // Join 将分片合并并将数据段写入dst。 // // 参数: // - dst: 用于写入合并后数据的写入器 // - shards: 包含所有分片的读取器切片 // - outSize: 期望的输出数据大小 // // 返回值: // - error: 如果合并过程中出现错误则返回,否则返回nil // // 注意: // - 只考虑数据分片 // - 如果给定的分片太少,将返回ErrTooFewShards // - 如果总数据大小小于outSize,将返回ErrShortData Join(dst io.Writer, shards []io.Reader, outSize int64) error }
StreamEncoder 是一个接口,用于对数据进行Reed-Solomon奇偶校验编码。 它提供了完全流式的接口,并以最大4MB的块处理数据。
对于10MB及以下的小分片大小,建议使用内存接口, 因为流式接口有启动开销。
对于所有操作,读取器和写入器不应假定任何单个读/写的顺序/大小。
使用示例请参见examples文件夹中的"stream-encoder.go"和"streamdecoder.go"。
Example ¶
ExampleStreamEncoder 展示了一个简单的流编码器,我们从包含每个分片的读取器的[]io.Reader中进行编码
输入和输出可以与文件、网络流或适合你需求的任何东西交换
package main import ( "bytes" "fmt" "io" "io/ioutil" "log" "math/rand" "github.com/bpfs/defs/v2/reedsolomon" ) // fillRandom 用随机数据填充字节切片 // 参数: // - p: 要填充的字节切片 func fillRandom(p []byte) { for i := 0; i < len(p); i += 7 { val := rand.Int63() for j := 0; i+j < len(p) && j < 7; j++ { p[i+j] = byte(val) val >>= 8 } } } func main() { dataShards := 5 parityShards := 2 // 创建一个具有指定数据和奇偶校验分片数量的StreamEncoder rs, err := reedsolomon.NewStream(dataShards, parityShards) if err != nil { log.Fatal(err) } shardSize := 50000 // 创建输入数据分片 input := make([][]byte, dataShards) for s := range input { input[s] = make([]byte, shardSize) fillRandom(input[s]) } // 将我们的缓冲区转换为io.Readers readers := make([]io.Reader, dataShards) for i := range readers { readers[i] = io.Reader(bytes.NewBuffer(input[i])) } // 创建我们的输出io.Writers out := make([]io.Writer, parityShards) for i := range out { out[i] = ioutil.Discard } // 从输入编码到输出 err = rs.Encode(readers, out) if err != nil { log.Fatal(err) } fmt.Println("ok") }
Output: ok
func NewStream ¶
func NewStream(dataShards, parityShards int, o ...Option) (StreamEncoder, error)
NewStream 创建一个新的编码器并初始化它 参数:
- dataShards: int, 数据分片的数量
- parityShards: int, 奇偶校验分片的数量
- o: ...Option, 可选的配置选项
返回值:
- StreamEncoder: 创建的流编码器
- error: 如果创建过程中出现错误则返回,否则为 nil
注意:
- 数据分片的最大数量为 256
- 可以重复使用此编码器
func NewStreamC ¶
func NewStreamC(dataShards, parityShards int, conReads, conWrites bool, o ...Option) (StreamEncoder, error)
NewStreamC 创建一个新的流编码器并初始化数据分片和校验分片数量
参数:
- dataShards: 数据分片数量
- parityShards: 校验分片数量
- conReads: 是否启用并发读取
- conWrites: 是否启用并发写入
- o: ...Option, 可选的配置选项
返回值:
- StreamEncoder: 创建的流编码器
- error: 如果创建过程中出现错误则返回,否则为 nil
说明:
- 此函数功能与 NewStream 相同,但允许启用并发读写
type StreamReadError ¶
StreamReadError 表示在读取流时遇到的错误。 它可以帮助定位哪个读取器失败了。
字段:
- Err: 具体的错误信息
- Stream: 发生错误的流序号
func (StreamReadError) Error ¶
func (s StreamReadError) Error() string
Error 返回格式化的错误字符串。
返回值:
- string: 包含流序号和错误信息的格式化字符串
func (StreamReadError) String ¶
func (s StreamReadError) String() string
String 返回错误的字符串表示。
返回值:
- string: 与Error()方法返回相同的错误字符串
type StreamWriteError ¶
StreamWriteError 表示在写入流时遇到的错误。 它可以帮助定位哪个写入器失败了。
字段:
- Err: 具体的错误信息
- Stream: 发生错误的流序号
func (StreamWriteError) Error ¶
func (s StreamWriteError) Error() string
Error 返回格式化的错误字符串。
返回值:
- string: 包含流序号和错误信息的格式化字符串
func (StreamWriteError) String ¶
func (s StreamWriteError) String() string
String 返回错误的字符串表示。
返回值:
- string: 与Error()方法返回相同的错误字符串