Version: v0.19.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2022 License: Apache-2.0 Imports: 43 Imported by: 0



Package testutil contains shared test utilities for the Pinniped project.

As of right now, it is more or less a dumping ground for our test utilities.



This section is empty.


This section is empty.


func CreateCertificate

func CreateCertificate(notBefore, notAfter time.Time) ([]byte, []byte, error)

CreateCertificate creates a certificate with the provided time bounds, and returns the PEM representation of the certificate and its private key. The returned certificate is capable of signing child certificates.

func ExpectedLoginPageHTML added in v0.18.0

func ExpectedLoginPageHTML(wantCSS, wantIDPName, wantPostPath, wantEncodedState, wantAlert string) string

func KubeServerSupportsCertificatesV1API added in v0.12.1

func KubeServerSupportsCertificatesV1API(t *testing.T, discoveryClient discovery.DiscoveryInterface) bool

func LogActualJSONFromCreateAction added in v0.13.0

func LogActualJSONFromCreateAction(t *testing.T, client *fake.Clientset, actionIndex int)

func LogActualJSONFromUpdateAction added in v0.13.0

func LogActualJSONFromUpdateAction(t *testing.T, client *fake.Clientset, actionIndex int)

func NewFakePinnipedSession added in v0.13.0

func NewFakePinnipedSession() *psession.PinnipedSession

func NewPreconditions added in v0.11.0

func NewPreconditions(uid types.UID, rv string) metav1.DeleteOptions

func RequireEqualContentType added in v0.3.0

func RequireEqualContentType(t *testing.T, actual string, expected string)

func RequireNumberOfSecretsMatchingLabelSelector added in v0.3.0

func RequireNumberOfSecretsMatchingLabelSelector(t *testing.T, secrets v1.SecretInterface, labelSet labels.Set, expectedNumberOfSecrets int)

func RequireSecurityHeadersWithFormPostPageCSPs added in v0.18.0

func RequireSecurityHeadersWithFormPostPageCSPs(t *testing.T, response *httptest.ResponseRecorder)

func RequireSecurityHeadersWithLoginPageCSPs added in v0.18.0

func RequireSecurityHeadersWithLoginPageCSPs(t *testing.T, response *httptest.ResponseRecorder)

func RequireSecurityHeadersWithoutCustomCSPs added in v0.18.0

func RequireSecurityHeadersWithoutCustomCSPs(t *testing.T, response *httptest.ResponseRecorder)

func RequireTimeInDelta added in v0.3.0

func RequireTimeInDelta(t *testing.T, t1 time.Time, t2 time.Time, delta time.Duration)

func SHA256 added in v0.3.0

func SHA256(s string) string

SHA256 returns the base64 URL encoding of the SHA256 sum of the provided string.

func TLSTestServer

func TLSTestServer(t *testing.T, handler http.HandlerFunc) (caBundlePEM, url string)

TLSTestServer starts a test server listening on a local port using a test CA. It returns the PEM CA bundle and the URL of the listening server. The lifetime of the server is bound to the provided *testing.T.

func TLSTestServerWithCert added in v0.9.0

func TLSTestServerWithCert(t *testing.T, handler http.HandlerFunc, certificate *tls.Certificate) (url string)

func TempDir added in v0.3.0

func TempDir(t *testing.T) string

func WriteStringToTempFile added in v0.9.0

func WriteStringToTempFile(t *testing.T, filename string, fileBody string) *os.File

func X509UntrustedCertError added in v0.16.0

func X509UntrustedCertError(commonName string) string


type ErrorWriter

