Versions in this module Expand all Collapse all v0 v0.2.0 Aug 20, 2021 v0.1.1 Jul 8, 2021 Changes in this version + func Close() error + func GetAdapterName() string + func InitDb(path, jsonconf string, reset bool) error + func IsOpen() bool + func Open(path, jsonconf string, reset bool) error + func RegisterAdapter(name string, a adapter.Adapter) + type MessageLog struct + var Log MessageLog + func (l *MessageLog) Delete(key uint64) + func (l *MessageLog) Get(proto lp.ProtoAdapter, key uint64) lp.LineProtocol + func (l *MessageLog) Keys(prefix uint32) []uint64 + func (l *MessageLog) PersistInbound(proto lp.ProtoAdapter, blockID uint32, inMsg lp.LineProtocol) + func (l *MessageLog) PersistOutbound(proto lp.ProtoAdapter, blockID uint32, outMsg lp.LineProtocol) + func (l *MessageLog) Reset(prefix uint32) + type MessageStore struct + var Message MessageStore + func (m *MessageStore) Get(contract uint32, topic []byte, last string) (matches []message.Message, err error) + func (m *MessageStore) Put(contract uint32, topic, payload []byte, ttl string) error + 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 + type SubscriptionStore struct + var Subscription SubscriptionStore + func (s *SubscriptionStore) Delete(contract uint32, messageId, topic []byte) error + func (s *SubscriptionStore) Get(contract uint32, topic []byte) (matches [][]byte, err error) + func (s *SubscriptionStore) NewID() ([]byte, error) + func (s *SubscriptionStore) Put(contract uint32, messageId, topic, payload []byte) error
Go to main page