remove old state hook code
This commit is contained in:
parent
cd7c5cb61d
commit
b3795e2d29
|
@ -1,33 +0,0 @@
|
||||||
package command
|
|
||||||
|
|
||||||
import (
|
|
||||||
"sync"
|
|
||||||
|
|
||||||
"github.com/hashicorp/terraform/state"
|
|
||||||
"github.com/hashicorp/terraform/terraform"
|
|
||||||
)
|
|
||||||
|
|
||||||
// StateHook is a hook that continuously updates the state by calling
|
|
||||||
// WriteState on a state.State.
|
|
||||||
type StateHook struct {
|
|
||||||
terraform.NilHook
|
|
||||||
sync.Mutex
|
|
||||||
|
|
||||||
State state.State
|
|
||||||
}
|
|
||||||
|
|
||||||
func (h *StateHook) PostStateUpdate(
|
|
||||||
s *terraform.State) (terraform.HookAction, error) {
|
|
||||||
h.Lock()
|
|
||||||
defer h.Unlock()
|
|
||||||
|
|
||||||
if h.State != nil {
|
|
||||||
// Write the new state
|
|
||||||
if err := h.State.WriteState(s); err != nil {
|
|
||||||
return terraform.HookActionHalt, err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Continue forth
|
|
||||||
return terraform.HookActionContinue, nil
|
|
||||||
}
|
|
|
@ -1,29 +0,0 @@
|
||||||
package command
|
|
||||||
|
|
||||||
import (
|
|
||||||
"testing"
|
|
||||||
|
|
||||||
"github.com/hashicorp/terraform/state"
|
|
||||||
"github.com/hashicorp/terraform/terraform"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestStateHook_impl(t *testing.T) {
|
|
||||||
var _ terraform.Hook = new(StateHook)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestStateHook(t *testing.T) {
|
|
||||||
is := &state.InmemState{}
|
|
||||||
var hook terraform.Hook = &StateHook{State: is}
|
|
||||||
|
|
||||||
s := state.TestStateInitial()
|
|
||||||
action, err := hook.PostStateUpdate(s)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("err: %s", err)
|
|
||||||
}
|
|
||||||
if action != terraform.HookActionContinue {
|
|
||||||
t.Fatalf("bad: %v", action)
|
|
||||||
}
|
|
||||||
if !is.State().Equal(s) {
|
|
||||||
t.Fatalf("bad state: %#v", is.State())
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in New Issue