Function TestStatusManager_InitialState

status_manager_test.go:100–118

(t *testing.T)

}

func TestStatusManager_InitialState(t *testing.T) {
	sm := NewStatusManager(DefaultStatusManagerConfig())

	if sm.isClosingOrClosed() {
		t.Fatal("expected StatusManager to start open for work")
	}

	select {
	case <-sm.closedCh:
		t.Fatal("expected closedCh to remain open before Close()")
	default:
	}

	select {
	case <-sm.Context().Done():
		t.Fatal("expected Context to not be cancelled before Close()")
	default:
	}
}

func TestStatusManager_StartRollbackOnFailure(t *testing.T) {
	sm := NewStatusManager(DefaultStatusManagerConfig())