zmq

package
v0.0.0-...-6a0cb6c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Mdcli

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

Mdcli we access these properties only via class methods

func NewMdcli

func NewMdcli(broker string, verbose bool) (mdcli *Mdcli, err error)

NewMdcli Constructor

func (*Mdcli) Close

func (mdcli *Mdcli) Close() (err error)

Close Destructor

func (*Mdcli) ConnectToBroker

func (mdcli *Mdcli) ConnectToBroker() (err error)

ConnectToBroker or reconnect to broker.

func (*Mdcli) Send

func (mdcli *Mdcli) Send(service string, request ...string) (reply []string, err error)

Send message Here is the send method. It sends a request to the broker and gets a reply even if it has to retry several times. It returns the reply message, or error if there was no reply after multiple attempts:

func (*Mdcli) SetRetries

func (mdcli *Mdcli) SetRetries(retries int)

SetRetries Set request retries.

func (*Mdcli) SetTimeout

func (mdcli *Mdcli) SetTimeout(timeout time.Duration)

SetTimeout request timeout.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL