Documentation
¶
Index ¶
- type Controller
- func (ctr *Controller) Done(disk manager.Event)
- func (ctr *Controller) Forget(disk manager.Event)
- func (ctr *Controller) HandleEvent()
- func (ctr *Controller) Pop() manager.Event
- func (ctr *Controller) Push(disk manager.Event)
- func (ctr *Controller) PushRateLimited(disk manager.Event)
- func (ctr *Controller) StartMonitor()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller
func (*Controller) Done ¶
func (ctr *Controller) Done(disk manager.Event)
Done completes the task and remove from the queue
func (*Controller) Forget ¶
func (ctr *Controller) Forget(disk manager.Event)
Forget completes the task and remove from the queue
func (*Controller) Pop ¶
func (ctr *Controller) Pop() manager.Event
Pop pops an item from the work queue, it will block until it returns an item
func (*Controller) Push ¶
func (ctr *Controller) Push(disk manager.Event)
Push pushes item to the work queue
func (*Controller) PushRateLimited ¶
func (ctr *Controller) PushRateLimited(disk manager.Event)
PushRateLimited pushes an item to the work queue after the rate limiter says it's ok
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.