@@ -767,8 +767,8 @@ func TestKubernetesAgentHelm(t *testing.T) {
767767 },
768768 "outputs" : map [string ]any {
769769 "default" : map [string ]any {
770- "type" : "Logstash" ,
771- "hosts" : [1 ]string {"logstash-agent:5044" },
770+ "type" : "Logstash" ,
771+ "hosts" : [1 ]string {"logstash-agent:5044" },
772772 "ssl" : map [string ]any {
773773 "certificateAuthorities" : []map [string ]any {{
774774 "valueFromSecret" : map [string ]any {
@@ -1257,7 +1257,6 @@ func k8sStepLogstashCreate() k8sTestStep {
12571257 }
12581258}
12591259
1260-
12611260func k8sStepLogstashDelete () k8sTestStep {
12621261 return func (t * testing.T , ctx context.Context , kCtx k8sContext , namespace string ) {
12631262 logstashPod := & corev1.Pod {}
@@ -1268,6 +1267,7 @@ func k8sStepLogstashDelete() k8sTestStep {
12681267 require .NoError (t , err , "failed to delete logstash k8s objects" )
12691268 }
12701269}
1270+
12711271func k8sStepLogstashCheckStatus (logstashPodLabelSelector string , logstashExpected bool ) k8sTestStep {
12721272 return func (t * testing.T , ctx context.Context , kCtx k8sContext , namespace string ) {
12731273 logstashPodList := & corev1.PodList {}
@@ -1283,8 +1283,10 @@ func k8sStepLogstashCheckStatus(logstashPodLabelSelector string, logstashExpecte
12831283 if (pod .Status .Phase == corev1 .PodRunning ) && ! logstashExpected {
12841284 t .Errorf ("logstash pod %s is running but it should not" , pod .Name )
12851285 }
1286+ }
12861287 }
12871288}
1289+
12881290func k8sStepHintsRedisCreate () k8sTestStep {
12891291 return func (t * testing.T , ctx context.Context , kCtx k8sContext , namespace string ) {
12901292 r , err := os .Open ("testdata/k8s.hints.redis.yaml" )
0 commit comments