Versions in this module Expand all Collapse all v0 v0.0.0 Apr 4, 2019 Changes in this version + type NatsTransporter struct + func NewNatsTransporter(servers string, timeout time.Duration, opts ...nats.Option) (*NatsTransporter, error) + func NewNatsTransporterFromConn(natsConnection *nats.Conn, timeout time.Duration) (*NatsTransporter, error) + func (n *NatsTransporter) Call(ctx context.Context, function string, requestData []byte) (response []byte, err error) + func (n *NatsTransporter) Close() error + func (n *NatsTransporter) Listen(function string, ...) error