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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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 ¶
Source Files
Click to show internal directories.
Click to hide internal directories.