Documentation ¶
Index ¶
- Constants
- Variables
- 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.Interface) ([]kapi.Pod, []kapi.Pod, error)
- func GetLocalNode(kubeClient kclientset.Interface) (string, string, error)
- func GetNodes(kubeClient kclientset.Interface) ([]kapi.Node, error)
- func GetOpenShiftNetworkPlugin(osClient *osclient.Client) (string, bool, error)
- func GetSchedulableNodes(kubeClient kclientset.Interface) ([]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" NetworkDiagDefaultTestPodProtocol = string(kapi.ProtocolTCP) NetworkDiagDefaultTestPodPort = 8080 )
Variables ¶
View Source
var ( NetworkDiagDefaultPodImage = variable.DefaultImagePrefix NetworkDiagDefaultTestPodImage = variable.DefaultImagePrefix + "-deployer" )
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 ¶
Determine expected connection status for the given pods true indicates success and false means failure
func GetLocalAndNonLocalDiagnosticPods ¶
func GetLocalAndNonLocalDiagnosticPods(kubeClient kclientset.Interface) ([]kapi.Pod, []kapi.Pod, error)
Get local/non-local pods in network diagnostic namespaces
func GetLocalNode ¶
func GetLocalNode(kubeClient kclientset.Interface) (string, string, error)
func GetSchedulableNodes ¶
func GetSchedulableNodes(kubeClient kclientset.Interface) ([]kapi.Node, error)
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.Interface)
func (*LogInterface) LogServices ¶
func (l *LogInterface) LogServices()
func (*LogInterface) LogSystem ¶
func (l *LogInterface) LogSystem()
func (*LogInterface) Run ¶
func (l *LogInterface) Run(cmd, outfile string)
Click to show internal directories.
Click to hide internal directories.