scheduler

type Configuration struct {
	QueueSize uint8
}

type DefaultStore struct {
	//Support sync locking
	*sync.RWMutex
	// contains filtered or unexported fields
}

type Scheduler struct {
	//Mutex for sync controling.
	*sync.RWMutex
	// contains filtered or unexported fields
}

type StatItem struct {
	//Metrics catalog
	Type string

	//The stat value
	Value uint32

	//Attach some other info
	Attachment interface{}
}

type StatSummary struct {
	//Count of scheduled policy
	PolicyCount uint32

	//Total count of tasks
	Tasks uint32

	//Count of successfully complete tasks
	CompletedTasks uint32

	//Count of tasks with errors
	TasksWithError uint32
}

type Store interface {
	//Put a new policy in.
	Put(key string, value *Watcher) error

	//Get the corresponding policy with the key.
	Get(key string) *Watcher

	//Exists is to check if the key existing in the store.
	Exists(key string) bool

	//Remove the specified policy and return its reference.
	Remove(key string) *Watcher

	//Size return the total count of items in store.
	Size() uint32

	//GetAll is to get all the items in the store.
	GetAll() []*Watcher

	//Clear store.
	Clear()
}

type Watcher struct {
	//Locker to sync related operations.
	*sync.RWMutex
	// contains filtered or unexported fields
}