caching

Oct 10, 2024

Changes in this version

type Cache

+ func (c *Cache) Exec(req *mqtt.Message, cb Callback) (*mqtt.Message, error)

+ type Callback = func() (*mqtt.Message, error)

+ type Clock interface

+ Now func() time.Time

Sep 7, 2024

Changes in this version

+ const FixedProcessingOverheadMs

+ const FixedStorageOverheadBytes

+ const MaxAggregatePayloadBytes

+ const MaxEntryCount

+ type Cache struct

+ func New(idempotent bool, requestTopic string) *Cache

+ func (c *Cache) Get(req *mqtt.Message) (*mqtt.Message, bool)

+ func (c *Cache) Set(req, res *mqtt.Message, expiry, ttl time.Time, exec time.Duration)