Skip to content

Commit

Permalink
Reverted default to false
Browse files Browse the repository at this point in the history
  • Loading branch information
thom-at-redhat authored and AaronH88 committed Jan 18, 2024
1 parent 24fb3e2 commit ab0066a
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions pkg/workceptor/kubernetes.go
Original file line number Diff line number Diff line change
Expand Up @@ -748,7 +748,7 @@ func (kw *kubeUnit) runWorkUsingLogger() {
func shouldUseReconnect() bool {
// Support for streaming from pod with timestamps using reconnect method is in all current versions
// Can override the detection by setting the RECEPTOR_KUBE_SUPPORT_RECONNECT
// accepted values: "enabled", "disabled", "auto" with "enabled" being the default
// accepted values: "enabled", "disabled", "auto" with "disabled" being the default
// all invalid value will assume to be "disabled"

env, ok := os.LookupEnv("RECEPTOR_KUBE_SUPPORT_RECONNECT")
Expand All @@ -765,7 +765,7 @@ func shouldUseReconnect() bool {
}
}

return true
return false
}

func parseTime(s string) *time.Time {
Expand Down
4 changes: 2 additions & 2 deletions pkg/workceptor/kubernetes_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ func TestShouldUseReconnect(t *testing.T) {
{
name: "Positive (undefined) test",
envValue: "",
want: true,
want: false,
},
{
name: "Enabled test",
Expand All @@ -33,7 +33,7 @@ func TestShouldUseReconnect(t *testing.T) {
{
name: "Auto test",
envValue: "auto",
want: true,
want: false,
},
{
name: "Default test",
Expand Down

0 comments on commit ab0066a

Please sign in to comment.