Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithGuidOpt ¶
func WithTimeout ¶
Types ¶
type MessageOpt ¶
type MessageOpt func(r *Request)
type NATSClient ¶
type NATSClient struct { *nats.Conn // contains filtered or unexported fields }
func NewNATSClient ¶
func NewNATSClient(log *logger.Logger, urls []string) (*NATSClient, error)
func (*NATSClient) NotifyProto ¶
func (this_ *NATSClient) NotifyProto(reqs ...proto.Message)
func (*NATSClient) RequestProto ¶
func (this_ *NATSClient) RequestProto(req proto.Message, out proto.Message, opts ...MessageOpt) error
Click to show internal directories.
Click to hide internal directories.