Versions in this module Expand all Collapse all v0 v0.8.0 Jun 24, 2017 Changes in this version + const RowsToRead + const SuperBlockSize + func ParseKeyHash(key_hash_string string) (uint64, uint32) + type Needle struct + Checksum int32 + Cookie uint32 + Data []byte + Key uint64 + Padding []byte + Size uint32 + func NewNeedle(r *http.Request) (n *Needle, e error) + func ReadNeedle(r *os.File) (*Needle, uint32) + func (n *Needle) Append(w io.Writer) uint32 + func (n *Needle) ParsePath(fid string) + func (n *Needle) Read(r io.Reader, size uint32) (int, error) + type NeedleMap struct + func LoadNeedleMap(file *os.File) *NeedleMap + func NewNeedleMap(file *os.File) *NeedleMap + func (nm *NeedleMap) Close() + func (nm *NeedleMap) Delete(key uint64) + func (nm *NeedleMap) Get(key uint64) (element *NeedleValue, ok bool) + func (nm *NeedleMap) Put(key uint64, offset uint32, size uint32) (int, error) + type NeedleValue struct + Offset uint32 + Size uint32 + type Store struct + Port int + PublicUrl string + func NewStore(port int, publicUrl, dirname string, volumeListString string) (s *Store) + func (s *Store) AddVolume(volumeListString string) error + func (s *Store) Close() + func (s *Store) Delete(i uint64, n *Needle) uint32 + func (s *Store) Join(mserver string) + func (s *Store) Read(i uint64, n *Needle) (int, error) + func (s *Store) Status() *[]*VolumeInfo + func (s *Store) Write(i uint64, n *Needle) uint32 + type Volume struct + Id uint32 + func NewVolume(dirname string, id uint32) (v *Volume) + func (v *Volume) Close() + func (v *Volume) Size() int64 + type VolumeInfo struct + Id uint32 + Size int64