scheduler

Documentation

Index

• type Cache
  • func NewCache(log logr.Logger, strategy CacheStrategy) *Cache
  • func (c *Cache) AddContainer(node *v1alpha1.VolumePool)
  • func (c *Cache) AddInstance(instance *v1alpha1.Volume) error
  • func (c *Cache) AssumeInstance(instance *v1alpha1.Volume) error
  • func (c *Cache) FinishBinding(instance *v1alpha1.Volume) error
  • func (c *Cache) ForgetInstance(instance *v1alpha1.Volume) error
  • func (c *Cache) IsAssumedInstance(instance *v1alpha1.Volume) (bool, error)
  • func (c *Cache) RemoveContainer(node *v1alpha1.VolumePool) error
  • func (c *Cache) RemoveInstance(instance *v1alpha1.Volume) error
  • func (c *Cache) Snapshot() *Snapshot
  • func (c *Cache) Start(ctx context.Context) error
  • func (c *Cache) UpdateContainer(_, newNode *v1alpha1.VolumePool)
  • func (c *Cache) UpdateInstance(oldInstance, newInstance *v1alpha1.Volume) error
• type CacheStrategy
• type ContainerInfo
  • func (n *ContainerInfo) MaxAllocatable(className string) resource.Quantity
  • func (n *ContainerInfo) Node() *v1alpha1.VolumePool
  • func (n *ContainerInfo) NumInstances() int
• type InstanceInfo
• type Snapshot
  • func (s *Snapshot) GetNode(name string) (*ContainerInfo, error)
  • func (s *Snapshot) ListNodes() []*ContainerInfo
  • func (s *Snapshot) NumNodes() int
  • func (s *Snapshot) Update()

Types

type Cache

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

func NewCache

func NewCache(log logr.Logger, strategy CacheStrategy) *Cache

func (*Cache) AddContainer

func (c *Cache) AddContainer(node *v1alpha1.VolumePool)

func (*Cache) AddInstance

func (c *Cache) AddInstance(instance *v1alpha1.Volume) error

func (*Cache) AssumeInstance

func (c *Cache) AssumeInstance(instance *v1alpha1.Volume) error

func (*Cache) FinishBinding

func (c *Cache) FinishBinding(instance *v1alpha1.Volume) error

func (*Cache) ForgetInstance

func (c *Cache) ForgetInstance(instance *v1alpha1.Volume) error

func (*Cache) IsAssumedInstance

func (c *Cache) IsAssumedInstance(instance *v1alpha1.Volume) (bool, error)

func (*Cache) RemoveContainer

func (c *Cache) RemoveContainer(node *v1alpha1.VolumePool) error

func (*Cache) RemoveInstance

func (c *Cache) RemoveInstance(instance *v1alpha1.Volume) error

func (*Cache) Snapshot

func (c *Cache) Snapshot() *Snapshot

func (*Cache) Start

func (c *Cache) Start(ctx context.Context) error

func (*Cache) UpdateContainer

func (c *Cache) UpdateContainer(_, newNode *v1alpha1.VolumePool)

func (*Cache) UpdateInstance

func (c *Cache) UpdateInstance(oldInstance, newInstance *v1alpha1.Volume) error

type CacheStrategy

type CacheStrategy interface {
	Key(instance *v1alpha1.Volume) (types.UID, error)
	ContainerKey(instance *v1alpha1.Volume) string
}

var DefaultCacheStrategy CacheStrategy = defaultCacheStrategy{}

type ContainerInfo

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

func (*ContainerInfo) MaxAllocatable

func (n *ContainerInfo) MaxAllocatable(className string) resource.Quantity

func (*ContainerInfo) Node

func (n *ContainerInfo) Node() *v1alpha1.VolumePool

func (*ContainerInfo) NumInstances

func (n *ContainerInfo) NumInstances() int

type InstanceInfo

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

type Snapshot

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

func (*Snapshot) GetNode

func (s *Snapshot) GetNode(name string) (*ContainerInfo, error)

func (*Snapshot) ListNodes

func (s *Snapshot) ListNodes() []*ContainerInfo

func (*Snapshot) NumNodes

func (s *Snapshot) NumNodes() int

func (*Snapshot) Update

func (s *Snapshot) Update()