disk

Documentation

Index

• type Controller
  • func NewController(mgr crmanager.Manager) *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()

Types

type Controller

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

Controller

func NewController

func NewController(mgr crmanager.Manager) *Controller

NewController

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) HandleEvent

func (ctr *Controller) HandleEvent()

HandleEvent

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

func (*Controller) StartMonitor

func (ctr *Controller) StartMonitor()

StartMonitor