util

Documentation

Index

• Constants
• func CreateNamespace(clusterAdminKubeConfig, name string) (err error)
• func DeleteAndWaitForNamespaceTermination(c kclientset.Interface, name string) error
• func DumpEtcdOnFailure(t *testing.T, etcd2 etcdclient.Client, etcd3 *etcdclientv3.Client)
• func GetBaseDir() string
• func GetClientForServiceAccount(adminClient kclientset.Interface, clientConfig restclient.Config, ...) (*kclientset.Clientset, *restclient.Config, error)
• func GetClientForUser(clusterAdminConfig *restclient.Config, username string) (kclientset.Interface, *restclient.Config, error)
• func GetClusterAdminClientConfig(adminKubeConfigFile string) (*restclient.Config, error)
• func GetClusterAdminClientConfigOrDie(adminKubeConfigFile string) *restclient.Config
• func GetClusterAdminKubeClient(adminKubeConfigFile string) (kclientset.Interface, error)
• func GetEtcdURL() string
• func GetImageFixture(filename string) (*imageapi.Image, error)
• func GetScopedClientForUser(clusterAdminClientConfig *restclient.Config, username string, scopes []string) (kclientset.Interface, *restclient.Config, error)
• func GetTemplateFixture(filename string) (*templateapi.Template, error)
• func KubeConfigPath() string
• func MakeNewEtcd3Client() (*etcdclientv3.Client, error)
• func MakeNewEtcdClient() (etcdclient.Client, error)
• func Namespace() string
• func NewDockerClient() (*dockerClient.Client, error)
• func NewEtcd3Client() *etcdclientv3.Client
• func NewEtcdClient() etcdclient.Client
• func NewTestLDAPServer() *testLDAPServer
• func RandomNamespace(prefix string) string
• func RequireDocker()
• func RequireEtcd3(t *testing.T) (*etcdtest.EtcdTestServer, *storagebackend.Config)
• func WaitForClusterPolicyUpdate(c authorizationtypedclient.SelfSubjectAccessReviewsGetter, verb string, ...) error
• func WaitForPolicyUpdate(c authorizationtypedclient.SelfSubjectAccessReviewsGetter, ...) error
• func WaitForResourceQuotaLimitSync(client kcoreclient.ResourceQuotaInterface, name string, ...) error
• type EtcdTestServer
  • func RequireEtcd(t *testing.T) EtcdTestServer
  • func RequireEtcd2(t *testing.T) EtcdTestServer
  • func (s EtcdTestServer) DumpEtcdOnFailure(t *testing.T)

Constants

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

Functions

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 DeleteAndWaitForNamespaceTermination

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

func DumpEtcdOnFailure

func DumpEtcdOnFailure(t *testing.T, etcd2 etcdclient.Client, etcd3 *etcdclientv3.Client)

func GetBaseDir

func GetBaseDir() string

GetBaseDir returns the base directory used for test.

func GetClientForServiceAccount

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

func GetClientForUser

func GetClientForUser(clusterAdminConfig *restclient.Config, username string) (kclientset.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) (kclientset.Interface, error)

func GetEtcdURL

func GetEtcdURL() string

func GetImageFixture

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

func GetScopedClientForUser

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

func GetTemplateFixture

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

func KubeConfigPath

func KubeConfigPath() string

func MakeNewEtcd3Client

func MakeNewEtcd3Client() (*etcdclientv3.Client, error)

func MakeNewEtcdClient

func MakeNewEtcdClient() (etcdclient.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 NewEtcd3Client

func NewEtcd3Client() *etcdclientv3.Client

func NewEtcdClient

func NewEtcdClient() etcdclient.Client

func NewTestLDAPServer

func NewTestLDAPServer() *testLDAPServer

func RandomNamespace

func RandomNamespace(prefix string) string

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 RequireEtcd3

func RequireEtcd3(t *testing.T) (*etcdtest.EtcdTestServer, *storagebackend.Config)

func WaitForClusterPolicyUpdate

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

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

func WaitForResourceQuotaLimitSync(
	client kcoreclient.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.

Types

type EtcdTestServer

type EtcdTestServer struct {
	*etcdtest.EtcdTestServer
}

func RequireEtcd

func RequireEtcd(t *testing.T) EtcdTestServer

RequireEtcd verifies if the etcd is running and accessible for testing

func RequireEtcd2

func RequireEtcd2(t *testing.T) EtcdTestServer

RequireEtcd verifies if the etcd is running and accessible for testing TODO: remove use of etcd2 specific apis in 1.6

func (EtcdTestServer) DumpEtcdOnFailure

func (s EtcdTestServer) DumpEtcdOnFailure(t *testing.T)