...

Source file src/edge-infra.dev/pkg/f8n/warehouse/k8s/controllers/lumperctl/internal/liveness_test.go

Documentation: edge-infra.dev/pkg/f8n/warehouse/k8s/controllers/lumperctl/internal

     1  package internal
     2  
     3  import (
     4  	"fmt"
     5  
     6  	"testing"
     7  
     8  	whv1 "edge-infra.dev/pkg/f8n/warehouse/k8s/apis/v1alpha2"
     9  
    10  	"github.com/go-logr/logr"
    11  )
    12  
    13  func TestLivenessWillWrap(t *testing.T) {
    14  	l := logr.New(nil)
    15  	lc := New(l)
    16  	for i := 0; i < maxIterations+435; i++ {
    17  		p := &whv1.UnpackedPallet{}
    18  		lc.AddStatus(p, nil)
    19  		if err := lc.Status(); err != nil {
    20  			t.Fatal("there was an error", err)
    21  		}
    22  	}
    23  }
    24  
    25  func TestLivenessNilErr(t *testing.T) {
    26  	l := logr.New(nil)
    27  	lc := New(l)
    28  	p := &whv1.UnpackedPallet{}
    29  	lc.AddStatus(p, nil)
    30  	t.Log("no panic")
    31  }
    32  
    33  func TestLivenessWillError(t *testing.T) {
    34  	l := logr.New(nil)
    35  	lc := New(l)
    36  	for i := 0; i < maxIterations+435; i++ {
    37  		fmt.Println("iteration", i)
    38  		p := &whv1.UnpackedPallet{}
    39  		err := fmt.Errorf("error %d", i)
    40  		lc.AddStatus(p, err)
    41  		statusErr := lc.Status()
    42  		if statusErr != nil {
    43  			fmt.Println("ending with iteration", err)
    44  			return
    45  		}
    46  	}
    47  
    48  	t.Fatal("no error detected")
    49  }
    50  

View as plain text