cron

Documentation

Index

• Variables
• func UpdateItems()
• func WorkerRun(item *g.Cluster)
• type Worker
  • func NewWorker(ci *g.Cluster) Worker
  • func (this Worker) Drop()
  • func (this Worker) Start()

Variables

var Workers = make(map[string]Worker)

Functions

func UpdateItems

func UpdateItems()

func WorkerRun

func WorkerRun(item *g.Cluster)

Types

type Worker

type Worker struct {
	Ticker      *time.Ticker
	ClusterItem *g.Cluster
	Quit        chan struct{}
}

func NewWorker

func NewWorker(ci *g.Cluster) Worker

func (Worker) Drop

func (this Worker) Drop()

func (Worker) Start

func (this Worker) Start()