(t *testing.T)
| 3876 | } |
| 3877 | |
| 3878 | func TestJetStreamManagement_GetMsg(t *testing.T) { |
| 3879 | t.Run("1-node", func(t *testing.T) { |
| 3880 | withJSServer(t, testJetStreamManagement_GetMsg) |
| 3881 | }) |
| 3882 | t.Run("3-node", func(t *testing.T) { |
| 3883 | withJSCluster(t, "GET", 3, testJetStreamManagement_GetMsg) |
| 3884 | }) |
| 3885 | } |
| 3886 | |
| 3887 | func testJetStreamManagement_GetMsg(t *testing.T, srvs ...*jsServer) { |
| 3888 | s := srvs[0] |
nothing calls this directly
no test coverage detected