Versions in this module Expand all Collapse all v0 v0.1.0 Feb 3, 2016 Changes in this version + const ADD + const DEL + const NodeStartupThreshold + const UPDATE + var MaxContainerFailures = 0 + var ServiceNodePortRange = util.PortRange + func BadEvents(events []*api.Event) int + func CheckCadvisorHealthOnAllNodes(c *client.Client, timeout time.Duration) + func ClusterLevelLoggingWithElasticsearch(f *Framework) + func ClusterLevelLoggingWithKibana(f *Framework) + func CoreDump(dir string) + func DeleteRC(c *client.Client, ns, name string) error + func FailedContainers(pod *api.Pod) map[string]ContainerFailures + func Failf(format string, a ...interface{}) + func GetKubeletPods(c *client.Client, node string) (*api.PodList, error) + func HighLatencyRequests(c *client.Client) (int, error) + func LaunchHostExecPod(client *client.Client, ns, name string) *api.Pod + func LaunchNetTestPodPerNode(f *Framework, nodes *api.NodeList, name, version string) []string + func LogSSHResult(result SSHResult) + func Logf(format string, a ...interface{}) + func NewHostExecPodSpec(ns, name string) *api.Pod + func NewRestartConfig(nodeName, daemonName string, healthzPort int, ...) *restartDaemonConfig + func NodeAddresses(nodelist *api.NodeList, addrType api.NodeAddressType) []string + func NodeSSHHosts(c *client.Client) ([]string, error) + func OpenWebSocketForURL(url *url.URL, config *client.Config, protocols []string) (*websocket.Conn, error) + func ReserveCpu(f *Framework, id string, millicores int) + func ReserveMemory(f *Framework, id string, megabytes int) + func RunDeployment(config DeploymentConfig) error + func RunHostCmd(ns, name, cmd string) (string, error) + func RunHostCmdOrDie(ns, name, cmd string) string + func RunRC(config RCConfig) error + func ScaleRC(c *client.Client, ns, name string, size uint, wait bool) error + func ServeImageOrFail(f *Framework, test string, image string) + func SetTestContext(t TestContextType) + func SkipIfProviderIs(unsupportedProviders ...string) + func SkipUnlessNodeCountIsAtLeast(minNodeCount int) + func SkipUnlessProviderIs(supportedProviders ...string) + func Skipf(format string, args ...interface{}) + func VerifyPodStartupLatency(latency PodStartupLatency) error + func VerifySchedulerLatency() error + type APICall struct + Latency LatencyMetric + Resource string + Verb string + type APIResponsiveness struct + APICalls []APICall + func (a APIResponsiveness) Len() int + func (a APIResponsiveness) Less(i, j int) bool + func (a APIResponsiveness) Swap(i, j int) + type CloudConfig struct + Cluster string + ClusterTag string + MasterName string + NodeInstanceGroup string + NumNodes int + ProjectID string + Provider cloudprovider.Interface + ServiceAccount string + Zone string + type ContainerFailures struct + type DeploymentConfig struct + type Framework struct + BaseName string + Client *client.Client + Namespace *api.Namespace + NamespaceDeletionTimeout time.Duration + func NewFramework(baseName string) *Framework + func (f *Framework) ReadFileViaContainer(podName, containerName string, path string) (string, error) + func (f *Framework) TestContainerOutput(scenarioName string, pod *api.Pod, containerIndex int, expectedOutput []string) + func (f *Framework) TestContainerOutputRegexp(scenarioName string, pod *api.Pod, containerIndex int, expectedOutput []string) + func (f *Framework) WaitForAnEndpoint(serviceName string) error + func (f *Framework) WaitForPodRunning(podName string) error + func (f *Framework) WaitForPodRunningSlow(podName string) error + func (f *Framework) WriteFileViaContainer(podName, containerName string, path string, contents string) error + type KubeProxyTestConfig struct + type KubeletManagedHostConfig struct + type KubeletMetric struct + Latency time.Duration + Method string + Operation string + Quantile float64 + func HighLatencyKubeletOperations(c *client.Client, threshold time.Duration, nodeName string) ([]KubeletMetric, error) + func ParseKubeletMetrics(metricsBlob string) ([]KubeletMetric, error) + type KubeletMetricByLatency []KubeletMetric + func (a KubeletMetricByLatency) Len() int + func (a KubeletMetricByLatency) Less(i, j int) bool + func (a KubeletMetricByLatency) Swap(i, j int) + type LBCTester interface + type LatencyMetric struct + Perc50 time.Duration + Perc90 time.Duration + Perc99 time.Duration + type LogSizeGatherer struct + func (g *LogSizeGatherer) Run() + func (g *LogSizeGatherer) Work() bool + type LogsSizeData struct + func (d *LogsSizeData) AddNewData(ip, path string, timestamp time.Time, size int) + func (d *LogsSizeData) PrintData() string + type LogsSizeVerifier struct + func NewLogsVerifier(c *client.Client, stopChannel chan bool) *LogsSizeVerifier + func (v *LogsSizeVerifier) PrintData() string + func (v *LogsSizeVerifier) Run() + type PodDiff map[string]*podInfo + func Diff(oldPods []*api.Pod, curPods []*api.Pod) PodDiff + func (p PodDiff) Print(ignorePhases sets.String) + type PodStartupLatency struct + Latency LatencyMetric + type PortsByPodName map[string][]int + type PortsByPodUID map[types.UID][]int + type PrivilegedPodTestConfig struct + type RCConfig struct + Client *client.Client + Command []string + CpuLimit int64 + CpuRequest int64 + CreatedPods *[]*api.Pod + Env map[string]string + Image string + Labels map[string]string + MaxContainerFailures *int + MemLimit int64 + MemRequest int64 + Name string + Namespace string + PodStatusFile *os.File + PollInterval time.Duration + Ports map[string]int + Replicas int + Timeout time.Duration + type ResourceConsumer struct + func NewDynamicResourceConsumer(name, kind string, replicas, initCPUTotal, initMemoryTotal int, ...) *ResourceConsumer + func NewStaticResourceConsumer(name string, replicas, initCPUTotal, initMemoryTotal int, ...) *ResourceConsumer + func (rc *ResourceConsumer) CleanUp() + func (rc *ResourceConsumer) ConsumeCPU(millicores int) + func (rc *ResourceConsumer) ConsumeMem(megabytes int) + func (rc *ResourceConsumer) EnsureDesiredReplicas(desiredReplicas int, timeout time.Duration) + func (rc *ResourceConsumer) GetReplicas() int + func (rc *ResourceConsumer) WaitForReplicas(desiredReplicas int) + type SSHResult struct + Cmd string + Code int + Host string + Stderr string + Stdout string + User string + func SSH(cmd, host, provider string) (SSHResult, error) + type SchedulingLatency struct + Binding LatencyMetric + Scheduling LatencyMetric + Total LatencyMetric + type State struct + Received map[string]int + type TestContextType struct + CertDir string + CleanStart bool + CloudConfig CloudConfig + DeleteNamespace bool + GatherKubeSystemResourceUsageData bool + GatherLogsSizes bool + Host string + KubeConfig string + KubeContext string + KubectlPath string + MinStartupPods int + OutputDir string + PrometheusPushGateway string + Provider string + RepoRoot string + UpgradeTarget string + VerifyServiceAccount bool + type TimestampedSize struct + type VolumeTestConfig struct + type WebserverTest struct + Client *client.Client + Labels map[string]string + Namespace string + ServiceName string + TestId string + func NewWebserverTest(client *client.Client, namespace string, serviceName string) *WebserverTest + func (t *WebserverTest) BuildServiceSpec() *api.Service + func (t *WebserverTest) Cleanup() []error + func (t *WebserverTest) CreateService(service *api.Service) (*api.Service, error) + func (t *WebserverTest) CreateWebserverRC(replicas int) *api.ReplicationController + func (t *WebserverTest) DeleteService(serviceName string) error + type WorkItem struct
Go to main page