server

Apr 30, 2025

Changes in this version

+ type Map struct

+ func NewMap(fileStore string, log *logging.Logger, gcSize int, mapSize int) (*Map, error)

+ func (m *Map) GarbageCollect() error

+ func (m *Map) Get(msgID common.MessageID) ([]byte, error)

+ func (m *Map) OnCommand(cmd cborplugin.Command) error

+ func (m *Map) Put(msgID common.MessageID, payload []byte) error

+ func (m *Map) RegisterConsumer(svr *cborplugin.Server)

+ func (m *Map) Shutdown()

+ func (m *Map) Wait(msgID common.MessageID, response *cborplugin.Response)

+ func (m *Map) Wake(msgID common.MessageID, payload []byte) error