utils

package

Go to main page

Versions in this module

v1

v1.0.1

May 14, 2019

v1.0.0

May 2, 2019

Changes in this version

type K8sHelper

+ func (k8sh *K8sHelper) ExecWithRetry(retries int, namespace, podName, command string, commandArgs []string) (string, error)

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

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

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

v0

v0.9.3

Mar 2, 2019

v0.9.2

Jan 26, 2019

v0.9.1

Jan 1, 2019

v0.9.0

Dec 8, 2018

Changes in this version

+ const TestMountPath

type HelmHelper

+ HelmPath string

type K8sHelper

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

+ func (k8sh *K8sHelper) DeletePods(pods ...string) (msg string, err error)

+ func (k8sh *K8sHelper) DeleteResourceAndWait(wait bool, args ...string) (string, error)

+ func (k8sh *K8sHelper) GetDockerImage(image string) error

+ func (k8sh *K8sHelper) GetPV(name string) (*v1.PersistentVolume, error)

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

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

+ func (k8sh *K8sHelper) IsPodTerminatedWithOpts(name string, namespace string, getOpts metav1.GetOptions) bool

+ func (k8sh *K8sHelper) PurgeClusters() error

+ func (k8sh *K8sHelper) ReadFromPod(namespace, podName, filename, expectedMessage string) error

+ func (k8sh *K8sHelper) ReadFromPodRetry(namespace, podName, filename, expectedMessage string, retries int) error

+ func (k8sh *K8sHelper) SetDeploymentVersion(namespace, deploymentName, containerName, version string) error

+ func (k8sh *K8sHelper) WaitForCustomResourceDeletion(namespace string, checkerFunc func() error) error

+ func (k8sh *K8sHelper) WaitForLabeledPodsToRun(label, namespace string) error

+ func (k8sh *K8sHelper) WaitForLabeledPodsToRunWithRetries(label string, namespace string, retries int) error

+ func (k8sh *K8sHelper) WriteToPod(namespace, podName, filename, message string) error

+ func (k8sh *K8sHelper) WriteToPodRetry(namespace, podName, filename, message string, retries int) error

v0.8.3

Oct 1, 2018

Changes in this version

type K8sHelper

+ func (k8sh *K8sHelper) ChangeHostnames() error

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

v0.8.2

Sep 18, 2018

v0.8.1

Aug 1, 2018

v0.8.0

Jul 18, 2018

Changes in this version

+ func IsKubectlErrorNotFound(output string, err error) bool

type K8sHelper

+ func (k8sh *K8sHelper) CountPodsWithLabel(label string, namespace string) (int, error)

+ func (k8sh *K8sHelper) CreateNamespace(namespace string) error

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

+ func (k8sh *K8sHelper) Exec(namespace, podName, command string, commandArgs []string) (string, error)

+ func (k8sh *K8sHelper) GetPodNamesForApp(appName, namespace string) ([]string, error)

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

+ func (k8sh *K8sHelper) IsDefaultStorageClassPresent() (bool, error)

+ func (k8sh *K8sHelper) IsRookClientsetAvailable() bool

+ func (k8sh *K8sHelper) IsVolumeResourceAbsent(namespace, volumeName string) bool

+ func (k8sh *K8sHelper) IsVolumeResourcePresent(namespace, volumeName string) bool

+ func (k8sh *K8sHelper) MakeContext() *clusterd.Context

+ func (k8sh *K8sHelper) PrintEventsForNamespace(namespace string)

+ func (k8sh *K8sHelper) PrintPVCs(namespace string, detailed bool)

+ func (k8sh *K8sHelper) PrintPVs(detailed bool)

+ func (k8sh *K8sHelper) PrintPodDescribe(name, namespace string)

+ func (k8sh *K8sHelper) PrintPodDescribeForNamespace(namespace string)

+ func (k8sh *K8sHelper) PrintPodStatus(namespace string)

+ func (k8sh *K8sHelper) PrintStorageClasses(detailed bool)

+ func (k8sh *K8sHelper) WaitForLabeledPodToRun(label string, namespace string) error

+ func (k8sh *K8sHelper) WaitForPodCount(label, namespace string, count int) error

v0.7.1

Mar 9, 2018

v0.7.0

Feb 21, 2018

Changes in this version

type K8sHelper

+ RookClientset *rookclient.Clientset

+ func (k8sh *K8sHelper) CheckPvcCountAndStatus(podName string, namespace string, expectedPvcCount int, expectedStatus string) bool

+ func (k8sh *K8sHelper) DeletePvcWithLabel(namespace string, podName string) bool

+ func (k8sh *K8sHelper) GetPVCAccessModes(namespace string, name string) ([]v1.PersistentVolumeAccessMode, error)

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

+ func (k8sh *K8sHelper) ScaleStatefulSet(statefulSetName, namespace string, replicationSize int) error

type S3Helper

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

v0.6.2

Dec 12, 2017

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)

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