Versions in this module Expand all Collapse all v0 v0.5.2 Jan 31, 2023 Changes in this version + type IterateFn func(session *gmqtt.Session) bool + type MockStore struct + func NewMockStore(ctrl *gomock.Controller) *MockStore + func (m *MockStore) EXPECT() *MockStoreMockRecorder + func (m *MockStore) Get(clientID string) (*gmqtt.Session, error) + func (m *MockStore) Iterate(fn IterateFn) error + func (m *MockStore) Remove(clientID string) error + func (m *MockStore) Set(session *gmqtt.Session) error + func (m *MockStore) SetSessionExpiry(clientID string, expiry uint32) error + type MockStoreMockRecorder struct + func (mr *MockStoreMockRecorder) Get(clientID interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) Iterate(fn interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) Remove(clientID interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) Set(session interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) SetSessionExpiry(clientID, expiry interface{}) *gomock.Call + type Store interface + Get func(clientID string) (*gmqtt.Session, error) + Iterate func(fn IterateFn) error + Remove func(clientID string) error + Set func(session *gmqtt.Session) error + SetSessionExpiry func(clientID string, expiry uint32) error
Go to main page