util

package

v3.6.0-alpha.2+incompa... Latest Latest Go to latest Published: Jun 7, 2017 License: Apache-2.0 Imports: 20 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
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 ¶

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 GetNodes ¶

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

func GetOpenShiftNetworkPlugin ¶

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

func GetSchedulableNodes ¶

func GetSchedulableNodes(kubeClient kclientset.Interface) ([]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.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)

Source Files ¶

log.go
util.go

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