nats

Documentation

Index

• Variables
• type HandlerFunc
• type ReplyFunc
• type ReplyHandlerFunc
• type Request
  • func (request *Request) Close()
  • func (request *Request) Receive(handler HandlerFunc, matches ...protocol.MsgMatch) error
  • func (request *Request) Send(dest, verb, msg string, uuid ...string) error
  • func (request *Request) SendRequest(handler ReplyHandlerFunc, dest, verb, msg string, uuid ...string) error

Variables

var (
	ErrNoReceivers = errors.New("no known receivers")
)

Types

type HandlerFunc

type HandlerFunc func(ctx context.Context, message *protocol.Message, replyFunc ReplyFunc)

type ReplyFunc

type ReplyFunc func(message *protocol.Message) error

type ReplyHandlerFunc

type ReplyHandlerFunc func(ctx context.Context, message *protocol.Message)

type Request

type Request struct {
	Config          *protocol.Config
	SenderPublicKey protocol.Base58Bytes
	Subject         string
	Timeout         time.Duration
	// contains filtered or unexported fields
}

func (*Request) Close

func (request *Request) Close()

func (*Request) Receive

func (request *Request) Receive(handler HandlerFunc, matches ...protocol.MsgMatch) error

func (*Request) Send

func (request *Request) Send(dest, verb, msg string, uuid ...string) error

func (*Request) SendRequest

func (request *Request) SendRequest(handler ReplyHandlerFunc, dest, verb, msg string, uuid ...string) error