client

package

v1.1.3 Latest Latest Go to latest Published: Jun 18, 2022 License: BSD-3-Clause Imports: 6 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)

New 创建客户端

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

Get 获取调度信息

func (x *Schedule) List() (keys []string, err error)

List 列出配置标识

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

Remove 移除调度

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

Set 设置调度

func (x *Schedule) Status(key string, running bool) (result []byte, err error)

Status 设置状态