Versions in this module Expand all Collapse all v0 v0.0.2 Sep 9, 2015 Changes in this version + const Version + var CurrentTime = func() int64 + var ErrNoModify = errors.New("storage: Row not modified") + type ExpireMessage struct + MessageID [message.MessageIDSize]byte + SignerPub [message.SignerPubKeySize]byte + type MessageBlob struct + Data []byte + ID uint64 + MessageID [message.MessageIDSize]byte + OneTime bool + SignerPublicKey [message.SignerPubKeySize]byte + type MessageDB struct + NumShards uint64 + func New(driver, url, dir string, shards int) (*MessageDB, error) + func (db *MessageDB) AddMessage(pk *[message.SignerPubKeySize]byte) error + func (db *MessageDB) AddToGlobalIndex(id uint64) error + func (db *MessageDB) Close() error + func (db *MessageDB) DelMessage(pk *[message.SignerPubKeySize]byte) error + func (db *MessageDB) DeleteBlob(messageID *[message.MessageIDSize]byte) error + func (db *MessageDB) DeleteBlobDB(messageID *[message.MessageIDSize]byte) error + func (db *MessageDB) DeleteBlobFS(messageID *[message.MessageIDSize]byte) error + func (db *MessageDB) DeleteMessageByID(mid *[message.MessageIDSize]byte) error + func (db *MessageDB) ExpireMessageCounter(maxAge int64) error + func (db *MessageDB) ExpireSigners(maxAge int64) (int64, int64, error) + func (db *MessageDB) ForgetMessages(expireTime int64) error + func (db *MessageDB) GetBlob(messageID *[message.MessageIDSize]byte) (*MessageBlob, error) + func (db *MessageDB) GetBlobDB(messageID *[message.MessageIDSize]byte) (*MessageBlob, error) + func (db *MessageDB) GetBlobFS(messageID *[message.MessageIDSize]byte) (*MessageBlob, error) + func (db *MessageDB) GetGlobalIndex(start, count int64) ([][]byte, int, error) + func (db *MessageDB) GetKeyIndex(index *message.Curve25519Key, start int64, count int64) ([][]byte, int, error) + func (db *MessageDB) InsertBlob(id uint64, messageID *[message.MessageIDSize]byte, ...) error + func (db *MessageDB) InsertBlobDB(id uint64, messageID *[message.MessageIDSize]byte, ...) error + func (db *MessageDB) InsertBlobFS(messageID *[message.MessageIDSize]byte, data []byte) error + func (db *MessageDB) InsertBlobStruct(mb *MessageBlob) error + func (db *MessageDB) InsertMessage(msg *structs.MessageStruct) (uint64, error) + func (db *MessageDB) InsertOrUpdateSigner(signerStruct *structs.SignerStruct) error + func (db *MessageDB) InsertPeer(pubkey *[ed25519.PublicKeySize]byte) error + func (db *MessageDB) InsertSigner(signerStruct *structs.SignerStruct) (int64, error) + func (db *MessageDB) LearnMessage(mid *[message.MessageIDSize]byte) error + func (db *MessageDB) LockShard(s []byte) + func (db *MessageDB) MessageKnown(mid *[message.MessageIDSize]byte) bool + func (db *MessageDB) SelectMessageByID(mid *[message.MessageIDSize]byte) (uint64, *structs.MessageStruct, error) + func (db *MessageDB) SelectMessageExpire(now int64) ([]ExpireMessage, error) + func (db *MessageDB) SelectPeer(pubkey *[ed25519.PublicKeySize]byte) (*structs.PeerStruct, error) + func (db *MessageDB) SelectSigner(pk *[message.SignerPubKeySize]byte) (int64, *structs.SignerStruct, error) + func (db *MessageDB) SelectSignerByID(id int64) (int64, *structs.SignerStruct, error) + func (db *MessageDB) SetMessageExpireByID(mid *[message.MessageIDSize]byte, expire int64) error + func (db *MessageDB) TouchPeer(pubkey *[ed25519.PublicKeySize]byte) error + func (db *MessageDB) UnlockShard(s []byte) + func (db *MessageDB) UpdatePeerNotification(pubkey *[ed25519.PublicKeySize]byte, hasError bool) error + func (db *MessageDB) UpdatePeerStats(pubkey *[ed25519.PublicKeySize]byte, lastFetch, lastPos, lastErrors uint64) error + func (db *MessageDB) UpdatePeerToken(pubkey *[ed25519.PublicKeySize]byte, ...) error + func (db *MessageDB) UpdateSigner(signerStruct *structs.SignerStruct) error