Versions in this module Expand all Collapse all v0 v0.0.3 Apr 15, 2022 v0.0.1 Apr 15, 2022 Changes in this version + var Flags = initializeFlags() + var IsOneOfStatusCodes = spoof.IsOneOfStatusCodes + var IsStatusOK = spoof.IsStatusOK + var MatchesAllBodies = spoof.MatchesAllBodies + var MatchesAllOf = spoof.MatchesAllOf + var MatchesBody = spoof.MatchesBody + var WithHeader = spoof.WithHeader + func BuildClientConfig(kubeConfigPath string, clusterName string) (*rest.Config, error) + func CheckEndpointState(ctx context.Context, kubeClient kubernetes.Interface, ...) (*spoof.Response, error) + func CleanupOnInterrupt(f func(), log logFunc) + func ClusterRoleBinding(name string, namespace string, serviceAccount string, role string) *rbacv1.ClusterRoleBinding + func CoreV1ObjectReference(kind, apiversion, name string) *corev1.ObjectReference + func CreatePod(ctx context.Context, client kubernetes.Interface, pod *corev1.Pod) (*corev1.Pod, error) + func DeploymentScaledToZeroFunc() func(d *appsv1.Deployment) (bool, error) + func GetConfigMap(client kubernetes.Interface, namespace string) k8styped.ConfigMapInterface + func GetEndpointAddresses(ctx context.Context, client kubernetes.Interface, svcName, svcNamespace string) ([]string, error) + func ImagePath(name string) string + func NewSpoofingClient(ctx context.Context, client kubernetes.Interface, logf logging.FormatLogger, ...) (*spoof.SpoofingClient, error) + func NginxPod(namespace string) *corev1.Pod + func OnInterrupt(cleanupFunc func()) + func PodLogs(ctx context.Context, client kubernetes.Interface, ...) ([]byte, error) + func ServiceAccount(name, namespace string) *corev1.ServiceAccount + func SetupLoggingFlags() + func UpdateConfigMap(ctx context.Context, client kubernetes.Interface, name string, ...) error + func WaitForAllPodsRunning(ctx context.Context, client kubernetes.Interface, namespace string) error + func WaitForChangedEndpoints(ctx context.Context, client kubernetes.Interface, svcName, svcNamespace string, ...) error + func WaitForDeploymentScale(ctx context.Context, client kubernetes.Interface, name, namespace string, ...) error + func WaitForDeploymentState(ctx context.Context, client kubernetes.Interface, name string, ...) error + func WaitForEndpointState(ctx context.Context, kubeClient kubernetes.Interface, ...) (*spoof.Response, error) + func WaitForEndpointStateWithTimeout(ctx context.Context, kubeClient kubernetes.Interface, ...) (*spoof.Response, error) + func WaitForLogContent(ctx context.Context, client kubernetes.Interface, ...) error + func WaitForPodDeleted(ctx context.Context, client kubernetes.Interface, name, namespace string) error + func WaitForPodListState(ctx context.Context, client kubernetes.Interface, ...) error + func WaitForPodRunning(ctx context.Context, client kubernetes.Interface, name string, ...) error + func WaitForPodState(ctx context.Context, client kubernetes.Interface, ...) error + func WaitForServiceEndpoints(ctx context.Context, client kubernetes.Interface, svcName string, ...) error + type EnvironmentFlags struct + type RequestOption = spoof.RequestOption + type T interface + Cleanup func(func()) + Error func(args ...interface{}) + Helper func() + Log func(args ...interface{}) + Name func() string + SkipNow func() + type TLegacy interface + Fatal func(args ...interface{}) + Logf func(fmt string, args ...interface{})