mirror of
https://github.com/kemko/nomad.git
synced 2026-01-01 16:05:42 +03:00
drivers: fix func naming
This commit is contained in:
@@ -271,7 +271,7 @@ func (d *Driver) RecoverTask(handle *drivers.TaskHandle) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return d.recoverPre09task(handle.Config, reattachConfig)
|
||||
return d.recoverPre09Task(handle.Config, reattachConfig)
|
||||
}
|
||||
|
||||
// If already attached to handle there's nothing to recover.
|
||||
|
||||
@@ -10,7 +10,7 @@ import (
|
||||
"github.com/hashicorp/nomad/plugins/drivers"
|
||||
)
|
||||
|
||||
func (d *Driver) recoverPre09task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
func (d *Driver) recoverPre09Task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
config.ID = fmt.Sprintf("pre09-%s", uuid.Generate())
|
||||
exec, pluginClient, err := executor.ReattachToPre09Executor(reattach,
|
||||
d.logger.With("task_name", config.Name, "alloc_id", config.AllocID))
|
||||
|
||||
@@ -259,7 +259,7 @@ func (d *Driver) RecoverTask(handle *drivers.TaskHandle) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return d.recoverPre09task(handle.Config, reattachConfig)
|
||||
return d.recoverPre09Task(handle.Config, reattachConfig)
|
||||
}
|
||||
|
||||
// If already attached to handle there's nothing to recover.
|
||||
|
||||
@@ -10,7 +10,7 @@ import (
|
||||
"github.com/hashicorp/nomad/plugins/drivers"
|
||||
)
|
||||
|
||||
func (d *Driver) recoverPre09task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
func (d *Driver) recoverPre09Task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
config.ID = fmt.Sprintf("pre09-%s", uuid.Generate())
|
||||
exec, pluginClient, err := executor.ReattachToPre09Executor(reattach,
|
||||
d.logger.With("task_name", config.Name, "alloc_id", config.AllocID))
|
||||
|
||||
@@ -257,7 +257,7 @@ func (d *Driver) RecoverTask(handle *drivers.TaskHandle) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return d.recoverPre09task(handle.Config, reattachConfig)
|
||||
return d.recoverPre09Task(handle.Config, reattachConfig)
|
||||
}
|
||||
|
||||
// If already attached to handle there's nothing to recover.
|
||||
|
||||
@@ -10,7 +10,7 @@ import (
|
||||
"github.com/hashicorp/nomad/plugins/drivers"
|
||||
)
|
||||
|
||||
func (d *Driver) recoverPre09task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
func (d *Driver) recoverPre09Task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
config.ID = fmt.Sprintf("pre09-%s", uuid.Generate())
|
||||
exec, pluginClient, err := executor.ReattachToPre09Executor(reattach,
|
||||
d.logger.With("task_name", config.Name, "alloc_id", config.AllocID))
|
||||
|
||||
@@ -263,7 +263,7 @@ func (d *Driver) RecoverTask(handle *drivers.TaskHandle) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return d.recoverPre0_9Task(handle.Config, reattachConfig)
|
||||
return d.recoverPre09Task(handle.Config, reattachConfig)
|
||||
}
|
||||
|
||||
// If already attached to handle there's nothing to recover.
|
||||
|
||||
@@ -10,7 +10,7 @@ import (
|
||||
"github.com/hashicorp/nomad/plugins/drivers"
|
||||
)
|
||||
|
||||
func (d *Driver) recoverPre09task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
func (d *Driver) recoverPre09Task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
config.ID = fmt.Sprintf("pre09-%s", uuid.Generate())
|
||||
exec, pluginClient, err := executor.ReattachToPre09Executor(reattach,
|
||||
d.logger.With("task_name", config.Name, "alloc_id", config.AllocID))
|
||||
|
||||
@@ -370,7 +370,7 @@ func (d *Driver) RecoverTask(handle *drivers.TaskHandle) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return d.recoverPre09task(handle.Config, reattachConfig)
|
||||
return d.recoverPre09Task(handle.Config, reattachConfig)
|
||||
}
|
||||
|
||||
// If already attached to handle there's nothing to recover.
|
||||
|
||||
@@ -10,7 +10,7 @@ import (
|
||||
"github.com/hashicorp/nomad/plugins/drivers"
|
||||
)
|
||||
|
||||
func (d *Driver) recoverPre09task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
func (d *Driver) recoverPre09Task(config *drivers.TaskConfig, reattach *plugin.ReattachConfig) error {
|
||||
config.ID = fmt.Sprintf("pre09-%s", uuid.Generate())
|
||||
exec, pluginClient, err := executor.ReattachToPre09Executor(reattach,
|
||||
d.logger.With("task_name", config.Name, "alloc_id", config.AllocID))
|
||||
|
||||
Reference in New Issue
Block a user