store

Documentation

Index

• type SDB
  • func New() *SDB
  • func (db *SDB) Add(name string, d *database.DB)
  • func (db *SDB) Close()
  • func (db *SDB) Del(rec *acproto.ACPY2MapDatum) error
  • func (db *SDB) Distrib(loc *soty.Loc, rec *acproto.ACPY2DistRequest, onDone func(int))
  • func (db *SDB) Get(rec *acproto.ACPY2MapDatum) (bool, error)
  • func (db *SDB) GetMerkle(name string, level int, treeid uint16, ver uint64) ([]*merkle.Result, error)
  • func (db *SDB) GetRange(req *acproto.ACPY2GetRange, res *acproto.ACPY2GetSet) (bool, error)
  • func (db *SDB) GetRingConf(name string, dc string) (*acproto.ACPY2RingConfReply, error)
  • func (db *SDB) Handoff(rec *acproto.ACPY2DistRequest)
  • func (db *SDB) PeerUpdate(id string, isup bool, pd *kibitz.Export, dat *acproto.ACPHeartBeat)
  • func (db *SDB) Put(rec *acproto.ACPY2MapDatum) (int, *soty.Loc)
  • func (db *SDB) Redirect(rec *acproto.ACPY2MapDatum)
  • func (db *SDB) RingIsStable(name string) bool

Types

type SDB

type SDB struct {
	Uptodate bool
	// contains filtered or unexported fields
}

func New

func New() *SDB

func (*SDB) Add

func (db *SDB) Add(name string, d *database.DB)

func (*SDB) Close

func (db *SDB) Close()

func (*SDB) Del

func (db *SDB) Del(rec *acproto.ACPY2MapDatum) error

func (*SDB) Distrib

func (db *SDB) Distrib(loc *soty.Loc, rec *acproto.ACPY2DistRequest, onDone func(int))

func (*SDB) Get

func (db *SDB) Get(rec *acproto.ACPY2MapDatum) (bool, error)

func (*SDB) GetMerkle

func (db *SDB) GetMerkle(name string, level int, treeid uint16, ver uint64) ([]*merkle.Result, error)

func (*SDB) GetRange

func (db *SDB) GetRange(req *acproto.ACPY2GetRange, res *acproto.ACPY2GetSet) (bool, error)

func (*SDB) GetRingConf

func (db *SDB) GetRingConf(name string, dc string) (*acproto.ACPY2RingConfReply, error)

func (*SDB) Handoff

func (db *SDB) Handoff(rec *acproto.ACPY2DistRequest)

func (*SDB) PeerUpdate

func (db *SDB) PeerUpdate(id string, isup bool, pd *kibitz.Export, dat *acproto.ACPHeartBeat)

func (*SDB) Put

func (db *SDB) Put(rec *acproto.ACPY2MapDatum) (int, *soty.Loc)

func (*SDB) Redirect

func (db *SDB) Redirect(rec *acproto.ACPY2MapDatum)

func (*SDB) RingIsStable

func (db *SDB) RingIsStable(name string) bool