object

Documentation

Index

• func SplitSlabs(slabs []Slab, lengths []int) [][]SlabSlice
• type EncryptionKey
  • func GenerateEncryptionKey() EncryptionKey
  • func (k EncryptionKey) Decrypt(w io.Writer, offset int64) cipher.StreamWriter
  • func (k EncryptionKey) Encrypt(r io.Reader) cipher.StreamReader
  • func (k EncryptionKey) MarshalText() ([]byte, error)
  • func (k EncryptionKey) String() string
  • func (k *EncryptionKey) UnmarshalText(b []byte) error
• type Object
  • func (o Object) Size() int64
• type Sector
• type Slab
  • func (s Slab) Encode(buf []byte, shards [][]byte)
  • func (s Slab) Encrypt(shards [][]byte)
  • func (s Slab) Length() int
  • func (s Slab) Reconstruct(shards [][]byte) error
• type SlabSlice
  • func SingleSlabs(slabs []Slab, length int) []SlabSlice
  • func (ss SlabSlice) Decrypt(shards [][]byte)
  • func (ss SlabSlice) Recover(w io.Writer, shards [][]byte) error
  • func (ss SlabSlice) SectorRegion() (offset, length uint64)

Functions

func SplitSlabs

func SplitSlabs(slabs []Slab, lengths []int) [][]SlabSlice

SplitSlabs splits a set of slabs into slices comprising objects with the specified lengths.

Types

type EncryptionKey

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

A EncryptionKey can encrypt and decrypt messages.

func GenerateEncryptionKey

func GenerateEncryptionKey() EncryptionKey

GenerateEncryptionKey returns a random encryption key.

func (EncryptionKey) Decrypt

func (k EncryptionKey) Decrypt(w io.Writer, offset int64) cipher.StreamWriter

Decrypt returns a cipher.StreamWriter that decrypts w with k, starting at the specified offset.

func (EncryptionKey) Encrypt

func (k EncryptionKey) Encrypt(r io.Reader) cipher.StreamReader

Encrypt returns a cipher.StreamReader that encrypts r with k.

func (EncryptionKey) MarshalText

func (k EncryptionKey) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface.

func (EncryptionKey) String

func (k EncryptionKey) String() string

String implements fmt.Stringer.

func (*EncryptionKey) UnmarshalText

func (k *EncryptionKey) UnmarshalText(b []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface.

type Object

type Object struct {
	Key   EncryptionKey
	Slabs []SlabSlice
}

An Object is a unit of data that has been stored on a host.

func (Object) Size

func (o Object) Size() int64

Size returns the total size of the object.

type Sector

type Sector struct {
	Host types.PublicKey
	Root types.Hash256
}

A Sector uniquely identifies a sector stored on a particular host.

type Slab

type Slab struct {
	Key       EncryptionKey
	MinShards uint8
	Shards    []Sector
}

A Slab is raw data that has been erasure-encoded into sector-sized shards, encrypted, and stored across a set of hosts. A distinct EncryptionKey should be used for each Slab, and should not be the same key used for the parent Object.

func (Slab) Encode

func (s Slab) Encode(buf []byte, shards [][]byte)

Encode encodes slab data into sector-sized shards. The supplied shards should have a capacity of at least rhpv2.SectorSize, or they will be reallocated.

func (Slab) Encrypt

func (s Slab) Encrypt(shards [][]byte)

Encrypt xors shards with the keystream derived from s.Key, using a different nonce for each shard.

func (Slab) Length

func (s Slab) Length() int

Length returns the length of the raw data stored in s.

func (Slab) Reconstruct

func (s Slab) Reconstruct(shards [][]byte) error

Reconstruct reconstructs the missing shards of a slab. Missing shards must have a len of zero. All shards should have a capacity of at least rhpv2.SectorSize, or they will be reallocated.

type SlabSlice

type SlabSlice struct {
	Slab
	Offset uint32
	Length uint32
}

A SlabSlice is a contiguous region within a Slab. Note that the offset and length always refer to the reconstructed data, and therefore may not necessarily be aligned to a leaf or chunk boundary. Use the SectorRegion method to compute the chunk-aligned offset and length.

func SingleSlabs

func SingleSlabs(slabs []Slab, length int) []SlabSlice

SingleSlabs converts a set of slabs into slices comprising a single object with the specified length.

func (SlabSlice) Decrypt

func (ss SlabSlice) Decrypt(shards [][]byte)

Decrypt xors shards with the keystream derived from s.Key (starting at the slice offset), using a different nonce for each shard.

func (SlabSlice) Recover

func (ss SlabSlice) Recover(w io.Writer, shards [][]byte) error

Recover recovers a slice of slab data from the supplied shards.

func (SlabSlice) SectorRegion

func (ss SlabSlice) SectorRegion() (offset, length uint64)

SectorRegion returns the offset and length of the sector region that must be downloaded in order to recover the data referenced by the SlabSlice.