client

package

v1.4.3 Latest Latest Go to latest Published: Oct 13, 2023 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 {
	Namespace string
	Node      string
	Nats      *nats.Conn
	JetStream nats.JetStreamContext
	KeyValue  nats.KeyValue
}

func New(options ...Option) (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)

type Option func(x *Client)

func SetJetStream(v nats.JetStreamContext) Option

func SetNamespace(v string) Option

func SetNats(v *nats.Conn) Option

func SetNode(v string) Option