mv node.go

liqotech · Aug 2, 2021 · 5c76a80 · 5c76a80
1 parent d993df0
commit 5c76a80
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/pkg/virtualKubelet/node/provider/node.go → cmd/virtual-kubelet/root/node.go b/pkg/virtualKubelet/node/provider/node.go → cmd/virtual-kubelet/root/node.go
@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package provider
+package root
 
 import (
 	"context"

diff --git a/cmd/virtual-kubelet/root/opts.go b/cmd/virtual-kubelet/root/opts.go
@@ -20,6 +20,7 @@ import (
 	"time"
 
 	"github.com/pkg/errors"
+	corev1 "k8s.io/api/core/v1"
 
 	"github.com/liqotech/liqo/pkg/consts"
 )
@@ -34,6 +35,11 @@ const (
 	DefaultPodSyncWorkers                         = 10
 	DefaultKubeClusterDomain                      = "cluster.local"
 
+	DefaultTaintEffect           = string(corev1.TaintEffectNoSchedule)
+	DefaultTaintKey              = "virtual-kubelet.io/provider"
+	DefaultStreamIdleTimeout     = 30 * time.Second
+	DefaultStreamCreationTimeout = 30 * time.Second
+
 	DefaultKubeletNamespace = "default"
 	DefaultHomeClusterID    = "cluster1"
 	DefaultLiqoIpamServer   = consts.NetworkManagerServiceName

diff --git a/cmd/virtual-kubelet/root/root.go b/cmd/virtual-kubelet/root/root.go
@@ -44,7 +44,6 @@ import (
 	"github.com/liqotech/liqo/pkg/virtualKubelet"
 	liqonodeprovider "github.com/liqotech/liqo/pkg/virtualKubelet/liqoNodeProvider"
 	"github.com/liqotech/liqo/pkg/virtualKubelet/manager"
-	nodeProvider "github.com/liqotech/liqo/pkg/virtualKubelet/node/provider"
 	liqoprovider "github.com/liqotech/liqo/pkg/virtualKubelet/provider"
 )
 
@@ -145,7 +144,7 @@ func runRootCommand(ctx context.Context, s *provider.Store, c *Opts) error {
 
 	var nodeRunner *module.NodeController
 
-	pNode, err := nodeProvider.NodeFromProvider(ctx, c.NodeName, p, c.Version, []metav1.OwnerReference{})
+	pNode, err := NodeFromProvider(ctx, c.NodeName, p, c.Version, []metav1.OwnerReference{})
 	if err != nil {
 		klog.Fatal(err)
 	}