scheduler

Documentation

Index

• Constants
• func GetNamespaceAndName(namespacedName string) (string, string)
• func NamespacedName(namespace, name string) string
• func New(apiClient client.Client, informerCache runtimecache.Cache, ...) apisv1alpha1.VolumeScheduler
• type PriorityItem
• type PriorityQueue
  • func (pq PriorityQueue) Len() int
  • func (pq PriorityQueue) Less(i, j int) bool
  • func (pq *PriorityQueue) Pop() interface{}
  • func (pq *PriorityQueue) Push(x interface{})
  • func (pq PriorityQueue) Swap(i, j int)

Constants

const (
	HwameiStorSchedulerName = "hwameistor-scheduler"
)

Functions

func GetNamespaceAndName

func GetNamespaceAndName(namespacedName string) (string, string)

func NamespacedName

func NamespacedName(namespace, name string) string

func New

func New(apiClient client.Client, informerCache runtimecache.Cache, maxHAVolumeCount int) apisv1alpha1.VolumeScheduler

New a scheduler instance

Types

type PriorityItem

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

An Item is something we manage in a priority queue.

type PriorityQueue

type PriorityQueue []*PriorityItem

A PriorityQueue implements heap.Interface and holds Items.

func (PriorityQueue) Len

func (pq PriorityQueue) Len() int

func (PriorityQueue) Less

func (pq PriorityQueue) Less(i, j int) bool

func (*PriorityQueue) Pop

func (pq *PriorityQueue) Pop() interface{}

func (*PriorityQueue) Push

func (pq *PriorityQueue) Push(x interface{})

func (PriorityQueue) Swap

func (pq PriorityQueue) Swap(i, j int)