selector

Documentation

Index

• Constants
• func RunSpread(plugins func() discovery.Plugins, name plugin.Name, config *types.Any) (transport plugin.Transport, impls map[run.PluginCode]interface{}, ...)
• func RunTiered(plugins func() discovery.Plugins, name plugin.Name, config *types.Any) (transport plugin.Transport, impls map[run.PluginCode]interface{}, ...)
• func RunWeighted(plugins func() discovery.Plugins, name plugin.Name, config *types.Any) (transport plugin.Transport, impls map[run.PluginCode]interface{}, ...)

Constants

const (
	// KindWeighted is the canonical name of the plugin for starting up, etc.
	KindWeighted = "selector/weighted"

	// KindSpread is the canonical name of the plugin for starting up, etc.
	KindSpread = "selector/spread"

	// KindTiered is the canonical name of the plugin for starting up, etc.
	KindTiered = "selector/tiered"

	// EnvSpreadPlugins is the env to set to specifiy the plugins and labels
	// ex) aws/compute=a:b,x:y;gcp/compute=a:1,b:2
	EnvSpreadPlugins = "INFRAKIT_SELECTOR_SPREAD_PLUGINS"

	// EnvWeightedPlugins is the env to set to specifiy the weighting of plugins
	// ex) aws/compute=80;gcp/compute=20
	EnvWeightedPlugins = "INFRAKIT_SELECTOR_WEIGHTED_PLUGINS"

	// EnvTieredPlugins is the env to set to specifiy the ordered list of plugins
	// ex) spot/compute;ondemand/compute
	EnvTieredPlugins = "INFRAKIT_SELECTOR_TIERED_PLUGINS"
)

Functions

func RunSpread

func RunSpread(plugins func() discovery.Plugins, name plugin.Name,
	config *types.Any) (transport plugin.Transport, impls map[run.PluginCode]interface{}, onStop func(), err error)

RunSpread runs the plugin, blocking the current thread. Error is returned immediately if start fails

func RunTiered

func RunTiered(plugins func() discovery.Plugins, name plugin.Name,
	config *types.Any) (transport plugin.Transport, impls map[run.PluginCode]interface{}, onStop func(), err error)

RunTiered runs the plugin, blocking the current thread. Error is returned immediately if start fails

func RunWeighted

func RunWeighted(plugins func() discovery.Plugins, name plugin.Name,
	config *types.Any) (transport plugin.Transport, impls map[run.PluginCode]interface{}, onStop func(), err error)

RunWeighted runs the plugin, blocking the current thread. Error is returned immediately if start fails