client

Sep 24, 2023

Changes in this version

+ type Client struct

+ Js nats.JetStreamContext

+ KeyValue nats.KeyValue

+ Namespace string

+ func New(options ...Option) (x *Client, err error)

+ func (x *Client) Get(key string) (result map[string]interface{}, err error)

+ func (x *Client) Publish(ctx context.Context, key string, payload Payload) (err error)

+ func (x *Client) Remove(key string) (err error)

+ func (x *Client) Set(ctx context.Context, option StreamOption) (err error)

+ func (x *Client) Update(ctx context.Context, option StreamOption) (err error)

+ type Option func(x *Client)

+ func SetJetStream(v nats.JetStreamContext) Option

+ func SetNamespace(v string) Option

+ type Payload struct

+ Data map[string]interface{}

+ Timestamp time.Time

+ XData map[string]interface{}

+ type StreamOption struct

+ Description string

+ Key string