Add exports to proxy plugin config
Allows external plugins to define exports. Signed-off-by: Derek McGowan <derek@mcg.dev>
This commit is contained in:
parent
aef2ebc76a
commit
e4639ad18b
@ -235,9 +235,10 @@ type CgroupConfig struct {
|
||||
|
||||
// ProxyPlugin provides a proxy plugin configuration
|
||||
type ProxyPlugin struct {
|
||||
Type string `toml:"type"`
|
||||
Address string `toml:"address"`
|
||||
Platform string `toml:"platform"`
|
||||
Type string `toml:"type"`
|
||||
Address string `toml:"address"`
|
||||
Platform string `toml:"platform"`
|
||||
Exports map[string]string `toml:"exports"`
|
||||
}
|
||||
|
||||
// Decode unmarshals a plugin specific configuration by plugin id
|
||||
|
@ -491,11 +491,17 @@ func LoadPlugins(ctx context.Context, config *srvconfig.Config) ([]plugin.Regist
|
||||
p = platforms.DefaultSpec()
|
||||
}
|
||||
|
||||
exports := pp.Exports
|
||||
if exports == nil {
|
||||
exports = map[string]string{}
|
||||
}
|
||||
exports["address"] = address
|
||||
|
||||
registry.Register(&plugin.Registration{
|
||||
Type: t,
|
||||
ID: name,
|
||||
InitFn: func(ic *plugin.InitContext) (interface{}, error) {
|
||||
ic.Meta.Exports["address"] = address
|
||||
ic.Meta.Exports = exports
|
||||
ic.Meta.Platforms = append(ic.Meta.Platforms, p)
|
||||
conn, err := clients.getClient(address)
|
||||
if err != nil {
|
||||
|
Loading…
Reference in New Issue
Block a user