plugin

Documentation

Index

• type Config
  • func DefaultConfig() *Config
• type Fetch
  • func (Fetch) Client(b *gop.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (n *Fetch) Server(*gop.MuxBroker) (interface{}, error)
• type FetchImpl
• type FetchRPC
  • func (n *FetchRPC) Run(host string) FetchResult
• type FetchRPCServer
  • func (n *FetchRPCServer) Run(host string, resp *FetchResult) error
• type FetchResult
• type Filter
  • func (Filter) Client(b *gop.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (n *Filter) Server(*gop.MuxBroker) (interface{}, error)
• type FilterImpl
• type FilterRPC
  • func (n *FilterRPC) Run(args *common.Args) FilterResult
• type FilterRPCServer
  • func (n *FilterRPCServer) Run(args *common.Args, resp *FilterResult) error
• type FilterResult
• type Plugin
  • func New(_ context.Context, cfg *Config) Plugin
• type Score
  • func (Score) Client(b *gop.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (n *Score) Server(*gop.MuxBroker) (interface{}, error)
• type ScoreImpl
• type ScoreRPC
  • func (n *ScoreRPC) Run(args *common.Args) ScoreResult
• type ScoreRPCServer
  • func (n *ScoreRPCServer) Run(args *common.Args, resp *ScoreResult) error
• type ScoreResult

Types

type Config

type Config struct {
	Config config.Config
}

func DefaultConfig

func DefaultConfig() *Config

type Fetch

type Fetch struct {
	Impl FetchImpl
}

func (Fetch) Client

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

func (*Fetch) Server

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

type FetchImpl

type FetchImpl interface {
	Run(string) FetchResult
}

type FetchRPC

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

func (*FetchRPC) Run

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

type FetchRPCServer

type FetchRPCServer struct {
	Impl FetchImpl
}

func (*FetchRPCServer) Run

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

type FetchResult

type FetchResult struct {
	AllocatableResource common.Resource
	RequestedResource   common.Resource
}

type Filter

type Filter struct {
	Impl FilterImpl
}

func (Filter) Client

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

func (*Filter) Server

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

type FilterImpl

type FilterImpl interface {
	Run(*common.Args) FilterResult
}

type FilterRPC

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

func (*FilterRPC) Run

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

type FilterRPCServer

type FilterRPCServer struct {
	Impl FilterImpl
}

func (*FilterRPCServer) Run

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

type FilterResult

type FilterResult struct {
	Error string
}

type Plugin

type Plugin interface {
	Init(context.Context) error
	Deinit(context.Context) error
	RunFetch(context.Context, string, string) (FetchResult, error)
	RunFilter(context.Context, string, *common.Task, *common.Node) (FilterResult, error)
	RunScore(context.Context, string, *common.Task, *common.Node) (ScoreResult, error)
}

func New

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

type Score

type Score struct {
	Impl ScoreImpl
}

func (Score) Client

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

func (*Score) Server

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

type ScoreImpl

type ScoreImpl interface {
	Run(*common.Args) ScoreResult
}

type ScoreRPC

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

func (*ScoreRPC) Run

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

type ScoreRPCServer

type ScoreRPCServer struct {
	Impl ScoreImpl
}

func (*ScoreRPCServer) Run

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

type ScoreResult

type ScoreResult struct {
	Score int64
}