scheduler

Documentation

Index

• type Cache
  • func NewCache(log logr.Logger, strategy CacheStrategy) *Cache
  • func (c *Cache) AddContainer(fleet *corev1alpha1.Fleet)
  • func (c *Cache) AddInstance(instance *corev1alpha1.Instance) error
  • func (c *Cache) AssumeInstance(instance *corev1alpha1.Instance) error
  • func (c *Cache) FinishBinding(instance *corev1alpha1.Instance) error
  • func (c *Cache) ForgetInstance(instance *corev1alpha1.Instance) error
  • func (c *Cache) IsAssumedInstance(instance *corev1alpha1.Instance) (bool, error)
  • func (c *Cache) RemoveContainer(fleet *corev1alpha1.Fleet) error
  • func (c *Cache) RemoveInstance(instance *corev1alpha1.Instance) error
  • func (c *Cache) Snapshot() *Snapshot
  • func (c *Cache) Start(ctx context.Context) error
  • func (c *Cache) UpdateContainer(_, newFleet *corev1alpha1.Fleet)
  • func (c *Cache) UpdateInstance(oldInstance, newInstance *corev1alpha1.Instance) error
• type CacheStrategy
• type ContainerInfo
  • func (n *ContainerInfo) Fleet() *corev1alpha1.Fleet
  • func (n *ContainerInfo) MaxAllocatable(typName string) int64
  • func (n *ContainerInfo) NumInstances() int
• type InstanceInfo
• type Snapshot
  • func (s *Snapshot) GetFleet(name string) (*ContainerInfo, error)
  • func (s *Snapshot) ListFleets() []*ContainerInfo
  • func (s *Snapshot) NumFleets() 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(fleet *corev1alpha1.Fleet)

func (*Cache) AddInstance

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

func (*Cache) AssumeInstance

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

func (*Cache) FinishBinding

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

func (*Cache) ForgetInstance

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

func (*Cache) IsAssumedInstance

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

func (*Cache) RemoveContainer

func (c *Cache) RemoveContainer(fleet *corev1alpha1.Fleet) error

func (*Cache) RemoveInstance

func (c *Cache) RemoveInstance(instance *corev1alpha1.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(_, newFleet *corev1alpha1.Fleet)

func (*Cache) UpdateInstance

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

type CacheStrategy

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

var DefaultCacheStrategy CacheStrategy = defaultCacheStrategy{}

type ContainerInfo

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

func (*ContainerInfo) Fleet

func (n *ContainerInfo) Fleet() *corev1alpha1.Fleet

func (*ContainerInfo) MaxAllocatable

func (n *ContainerInfo) MaxAllocatable(typName string) int64

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

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

func (*Snapshot) ListFleets

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

func (*Snapshot) NumFleets

func (s *Snapshot) NumFleets() int

func (*Snapshot) Update

func (s *Snapshot) Update()