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.Interface) ([]kapi.Pod, []kapi.Pod, error)
- func GetLocalNode(kubeClient kclientset.Interface) (string, string, error)
- func GetNetworkDiagDefaultPodImage() string
- func GetNetworkDiagDefaultTestPodImage() string
- func GetNodes(kubeClient kclientset.Interface) ([]kapi.Node, error)
- func GetOpenShiftNetworkPlugin(clusterNetworkClient networktypedclient.ClusterNetworksGetter) (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 ¶
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.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 GetNetworkDiagDefaultPodImage ¶
func GetNetworkDiagDefaultPodImage() string
func GetNetworkDiagDefaultTestPodImage ¶
func GetNetworkDiagDefaultTestPodImage() string
func GetOpenShiftNetworkPlugin ¶
func GetOpenShiftNetworkPlugin(clusterNetworkClient networktypedclient.ClusterNetworksGetter) (string, bool, error)
func GetSchedulableNodes ¶
func GetSchedulableNodes(kubeClient kclientset.Interface) ([]kapi.Node, error)
Types ¶
type LogInterface ¶
type LogInterface struct {
Result types.DiagnosticResult
Logdir string
}
func (*LogInterface) LogServices ¶
func (l *LogInterface) LogServices()
Source Files
Click to show internal directories.
Click to hide internal directories.