Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

framework

package

Go to main page

Versions in this module

v1

v1.2.2

Feb 3, 2026

v1.2.1

Dec 11, 2025

v1.2.0

Oct 21, 2025

Changes in this version

+ func GenerateName() string

+ func GetEventsForObject(ctx context.Context, client *kubernetes.Clientset, objectName string, ...) ([]corev1.Event, error)

+ func ValidateCreationWhenObjectsAreMarkedForDeletion(cl client.Client, ctx context.Context, pluginObjectsSet ...PluginObjectsSet) func(gomega.Gomega)

+ func VerifyPodsEvents(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(g Gomega)

+ type PluginObjectsSet int

+ const ENoExecPlugin

+ const EnoExecPluginDaemonSet

+ const EnoExecPluginDeployment

+ const EnoExecPluginDeploymentObjects

+ const MainPlugin

v1.1.1

May 20, 2025

Changes in this version

+ func GetClusterMinorVersion(kc kubernetes.Interface) (int, error)

v1.1.0

Mar 5, 2025

Changes in this version

+ func DecorateWithWaitGroup(wg *sync.WaitGroup, f func())

+ func EnsureNamespaces(ctx context.Context, client client.Client, namespaces ...string)

+ func FromEnvTestConfig(cfg *rest.Config) api.Config

+ func GetImageConfig(ctx context.Context, client runtimeclient.Client) (*ocpconfigv1.Image, error)

+ func GetImageRepository(image string) string

+ func GetNodesWithLabel(ctx context.Context, client runtimeclient.Client, labelKey string, ...) (*corev1.NodeList, error)

+ func GetPodLog(ctx context.Context, clientset *kubernetes.Clientset, ...) (string, error)

+ func GetPodsWithLabel(ctx context.Context, client runtimeclient.Client, ...) (*v1.PodList, error)

+ func GetRandomNodeName(ctx context.Context, client runtimeclient.Client, labelKey string, ...) (string, error)

+ func GetReplacedImageURI(image, replacedRegistry string) string

+ func HaveEquivalentNodeAffinity(expected interface{}) types.GomegaMatcher

+ func HaveEquivalentPreferredNodeAffinity(expected *corev1.NodeAffinity) types.GomegaMatcher

+ func LoadClient() (client.Client, error)

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

+ func NewEphemeralNamespace() *corev1.Namespace

+ func NormalizeNameString(name string) string

+ func RegisterScheme(s *runtime.Scheme) error

+ func StartChannelMonitor(ch chan error, descr string)

+ func StorePodsLog(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ func ValidateCreation(cl client.Client, ctx context.Context) func(gomega.Gomega)

+ func ValidateDeletion(cl client.Client, ctx context.Context) func(gomega.Gomega)

+ func VerifyCOAreUpdated(g Gomega, ctx context.Context, client runtimeclient.Client, ...)

+ func VerifyCOAreUpdating(g Gomega, ctx context.Context, client runtimeclient.Client, ...)

+ func VerifyConditions(ctx context.Context, c client.Client, ...) func(g gomega.Gomega)

+ func VerifyDaemonSetPodNodeAffinity(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(g gomega.Gomega)

+ func VerifyDaemonSetPreferredPodNodeAffinity(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(g gomega.Gomega)

+ func VerifyMCPAreUpdated(ctx context.Context, client runtimeclient.Client, poolName string)

+ func VerifyMCPsAreUpdating(g Gomega, ctx context.Context, client runtimeclient.Client)

+ func VerifyPodAnnotations(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(g gomega.Gomega)

+ func VerifyPodLabels(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(g gomega.Gomega)

+ func VerifyPodLabelsAreSet(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(g gomega.Gomega)

+ func VerifyPodNodeAffinity(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(gomega.Gomega)

+ func VerifyPodPreferredNodeAffinity(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(gomega.Gomega)

+ func VerifyPodsAreRunning(ctx context.Context, client runtimeclient.Client, ns *v1.Namespace, ...) func(gomega.Gomega)

+ func WaitForCOComplete(ctx context.Context, client runtimeclient.Client, operatorName string)

+ func WaitForMCPComplete(ctx context.Context, client runtimeclient.Client)

+ func WriteToFile(dir, fileName, content string) error

+ type ConditionTypeStatusTuple struct

+ ConditionStatus corev1.ConditionStatus

+ ConditionType string

+ func NewConditionTypeStatusTuple(conditionType string, conditionStatus corev1.ConditionStatus) ConditionTypeStatusTuple