util

Documentation

Index

• Constants
• func AddAdditionalAllowedRegistries(hostPortGlobs ...string)
• func CreateNamespace(clusterAdminKubeConfig, name string) (err error)
• func GetAdditionalAllowedRegistries() sets.String
• func GetBaseDir() string
• func GetClientForServiceAccount(adminClient kubernetes.Interface, clientConfig restclient.Config, ...) (*kubernetes.Clientset, *restclient.Config, error)
• func GetClientForUser(clusterAdminConfig *restclient.Config, username string) (kubernetes.Interface, *restclient.Config, error)
• func GetClusterAdminClientConfig(adminKubeConfigFile string) (*restclient.Config, error)
• func GetClusterAdminClientConfigOrDie(adminKubeConfigFile string) *restclient.Config
• func GetClusterAdminKubeClient(adminKubeConfigFile string) (kubernetes.Interface, error)
• func GetImageFixture(filename string) (*imageapi.Image, error)
• func GetScopedClientForUser(clusterAdminClientConfig *restclient.Config, username string, scopes []string) (kubernetes.Interface, *restclient.Config, error)
• func GetTemplateFixture(filename string) (*templateapi.Template, error)
• func KubeConfigPath() string
• func Namespace() string
• func NewDockerClient() (*dockerClient.Client, error)
• func NewTestLDAPServer() *testLDAPServer
• func NonProtobufConfig(inConfig *rest.Config) *rest.Config
• func SetAdditionalAllowedRegistries(hostPortGlobs ...string)
• func WaitForClusterPolicyUpdate(c authorizationv1client.SelfSubjectAccessReviewsGetter, verb string, ...) error
• func WaitForClusterResourceQuotaCRDAvailable(clusterAdminClientConfig *rest.Config) error
• func WaitForPolicyUpdate(c authorizationv1client.SelfSubjectAccessReviewsGetter, namespace, verb string, ...) error
• func WaitForResourceQuotaLimitSync(client corev1client.ResourceQuotaInterface, name string, ...) error

Constants

const (
	PolicyCachePollInterval = 100 * time.Millisecond
	PolicyCachePollTimeout  = 10 * time.Second
)

Functions

func AddAdditionalAllowedRegistries

func AddAdditionalAllowedRegistries(hostPortGlobs ...string)

func CreateNamespace

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 GetAdditionalAllowedRegistries

func GetAdditionalAllowedRegistries() sets.String

func GetBaseDir

func GetBaseDir() string

GetBaseDir returns the base directory used for test.

func GetClientForServiceAccount

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

func GetClientForUser

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

func GetClusterAdminClientConfig

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

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

func GetImageFixture

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

func GetScopedClientForUser

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

func GetTemplateFixture

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

func KubeConfigPath

func KubeConfigPath() string

func Namespace

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

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

func NewTestLDAPServer() *testLDAPServer

func NonProtobufConfig

func NonProtobufConfig(inConfig *rest.Config) *rest.Config

func SetAdditionalAllowedRegistries

func SetAdditionalAllowedRegistries(hostPortGlobs ...string)

func WaitForClusterPolicyUpdate

func WaitForClusterPolicyUpdate(c authorizationv1client.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 WaitForClusterResourceQuotaCRDAvailable

func WaitForClusterResourceQuotaCRDAvailable(clusterAdminClientConfig *rest.Config) error

func WaitForPolicyUpdate

func WaitForPolicyUpdate(c authorizationv1client.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

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

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