drivers: fix func naming
This commit is contained in:
parent
80c90ef745
commit
9eabf0f2c7
|
@ -235,7 +235,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))
|
||||
|
|
|
@ -360,7 +360,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))
|
||||
|
|
Loading…
Reference in New Issue