util

package
v3.11.18-1+incompatible Latest Latest
Warning

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

Go to latest
Published: Sep 30, 2018 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PolicyCachePollInterval = 100 * time.Millisecond
	PolicyCachePollTimeout  = 5 * time.Second
)

Variables

This section is empty.

Functions

func AddAdditionalAllowedRegistries

func AddAdditionalAllowedRegistries(hostPortGlobs ...string)

func CreateNamespace added in v0.4.4

func CreateNamespace(clusterAdminKubeConfig, name string) (err error)

CreateNamespace creates a namespace with the specified name using the provided kubeconfig DO NOT USE, use create project instead

func DeleteAndWaitForNamespaceTermination added in v1.1.5

func DeleteAndWaitForNamespaceTermination(c kclientset.Interface, name string) error

func GetAdditionalAllowedRegistries

func GetAdditionalAllowedRegistries() sets.String

func GetBaseDir added in v0.4.2

func GetBaseDir() string

GetBaseDir returns the base directory used for test.

func GetClientForServiceAccount added in v1.0.7

func GetClientForServiceAccount(adminClient kclientset.Interface, clientConfig restclient.Config, namespace, name string) (*kclientset.Clientset, *restclient.Config, error)

func GetClientForUser added in v0.6.1

func GetClientForUser(clusterAdminConfig *restclient.Config, username string) (kclientset.Interface, *restclient.Config, error)

func GetClusterAdminClientConfig added in v0.4.2

func GetClusterAdminClientConfig(adminKubeConfigFile string) (*restclient.Config, error)

func GetClusterAdminClientConfigOrDie

func GetClusterAdminClientConfigOrDie(adminKubeConfigFile string) *restclient.Config

GetClusterAdminClientConfigOrDie returns a REST config for the cluster admin user or panic.

func GetClusterAdminKubeClient added in v0.4.2

func GetClusterAdminKubeClient(adminKubeConfigFile string) (kubernetes.Interface, error)

func GetClusterAdminKubeInternalClient

func GetClusterAdminKubeInternalClient(adminKubeConfigFile string) (kclientset.Interface, error)

func GetImageFixture added in v1.3.0

func GetImageFixture(filename string) (*imageapi.Image, error)

func GetScopedClientForUser added in v1.3.0

func GetScopedClientForUser(clusterAdminClientConfig *restclient.Config, username string, scopes []string) (kclientset.Interface, *restclient.Config, error)

func GetTemplateFixture added in v1.0.7

func GetTemplateFixture(filename string) (*templateapi.Template, error)

func KubeConfigPath added in v0.4.2

func KubeConfigPath() string

func Namespace added in v0.4.2

func Namespace() string

Namespace returns the test namespace. The default namespace is set to 'integration-test'. You can override it by setting the 'OS_TEST_NAMESPACE' environment variable

func NewDockerClient added in v0.4.2

func NewDockerClient() (*dockerClient.Client, error)

newDockerClient creates a docker client using the env var DOCKER_ENDPOINT or, if not supplied, uses the default docker endpoint /var/run/docker.sock

func NewTestLDAPServer added in v1.0.2

func NewTestLDAPServer() *testLDAPServer

func RandomNamespace added in v0.4.2

func RandomNamespace(prefix string) string

RandomNamespace provides random Kubernetes namespace name based on the UNIX timestamp. Optionally you can set the prefix.

func RequireDocker added in v0.4.2

func RequireDocker()

RequireDocker ensures that a new docker client can be created and that a ListImages command can be run on the client or it fails with glog.Fatal

func SetAdditionalAllowedRegistries

func SetAdditionalAllowedRegistries(hostPortGlobs ...string)

func WaitForClusterPolicyUpdate added in v1.0.6

func WaitForClusterPolicyUpdate(c authorizationtypedclient.SelfSubjectAccessReviewsGetter, verb string, resource schema.GroupResource, allowed bool) error

WaitForClusterPolicyUpdate checks if the given client can perform the named verb and action. If PolicyCachePollTimeout is reached without the expected condition matching, an error is returned

func WaitForPolicyUpdate added in v1.0.1

func WaitForPolicyUpdate(c authorizationtypedclient.SelfSubjectAccessReviewsGetter, namespace, verb string, resource schema.GroupResource, allowed bool) error

WaitForPolicyUpdate checks if the given client can perform the named verb and action. If PolicyCachePollTimeout is reached without the expected condition matching, an error is returned

func WaitForResourceQuotaLimitSync added in v1.3.0

func WaitForResourceQuotaLimitSync(
	client kcoreclient.ResourceQuotaInterface,
	name string,
	hardLimit kapi.ResourceList,
	timeout time.Duration,
) error

WaitForResourceQuotaLimitSync watches given resource quota until its hard limit is updated to match the desired spec or timeout occurs.

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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