client

package

v1.0.5 Latest Latest Go to latest Published: May 29, 2022 License: BSD-3-Clause Imports: 5 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Schedule struct {
	Namespace string
	Nats      *nats.Conn
	Js        nats.JetStreamContext
	Store     nats.ObjectStore
}

func New(namespace string, nc *nats.Conn, js nats.JetStreamContext) (x *Schedule, err error)

func (x *Schedule) Get(key string) (jobs []common.Job, err error)

Get 获取调度信息

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

Remove 移除调度

func (x *Schedule) Set(key string, jobs ...common.Job) (err error)

Set 设置调度