client

package

v1.0.4 Latest Latest Go to latest Published: Feb 22, 2022 License: BSD-3-Clause Imports: 5 Imported by: 1

Details

This section is empty.

This section is empty.

func HttpWorker(spec string, option model.HttpJob) (job *api.Job, err error)

HttpWorker HTTP回调 @spec Crontab 规则 @option HTTP 配置

type Schedule struct {
	// contains filtered or unexported fields
}

func New(addr string, opts ...grpc.DialOption) (x *Schedule, err error)

func (x *Schedule) Close() error

func (x *Schedule) Delete(ctx context.Context, key string) (err error)

Delete 删除任务 @key 唯一标识

func (x *Schedule) Get(ctx context.Context, keys []string) (data map[string]*api.Schedule, err error)

Get 获取任务 @keys 唯一标识数组

func (x *Schedule) Put(ctx context.Context, key string, jobs ...*api.Job) (err error)

Put 更新任务 @key 唯一标识 @jobs 工作流