plugin

May 19, 2022

Changes in this version

type Plugin

+ Deinit func() error

May 14, 2022

Changes in this version

type FetchImpl

+ Run func(string) FetchResult

+ type FetchRoutine func(string) FetchResult

type FilterImpl

+ Run func(args *common.Args) FilterResult

+ type FilterRoutine func(args *common.Args) FilterResult

type ScoreImpl

+ Run func(args *common.Args) ScoreResult

+ type ScoreRoutine func(args *common.Args) ScoreResult

May 14, 2022

Changes in this version

+ type FetchImpl func(string) FetchResult

+ type FilterImpl func(args *common.Args) FilterResult

+ type ScoreImpl func(args *common.Args) ScoreResult

May 13, 2022

Changes in this version

+ type Fetch struct

+ Impl FetchPlugin

+ func (Fetch) Client(b *gop.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (n *Fetch) Server(*gop.MuxBroker) (interface{}, error)

+ type FetchRPC struct

+ func (n *FetchRPC) Run(host string) FetchResult

+ type FetchRPCServer struct

+ Impl FetchPlugin

+ func (n *FetchRPCServer) Run(host string, resp *FetchResult) error

+ type Filter struct

+ Impl FilterPlugin

+ func (Filter) Client(b *gop.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (n *Filter) Server(*gop.MuxBroker) (interface{}, error)

+ type FilterRPC struct

+ func (n *FilterRPC) Run(args *common.Args) FilterResult

+ type FilterRPCServer struct

+ Impl FilterPlugin

+ func (n *FilterRPCServer) Run(args *common.Args, resp *FilterResult) error

+ type Score struct

+ Impl ScorePlugin

+ func (Score) Client(b *gop.MuxBroker, c *rpc.Client) (interface{}, error)

+ func (n *Score) Server(*gop.MuxBroker) (interface{}, error)

+ type ScoreRPC struct

+ func (n *ScoreRPC) Run(args *common.Args) ScoreResult

+ type ScoreRPCServer struct

+ Impl ScorePlugin

+ func (n *ScoreRPCServer) Run(args *common.Args, resp *ScoreResult) error

May 13, 2022

Changes in this version

type Plugin

+ RunFetch func(string) FetchResult

+ RunFilter func(*common.Args) FilterResult

+ RunScore func(*common.Args) ScoreResult

May 13, 2022

Changes in this version

+ type Config struct

+ Config config.Config

+ func DefaultConfig() *Config

+ type FetchPlugin interface

+ Run func(string) FetchResult

+ type FetchResult struct

+ AllocatableResource Resource

+ RequestedResource Resource

+ type FilterPlugin interface

+ Run func(*Args) FilterResult

+ type FilterResult struct

+ Error string

+ type Plugin interface

+ Init func() error

+ Run func() error

+ func New(_ context.Context, cfg *Config) Plugin

+ type ScorePlugin interface

+ Run func(*Args) ScoreResult

+ type ScoreResult struct

+ Score int64

May 11, 2022

Changes in this version

+ const DefaultCPUWeight

+ const DefaultMemoryRequest

+ const DefaultMemoryWeight

+ const DefaultMilliCPURequest

+ const DefaultStorageWeight

+ const MaxNodeScore

+ const MaxTotalScore

+ const MinNodeScore

+ const ResourceCPU

+ const ResourceMemory

+ const ResourceStorage

+ type Args struct

+ Node Node

+ Task Task

+ type Label map[string]string

+ type Node struct

+ AllocatableResource Resource

+ Host string

+ Label Label

+ Name string

+ RequestedResource Resource

+ Unschedulable bool

+ type Resource struct

+ Memory int64

+ MilliCPU int64

+ Storage int64

+ type Selector map[string][]string

+ type Task struct

+ Name string

+ NodeName string

+ NodeSelector Selector

+ RequestedResource Resource

+ ToleratesUnschedulable bool