kcron

package

v1.0.3 Latest Latest Go to latest Published: Feb 19, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/guojiangli/picasso

Links

Open Source Insights

Documentation ¶

Index ¶

type JobWrapper
- func (job JobWrapper) Run()
type Kcron
- func New(option ...*Option) (k *Kcron, err error)
type NodePool
- func (np *NodePool) InitPoolGrabService()
- func (np *NodePool) PickNodeByJobName(jobName string) string
type Option

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type JobWrapper ¶

type JobWrapper struct {
	ID      cron.EntryID
	Kcron   *Kcron
	Name    string
	CronStr string
	Func    func()
	Job     cron.Job
}

JobWarpper is a job warpper

func (JobWrapper) Run ¶

func (job JobWrapper) Run()

Run is run job

type Kcron ¶

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

Kcron is main struct

func New ¶

func New(option ...*Option) (k *Kcron, err error)

NewKcron create a Kcron

func (*Kcron) AddFunc ¶

func (d *Kcron) AddFunc(jobName, cronStr string, cmd func()) (err error)

AddFunc add a cron func

func (*Kcron) AddJob ¶

func (d *Kcron) AddJob(jobName, cronStr string, job cron.Job) (err error)

AddJob add a job

func (*Kcron) Remove ¶

func (d *Kcron) Remove(jobName string)

Remove Job

func (*Kcron) Run ¶

func (d *Kcron) Run() error

Start start job

func (*Kcron) Stop ¶

func (d *Kcron) Stop() error

Stop stop job

type NodePool ¶

type NodePool struct {
	NodeID string

	Driver driver.Driver
	// contains filtered or unexported fields
}

NodePool is a node pool

func (*NodePool) InitPoolGrabService ¶

func (np *NodePool) InitPoolGrabService()

func (*NodePool) PickNodeByJobName ¶

func (np *NodePool) PickNodeByJobName(jobName string) string

PickNodeByJobName : 使用一致性hash算法根据任务名获取一个执行节点

type Option ¶

type Option struct {
	WorkerName string
	Driver     driver.Driver
	Logger     baselogger.KcronLogger
}

func NewOption ¶

func NewOption() *Option

func SetDriver ¶

func SetDriver(d driver.Driver) *Option

func SetLogger ¶

func SetLogger(l baselogger.KcronLogger) *Option

func SetWorkerName ¶

func SetWorkerName(s string) *Option

func (*Option) MergeOption ¶

func (c *Option) MergeOption(opts ...*Option) *Option

func (*Option) SetDriver ¶

func (c *Option) SetDriver(d driver.Driver) *Option

func (*Option) SetLogger ¶

func (c *Option) SetLogger(l baselogger.KcronLogger) *Option

func (*Option) SetWorkerName ¶

func (c *Option) SetWorkerName(s string) *Option

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
consistenthash
driver
redis

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL