Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

k8s

package

Go to main page

Versions in this module

v1

v1.7.0-alpha.3

Dec 10, 2024

v1.7.0-alpha.2

Nov 11, 2024

v1.7.0-alpha.1

Aug 28, 2024

v1.6.0

May 24, 2024

Changes in this version

+ const AllContainers

+ const ClaimProvisionShortTimeout

+ const ClaimProvisionTimeout

+ const DefaultNamespaceDeletionTimeout

+ const DefaultNumNodes

+ const DefaultPodDeletionTimeout

+ const KubeControllerManagerPort

+ const KubeletPort

+ const NodeReadyInitialTimeout

+ const PodDeleteTimeout

+ const PodEventTimeout

+ const PodGetTimeout

+ const PodListTimeout

+ const PodReadyBeforeTimeout

+ const PodStartShortTimeout

+ const PodStartTimeout

+ const Poll

+ const PollShortTimeout

+ const RestartNodeReadyAgainTimeout

+ const RestartPodReadyAgainTimeout

+ const ServiceAccountProvisionTimeout

+ const ServiceStartTimeout

+ const SingleCallTimeout

+ const SnapshotCreateTimeout

+ const SnapshotDeleteTimeout

+ var ImagePrePullList sets.String

+ var ProvidersWithSSH = []string

+ var RunID = uuid.NewUUID()

+ func APIAddress() string

+ func AfterReadingAllFlags(t *TestContextType)

+ func AllNodesReady(c clientset.Interface, timeout time.Duration) error

+ func CheckTestingNSDeletedExcept(c clientset.Interface, skip string) error

+ func ConformanceIt(text string, body interface{}, timeout ...float64) bool

+ func CoreDump(dir string)

+ func CreateTestingNS(baseName string, c clientset.Interface, labels map[string]string) (*v1.Namespace, error)

+ func DeleteNamespaces(c clientset.Interface, deleteFilter, skipFilter []string) ([]string, error)

+ func DumpAllNamespaceInfo(c clientset.Interface, namespace string)

+ func DumpNodeDebugInfo(c clientset.Interface, nodeNames []string, ...)

+ func ExpectConsistOf(actual interface{}, extra interface{}, explain ...interface{})

+ func ExpectEmpty(actual interface{}, explain ...interface{})

+ func ExpectEqual(actual interface{}, extra interface{}, explain ...interface{})

+ func ExpectError(err error, explain ...interface{})

+ func ExpectHaveKey(actual interface{}, key interface{}, explain ...interface{})

+ func ExpectNoError(err error, explain ...interface{})

+ func ExpectNoErrorWithOffset(offset int, err error, explain ...interface{})

+ func ExpectNotEqual(actual interface{}, extra interface{}, explain ...interface{})

+ func GenerateSecureToken(tokenLen int) (string, error)

+ func GetProviders() []string

+ func LoadClientset() (*clientset.Clientset, error)

+ func LoadConfig() (config *restclient.Config, err error)

+ func MasterOSDistroIs(supportedMasterOsDistros ...string) bool

+ func NodeOSArchIs(supportedNodeOsArchs ...string) bool

+ func NodeOSDistroIs(supportedNodeOsDistros ...string) bool

+ func PrettyPrintJSON(metrics interface{}) string

+ func ProviderIs(providers ...string) bool

+ func RandomSuffix() string

+ func RegisterClusterFlags(flags *flag.FlagSet)

+ func RegisterCommonFlags(flags *flag.FlagSet)

+ func RegisterProvider(name string, factory Factory)

+ func RemoveCleanupAction(p CleanupActionHandle)

+ func RunCleanupActions()

+ func RunHostCmd(ns, name, cmd string) (string, error)

+ func RunKubectl(namespace string, args ...string) (string, error)

+ func WaitForAllNodesSchedulable(c clientset.Interface, timeout time.Duration) error

+ func WaitForDefaultServiceAccountInNamespace(c clientset.Interface, namespace string) error

+ func WaitForKubeRootCAInNamespace(c clientset.Interface, namespace string) error

+ func WaitForNamespacesDeleted(c clientset.Interface, namespaces []string, timeout time.Duration) error

+ func WaitForServiceEndpointsNum(c clientset.Interface, namespace, serviceName string, expectNum int, ...) error

+ type AfterEachActionFunc func(f *Framework, failed bool)

+ type CleanupActionHandle *int

+ func AddCleanupAction(fn func()) CleanupActionHandle

+ type ClientConfigGetter func() (*restclient.Config, error)

+ type CloudConfig struct

+ APIEndpoint string

+ Cluster string

+ ClusterIPRange string

+ ClusterTag string

+ ConfigFile string

+ MasterName string

+ MasterTag string

+ MultiMaster bool

+ MultiZone bool

+ Network string

+ NodeInstanceGroup string

+ NodeTag string

+ NumNodes int

+ ProjectID string

+ Provider ProviderInterface

+ Region string

+ Zone string

+ Zones []string

+ type ClusterVerification struct

+ func (cl *ClusterVerification) ForEach(podFunc func(v1.Pod)) error

+ func (cl *ClusterVerification) WaitFor(atLeast int, timeout time.Duration) ([]v1.Pod, error)

+ func (cl *ClusterVerification) WaitForOrFail(atLeast int, timeout time.Duration)

+ type ContainerResourceGatherer struct

+ func NewResourceUsageGatherer(c clientset.Interface, options ResourceGathererOptions, pods *v1.PodList) (*ContainerResourceGatherer, error)

+ func (g *ContainerResourceGatherer) StartGatheringData()

+ func (g *ContainerResourceGatherer) StopAndSummarize(percentiles []int, constraints map[string]ResourceConstraint) (*ResourceUsageSummary, error)

+ type ContainerResourceUsage struct

+ CPUInterval time.Duration

+ CPUUsageInCores float64

+ MemoryRSSInBytes uint64

+ MemoryUsageInBytes uint64

+ MemoryWorkingSetInBytes uint64

+ Name string

+ Timestamp time.Time

+ type ContainerType int

+ const Containers

+ const EphemeralContainers

+ const FeatureEphemeralContainers

+ const InitContainers

+ type ContainerVisitor func(container *v1.Container, containerType ContainerType) (shouldContinue bool)

+ type CreateTestingNSFn func(baseName string, c clientset.Interface, labels map[string]string) (*v1.Namespace, error)

+ type EventsLister func(opts metav1.ListOptions, ns string) (*v1.EventList, error)

+ type ExecOptions struct

+ CaptureStderr bool

+ CaptureStdout bool

+ Command []string

+ ContainerName string

+ Namespace string

+ PodName string

+ PreserveWhitespace bool

+ Quiet bool

+ Stdin io.Reader

+ type Factory func() (ProviderInterface, error)

+ type FlakeReport struct

+ FlakeCount int

+ Flakes []string

+ func NewFlakeReport() *FlakeReport

+ func (f *FlakeReport) GetFlakeCount() int

+ func (f *FlakeReport) PrintHumanReadable() string

+ func (f *FlakeReport) PrintJSON() string

+ func (f *FlakeReport) RecordFlakeIfError(err error, optionalDescription ...interface{})

+ func (f *FlakeReport) SummaryKind() string

+ type Framework struct

+ AddonResourceConstraints map[string]ResourceConstraint

+ BaseName string

+ ClientSet clientset.Interface

+ DynamicClient dynamic.Interface

+ KubemarkExternalClusterClientSet clientset.Interface

+ Namespace *v1.Namespace

+ NamespaceDeletionTimeout time.Duration

+ Options Options

+ ScalesGetter scaleclient.ScalesGetter

+ SkipNamespaceCreation bool

+ TestSummaries []TestDataSummary

+ Timeouts *TimeoutContext

+ UniqueName string

+ func NewDefaultFramework(baseName string) *Framework

+ func NewFramework(baseName string, options Options, client clientset.Interface) *Framework

+ func NewFrameworkWithCustomTimeouts(baseName string, timeouts *TimeoutContext) *Framework

+ func (f *Framework) AddAfterEach(name string, fn AfterEachActionFunc)

+ func (f *Framework) AddNamespacesToDelete(namespaces ...*v1.Namespace)

+ func (f *Framework) AfterEach()

+ func (f *Framework) BeforeEach()

+ func (f *Framework) ClientConfig() *rest.Config

+ func (f *Framework) CreateNamespace(baseName string, labels map[string]string) (*v1.Namespace, error)

+ func (f *Framework) DeleteNamespace(name string)

+ func (f *Framework) ExecCommandInContainer(podName, containerName string, cmd ...string) string

+ func (f *Framework) ExecCommandInContainerWithFullOutput(podName, containerName string, cmd ...string) (string, string, error)

+ func (f *Framework) ExecWithOptions(options ExecOptions) (string, string, error)

+ func (f *Framework) MatchContainerOutput(pod *v1.Pod, containerName string, expectedOutput []string, ...) error

+ func (f *Framework) NewClusterVerification(namespace *v1.Namespace, filter PodStateVerification) *ClusterVerification

+ func (f *Framework) PodClient() *PodClient

+ func (f *Framework) PodClientNS(namespace string) *PodClient

+ func (f *Framework) RecordFlakeIfError(err error, optionalDescription ...interface{})

+ type KubeCluster struct

+ Cluster struct{ ... }

+ Name string

+ type KubeConfig struct

+ Clusters []KubeCluster

+ Contexts []struct{ ... }

+ Users []KubeUser

+ func (kc *KubeConfig) FindCluster(name string) *KubeCluster

+ func (kc *KubeConfig) FindUser(name string) *KubeUser

+ type KubeUser struct

+ Name string

+ User struct{ ... }

+ type KubectlBuilder struct

+ func NewKubectlCommand(namespace string, args ...string) *KubectlBuilder

+ func (b KubectlBuilder) Exec() (string, error)

+ func (b KubectlBuilder) ExecWithFullOutput() (string, string, error)

+ type NodeKillerConfig struct

+ Enabled bool

+ FailureRatio float64

+ Interval time.Duration

+ JitterFactor float64

+ NodeKillerStopCh chan struct{}

+ SimulatedDowntime time.Duration

+ type NodeTestContextType struct

+ ExtraEnvs map[string]string

+ ImageDescription string

+ NodeConformance bool

+ NodeE2E bool

+ NodeName string

+ PrepullImages bool

+ RestartKubelet bool

+ RuntimeConfig map[string]string

+ SystemSpecName string

+ type NodesSet int

+ const AllNodes

+ const MasterAndDNSNodes

+ const MasterNodes

+ type NullProvider struct

+ func (n NullProvider) CleanupServiceResources(c clientset.Interface, loadBalancerName, region, zone string)

+ func (n NullProvider) CreatePD(zone string) (string, error)

+ func (n NullProvider) CreatePVSource(zone, diskName string) (*v1.PersistentVolumeSource, error)

+ func (n NullProvider) DeleteNode(node *v1.Node) error

+ func (n NullProvider) DeletePD(pdName string) error

+ func (n NullProvider) DeletePVSource(pvSource *v1.PersistentVolumeSource) error

+ func (n NullProvider) EnableAndDisableInternalLB() (enable, disable func(svc *v1.Service))

+ func (n NullProvider) EnsureLoadBalancerResourcesDeleted(ip, portRange string) error

+ func (n NullProvider) FrameworkAfterEach(f *Framework)

+ func (n NullProvider) FrameworkBeforeEach(f *Framework)

+ func (n NullProvider) GetGroupNodes(group string) ([]string, error)

+ func (n NullProvider) GroupSize(group string) (int, error)

+ func (n NullProvider) LoadBalancerSrcRanges() []string

+ func (n NullProvider) ResizeGroup(string, int32) error

+ type Options struct

+ ClientBurst int

+ ClientQPS float32

+ GroupVersion *schema.GroupVersion

+ type PodClient struct

+ func (c *PodClient) Create(pod *v1.Pod) *v1.Pod

+ func (c *PodClient) DeleteSync(name string, options metav1.DeleteOptions, timeout time.Duration)

+ type PodStateVerification struct

+ PodName string

+ Selectors map[string]string

+ ValidPhases []v1.PodPhase

+ Verify func(v1.Pod) (bool, error)

+ type ProviderInterface interface

+ CleanupServiceResources func(c clientset.Interface, loadBalancerName, region, zone string)

+ CreatePD func(zone string) (string, error)

+ CreatePVSource func(zone, diskName string) (*v1.PersistentVolumeSource, error)

+ DeleteNode func(node *v1.Node) error

+ DeletePD func(pdName string) error

+ DeletePVSource func(pvSource *v1.PersistentVolumeSource) error

+ EnableAndDisableInternalLB func() (enable, disable func(svc *v1.Service))

+ EnsureLoadBalancerResourcesDeleted func(ip, portRange string) error

+ FrameworkAfterEach func(f *Framework)

+ FrameworkBeforeEach func(f *Framework)

+ GetGroupNodes func(group string) ([]string, error)

+ GroupSize func(group string) (int, error)

+ LoadBalancerSrcRanges func() []string

+ ResizeGroup func(group string, size int32) error

