nats

README

xk6-nats-jetstream

This project is based on: https://github.com/grafana/xk6/issues/15

Documentation

Index

• type Client
  • func (c *Client) Publish(subject string, payload string) error
  • func (c *Client) PublishJetstream(stream string, subject string, payload string, ackwait int) (*nats.PubAck, error)
  • func (c *Client) Request(subject string, payload string) (string, error)
• type Nats
  • func (r *Nats) XClient(ctxPtr *context.Context, natsServer string, timeoutMS int) interface{}

Types

type Client

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

func (*Client) Publish

func (c *Client) Publish(subject string, payload string) error

func (*Client) PublishJetstream

func (c *Client) PublishJetstream(stream string, subject string, payload string, ackwait int) (*nats.PubAck, error)

func (*Client) Request

func (c *Client) Request(subject string, payload string) (string, error)

type Nats

type Nats struct{}

func (*Nats) XClient

func (r *Nats) XClient(ctxPtr *context.Context, natsServer string, timeoutMS int) interface{}