client

Documentation

Index

• type Client
  • func New(node string, nc *nats.Conn) (x *Client, err error)
  • func (x *Client) Get(key string) (option common.ScheduleOption, err error)
  • func (x *Client) Lists() (keys []string, err error)
  • func (x *Client) Ping() (result bool, err error)
  • func (x *Client) Remove(key string) (err error)
  • func (x *Client) Set(key string, option common.ScheduleOption) (err error)
  • func (x *Client) Status(key string, value bool) (err error)

Types

type Client

type Client struct {
	Node      string
	Nats      *nats.Conn
	JetStream nats.JetStreamContext
	KeyValue  nats.KeyValue
}

func New

func New(node string, nc *nats.Conn) (x *Client, err error)

func (*Client) Get

func (x *Client) Get(key string) (option common.ScheduleOption, err error)

func (*Client) Lists

func (x *Client) Lists() (keys []string, err error)

func (*Client) Ping

func (x *Client) Ping() (result bool, err error)

func (*Client) Remove

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

func (*Client) Set

func (x *Client) Set(key string, option common.ScheduleOption) (err error)

func (*Client) Status

func (x *Client) Status(key string, value bool) (err error)