server

package

v0.0.55 Latest Latest Go to latest Published: Jul 11, 2025 License: AGPL-3.0, AGPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Map struct {
	worker.Worker
	// contains filtered or unexported fields
}

Map holds reference to the database and logger and provides methods to store and retrieve data

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

NewMap instantiates a map

func (m *Map) GarbageCollect() error

GarbageCollect prunes the oldest bucket of entries when the map size limit is exceeded

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

Get retrieves an item from the db

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

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

Put places an item in the db

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

func (m *Map) Shutdown()

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

Wait adds pending cborplugin.Responses (with SURBs) by MessageID to a waiting map

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

Wake returns the pending responses from the waiting map and removes the entries