type ErrorWriter struct {
	ReturnError error

ErrorWriter implements io.Writer by returning a fixed error.

func (*ErrorWriter) Write

func (e *ErrorWriter) Write([]byte) (int, error)

type ObservableWithInformerOption

type ObservableWithInformerOption struct {
	// contains filtered or unexported fields

func NewObservableWithInformerOption

func NewObservableWithInformerOption() *ObservableWithInformerOption

func (*ObservableWithInformerOption) GetFilterForInformer

func (*ObservableWithInformerOption) WithInformer

type ObservableWithInitialEventOption

type ObservableWithInitialEventOption struct {
	// contains filtered or unexported fields

func NewObservableWithInitialEventOption

func NewObservableWithInitialEventOption() *ObservableWithInitialEventOption

func (*ObservableWithInitialEventOption) GetInitialEventKey

func (i *ObservableWithInitialEventOption) GetInitialEventKey() *controllerlib.Key

func (*ObservableWithInitialEventOption) WithInitialEvent

type RoundTrip added in v0.5.0

type RoundTrip struct {
	MutateRequests, MutateResponses []func(kubeclient.Object) error
	// contains filtered or unexported fields

RoundTrip is an implementation of kubeclient.RoundTrip that is easy to use in tests.

func (*RoundTrip) MutateRequest added in v0.5.0

func (rt *RoundTrip) MutateRequest(fn func(kubeclient.Object) error)

func (*RoundTrip) MutateResponse added in v0.5.0

func (rt *RoundTrip) MutateResponse(fn func(kubeclient.Object) error)

func (*RoundTrip) Namespace added in v0.5.0

func (rt *RoundTrip) Namespace() string

func (*RoundTrip) NamespaceScoped added in v0.5.0

func (rt *RoundTrip) NamespaceScoped() bool

func (*RoundTrip) Resource added in v0.5.0

func (rt *RoundTrip) Resource() schema.GroupVersionResource

func (*RoundTrip) Subresource added in v0.5.0

func (rt *RoundTrip) Subresource() string

func (*RoundTrip) Verb added in v0.5.0

func (rt *RoundTrip) Verb() kubeclient.Verb

func (*RoundTrip) WithNamespace added in v0.5.0

func (rt *RoundTrip) WithNamespace(namespace string) *RoundTrip

func (*RoundTrip) WithResource added in v0.5.0

func (rt *RoundTrip) WithResource(resource schema.GroupVersionResource) *RoundTrip

func (*RoundTrip) WithSubresource added in v0.5.0

func (rt *RoundTrip) WithSubresource(subresource string) *RoundTrip

func (*RoundTrip) WithVerb added in v0.5.0

func (rt *RoundTrip) WithVerb(verb kubeclient.Verb) *RoundTrip

type TranscriptLogMessage

type TranscriptLogMessage struct {
	Level   string
	Message string

type TranscriptLogger

type TranscriptLogger struct {
	// contains filtered or unexported fields

func NewTranscriptLogger deprecated

func NewTranscriptLogger(t *testing.T) *TranscriptLogger

Deprecated: Use plog.TestLogger or plog.TestZapr instead. This is meant for old tests only.

func (*TranscriptLogger) Enabled

func (log *TranscriptLogger) Enabled(level int) bool

func (*TranscriptLogger) Error

func (log *TranscriptLogger) Error(_ error, msg string, _ ...interface{})

func (*TranscriptLogger) Info

func (log *TranscriptLogger) Info(level int, msg string, keysAndValues ...interface{})

func (*TranscriptLogger) Init added in v0.13.0

func (log *TranscriptLogger) Init(info logr.RuntimeInfo)

func (*TranscriptLogger) Transcript

func (log *TranscriptLogger) Transcript() []TranscriptLogMessage

func (*TranscriptLogger) V

func (log *TranscriptLogger) V(_ int) logr.LogSink

func (*TranscriptLogger) WithName

func (log *TranscriptLogger) WithName(_ string) logr.LogSink

func (*TranscriptLogger) WithValues

func (log *TranscriptLogger) WithValues(_ ...interface{}) logr.LogSink

type ValidCert

type ValidCert struct {
	// contains filtered or unexported fields

func ValidateClientCertificate added in v0.7.0

func ValidateClientCertificate(t *testing.T, caPEM string, certPEM string) *ValidCert

func ValidateServerCertificate added in v0.7.0

func ValidateServerCertificate(t *testing.T, caPEM string, certPEM string) *ValidCert

ValidateServerCertificate validates a certificate and provides an object for asserting properties of the certificate.

func (*ValidCert) RequireCommonName

func (v *ValidCert) RequireCommonName(commonName string)

RequireCommonName asserts that the certificate contains the provided commonName.

func (*ValidCert) RequireDNSName

func (v *ValidCert) RequireDNSName(expectDNSName string)

RequireDNSName asserts that the certificate matches the provided DNS name.

func (*ValidCert) RequireDNSNames added in v0.7.0

func (v *ValidCert) RequireDNSNames(names []string)

func (*ValidCert) RequireEmptyDNSNames added in v0.7.0

func (v *ValidCert) RequireEmptyDNSNames()

func (*ValidCert) RequireEmptyIPs added in v0.7.0

func (v *ValidCert) RequireEmptyIPs()

func (*ValidCert) RequireIPs added in v0.7.0

func (v *ValidCert) RequireIPs(ips []net.IP)

func (*ValidCert) RequireLifetime

func (v *ValidCert) RequireLifetime(expectNotBefore time.Time, expectNotAfter time.Time, delta time.Duration)

RequireLifetime asserts that the lifetime of the certificate matches the expected timestamps.

func (*ValidCert) RequireMatchesPrivateKey

func (v *ValidCert) RequireMatchesPrivateKey(keyPEM string)

RequireMatchesPrivateKey asserts that the public key in the certificate matches the provided private key.

func (*ValidCert) RequireOrganizations added in v0.7.0

func (v *ValidCert) RequireOrganizations(orgs []string)


Path Synopsis
Package fakekubeapi contains a *very* simple httptest.Server that can be used to stand in for a real Kube API server in tests.
Package fakekubeapi contains a *very* simple httptest.Server that can be used to stand in for a real Kube API server in tests.
Package testlogger wraps logr.Logger to allow for writing test assertions.
Package testlogger wraps logr.Logger to allow for writing test assertions.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL