Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

util

package

Go to main page

Versions in this module

v1

v1.0.8

Nov 7, 2015

v1.0.7

Oct 29, 2015

Changes in this version

+ var CheckPodIsRunningFunc = func(pod kapi.Pod) bool

+ func ArtifactDirPath() string

+ func ArtifactPath(elem ...string) string

+ func BuildAuthConfiguration(credKey string, oc *CLI) (*dockerClient.AuthConfiguration, error)

+ func CleanupHostPathVolumes(c kclient.PersistentVolumeInterface, prefix string) error

+ func CreatePersistentVolume(name, capacity, hostPath string) *kapi.PersistentVolume

+ func CreateResource(jsonFilePath string, oc *CLI) error

+ func DumpAndReturnTagging(tags []string) []string

+ func ExecuteTest(t *testing.T, suite string)

+ func FetchURL(url string, retryTimeout time.Duration) (response string, err error)

+ func GetEndpointAddress(oc *CLI, name string) (string, error)

+ func GetPodForContainer(container kapi.Container) *kapi.Pod

+ func GetPodForImage(dockerImageReference string) *kapi.Pod

+ func GetPodNamesByFilter(c kclient.PodInterface, label labels.Selector, predicate func(kapi.Pod) bool) (podNames []string, err error)

+ func InitTest()

+ func ParseLabelsOrDie(str string) labels.Selector

+ func PushImage(name string, authCfg dockerClient.AuthConfiguration) error

+ func SetupHostPathVolumes(c kclient.PersistentVolumeInterface, prefix, capacity string, count int) (volumes []*kapi.PersistentVolume, err error)

+ func StartBuildFromJSON(jsonFile, buildPrefix string, oc *CLI)

+ func VarSubOnFile(srcFile, destFile, varToSub, val string) error

+ func WaitForPods(c kclient.PodInterface, label labels.Selector, predicate func(kapi.Pod) bool, ...) ([]string, error)

+ func WaitForQueryOutput(oc *CLI, d Database, timeout time.Duration, admin bool, ...) error

+ func WaitUntilAllHelpersAreUp(oc *CLI, helpers []Database) error

+ func WaitUntilPodIsGone(c kclient.PodInterface, podName string, timeout time.Duration) error

+ func WaitUntilUp(oc *CLI, d Database, timeout time.Duration) error

type CLI

+ func (c *CLI) AdminKubeREST() *kclient.Client

+ func (c *CLI) AsAdmin() *CLI

+ func (c *CLI) InputString(input string) *CLI

+ func (c *CLI) Stdout() io.Writer

+ type Database interface

+ GetPodName func() string

+ IsReady func(oc *CLI) (bool, error)

+ Query func(oc *CLI, query string) (string, error)

+ QueryPrivileged func(oc *CLI, query string) (string, error)

+ TestRemoteLogin func(oc *CLI, hostAddress string) error

+ func NewMysql(c kclient.PodInterface, podName, masterPodName string) Database

+ type MySQL struct

+ MasterPodName string

+ PodName string

+ func (m MySQL) GetPodName() string

+ func (m MySQL) IsReady(oc *CLI) (bool, error)

+ func (m MySQL) Query(oc *CLI, query string) (string, error)

+ func (m MySQL) QueryPrivileged(oc *CLI, query string) (string, error)

+ func (m MySQL) TestRemoteLogin(oc *CLI, hostAddress string) error

+ type PodConfig struct

+ Container string

+ Env map[string]string

+ func GetPodConfig(c kclient.PodInterface, podName string) (conf *PodConfig, err error)

+ type SimpleReporter struct

+ Output io.Writer

+ func NewSimpleReporter() *SimpleReporter

+ func (r *SimpleReporter) AfterSuiteDidRun(setupSummary *types.SetupSummary)

+ func (r *SimpleReporter) BeforeSuiteDidRun(*types.SetupSummary)

+ func (r *SimpleReporter) SpecDidComplete(spec *types.SpecSummary)

+ func (r *SimpleReporter) SpecSuiteDidEnd(summary *types.SuiteSummary)

+ func (r *SimpleReporter) SpecSuiteWillBegin(config config.GinkgoConfigType, summary *types.SuiteSummary)

+ func (r *SimpleReporter) SpecWillRun(spec *types.SpecSummary)

v1.0.6

Sep 13, 2015

Changes in this version

+ var CheckBuildFailedFunc = func(b *buildapi.Build) bool

+ var CheckBuildSuccessFunc = func(b *buildapi.Build) bool

+ var CheckDeploymentCompletedFunc = func(d *kapi.ReplicationController) bool

+ var CheckDeploymentFailedFunc = func(d *kapi.ReplicationController) bool

+ var CheckImageStreamLatestTagPopulatedFunc = func(i *imageapi.ImageStream) bool

+ var CheckImageStreamTagNotFoundFunc = func(i *imageapi.ImageStream) bool

+ func WaitForADeployment(client kclient.ReplicationControllerInterface, name string, ...) error

+ func WaitForAnImageStream(client client.ImageStreamInterface, name string, ...) error

+ func WaitForBuilderAccount(c kclient.ServiceAccountsInterface) error

v1.0.5

Aug 24, 2015

Changes in this version

+ var TestContext e2e.TestContextType

+ func CorruptImage(corruptee, corruptor, strategy string)

+ func CreatePodForImage(dockerImageReference string) *kapi.Pod

+ func ExtendedTestPath() string

+ func FatalErr(msg interface{})

+ func FixturePath(elem ...string) string

+ func GetDockerImageReference(c client.ImageStreamInterface, name, tag string) (string, error)

+ func GetImageIDForTags(comps []string) ([]string, error)

+ func KubeConfigPath() string

+ func PullImage(name string) error

+ func ResetImage(tags map[string]string)

+ func StartBuild(jsonFile, buildPrefix string, oc *CLI)

+ func TagImage(tagee, tagor string) error

+ func VerifyImagesDifferent(comp1, comp2, strategy string)

+ func VerifyImagesSame(comp1, comp2, strategy string)

+ func WaitForABuild(c client.BuildInterface, name string, ...) error

+ func WaitForBuild(context, buildName string, oc *CLI)

+ func WriteObjectToFile(obj runtime.Object, filename string) error

+ type CLI struct

+ func NewCLI(project, adminConfigPath string) *CLI

+ func (c *CLI) AdminREST() *client.Client

+ func (c *CLI) Args(args ...string) *CLI

+ func (c *CLI) ChangeUser(name string) *CLI

+ func (c *CLI) Execute() error

+ func (c *CLI) KubeFramework() *e2e.Framework

+ func (c *CLI) KubeREST() *kclient.Client

+ func (c *CLI) Namespace() string

+ func (c *CLI) Output() (string, error)

+ func (c *CLI) OutputToFile(filename string) (string, error)

+ func (c *CLI) REST() *client.Client

+ func (c *CLI) Run(verb string) *CLI

+ func (c *CLI) SetNamespace(ns string) *CLI

+ func (c *CLI) SetOutput(out io.Writer) *CLI

+ func (c *CLI) SetOutputDir(dir string) *CLI

+ func (c *CLI) SetupProject(name string, kubeClient *kclient.Client) (*kapi.Namespace, error)

+ func (c *CLI) Template(t string) *CLI

+ func (c *CLI) Username() string

+ func (c *CLI) Verbose() *CLI

+ type MissingTagError struct

+ Tags []string

+ func (mte MissingTagError) Error() string