(t *testing.T)
| 524 | } |
| 525 | |
| 526 | func connectJS(t *testing.T) (*nats.Conn, nats.JetStreamContext) { |
| 527 | nc := connect(t) |
| 528 | js, err := nc.JetStream() |
| 529 | if err != nil { |
| 530 | t.Fatalf("Error getting JetStream context: %v", err) |
| 531 | } |
| 532 | return nc, js |
| 533 | } |
| 534 | |
| 535 | type serviceStepConfig[T any] struct { |
| 536 | Suite string `json:"suite"` |