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

v0

v0.7.0

Mar 18, 2024

v0.6.0

Dec 7, 2023

Changes in this version

+ const DefaultNamespaceDeletionTimeout

+ const DefaultNumNodes

+ const KubeControllerManagerPort

+ const KubeletPort

+ const PodGetTimeout

+ const Poll

+ const ServiceAccountProvisionTimeout

+ const SingleCallTimeout

+ var RunID = uuid.NewUUID()

+ func AfterReadingAllFlags(t *TestContextType)

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

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

+ func CoreDump(dir string)

+ func CreatePrivilegedPSPBinding(kubeClient clientset.Interface, namespace 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 DumpDebugInfo(c clientset.Interface, ns 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 Fail(msg string, callerSkip ...int)

+ func Failf(format string, args ...interface{})

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

+ func GetProviders() []string

+ func IsPodSecurityPolicyEnabled(kubeClient clientset.Interface) bool

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

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

+ func Logf(format string, args ...interface{})

+ func PrettyPrintJSON(metrics interface{}) string

+ func ProviderIs(providers ...string) bool

+ func PrunedStack(skip int) []byte

+ 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 RunHostCmdWithRetries(ns, name, cmd string, interval, timeout time.Duration) (string, error)

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

+ func RunKubectlOrDie(namespace string, args ...string) string

+ 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

+ 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 ContainerResourceGatherer struct

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

+ func (g *ContainerResourceGatherer) StartGatheringData()

+ type ContainerResourceUsage struct

+ CPUInterval time.Duration

+ CPUUsageInCores float64

+ MemoryRSSInBytes uint64

+ MemoryUsageInBytes uint64

+ MemoryWorkingSetInBytes uint64

+ Name string

+ Timestamp time.Time

+ 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 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

+ SkipPrivilegedPSPBinding bool

+ TestSummaries []TestDataSummary

+ Timeouts *TimeoutContext

+ UniqueName string

+ func NewDefaultFramework(baseName string) *Framework

+ func NewFramework(baseName string, options Options, client clientset.Interface) *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) CreateNamespace(baseName string, labels map[string]string) (*v1.Namespace, error)

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

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

+ type KubectlBuilder struct

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

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

+ func (b KubectlBuilder) ExecOrDie(namespace string) string

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

+ type LogSizeDataTimeseries map[string]map[string][]TimestampedSize

+ type LogSizeGatherer struct

+ type LogsSizeData struct

+ type LogsSizeVerifier struct

+ 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) Update(name string, updateFn func(pod *v1.Pod))

+ 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 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

+ type TimestampedSize struct

+ type WorkItem struct

v0.5.1-alpha.1

Nov 24, 2023