new file mode 100644

@@ -0,0 +1,57 @@

+package network

+

+import (

+	"errors"

+	"fmt"

+	"path/filepath"

+

+	kclient "k8s.io/kubernetes/pkg/client/unversioned"

+

+	"github.com/openshift/origin/pkg/diagnostics/networkpod/util"

+	"github.com/openshift/origin/pkg/diagnostics/types"

+)

+

+const (

+	CollectNetworkInfoName = "CollectNetworkInfo"

+)

+

+// CollectNetworkInfo is a Diagnostic to collect network information in the cluster.

+type CollectNetworkInfo struct {

+	KubeClient *kclient.Client

+}

+

+// Name is part of the Diagnostic interface and just returns name.

+func (d CollectNetworkInfo) Name() string {

+	return CollectNetworkInfoName

+}

+

+// Description is part of the Diagnostic interface and just returns the diagnostic description.

+func (d CollectNetworkInfo) Description() string {

+	return "Collect network information in the cluster."

+}

+

+// CanRun is part of the Diagnostic interface; it determines if the conditions are right to run this diagnostic.

+func (d CollectNetworkInfo) CanRun() (bool, error) {

+	if d.KubeClient == nil {

+		return false, errors.New("must have kube client")

+	}

+	return true, nil

+}

+

+// Check is part of the Diagnostic interface; it runs the actual diagnostic logic

+func (d CollectNetworkInfo) Check() types.DiagnosticResult {

+	r := types.NewDiagnosticResult(CollectNetworkInfoName)

+

+	nodeName, _, err := util.GetLocalNode(d.KubeClient)

+	if err != nil {

+		r.Error("DColNet1001", err, fmt.Sprintf("Fetching local node info failed: %s", err))

+		return r

+	}

+

+	l := util.LogInterface{

+		Result: r,

+		Logdir: filepath.Join(util.NetworkDiagDefaultLogDir, util.NetworkDiagNodeLogDirPrefix, nodeName),

+	}

+	l.LogNode(d.KubeClient)

+	return r

+}