controller

Documentation

Index

• type Controller
  • func New(drainer Drainer, requests chan Request, cooldown time.Duration) *Controller
  • func (c *Controller) Drain(request Request)
  • func (c *Controller) Reconcile(ctx context.Context) error
  • func (c *Controller) RegisterMetrics(r *prometheus.Registry)
• type Drainer
• type Queue
  • func NewQueue(gauge prometheus.Gauge) *Queue
  • func (q *Queue) Add(r Request)
  • func (q *Queue) Poll() *Request
• type Request

Types

type Controller

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

func New

func New(drainer Drainer, requests chan Request, cooldown time.Duration) *Controller

func (*Controller) Drain

func (c *Controller) Drain(request Request)

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context) error

func (*Controller) RegisterMetrics

func (c *Controller) RegisterMetrics(r *prometheus.Registry)

type Drainer

type Drainer interface {
	Drain(string) (int, error)
}

type Queue

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

func NewQueue

func NewQueue(gauge prometheus.Gauge) *Queue

func (*Queue) Add

func (q *Queue) Add(r Request)

Add inserts the specified element into this queue.

func (*Queue) Poll

func (q *Queue) Poll() *Request

Poll retrieves, but does not remove, the head of this queue, or returns null if this queue is empty.

type Request

type Request struct {
	NodeName string
	Fastpath bool
	OnDone   func()
}