util

package

v1.5.0-alpha.1 Latest Latest Go to latest Published: Dec 29, 2016 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitproxy.zycloud.tk/openshift/origin

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Execute(factory *osclientcmd.Factory, command []string, pod *kapi.Pod, in io.Reader, ...) error
func ExpectedConnectionStatus(ns1, ns2 string, vnidMap map[string]uint32) bool
func GetGlobalAndNonGlobalPods(pods []kapi.Pod, vnidMap map[string]uint32) ([]kapi.Pod, []kapi.Pod)
func GetLocalAndNonLocalDiagnosticPods(kubeClient *kclientset.Clientset) ([]kapi.Pod, []kapi.Pod, error)
func GetLocalNode(kubeClient *kclientset.Clientset) (string, string, error)
func GetNodes(kubeClient *kclientset.Clientset) ([]kapi.Node, error)
func GetOpenShiftNetworkPlugin(osClient *osclient.Client) (string, bool, error)
func GetSchedulableNodes(kubeClient *kclientset.Clientset) ([]kapi.Node, error)
func PrintPod(pod *kapi.Pod) string
type LogInterface

Constants ¶

View Source

const (
	NetworkDiagNamespacePrefix       = "network-diag-ns"
	NetworkDiagGlobalNamespacePrefix = "network-diag-global-ns"
	NetworkDiagPodNamePrefix         = "network-diag-pod"
	NetworkDiagSCCNamePrefix         = "network-diag-privileged"
	NetworkDiagSecretName            = "network-diag-secret"

	NetworkDiagTestPodNamePrefix     = "network-diag-test-pod"
	NetworkDiagTestServiceNamePrefix = "network-diag-test-service"
	NetworkDiagContainerMountPath    = "/host"
	NetworkDiagDefaultLogDir         = "/tmp/openshift/"
	NetworkDiagNodeLogDirPrefix      = "/nodes"
	NetworkDiagMasterLogDirPrefix    = "/master"
	NetworkDiagPodLogDirPrefix       = "/pods"
)

Variables ¶

This section is empty.

Functions ¶

func Execute ¶

func Execute(factory *osclientcmd.Factory, command []string, pod *kapi.Pod, in io.Reader, out, errOut io.Writer) error

Execute() will run a command in a pod and streams the out/err

func ExpectedConnectionStatus ¶

func ExpectedConnectionStatus(ns1, ns2 string, vnidMap map[string]uint32) bool

Determine expected connection status for the given pods true indicates success and false means failure

func GetGlobalAndNonGlobalPods ¶

func GetGlobalAndNonGlobalPods(pods []kapi.Pod, vnidMap map[string]uint32) ([]kapi.Pod, []kapi.Pod)

func GetLocalAndNonLocalDiagnosticPods ¶

func GetLocalAndNonLocalDiagnosticPods(kubeClient *kclientset.Clientset) ([]kapi.Pod, []kapi.Pod, error)

Get local/non-local pods in network diagnostic namespaces

func GetLocalNode ¶

func GetLocalNode(kubeClient *kclientset.Clientset) (string, string, error)

func GetNodes ¶

func GetNodes(kubeClient *kclientset.Clientset) ([]kapi.Node, error)

func GetOpenShiftNetworkPlugin ¶

func GetOpenShiftNetworkPlugin(osClient *osclient.Client) (string, bool, error)

func GetSchedulableNodes ¶

func GetSchedulableNodes(kubeClient *kclientset.Clientset) ([]kapi.Node, error)

func PrintPod ¶

func PrintPod(pod *kapi.Pod) string

Types ¶

type LogInterface ¶

type LogInterface struct {
	Result types.DiagnosticResult
	Logdir string
}

func (*LogInterface) LogMaster ¶

func (l *LogInterface) LogMaster()

func (*LogInterface) LogNode ¶

func (l *LogInterface) LogNode(kubeClient *kclientset.Clientset)

func (*LogInterface) LogServices ¶

func (l *LogInterface) LogServices()

func (*LogInterface) LogSystem ¶

func (l *LogInterface) LogSystem()

func (*LogInterface) Run ¶

func (l *LogInterface) Run(cmd, outfile string)

Source Files ¶

log.go
util.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL