Versions in this module Expand all Collapse all v0 v0.0.2 Sep 13, 2021 Changes in this version + type BaseStore interface + Start func(ctx context.Context, config config.SIConfig) error + Stop func(ctx context.Context) error + type EventStore interface + GetEvent func(ctx context.Context, maxEventTime int64) ([]common.Event, error) + GetEventMaxTime func(ctx context.Context) (int64, error) + PubEvent func(ctx context.Context, event common.Event) error + type MessageStore interface + ClearRetainMessage func(ctx context.Context, topic string) error + ClearWillMessage func(ctx context.Context, clientId string) error + GetAllRetainMsg func(ctx context.Context) ([]*messagev5.PublishMessage, error) + GetRetainMessage func(ctx context.Context, topic string) (*messagev5.PublishMessage, error) + GetWillMessage func(ctx context.Context, clientId string) (*messagev5.PublishMessage, error) + StoreRetainMessage func(ctx context.Context, topic string, message *messagev5.PublishMessage) error + StoreWillMessage func(ctx context.Context, clientId string, message *messagev5.PublishMessage) error + type SessionStore interface + CacheInflowMsg func(ctx context.Context, clientId string, message messagev5.Message) error + CacheOutflowMsg func(ctx context.Context, client string, message messagev5.Message) error + CacheOutflowSecMsgId func(ctx context.Context, clientId string, pkId uint16) error + ClearOfflineMsgById func(ctx context.Context, clientId string, msgIds []string) error + ClearOfflineMsgs func(ctx context.Context, clientId string) error + ClearSession func(ctx context.Context, clientId string, clearOfflineMsg bool) error + ClearSubscriptions func(ctx context.Context, clientId string) error + DelSubscription func(ctx context.Context, client, topic string) error + GetAllInflowMsg func(ctx context.Context, clientId string) ([]messagev5.Message, error) + GetAllOfflineMsg func(ctx context.Context, clientId string) ([]messagev5.Message, []string, error) + GetAllOutflowMsg func(ctx context.Context, clientId string) ([]messagev5.Message, error) + GetAllOutflowSecMsg func(ctx context.Context, clientId string) ([]uint16, error) + GetSession func(ctx context.Context, clientId string) (sessionsv5.Session, error) + GetSubscriptions func(ctx context.Context, clientId string) ([]*messagev5.SubscribeMessage, error) + ReleaseInflowMsg func(ctx context.Context, clientId string, pkId uint16) (messagev5.Message, error) + ReleaseOutflowMsg func(ctx context.Context, clientId string, pkId uint16) (messagev5.Message, error) + ReleaseOutflowSecMsgId func(ctx context.Context, clientId string, pkId uint16) error + StoreOfflineMsg func(ctx context.Context, clientId string, message messagev5.Message) error + StoreSession func(ctx context.Context, clientId string, session sessionsv5.Session) error + StoreSubscription func(ctx context.Context, clientId string, subscription *messagev5.SubscribeMessage) error + type Store interface + SetStore func(store SessionStore, messageStore MessageStore)