Skip to content

Commit

Permalink
Revert some signature changes.
Browse files Browse the repository at this point in the history
  • Loading branch information
friedrichwilken committed Dec 9, 2023
1 parent bbcd5f8 commit 9960482
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions e2e/setup/setup_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ func Test_CR(t *testing.T) {

// Get the NATS CR from the cluster.
actual, err := RetryGet(attempts, interval, func() (*natsv1alpha1.NATS, error) {
return getNATSCR(want.Name, want.Namespace)
return getNATSCR(context.TODO(), want.Name, want.Namespace)
})
require.NoError(t, err)

Expand Down Expand Up @@ -246,7 +246,7 @@ func Test_PodsReady(t *testing.T) {

// RetryGet the NATS CR. It will tell us how many Pods we should expect.
natsCR, err := RetryGet(attempts, interval, func() (*natsv1alpha1.NATS, error) {
return getNATSCR(CRName, NamespaceName)
return getNATSCR(context.TODO(), CRName, NamespaceName)
})
require.NoError(t, err)

Expand Down Expand Up @@ -342,9 +342,9 @@ func Test_Secret(t *testing.T) {
require.NoError(t, err)
}

func getNATSCR(name, namespace string) (*natsv1alpha1.NATS, error) {
func getNATSCR(ctx context.Context, name, namespace string) (*natsv1alpha1.NATS, error) {
var natsCR natsv1alpha1.NATS
err := k8sClient.Get(context.TODO(), k8stypes.NamespacedName{
err := k8sClient.Get(ctx, k8stypes.NamespacedName{
Name: name,
Namespace: namespace,
}, &natsCR)
Expand Down Expand Up @@ -395,7 +395,7 @@ func waitForNATSCRReady() error {

// Get the NATS CR from the cluster.
gotNATSCR, err := RetryGet(attempts, interval, func() (*natsv1alpha1.NATS, error) {
return getNATSCR(want.Name, want.Namespace)
return getNATSCR(context.TODO(), want.Name, want.Namespace)
})
if err != nil {
return err
Expand Down

0 comments on commit 9960482

Please sign in to comment.