scheduler

Documentation

Index

• type Cache
  • func NewCache(log logr.Logger, strategy CacheStrategy) *Cache
  • func (c *Cache) AddContainer(node *v1alpha1.Node)
  • func (c *Cache) AddInstance(instance *v1alpha1.Instance) error
  • func (c *Cache) AssumeInstance(instance *v1alpha1.Instance) error
  • func (c *Cache) FinishBinding(instance *v1alpha1.Instance) error
  • func (c *Cache) ForgetInstance(instance *v1alpha1.Instance) error
  • func (c *Cache) IsAssumedInstance(instance *v1alpha1.Instance) (bool, error)
  • func (c *Cache) RemoveContainer(node *v1alpha1.Node) error
  • func (c *Cache) RemoveInstance(instance *v1alpha1.Instance) error
  • func (c *Cache) Snapshot() *Snapshot
  • func (c *Cache) Start(ctx context.Context) error
  • func (c *Cache) UpdateContainer(_, newNode *v1alpha1.Node)
  • func (c *Cache) UpdateInstance(oldInstance, newInstance *v1alpha1.Instance) error
• type CacheStrategy
• type ContainerInfo
  • func (n *ContainerInfo) Instances() []*InstanceInfo
  • func (n *ContainerInfo) Node() *v1alpha1.Node
  • func (n *ContainerInfo) NumInstances() int
• type InstanceInfo
  • func (i *InstanceInfo) Instance() *v1alpha1.Instance
• 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.Node)

func (*Cache) AddInstance

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

func (*Cache) AssumeInstance

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

func (*Cache) FinishBinding

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

func (*Cache) ForgetInstance

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

func (*Cache) IsAssumedInstance

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

func (*Cache) RemoveContainer

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

func (*Cache) RemoveInstance

func (c *Cache) RemoveInstance(instance *v1alpha1.Instance) 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.Node)

func (*Cache) UpdateInstance

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

type CacheStrategy

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

var DefaultCacheStrategy CacheStrategy = defaultCacheStrategy{}

type ContainerInfo

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

func (*ContainerInfo) Instances

func (n *ContainerInfo) Instances() []*InstanceInfo

func (*ContainerInfo) Node

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

func (*ContainerInfo) NumInstances

func (n *ContainerInfo) NumInstances() int

type InstanceInfo

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

func (*InstanceInfo) Instance

func (i *InstanceInfo) Instance() *v1alpha1.Instance

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