+ func SetupProviderConfig(providerName string) (ProviderInterface, error)

+ type ResourceConstraint struct

+ CPUConstraint float64

+ MemoryConstraint uint64

+ type ResourceGathererOptions struct

+ InKubemark bool

+ Nodes NodesSet

+ PrintVerboseLogs bool

+ ProbeDuration time.Duration

+ ResourceDataGatheringPeriod time.Duration

+ type ResourceUsagePerContainer map[string]*ContainerResourceUsage

+ type ResourceUsageSummary map[string][]SingleContainerSummary

+ func (s *ResourceUsageSummary) PrintHumanReadable() string

+ func (s *ResourceUsageSummary) PrintJSON() string

+ func (s *ResourceUsageSummary) SummaryKind() string

+ type SingleContainerSummary struct

+ CPU float64

+ Mem uint64

+ Name string

+ type TestContextType struct

+ AllowedNotReadyNodes int

+ BearerToken string

+ CertDir string

+ CleanStart bool

+ CloudConfig CloudConfig

+ ClusterDNSDomain string

+ ContainerRuntime string

+ ContainerRuntimeEndpoint string

+ ContainerRuntimePidFile string

+ ContainerRuntimeProcessName string

+ CreateTestingNS CreateTestingNSFn

+ DeleteNamespace bool

+ DeleteNamespaceOnFailure bool

+ DisableLogDump bool

+ DockerConfigFile string

+ DockershimCheckpointDir string

+ DumpLogsOnFailure bool

+ DumpSystemdJournal bool

+ EtcdUpgradeStorage string

+ EtcdUpgradeVersion string

+ FeatureGates map[string]bool

+ GCEUpgradeScript string

+ GatherKubeSystemResourceUsageData string

+ GatherLogsSizes bool

+ GatherMetricsAfterTest string

+ GatherSuiteMetricsAfterTest bool

+ Host string

+ IPFamily string

+ ImageServiceEndpoint string

+ IncludeClusterAutoscalerMetrics bool

+ KubeAPIContentType string

+ KubeConfig string

+ KubeContext string

+ KubeVolumeDir string

+ KubectlPath string

+ ListConformanceTests bool

+ ListImages bool

+ LogexporterGCSPath string

+ MasterOSDistro string

+ MaxNodesToGather int

+ MinStartupPods int

+ NodeKiller NodeKillerConfig

+ NodeOSArch string

+ NodeOSDistro string

+ NodeSchedulableTimeout time.Duration

+ NonblockingTaints string

+ OutputDir string

+ OutputPrintType string

+ Prefix string

+ ProgressReportURL string

+ Provider string

+ RepoRoot string

+ ReportDir string

+ ReportPrefix string

+ RequireDevices bool

+ SnapshotControllerHTTPPort int

+ SnapshotControllerPodName string

+ SpecSummaryOutput string

+ SriovdpConfigMapFile string

+ SystemDaemonsetStartupTimeout time.Duration

+ SystemPodsStartupTimeout time.Duration

+ SystemdServices string

+ Tooling string

+ VerifyServiceAccount bool

+ var TestContext TestContextType

+ func (tc TestContextType) ClusterIsIPv6() bool

+ type TestDataSummary interface

+ PrintHumanReadable func() string

+ PrintJSON func() string

+ SummaryKind func() string

+ type TimeoutContext struct

+ ClaimBound time.Duration

+ ClaimProvision time.Duration

+ ClaimProvisionShort time.Duration

+ PVBound time.Duration

+ PVCreate time.Duration

+ PVDelete time.Duration

+ PVDeleteSlow time.Duration

+ PVReclaim time.Duration

+ PodDelete time.Duration

+ PodStart time.Duration

+ PodStartShort time.Duration

+ PodStartSlow time.Duration

+ SnapshotControllerMetrics time.Duration

+ SnapshotCreate time.Duration

+ SnapshotDelete time.Duration

+ func NewTimeoutContextWithDefaults() *TimeoutContext

v1.6.0-beta.1

Mar 27, 2024

v1.6.0-alpha.16

May 16, 2024

v1.6.0-alpha.15

Apr 19, 2024

v1.6.0-alpha.14

Apr 7, 2024

v1.6.0-alpha.13

Mar 24, 2024

v1.6.0-alpha.12

Mar 20, 2024

v1.6.0-alpha.11

Mar 1, 2024

v1.6.0-alpha.10

Dec 20, 2023