client

package

v1.6.0 Latest Latest Go to latest Published: Mar 16, 2024 License: BSD-3-Clause Imports: 6 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

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)