burble/nomad-driver-containerd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

support volume_mount in task

Browse Source
This commit is contained in:
lisongmin 2021-01-03 09:34:08 +08:00
parent 4ab1c8f9ff
commit 1e9234971a
No known key found for this signature in database
GPG Key ID: 989E105F73407D49
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
containerd/driver.go
View File

@ -229,6 +229,22 @@ func NewPlugin(logger log.Logger) drivers.DriverPlugin {
} }
} }
func (tc *TaskConfig) setVolumeMounts(cfg *drivers.TaskConfig) {
for _, m := range cfg.Mounts {
hm := Mount{
Type: "bind",
Target: m.TaskPath,
Source: m.HostPath,
Options: []string{"rbind"},
}
if m.Readonly {
hm.Options = append(hm.Options, "ro")
}
tc.Mounts = append(tc.Mounts, hm)
}
}
// PluginInfo returns information describing the plugin. // PluginInfo returns information describing the plugin.
func (d *Driver) PluginInfo() (*base.PluginInfoResponse, error) { func (d *Driver) PluginInfo() (*base.PluginInfoResponse, error) {
return pluginInfo, nil return pluginInfo, nil
@ -345,6 +361,8 @@ func (d *Driver) StartTask(cfg *drivers.TaskConfig) (*drivers.TaskHandle, *drive
return nil, nil, fmt.Errorf("host_network and bridge network mode are mutually exclusive, and only one of them should be set") return nil, nil, fmt.Errorf("host_network and bridge network mode are mutually exclusive, and only one of them should be set")
} }
driverConfig.setVolumeMounts(cfg)
d.logger.Info("starting task", "driver_cfg", hclog.Fmt("%+v", driverConfig)) d.logger.Info("starting task", "driver_cfg", hclog.Fmt("%+v", driverConfig))
handle := drivers.NewTaskHandle(taskHandleVersion) handle := drivers.NewTaskHandle(taskHandleVersion)
handle.Config = cfg handle.Config = cfg