Versions in this module Expand all Collapse all v0 v0.20.0 Jun 24, 2015 Changes in this version + const NodeStartupThreshold + var ServiceNodePortRange = util.PortRange + func BadEvents(events []*api.Event) int + func CheckCadvisorHealthOnAllNodes(c *client.Client, timeout time.Duration) + func ClusterLevelLoggingWithElasticsearch(f *Framework) + func DeleteRC(c *client.Client, ns, name string) error + func FailedContainers(pod *api.Pod) map[string]ContainerFailures + func Failf(format string, a ...interface{}) + func HighLatencyRequests(c *client.Client, threshold time.Duration, ignoredResources util.StringSet) (int, error) + func LaunchNetTestPodPerNode(f *Framework, nodes *api.NodeList, name, version string) []string + func Logf(format string, a ...interface{}) + func NodeSSHHosts(c *client.Client) ([]string, error) + func RunRC(config RCConfig) error + func SSH(cmd, host, provider string) (string, string, int, error) + func ScaleRC(c *client.Client, ns, name string, size uint) error + func ServeImageOrFail(c *client.Client, test string, image string) + type CloudConfig struct + Cluster string + ClusterTag string + MasterName string + NodeInstanceGroup string + NumNodes int + ProjectID string + Provider cloudprovider.Interface + Zone string + type ContainerFailures struct + type Framework struct + BaseName string + Client *client.Client + Namespace *api.Namespace + func NewFramework(baseName string) *Framework + func (f *Framework) TestContainerOutput(scenarioName string, pod *api.Pod, expectedOutput []string) + func (f *Framework) WaitForAnEndpoint(serviceName string) error + func (f *Framework) WaitForPodRunning(podName string) error + 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 ReadKubeletMetrics(c *client.Client, nodeName 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 LatencyMetric struct + Latency time.Duration + Quantile float64 + Resource string + Verb string + func ReadLatencyMetrics(c *client.Client) ([]LatencyMetric, error) + type LatencyMetricByLatency []LatencyMetric + func (a LatencyMetricByLatency) Len() int + func (a LatencyMetricByLatency) Less(i, j int) bool + func (a LatencyMetricByLatency) Swap(i, j int) + type PodDiff map[string]*podInfo + func Diff(oldPods []*api.Pod, curPods []*api.Pod) PodDiff + func (p PodDiff) Print(ignorePhases util.StringSet) + type RCConfig struct + Client *client.Client + CreatedPods *[]*api.Pod + Env map[string]string + Image string + Labels map[string]string + Name string + Namespace string + PodStatusFile *os.File + PollInterval time.Duration + Ports map[string]int + Replicas int + type State struct + Received map[string]int + type TestContextType struct + CertDir string + CloudConfig CloudConfig + Host string + KubeConfig string + KubeContext string + KubectlPath string + MinStartupPods int + OutputDir string + Provider string + RepoRoot string + 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
Go to main page