Versions in this module Expand all Collapse all v0 v0.1.0 Aug 20, 2021 Changes in this version + func Close() error + func GetAdapterName() string + func IsOpen() bool + func Open(path string, size int64, reset bool) error + func RegisterAdapter(name string, l adapter.Adapter) + type MessageLog struct + var Log MessageLog + func (l *MessageLog) Delete(key uint64) + func (l *MessageLog) Get(key uint64) lp.MessagePack + func (l *MessageLog) Keys(prefix uint32) []uint64 + func (l *MessageLog) PersistInbound(blockID uint32, inMsg lp.MessagePack) + func (l *MessageLog) PersistOutbound(blockID uint32, outMsg lp.MessagePack) + func (l *MessageLog) Reset(prefix uint32) + type SessionStore struct + var Session SessionStore + func (s *SessionStore) Get(key uint64) (raw []byte, err error) + func (s *SessionStore) Put(key uint64, payload []byte) error
Go to main page