implement

Documentation

Index

• type Requester
  • func NewRequester(basePath string) (retRequester *Requester, retErr error)
  • func (t *Requester) Call(reqMsgData []byte, timeout time.Duration) (retRespData []byte, retErr error)
  • func (t *Requester) Send() error
  • func (t *Requester) Start() error
• type Responder
  • func NewResponder(basePath string, onReceivedMessage common.OnReceivedMessage) (retResponder *Responder, retErr error)
  • func (t *Responder) Start() error

Types

type Requester

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

func NewRequester

func NewRequester(basePath string) (retRequester *Requester, retErr error)

func (*Requester) Call

func (t *Requester) Call(reqMsgData []byte, timeout time.Duration) (retRespData []byte, retErr error)

func (*Requester) Send

func (t *Requester) Send() error

func (*Requester) Start

func (t *Requester) Start() error

type Responder

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

func NewResponder

func NewResponder(basePath string, onReceivedMessage common.OnReceivedMessage) (retResponder *Responder, retErr error)

func (*Responder) Start

func (t *Responder) Start() error