Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

plugin

package

Go to main page

Versions in this module

v0

v0.7.1

Apr 20, 2023

v0.7.0

Mar 14, 2023

Changes in this version

+ func NewLocalPluginWithKubeconfig(configuration runtime.Object, f framework.Handle, cfg *restclient.Config) (framework.Plugin, error)

v0.6.1

Jan 12, 2023

v0.6.0

Nov 2, 2022

Changes in this version

+ const PluginName

+ func NewLocalPlugin(configuration runtime.Object, f framework.Handle) (framework.Plugin, error)

+ type DeviceScorer struct

+ func NewDeviceScorer(strategy localtype.StrategyType, ...) *DeviceScorer

+ func (scorer *DeviceScorer) ScoreByCapacity(nodeAllocate *cache.NodeAllocateState) (score int64)

+ func (scorer *DeviceScorer) ScoreByCount(nodeAllocate *cache.NodeAllocateState) (score int64)

+ func (scorer *DeviceScorer) ScoreByNodeAntiAffinity(nodeAllocate *cache.NodeAllocateState) (score int64)

+ type LocalPlugin struct

+ func (plugin *LocalPlugin) Filter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (plugin *LocalPlugin) Name() string

+ func (plugin *LocalPlugin) NormalizeScore(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (plugin *LocalPlugin) OnNodeLocalStorageAdd(obj interface{})

+ func (plugin *LocalPlugin) OnNodeLocalStorageUpdate(oldObj, newObj interface{})

+ func (plugin *LocalPlugin) OnPVAdd(obj interface{})

+ func (plugin *LocalPlugin) OnPVCAdd(obj interface{})

+ func (plugin *LocalPlugin) OnPVCDelete(obj interface{})

+ func (plugin *LocalPlugin) OnPVCUpdate(oldObj, newObj interface{})

+ func (plugin *LocalPlugin) OnPVDelete(obj interface{})

+ func (plugin *LocalPlugin) OnPVUpdate(oldObj, newObj interface{})

+ func (plugin *LocalPlugin) OnPodAdd(obj interface{})

+ func (plugin *LocalPlugin) OnPodDelete(obj interface{})

+ func (plugin *LocalPlugin) OnPodUpdate(oldObj, newObj interface{})

+ func (plugin *LocalPlugin) PreBind(ctx context.Context, state *framework.CycleState, p *corev1.Pod, ...) *framework.Status

+ func (plugin *LocalPlugin) PreFilter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod) *framework.Status

+ func (plugin *LocalPlugin) PreFilterExtensions() framework.PreFilterExtensions

+ func (plugin *LocalPlugin) Reserve(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (plugin *LocalPlugin) ReserveReservation(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) *framework.Status

+ func (plugin *LocalPlugin) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)

+ func (plugin *LocalPlugin) ScoreExtensions() framework.ScoreExtensions

+ func (plugin *LocalPlugin) Unreserve(ctx context.Context, state *framework.CycleState, p *corev1.Pod, ...)

+ func (plugin *LocalPlugin) UnreserveReservation(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...)

+ type OpenLocalArg struct

+ KubeConfigPath string

+ NodeAntiAffinityConf string

+ SchedulerStrategy string

+ type ScoreCalculator struct

+ func NewScoreCalculator(strategy localtype.StrategyType, ...) *ScoreCalculator

+ func (scorer *ScoreCalculator) Score(nodeAllocate *cache.NodeAllocateState) (score int64)

+ func (scorer *ScoreCalculator) ScoreByCapacity(nodeAllocate *cache.NodeAllocateState) (score int64)

+ func (scorer *ScoreCalculator) ScoreByCount(nodeAllocate *cache.NodeAllocateState) (score int64)

+ func (scorer *ScoreCalculator) ScoreByNodeAntiAffinity(nodeAllocate *cache.NodeAllocateState) (score int64)

+ type Scorer interface

+ ScoreByCapacity func(nodeAllocate *cache.NodeAllocateState) (score int64)

+ ScoreByCount func(nodeAllocate *cache.NodeAllocateState) (score int64)

+ ScoreByNodeAntiAffinity func(nodeAllocate *cache.NodeAllocateState) (score int64)

+ type VolumeGroupScorer struct

+ func NewVolumeGroupScorer(strategy localtype.StrategyType) *VolumeGroupScorer

+ func (scorer *VolumeGroupScorer) ScoreByCapacity(nodeAllocate *cache.NodeAllocateState) (score int64)

+ func (scorer *VolumeGroupScorer) ScoreByCount(nodeAllocate *cache.NodeAllocateState) (score int64)

+ func (scorer *VolumeGroupScorer) ScoreByNodeAntiAffinity(nodeAllocate *cache.NodeAllocateState) (score int64)