queuemsgpack

package module

v0.4.1 Latest Latest Go to latest Published: Mar 17, 2023 License: MIT Imports: 2 Imported by: 0

Details

Package queuemsgpack provides utilities to inject/remove elements from a blobqueue using MessagePack encoding.

This section is empty.

This section is empty.

func Pop(q blobqueue.Queue, v interface{}) error

Pop removes the tail of the queue and deserialize it as MessagePack into v. v must be a pointer (see msgpack.Unmarshal).

func Push(q blobqueue.Queue, v interface{}) error

Push serialize v as MessagePack and pushes the blob on the queue. See msgpack.Marshal for the accepted values.

func Shift(q blobqueue.Queue, v interface{}) error

Shift removes the head of the queue and deserialize it as MessagePack into v. v must be a pointer (see msgpack.Unmarshal).

func Unshift(q blobqueue.Queue, v interface{}) error

Unshift serialize v as MessagePack and pushes the blob on the queue. See msgpack.Marshal for the accepted values.

This section is empty.