Versions in this module Expand all Collapse all v1 v1.0.2 Sep 5, 2023 Changes in this version + type Configuration struct + Servers []string + Token string + Unsafe bool + type Message struct + Data string + Header map[string]string + Raw []byte + Topic string + type MessageHandler func(Message) + type Nats struct + func (mi *Nats) Exports() modules.Exports + func (n *Nats) Close() + func (n *Nats) JetStreamDelete(name string) error + func (n *Nats) JetStreamPublish(topic string, message string) error + func (n *Nats) JetStreamPublishMsg(msg *Message) error + func (n *Nats) JetStreamPublishWithHeaders(topic, message string, headers map[string]string) error + func (n *Nats) JetStreamSetup(streamConfig *natsio.StreamConfig) error + func (n *Nats) JetStreamSubscribe(topic string, handler MessageHandler) (*Subscription, error) + func (n *Nats) Publish(topic, message string) error + func (n *Nats) PublishMsg(msg *Message) error + func (n *Nats) PublishWithHeaders(topic, message string, headers map[string]string) error + func (n *Nats) Request(subject, data string, headers map[string]string) (Message, error) + func (n *Nats) Subscribe(topic string, handler MessageHandler) (*Subscription, error) + type RootModule struct + func (r *RootModule) NewModuleInstance(vu modules.VU) modules.Instance + type Subscription struct + Close func() error v1.0.1 Jul 14, 2023
Go to main page