util

package
v0.4.4 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2015 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CleanupServiceAndPod added in v0.4.2

func CleanupServiceAndPod(pod *kapi.Pod, service *kapi.Service, ns string)

CleanupServiceAndPod removes the Service and the Pod

func CreateBootstrapPolicy added in v0.4.3

func CreateBootstrapPolicy(masterArgs *start.MasterArgs) error

func CreateMasterCerts added in v0.4.3

func CreateMasterCerts(masterArgs *start.MasterArgs) error

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 CreateNewProject added in v0.4.2

func CreateNewProject(clusterAdminClient *client.Client, clientConfig kclient.Config, projectName, adminUser string) (*client.Client, error)

CreateNewProject creates a new project using the clusterAdminClient, then gets a token for the adminUser and returns back a client for the admin user

func CreateNodeCerts added in v0.4.3

func CreateNodeCerts(nodeArgs *start.NodeArgs) error

func CreatePodFromImage added in v0.4.2

func CreatePodFromImage(stream *imageapi.ImageStream, tag, ns string) *kapi.Pod

CreatePodFromImage creates a Pod from the latest image available in the Image Stream

func CreateSampleImageStream added in v0.4.3

func CreateSampleImageStream(namespace string) *imageapi.ImageStream

CreateSampleImageStream creates an ImageStream in given namespace

func CreateServiceForPod added in v0.4.2

func CreateServiceForPod(pod *kapi.Pod, ns string) *kapi.Service

CreateServiceForPod creates a service to serve the provided Pod

func DefaultAllInOneOptions added in v0.4.3

func DefaultAllInOneOptions() (*configapi.MasterConfig, *configapi.NodeConfig, error)

func DefaultMasterOptions added in v0.4.3

func DefaultMasterOptions() (*configapi.MasterConfig, error)

func DeleteAllEtcdKeys added in v0.4.2

func DeleteAllEtcdKeys()

DeleteAllEtcdKeys removes all etcd keys

func DeleteSampleImageStream added in v0.4.3

func DeleteSampleImageStream(stream *imageapi.ImageStream, namespace string)

DeleteSampleImageStream removes the ImageStream created in given namespace

func FindAvailableBindAddress added in v0.4.4

func FindAvailableBindAddress() string

func GetBaseDir added in v0.4.2

func GetBaseDir() string

GetBaseDir returns the base directory used for test.

func GetBuildFixture added in v0.4.2

func GetBuildFixture(filename string) *buildapi.Build

GetBuildFixture reads the Build JSON and returns and Build object

func GetClusterAdminClient added in v0.4.2

func GetClusterAdminClient(adminKubeConfigFile string) (*client.Client, error)

func GetClusterAdminClientConfig added in v0.4.2

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

func GetClusterAdminKubeClient added in v0.4.2

func GetClusterAdminKubeClient(adminKubeConfigFile string) (*kclient.Client, error)

func GetEtcdURL added in v0.4.2

func GetEtcdURL() string

func GetSecretFixture added in v0.4.3

func GetSecretFixture(filename string) *kapi.Secret

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 NewEtcdClient added in v0.4.2

func NewEtcdClient() *etcd.Client

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 RequireEtcd added in v0.4.2

func RequireEtcd()

RequireEtcd verifies if the etcd is running and accessible for testing

func RequireServer added in v0.4.2

func RequireServer()

RequireServer verifies if the etcd, docker and the OpenShift server are available and you can successfully connected to them.

func StartConfiguredAllInOne added in v0.4.3

func StartConfiguredAllInOne(masterConfig *configapi.MasterConfig, nodeConfig *configapi.NodeConfig) (string, error)

func StartConfiguredMaster added in v0.4.3

func StartConfiguredMaster(masterConfig *configapi.MasterConfig) (string, error)

func StartTestAllInOne added in v0.4.2

func StartTestAllInOne() (*configapi.MasterConfig, string, error)

func StartTestMaster added in v0.4.2

func StartTestMaster() (*configapi.MasterConfig, string, error)

StartTestMaster starts up a test master and returns back the startOptions so you can get clients and certs

func VerifyImage added in v0.4.2

func VerifyImage(stream *imageapi.ImageStream, tag, ns string, validator ValidateFunc) error

VerifyImage verifies if the latest image in given ImageStream is valid

func WaitForAddress added in v0.4.2

func WaitForAddress(pod *kapi.Pod, service *kapi.Service, ns string) (string, error)

WaitForAddress waits for the Pod to be running and then for the Service to get the endpoint.

Types

type ValidateFunc added in v0.4.2

type ValidateFunc func(string) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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