Documentation
¶
Index ¶
- Constants
- func CleanupServiceAndPod(pod *kapi.Pod, service *kapi.Service, ns string)
- func CreateNamespace(clusterAdminKubeConfig, name string) (err error)
- func CreatePodFromImage(stream *imageapi.ImageStream, tag, ns string) *kapi.Pod
- func CreateServiceForPod(pod *kapi.Pod, ns string) *kapi.Service
- func DeleteAndWaitForNamespaceTermination(c *kclient.Client, name string) error
- func GetBaseDir() string
- func GetClientForServiceAccount(adminClient *kclient.Client, clientConfig restclient.Config, ...) (*client.Client, *kclient.Client, *restclient.Config, error)
- func GetClientForUser(clientConfig restclient.Config, username string) (*client.Client, *kclient.Client, *restclient.Config, error)
- func GetClusterAdminClient(adminKubeConfigFile string) (*client.Client, error)
- func GetClusterAdminClientConfig(adminKubeConfigFile string) (*restclient.Config, error)
- func GetClusterAdminKubeClient(adminKubeConfigFile string) (*kclient.Client, error)
- func GetEtcdURL() string
- func GetTemplateFixture(filename string) (*templateapi.Template, error)
- func KubeConfigPath() string
- func MakeNewEtcdClient() (newetcdclient.Client, error)
- func Namespace() string
- func NewDockerClient() (*dockerClient.Client, error)
- func NewEtcdClient() *etcd.Client
- func NewTestLDAPServer() *testLDAPServer
- func RandomNamespace(prefix string) string
- func RequireDocker()
- func RequireEtcd(t *testing.T) *etcdtest.EtcdTestServer
- func VerifyImage(stream *imageapi.ImageStream, tag, ns string, validator ValidateFunc) error
- func WaitForAddress(pod *kapi.Pod, service *kapi.Service, ns string) (string, error)
- func WaitForClusterPolicyUpdate(c *client.Client, verb string, resource unversioned.GroupResource, ...) error
- func WaitForPolicyUpdate(c *client.Client, namespace, verb string, resource unversioned.GroupResource, ...) error
- func WaitForResourceQuotaLimitSync(client kclient.ResourceQuotaInterface, name string, ...) error
- type ValidateFunc
Constants ¶
const ( PolicyCachePollInterval = 100 * time.Millisecond PolicyCachePollTimeout = 5 * time.Second )
Variables ¶
This section is empty.
Functions ¶
func CleanupServiceAndPod ¶
CleanupServiceAndPod removes the Service and the Pod
func CreateNamespace ¶
CreateNamespace creates a namespace with the specified name using the provided kubeconfig DO NOT USE, use create project instead
func CreatePodFromImage ¶
func CreatePodFromImage(stream *imageapi.ImageStream, tag, ns string) *kapi.Pod
CreatePodFromImage creates a Pod from the latest image available in the Image Stream
func CreateServiceForPod ¶
CreateServiceForPod creates a service to serve the provided Pod
func DeleteAndWaitForNamespaceTermination ¶ added in v1.1.5
func GetClientForServiceAccount ¶ added in v1.0.7
func GetClientForUser ¶
func GetClientForUser(clientConfig restclient.Config, username string) (*client.Client, *kclient.Client, *restclient.Config, error)
func GetClusterAdminClient ¶
func GetClusterAdminClientConfig ¶
func GetClusterAdminClientConfig(adminKubeConfigFile string) (*restclient.Config, error)
func GetEtcdURL ¶
func GetEtcdURL() string
func GetTemplateFixture ¶ added in v1.0.7
func GetTemplateFixture(filename string) (*templateapi.Template, error)
func KubeConfigPath ¶
func KubeConfigPath() string
func MakeNewEtcdClient ¶ added in v1.1.3
func MakeNewEtcdClient() (newetcdclient.Client, error)
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 NewEtcdClient ¶
func NewTestLDAPServer ¶ added in v1.0.2
func NewTestLDAPServer() *testLDAPServer
func RandomNamespace ¶
RandomNamespace provides random Kubernetes namespace name based on the UNIX timestamp. Optionally you can set the prefix.
func RequireDocker ¶
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 RequireEtcd ¶
func RequireEtcd(t *testing.T) *etcdtest.EtcdTestServer
RequireEtcd verifies if the etcd is running and accessible for testing
func VerifyImage ¶
func VerifyImage(stream *imageapi.ImageStream, tag, ns string, validator ValidateFunc) error
VerifyImage verifies if the latest image in given ImageStream is valid
func WaitForAddress ¶
WaitForAddress waits for the Pod to be running and then for the Service to get the endpoint.
func WaitForClusterPolicyUpdate ¶ added in v1.0.6
func WaitForClusterPolicyUpdate(c *client.Client, verb string, resource unversioned.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 *client.Client, namespace, verb string, resource unversioned.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 kclient.ResourceQuotaInterface, name string, hardLimit kapi.ResourceList, timeout time.Duration, ) error
WaitForResourceQuotaSync watches given resource quota until its hard limit is updated to match the desired spec or timeout occurs.
Source Files
Directories