Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

utils

package

Go to main page

Versions in this module

v0

v0.6.1

Dec 4, 2017

v0.6.0

Nov 8, 2017

Changes in this version

+ type HelmHelper struct

+ func NewHelmHelper() *HelmHelper

+ func (h *HelmHelper) DeleteLocalRookHelmChart(deployName string) error

+ func (h *HelmHelper) Execute(args ...string) (string, error)

+ func (h *HelmHelper) GetLocalRookHelmChartVersion(chartName string) (string, error)

+ func (h *HelmHelper) InstallLocalRookHelmChart(chartName string, deployName string, chartVersion string, namespace string) error

type K8sHelper

+ RunningInCluster bool

+ T func() *testing.T

+ func CreateK8sHelper(t func() *testing.T) (*K8sHelper, error)

+ func (k8sh *K8sHelper) CheckPodCountAndState(podName string, namespace string, minExpected int, expectedPhase string) bool

+ func (k8sh *K8sHelper) CreateAnonSystemClusterBinding()

+ func (k8sh *K8sHelper) CreateExternalRGWService(namespace, storeName string) error

+ func (k8sh *K8sHelper) DeleteRoleAndBindings(name, namespace string) error

+ func (k8sh *K8sHelper) GetExternalRGWServiceURL(storeName string, namespace string) (string, error)

+ func (k8sh *K8sHelper) GetInternalRGWServiceURL(storeName string, namespace string) (string, error)

+ func (k8sh *K8sHelper) GetPodEvents(podNamePattern string, namespace string) (*v1.EventList, error)

+ func (k8sh *K8sHelper) GetRookLogs(podAppName string, hostType string, namespace string, testName string)

+ func (k8sh *K8sHelper) GetServiceNodePort(serviceName string, namespace string) (string, error)

+ func (k8sh *K8sHelper) GetVolumeAttachmentResourceName(namespace, pvcName string) (string, error)

+ func (k8sh *K8sHelper) IsPodInError(podNamePattern, namespace, reason, containingMessage string) bool

+ func (k8sh *K8sHelper) IsPodWithLabelRunning(label string, namespace string) bool

+ func (k8sh *K8sHelper) IsRookInstalled(namespace string) bool

+ func (k8sh *K8sHelper) IsVolumeAttachmentResourceAbsent(namespace, volumeAttachmentName string) bool

+ func (k8sh *K8sHelper) IsVolumeAttachmentResourcePresent(namespace, volumeAttachmentName string) bool

+ func (k8sh *K8sHelper) VersionAtLeast(minVersion string) bool

+ func (k8sh *K8sHelper) WaitUntilNameSpaceIsDeleted(namespace string) bool

+ func (k8sh *K8sHelper) WaitUntilPVCIsDeleted(namespace string, pvcname string) bool

+ func (k8sh *K8sHelper) WaitUntilPodWithLabelDeleted(label string, namespace string) bool

type MySQLHelper

+ func (h *MySQLHelper) SelectRandomData(limit int) *sql.Rows

v0.5.1

Aug 15, 2017

v0.5.0

Aug 8, 2017

Changes in this version

+ const RetryInterval

+ const RetryLoop

+ type CommandArgs struct

+ CmdArgs []string

+ Command string

+ EnvironmentVariable []string

+ OptionalArgs []string

+ PipeToStdIn string

+ SubCommand string

+ type CommandOut struct

+ Err error

+ ExitCode int

+ StdErr string

+ StdOut string

+ func ExecuteCommand(cmdStruct CommandArgs) CommandOut

+ type K8sHelper struct

+ Clientset *kubernetes.Clientset

+ func CreatK8sHelper() (*K8sHelper, error)

+ func (k8sh *K8sHelper) DeleteResource(args []string) (string, error)

+ func (k8sh *K8sHelper) GetK8sServerVersion() string

+ func (k8sh *K8sHelper) GetMonIP(mon string) (string, error)

+ func (k8sh *K8sHelper) GetMonitorServices() (map[string]string, error)

+ func (k8sh *K8sHelper) GetPVCStatus(name string) (string, error)

+ func (k8sh *K8sHelper) GetPodDetails(podNamePattern string, namespace string) (string, error)

+ func (k8sh *K8sHelper) GetPodHostID(podNamePattern string, namespace string) (string, error)

+ func (k8sh *K8sHelper) GetRGWServiceURL() (string, error)

+ func (k8sh *K8sHelper) GetResource(args []string) (string, error)

+ func (k8sh *K8sHelper) GetService(servicename string) (string, error)

+ func (k8sh *K8sHelper) IsCRDPresent(crdName string) bool

+ func (k8sh *K8sHelper) IsPodInExpectedState(podNamePattern string, namespace string, state string) bool

+ func (k8sh *K8sHelper) IsPodRunning(name string) bool

+ func (k8sh *K8sHelper) IsPodRunningInNamespace(name string) bool

+ func (k8sh *K8sHelper) IsPodTerminated(name string) bool

+ func (k8sh *K8sHelper) IsPodTerminatedInNamespace(name string) bool

+ func (k8sh *K8sHelper) IsServiceUp(name string) bool

+ func (k8sh *K8sHelper) IsServiceUpInNameSpace(name string) bool

+ func (k8sh *K8sHelper) IsStorageClassPresent(name string) (bool, error)

+ func (k8sh *K8sHelper) IsThirdPartyResourcePresent(tprname string) bool

+ func (k8sh *K8sHelper) Kubectl(args ...string) (string, error)

+ func (k8sh *K8sHelper) KubectlWithStdin(stdin string, args ...string) (string, error)

+ func (k8sh *K8sHelper) ResourceOperation(action string, podDefiniton string) (string, error)

+ func (k8sh *K8sHelper) ResourceOperationFromTemplate(action string, podDefinition string, config map[string]string) (string, error)

+ func (k8sh *K8sHelper) WaitUntilPVCIsBound(pvcname string) bool

+ func (k8sh *K8sHelper) WaitUntilPodInNamespaceIsDeleted(podNamePattern string, namespace string) bool

+ func (k8sh *K8sHelper) WaitUntilPodIsDeleted(podNamePattern string) bool

+ type MySQLHelper struct

+ DB *sql.DB

+ func CreateNewMySQLHelper(username string, password string, url string, dbname string) *MySQLHelper

+ func (h *MySQLHelper) CloseConnection()

+ func (h *MySQLHelper) CreateTable() sql.Result

+ func (h *MySQLHelper) DeleteRandomRow() sql.Result

+ func (h *MySQLHelper) InsertRandomData() sql.Result

+ func (h *MySQLHelper) PingSuccess() bool

+ func (h *MySQLHelper) TableExists() bool

+ func (h *MySQLHelper) TableRowCount() (count int)

+ type S3Helper struct

+ func CreateNewS3Helper(endpoint string, keyID string, keySecret string) *S3Helper

+ func (h *S3Helper) CreateBucket(name string) (bool, error)

+ func (h *S3Helper) DeleteBucket(name string) (bool, error)

+ func (h *S3Helper) DeleteObjectInBucket(bucketname string, key string) (bool, error)

+ func (h *S3Helper) GetObjectInBucket(bucketname string, key string) (string, error)

+ func (h *S3Helper) PutObjectInBucket(bucketname string, body string, key string, contentType string) (bool, error)