store

Documentation

Index

• type Entry
  • func (e Entry) Marshal(buf []byte) (int, error)
  • func (e *Entry) Unmarshal(buf []byte) error
• type Store
  • func NewStore(cfg *StoreCfg) *Store
  • func (s *Store) Capacity() int64
  • func (s *Store) ListAll() <-chan Entry
  • func (s *Store) ListWithReplicaID(id uint64) <-chan Entry
  • func (s *Store) Read(publicKey ed25519.PublicKey, datKey string) (Entry, error)
  • func (s *Store) ReadBackup() error
  • func (s *Store) Used() int64
  • func (s *Store) Write(e *Entry) error
• type StoreCfg

Types

type Entry

type Entry struct {
	Dat      dat.Dat
	Replicas [network.FANOUT]uint64
}

func (Entry) Marshal

func (e Entry) Marshal(buf []byte) (int, error)

func (*Entry) Unmarshal

func (e *Entry) Unmarshal(buf []byte) error

type Store

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

func NewStore

func NewStore(cfg *StoreCfg) *Store

func (*Store) Capacity

func (s *Store) Capacity() int64

func (*Store) ListAll

func (s *Store) ListAll() <-chan Entry

func (*Store) ListWithReplicaID

func (s *Store) ListWithReplicaID(id uint64) <-chan Entry

func (*Store) Read

func (s *Store) Read(publicKey ed25519.PublicKey, datKey string) (Entry, error)

func (*Store) ReadBackup

func (s *Store) ReadBackup() error

func (*Store) Used

func (s *Store) Used() int64

func (*Store) Write

func (s *Store) Write(e *Entry) error

type StoreCfg

type StoreCfg struct {
	MyID           uint64
	Capacity       int64
	BackupFilename string
	Kill           <-chan struct{}
	Done           chan<- struct{}
	Logger         logger.Logger
}