client

Documentation

Index

• type Client
  • 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 SetJetStream(v nats.JetStreamContext) Option
  • func SetNamespace(v string) Option
• type Payload
• type StreamOption

Types

type Client

type Client struct {
	Namespace string
	Js        nats.JetStreamContext
	KeyValue  nats.KeyValue
}

func New

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

func (*Client) Get

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

func (*Client) Publish

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

func (*Client) Remove

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

func (*Client) Set

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

func (*Client) Update

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

type Option

type Option func(x *Client)

func SetJetStream

func SetJetStream(v nats.JetStreamContext) Option

func SetNamespace

func SetNamespace(v string) Option

type Payload

type Payload struct {
	Timestamp time.Time              `msgpack:"timestamp"`
	Data      map[string]interface{} `msgpack:"data"`
	XData     map[string]interface{} `msgpack:"xdata"`
}

type StreamOption

type StreamOption struct {
	Key         string `msgpack:"key"`
	Description string `msgpack:"description"`
}