Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dcron ¶
type Dcron struct { ServerName string // contains filtered or unexported fields }
func NewDcron ¶
func NewDcron(serverName, driverName string, dataSourceOption driver.DriverConnOpt) *Dcron
func NewDcronUseRedis ¶
func NewDcronUseRedis(serverName string, dataSourceOption driver.DriverConnOpt) *Dcron
func (*Dcron) RemoveFunc ¶
type JobWarpper ¶
func (JobWarpper) Run ¶
func (job JobWarpper) Run()
type NodePool ¶
type NodePool struct { NodeId string Driver driver.Driver // contains filtered or unexported fields }
func (*NodePool) PickNodeByJobName ¶
使用一致性hash算法根据任务名获取一个执行节点
type PoolOptions ¶
type PoolOptions struct { Replicas int HashFn consistenthash.Hash }
Click to show internal directories.
Click to hide internal directories.