kvsimple

package

v1.2.4 Latest Latest Go to latest Published: Feb 19, 2021 License: BSD-2-Clause Imports: 4 Imported by: 0

Details

kvsimple - simple key-value message class for example applications.

This is a very much unlike typical Go.

This section is empty.

This section is empty.

This section is empty.

type Kvmsg struct {
	// contains filtered or unexported fields
}

The Kvmsg type holds a single key-value message consisting of a list of 0 or more frames.

func NewKvmsg(sequence int64) (kvmsg *Kvmsg)

Constructor, takes a sequence number for the new Kvmsg instance.

func RecvKvmsg(socket *zmq.Socket) (kvmsg *Kvmsg, err error)

The RecvKvmsg function reads a key-value message from socket, and returns a new Kvmsg instance.

func (kvmsg *Kvmsg) Dump()

The dump method prints the key-value message to stderr, for debugging and tracing.

func (kvmsg *Kvmsg) GetBody() (body string, err error)

func (kvmsg *Kvmsg) GetKey() (key string, err error)

func (kvmsg *Kvmsg) GetSequence() (sequence int64, err error)

func (kvmsg *Kvmsg) Send(socket *zmq.Socket) (err error)

The send method sends a multi-frame key-value message to a socket.

func (kvmsg *Kvmsg) SetBody(body string)

func (kvmsg *Kvmsg) SetKey(key string)

func (kvmsg *Kvmsg) SetSequence(sequence int64)

func (kvmsg *Kvmsg) Size() int

The size method returns the body size of the last-read message, if any.

func (kvmsg *Kvmsg) Store(kvmap map[string]*Kvmsg)

The store method stores the key-value message into a hash map, unless the key is nil.