github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-21 19:43:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Exported test funcs (#872)

Browse Source
This commit is contained in:
RoyUP9 2022-03-02 18:34:51 +02:00 committed by GitHub
parent 7f4cb6dfd4
commit 5f8a5a3a29
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
acceptanceTests/testsUtils.go
View File

@ -265,11 +265,11 @@ func RunCypressTests(t *testing.T, cypressRunCmd string) {
t.Logf("%s", out) t.Logf("%s", out)
} }
func retriesExecute(retriesCount int, executeFunc func() error) error { func RetriesExecute(retriesCount int, executeFunc func() error) error {
var lastError interface{} var lastError interface{}
for i := 0; i < retriesCount; i++ { for i := 0; i < retriesCount; i++ {
if err := tryExecuteFunc(executeFunc); err != nil { if err := TryExecuteFunc(executeFunc); err != nil {
lastError = err lastError = err
time.Sleep(1 * time.Second) time.Sleep(1 * time.Second)
@ -282,7 +282,7 @@ func retriesExecute(retriesCount int, executeFunc func() error) error {
return fmt.Errorf("reached max retries count, retries count: %v, last err: %v", retriesCount, lastError) return fmt.Errorf("reached max retries count, retries count: %v, last err: %v", retriesCount, lastError)
} }
func tryExecuteFunc(executeFunc func() error) (err interface{}) { func TryExecuteFunc(executeFunc func() error) (err interface{}) {
defer func() { defer func() {
if panicErr := recover(); panicErr != nil { if panicErr := recover(); panicErr != nil {
err = panicErr err = panicErr
@ -308,10 +308,10 @@ func WaitTapPodsReady(apiServerUrl string) error {
return nil return nil
} }
return retriesExecute(LongRetriesCount, tapPodsReadyFunc) return RetriesExecute(LongRetriesCount, tapPodsReadyFunc)
} }
func jsonBytesToInterface(jsonBytes []byte) (interface{}, error) { func JsonBytesToInterface(jsonBytes []byte) (interface{}, error) {
var result interface{} var result interface{}
if parseErr := json.Unmarshal(jsonBytes, &result); parseErr != nil { if parseErr := json.Unmarshal(jsonBytes, &result); parseErr != nil {
return nil, parseErr return nil, parseErr
@ -334,7 +334,7 @@ func ExecuteHttpRequest(response *http.Response, requestErr error) (interface{},
return nil, readErr return nil, readErr
} }
return jsonBytesToInterface(data) return JsonBytesToInterface(data)
} }
func ExecuteHttpGetRequestWithHeaders(url string, headers map[string]string) (interface{}, error) { func ExecuteHttpGetRequestWithHeaders(url string, headers map[string]string) (interface{}, error) {