store

Documentation

Index

• type Cache
  • func NewCache() (*Cache, error)
  • func (c *Cache) GetACollectedSubject(k subject.HashHex) *subject.Subject
  • func (c *Cache) GetACreatedSubject(k subject.HashHex) *subject.Subject
  • func (c *Cache) GetBallotSet(subHashHex subject.HashHex) ballot.Map
  • func (c *Cache) GetCollectedSubjects() subject.Map
  • func (c *Cache) GetCreatedSubjects() subject.Map
  • func (c *Cache) GetIdentitySet(subHashHex subject.HashHex) identity.Set
  • func (c *Cache) InsertBallot(subHashHex subject.HashHex, ba *ballot.Ballot)
  • func (c *Cache) InsertBallotSet(subHashHex subject.HashHex, ballotMap ballot.Map)
  • func (c *Cache) InsertColletedSubject(k subject.HashHex, v *subject.Subject)
  • func (c *Cache) InsertCreatedSubject(k subject.HashHex, v *subject.Subject)
  • func (c *Cache) InsertIdentity(subHashHex subject.HashHex, id identity.Identity)
  • func (c *Cache) InsertIdentitySet(subHashHex subject.HashHex, idSet identity.Set)
  • func (c *Cache) IsExistedSubject(sHex subject.HashHex) bool
• type NodeValidator
  • func (nv NodeValidator) Select(key string, values [][]byte) (int, error)
  • func (nv NodeValidator) Validate(ket string, value []byte) error
• type Store
  • func NewStore(dht *dht.IpfsDHT, db datastore.Batching) (*Store, error)
  • func (store *Store) GetDHT() error
  • func (store *Store) GetLocal(k string) (string, error)
  • func (store *Store) PutDHT() error
  • func (store *Store) PutLocal(k, v string) error

Types

type Cache

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

Cache ...

func NewCache

func NewCache() (*Cache, error)

NewCache ...

func (*Cache) GetACollectedSubject

func (c *Cache) GetACollectedSubject(k subject.HashHex) *subject.Subject

GetACollectedSubject ...

func (*Cache) GetACreatedSubject

func (c *Cache) GetACreatedSubject(k subject.HashHex) *subject.Subject

GetACreatedSubject ...

func (*Cache) GetBallotSet

func (c *Cache) GetBallotSet(subHashHex subject.HashHex) ballot.Map

GetBallotSet .

func (*Cache) GetCollectedSubjects

func (c *Cache) GetCollectedSubjects() subject.Map

GetCollectedSubjects .

func (*Cache) GetCreatedSubjects

func (c *Cache) GetCreatedSubjects() subject.Map

GetCreatedSubjects .

func (*Cache) GetIdentitySet

func (c *Cache) GetIdentitySet(subHashHex subject.HashHex) identity.Set

func (*Cache) InsertBallot

func (c *Cache) InsertBallot(subHashHex subject.HashHex, ba *ballot.Ballot)

InsertBallot .

func (*Cache) InsertBallotSet

func (c *Cache) InsertBallotSet(subHashHex subject.HashHex, ballotMap ballot.Map)

InsertBallotSet .

func (*Cache) InsertColletedSubject

func (c *Cache) InsertColletedSubject(k subject.HashHex, v *subject.Subject)

InsertColletedSubject .

func (*Cache) InsertCreatedSubject

func (c *Cache) InsertCreatedSubject(k subject.HashHex, v *subject.Subject)

InsertCreatedSubject .

func (*Cache) InsertIdentity

func (c *Cache) InsertIdentity(subHashHex subject.HashHex, id identity.Identity)

func (*Cache) InsertIdentitySet

func (c *Cache) InsertIdentitySet(subHashHex subject.HashHex, idSet identity.Set)

func (*Cache) IsExistedSubject

func (c *Cache) IsExistedSubject(sHex subject.HashHex) bool

type NodeValidator

type NodeValidator struct{}

NodeValidator ...

func (NodeValidator) Select

func (nv NodeValidator) Select(key string, values [][]byte) (int, error)

Select ...

func (NodeValidator) Validate

func (nv NodeValidator) Validate(ket string, value []byte) error

Validate ...

type Store

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

Store ...

func NewStore

func NewStore(dht *dht.IpfsDHT, db datastore.Batching) (*Store, error)

NewStore ...

func (*Store) GetDHT

func (store *Store) GetDHT() error

GetDHT ...

func (*Store) GetLocal

func (store *Store) GetLocal(k string) (string, error)

GetLocal ...

func (*Store) PutDHT

func (store *Store) PutDHT() error

PutDHT ...

func (*Store) PutLocal

func (store *Store) PutLocal(k, v string) error

PutLocal ...