encoder

Documentation

Overview

Stream Encoder for erasure coding.

Index

• type StreamEncoder
  • func NewEncoder(iDataShards, iParityShards int) (*StreamEncoder, error)
  • func (e *StreamEncoder) Decode(in [][]byte, shardSize int) ([]byte, error)
  • func (e *StreamEncoder) Encode(in []byte) ([][]byte, error)

Types

type StreamEncoder

type StreamEncoder struct {
	// contains filtered or unexported fields
}

func NewEncoder

func NewEncoder(iDataShards, iParityShards int) (*StreamEncoder, error)

Creates New encoder instance and return index for further access

func (*StreamEncoder) Decode

func (e *StreamEncoder) Decode(in [][]byte, shardSize int) ([]byte, error)

func (*StreamEncoder) Encode

func (e *StreamEncoder) Encode(in []byte) ([][]byte, error)

Encodes and returns the shards on success and error on fails