archfilter

Documentation

Index

• Constants
• func AddToCache(cacheStore cache.Store, object ImageArch) error
• func DecodeInto(obj runtime.Object, into interface{}) error
• func DeleteFromCache(cacheStore cache.Store, object string) error
• func New(obj runtime.Object, handle framework.Handle) (framework.Plugin, error)
• type ArchFilter
  • func (s *ArchFilter) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (s *ArchFilter) Name() string
  • func (s *ArchFilter) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)
  • func (s *ArchFilter) ScoreExtensions() framework.ScoreExtensions
• type ImageArch
  • func FetchFromCache(cacheStore cache.Store, key string) (ImageArch, error)
  • func GetPodArchitectures(pod *v1.Pod) ([]ImageArch, error)
• type WeightArgs

Constants

const (
	// Name is plugin name
	Name = "archfilter"
)

Functions

func AddToCache

func AddToCache(cacheStore cache.Store, object ImageArch) error

func DecodeInto

func DecodeInto(obj runtime.Object, into interface{}) error

func DeleteFromCache

func DeleteFromCache(cacheStore cache.Store, object string) error

func New

func New(obj runtime.Object, handle framework.Handle) (framework.Plugin, error)

Types

type ArchFilter

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

func (*ArchFilter) Filter

func (s *ArchFilter) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, node *framework.NodeInfo) *framework.Status

func (*ArchFilter) Name

func (s *ArchFilter) Name() string

func (*ArchFilter) Score

func (s *ArchFilter) Score(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (int64, *framework.Status)

func (*ArchFilter) ScoreExtensions

func (s *ArchFilter) ScoreExtensions() framework.ScoreExtensions

ScoreExtensions of the Score plugin.

type ImageArch

type ImageArch struct {
	Image         string
	Architectures []string
}

func FetchFromCache

func FetchFromCache(cacheStore cache.Store, key string) (ImageArch, error)

func GetPodArchitectures

func GetPodArchitectures(pod *v1.Pod) ([]ImageArch, error)

type WeightArgs

type WeightArgs struct {
	Weight map[string]int64 `json:"weight,omitempty"`
}