client

Documentation

Index

• type Client
  • func New(namespace string, js nats.JetStreamContext) (x *Client, err error)
  • func (x *Client) Get(key string) (result *Result, err error)
  • func (x *Client) NamespaceParse() string
  • 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 Payload
• type Result
• type StreamOption

Types

type Client

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

func New

func New(namespace string, js nats.JetStreamContext) (x *Client, err error)

func (*Client) Get

func (x *Client) Get(key string) (result *Result, err error)

func (*Client) NamespaceParse

func (x *Client) NamespaceParse() string

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 Payload

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

type Result

type Result struct {
	Option StreamOption     `json:"option"`
	Info   *nats.StreamInfo `json:"info"`
}

type StreamOption

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