cik_job

README

分布式任务

Documentation

Overview

*

• @Author: cloudintheking
• @Description:
• @File: job
• @Version: 1.0.0
• @Date: 2022/7/13 15:24

Index

• func AddRunner(c *cron.Cron, runner JobRunner) (cron.EntryID, error)
• func JobDeserialize(data []byte, target JobRunner) error
• func JobSerialize(runner JobRunner) ([]byte, error)
• type JobRunner

Functions

func AddRunner

func AddRunner(c *cron.Cron, runner JobRunner) (cron.EntryID, error)

func JobDeserialize

func JobDeserialize(data []byte, target JobRunner) error

func JobSerialize

func JobSerialize(runner JobRunner) ([]byte, error)

Types

type JobRunner

type JobRunner interface {
	Call()           //执行函数
	GetCron() string //cron表达式
}