rpc

Documentation

Index

• Constants
• func Connect(pluginBinary string, logger *zap.Logger) (plugin.ClientProtocol, error)
• func Serve(services *ClientServices)
• type ClientServices
• type EngineFactory
  • func NewFactory(name string, cfg config.EngineConfig, logger *zap.SugaredLogger) (*EngineFactory, error)
  • func NewFactoryFromBinary(pluginBinary string, engineCfg json.RawMessage, logger *zap.SugaredLogger) (*EngineFactory, error)
  • func (f *EngineFactory) GetExperimentManager() (manager.ExperimentManager, error)
  • func (f *EngineFactory) GetExperimentRunner() (runner.ExperimentRunner, error)

Constants

const (
	ManagerPluginIdentifier = "experiment_manager"
	RunnerPluginIdentifier  = "experiment_runner"
)

Functions

func Connect

func Connect(pluginBinary string, logger *zap.Logger) (plugin.ClientProtocol, error)

Connect returns an instance of protocol client to be used to communicate with a plugin, served over net/rpc

func Serve

func Serve(services *ClientServices)

Serve serves provided ClientServices via net/rpc

Types

type ClientServices

type ClientServices struct {
	Manager manager.ConfigurableExperimentManager
	Runner  runner.ConfigurableExperimentRunner
}

type EngineFactory

type EngineFactory struct {
	sync.Mutex

	Client       plugin.ClientProtocol
	EngineConfig json.RawMessage
	// contains filtered or unexported fields
}

EngineFactory implements experiment.EngineFactory and creates experiment manager/runner backed by net/rpc plugin implementations

func NewFactory

func NewFactory(name string, cfg config.EngineConfig, logger *zap.SugaredLogger) (*EngineFactory, error)

func NewFactoryFromBinary

func NewFactoryFromBinary(
	pluginBinary string,
	engineCfg json.RawMessage,
	logger *zap.SugaredLogger,
) (*EngineFactory, error)

func (*EngineFactory) GetExperimentManager

func (f *EngineFactory) GetExperimentManager() (manager.ExperimentManager, error)

func (*EngineFactory) GetExperimentRunner

func (f *EngineFactory) GetExperimentRunner() (runner.ExperimentRunner, error)