Documentation
¶
Index ¶
- func AddLabelsToNode(c clientset.Interface, nodeName string, labels map[string]string) error
- func DoCleanupNode(client clientset.Interface, nodeName string, strategy PrepareNodeStrategy) error
- func DoPrepareNode(client clientset.Interface, node *api.Node, strategy PrepareNodeStrategy) error
- func FailedContainers(pod *api.Pod) map[string]ContainerFailures
- func MakeTempDirOrDie(prefix string, baseDir string) string
- func PodNotReady(p *api.Pod) (bool, error)
- func PodReady(pod *api.Pod) bool
- func PodRunningReady(p *api.Pod) (bool, error)
- func PodRunningReadyOrSucceeded(p *api.Pod) (bool, error)
- func RemoveLabelOffNode(c clientset.Interface, nodeName string, labelKeys []string) error
- func RunDeployment(config DeploymentConfig) error
- func RunRC(config RCConfig) error
- func RunReplicaSet(config ReplicaSetConfig) error
- func StartPods(c clientset.Interface, replicas int, namespace string, podNamePrefix string, ...) error
- func VerifyLabelsRemoved(c clientset.Interface, nodeName string, labelKeys []string) error
- func WaitForPodsWithLabelRunning(c clientset.Interface, ns string, label labels.Selector) error
- type ContainerFailures
- type CountToPodStrategy
- type CountToStrategy
- type DeploymentConfig
- type PodDiff
- type PodStore
- type PrepareNodeStrategy
- type RCConfig
- type RCStartupStatus
- type ReplicaSetConfig
- type TestNodePreparer
- type TestPodCreateStrategy
- type TestPodCreator
- type TestPodCreatorConfig
- type TrivialNodePrepareStrategy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddLabelsToNode ¶ added in v1.5.0
func DoCleanupNode ¶ added in v1.5.0
func DoCleanupNode(client clientset.Interface, nodeName string, strategy PrepareNodeStrategy) error
func DoPrepareNode ¶ added in v1.5.0
func FailedContainers ¶ added in v1.4.6
func FailedContainers(pod *api.Pod) map[string]ContainerFailures
FailedContainers inspects all containers in a pod and returns failure information for containers that have failed or been restarted. A map is returned where the key is the containerID and the value is a struct containing the restart and failure information
func MakeTempDirOrDie ¶
func PodNotReady ¶ added in v1.4.6
PodNotReady checks whether pod p's has a ready condition of status false.
func PodReady ¶ added in v1.4.6
podReady returns whether pod has a condition of Ready with a status of true. TODO: should be replaced with api.IsPodReady
func PodRunningReady ¶ added in v1.4.6
PodRunningReady checks whether pod p's phase is running and it has a ready condition of status true.
func PodRunningReadyOrSucceeded ¶ added in v1.4.6
func RemoveLabelOffNode ¶ added in v1.5.0
RemoveLabelOffNode is for cleaning up labels temporarily added to node, won't fail if target label doesn't exist or has been removed.
func RunDeployment ¶ added in v1.5.0
func RunDeployment(config DeploymentConfig) error
RunDeployment Launches (and verifies correctness) of a Deployment and will wait for all pods it spawns to become "Running". It's the caller's responsibility to clean up externally (i.e. use the namespace lifecycle for handling Cleanup).
func RunRC ¶ added in v1.5.0
RunRC Launches (and verifies correctness) of a Replication Controller and will wait for all pods it spawns to become "Running". It's the caller's responsibility to clean up externally (i.e. use the namespace lifecycle for handling Cleanup).
func RunReplicaSet ¶ added in v1.5.0
func RunReplicaSet(config ReplicaSetConfig) error
RunReplicaSet launches (and verifies correctness) of a ReplicaSet and waits until all the pods it launches to reach the "Running" state. It's the caller's responsibility to clean up externally (i.e. use the namespace lifecycle for handling Cleanup).
func StartPods ¶ added in v1.5.0
func StartPods(c clientset.Interface, replicas int, namespace string, podNamePrefix string, pod api.Pod, waitForRunning bool, logFunc func(fmt string, args ...interface{})) error
Simplified version of RunRC, that does not create RC, but creates plain Pods. Optionally waits for pods to start running (if waitForRunning == true). The number of replicas must be non-zero.
func VerifyLabelsRemoved ¶ added in v1.5.0
VerifyLabelsRemoved checks if Node for given nodeName does not have any of labels from labelKeys. Return non-nil error if it does.
Types ¶
type ContainerFailures ¶ added in v1.4.6
type ContainerFailures struct { Restarts int // contains filtered or unexported fields }
type CountToPodStrategy ¶ added in v1.5.0
type CountToPodStrategy struct { Count int Strategy TestPodCreateStrategy }
type CountToStrategy ¶ added in v1.5.0
type CountToStrategy struct { Count int Strategy PrepareNodeStrategy }
type DeploymentConfig ¶ added in v1.5.0
type DeploymentConfig struct {
RCConfig
}
type PodDiff ¶ added in v1.5.0
type PodDiff map[string]*podInfo
PodDiff is a map of pod name to podInfos
type PodStore ¶ added in v1.5.0
type PodStore struct { cache.Store Reflector *cache.Reflector // contains filtered or unexported fields }
Convenient wrapper around cache.Store that returns list of api.Pod instead of interface{}.
func NewPodStore ¶ added in v1.5.0
type PrepareNodeStrategy ¶ added in v1.5.0
type RCConfig ¶ added in v1.5.0
type RCConfig struct { Client clientset.Interface Image string Command []string Name string Namespace string PollInterval time.Duration Timeout time.Duration PodStatusFile *os.File Replicas int CpuRequest int64 // millicores CpuLimit int64 // millicores MemRequest int64 // bytes MemLimit int64 // bytes ReadinessProbe *api.Probe DNSPolicy *api.DNSPolicy // Env vars, set the same for every pod. Env map[string]string // Extra labels added to every pod. Labels map[string]string // Node selector for pods in the RC. NodeSelector map[string]string // Ports to declare in the container (map of name to containerPort). Ports map[string]int // Ports to declare in the container as host and container ports. HostPorts map[string]int Volumes []api.Volume VolumeMounts []api.VolumeMount // Pointer to a list of pods; if non-nil, will be set to a list of pods // created by this RC by RunRC. CreatedPods *[]*api.Pod // Maximum allowable container failures. If exceeded, RunRC returns an error. // Defaults to replicas*0.1 if unspecified. MaxContainerFailures *int // If set to false starting RC will print progress, otherwise only errors will be printed. Silent bool // If set this function will be used to print log lines instead of glog. LogFunc func(fmt string, args ...interface{}) // If set those functions will be used to gather data from Nodes - in integration tests where no // kubelets are running those variables should be nil. NodeDumpFunc func(c clientset.Interface, nodeNames []string, logFunc func(fmt string, args ...interface{})) ContainerDumpFunc func(c clientset.Interface, ns string, logFunc func(ftm string, args ...interface{})) }
func (*RCConfig) RCConfigLog ¶ added in v1.5.0
type RCStartupStatus ¶ added in v1.5.0
type RCStartupStatus struct { Expected int Terminating int Running int RunningButNotReady int Waiting int Pending int Unknown int Inactive int FailedContainers int Created []*api.Pod ContainerRestartNodes sets.String }
func ComputeRCStartupStatus ¶ added in v1.5.0
func ComputeRCStartupStatus(pods []*api.Pod, expected int) RCStartupStatus
func (*RCStartupStatus) String ¶ added in v1.5.0
func (s *RCStartupStatus) String(name string) string
type ReplicaSetConfig ¶ added in v1.5.0
type ReplicaSetConfig struct {
RCConfig
}
type TestNodePreparer ¶ added in v1.5.0
type TestPodCreateStrategy ¶ added in v1.5.0
func NewCustomCreatePodStrategy ¶ added in v1.5.0
func NewCustomCreatePodStrategy(podTemplate *api.Pod) TestPodCreateStrategy
func NewSimpleCreatePodStrategy ¶ added in v1.5.0
func NewSimpleCreatePodStrategy() TestPodCreateStrategy
func NewSimpleWithControllerCreatePodStrategy ¶ added in v1.5.0
func NewSimpleWithControllerCreatePodStrategy(controllerName string) TestPodCreateStrategy
type TestPodCreator ¶ added in v1.5.0
type TestPodCreator struct { Client clientset.Interface // namespace -> count -> strategy Config *TestPodCreatorConfig }
func NewTestPodCreator ¶ added in v1.5.0
func NewTestPodCreator(client clientset.Interface, config *TestPodCreatorConfig) *TestPodCreator
func (*TestPodCreator) CreatePods ¶ added in v1.5.0
func (c *TestPodCreator) CreatePods() error
type TestPodCreatorConfig ¶ added in v1.5.0
type TestPodCreatorConfig map[string][]CountToPodStrategy
func NewTestPodCreatorConfig ¶ added in v1.5.0
func NewTestPodCreatorConfig() *TestPodCreatorConfig
func (*TestPodCreatorConfig) AddStrategy ¶ added in v1.5.0
func (c *TestPodCreatorConfig) AddStrategy( namespace string, podCount int, strategy TestPodCreateStrategy)
type TrivialNodePrepareStrategy ¶ added in v1.5.0
type TrivialNodePrepareStrategy struct{}
func (*TrivialNodePrepareStrategy) CleanupNode ¶ added in v1.5.0
func (*TrivialNodePrepareStrategy) CleanupNode(node *api.Node) *api.Node
func (*TrivialNodePrepareStrategy) PreparePatch ¶ added in v1.5.0
func (*TrivialNodePrepareStrategy) PreparePatch(*api.Node) []byte