erasure_code

Documentation

Index

• type ErasureCodec
• type ReedSolomon
  • func (ReedSolomon) Decode(input [][]byte, dataShards int, parityShards int) ([]byte, error)
  • func (ReedSolomon) Encode(input []byte, dataShards int, parityShards int) ([][]byte, error)
  • func (ReedSolomon) RebuildECExtent(dataShards, parityShards int, sourceExtent []*extent.Extent, start uint32, ...) error
  • func (ReedSolomon) Reconstruct(input []io.Reader, dataShards int, parityShards int, output []io.Writer) error

Types

type ErasureCodec

type ErasureCodec interface {
	Encode(input []byte, dataShards int, parityShards int, chunkSize int) ([][]byte, error)
	Decode(input [][]byte, dataShards uint32, parityShards uint32, chunkSize int) ([]byte, error)
	Reconstruct(input []io.Reader, dataShards int, parityShards int, output []io.Writer, chunkSize int) error
}

type ReedSolomon

type ReedSolomon struct{}

func (ReedSolomon) Decode

func (ReedSolomon) Decode(input [][]byte, dataShards int, parityShards int) ([]byte, error)

func (ReedSolomon) Encode

func (ReedSolomon) Encode(input []byte, dataShards int, parityShards int) ([][]byte, error)

func (ReedSolomon) RebuildECExtent

func (ReedSolomon) RebuildECExtent(dataShards, parityShards int, sourceExtent []*extent.Extent, start uint32, replacingIndex int, targetExtent *extent.Extent) error

FIXME: add a channel to make ReadBlocks and Reconstruct asynchronized

func (ReedSolomon) Reconstruct

func (ReedSolomon) Reconstruct(input []io.Reader, dataShards int, parityShards int, output []io.Writer) error