plugin

package
v1.19.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 16, 2023 License: Apache-2.0 Imports: 10 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config added in v0.2.0

type Config struct {
	Config config.Config
}

func DefaultConfig added in v0.2.0

func DefaultConfig() *Config

type Fetch added in v0.4.0

type Fetch struct {
	Impl FetchImpl
}

func (Fetch) Client added in v0.4.0

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

func (*Fetch) Server added in v0.4.0

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

type FetchImpl added in v0.5.0

type FetchImpl interface {
	Run(string) FetchResult
}

type FetchRPC added in v0.4.0

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

func (*FetchRPC) Run added in v0.4.0

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

type FetchRPCServer added in v0.4.0

type FetchRPCServer struct {
	Impl FetchImpl
}

func (*FetchRPCServer) Run added in v0.4.0

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

type FetchResult added in v0.2.0

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

type Filter added in v0.4.0

type Filter struct {
	Impl FilterImpl
}

func (Filter) Client added in v0.4.0

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

func (*Filter) Server added in v0.4.0

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

type FilterImpl added in v0.5.0

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

type FilterRPC added in v0.4.0

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

func (*FilterRPC) Run added in v0.4.0

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

type FilterRPCServer added in v0.4.0

type FilterRPCServer struct {
	Impl FilterImpl
}

func (*FilterRPCServer) Run added in v0.4.0

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

type FilterResult added in v0.2.0

type FilterResult struct {
	Error string
}

type Plugin added in v0.2.0

func New added in v0.2.0

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

type Score added in v0.4.0

type Score struct {
	Impl ScoreImpl
}

func (Score) Client added in v0.4.0

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

func (*Score) Server added in v0.4.0

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

type ScoreImpl added in v0.5.0

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

type ScoreRPC added in v0.4.0

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

func (*ScoreRPC) Run added in v0.4.0

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

type ScoreRPCServer added in v0.4.0

type ScoreRPCServer struct {
	Impl ScoreImpl
}

func (*ScoreRPCServer) Run added in v0.4.0

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

type ScoreResult added in v0.2.0

type ScoreResult struct {
	Score int64
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL