(t *testing.T)
| 971 | } |
| 972 | |
| 973 | func TestAccountInfo(t *testing.T) { |
| 974 | t.Run("fetch account info", func(t *testing.T) { |
| 975 | srv := RunBasicJetStreamServer() |
| 976 | defer shutdownJSServerAndRemoveStorage(t, srv) |
| 977 | nc, err := nats.Connect(srv.ClientURL()) |
| 978 | if err != nil { |
| 979 | t.Fatalf("Unexpected error: %v", err) |
| 980 | } |
| 981 | |
| 982 | ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second) |
| 983 | defer cancel() |
| 984 | js, err := jetstream.New(nc) |
| 985 | if err != nil { |
| 986 | t.Fatalf("Unexpected error: %v", err) |
| 987 | } |
| 988 | defer nc.Close() |
| 989 | _, err = js.CreateStream(ctx, jetstream.StreamConfig{Name: "foo", Subjects: []string{"FOO.123"}}) |
| 990 | if err != nil { |
| 991 | t.Fatalf("Unexpected error: %v", err) |
| 992 | } |
| 993 | info, err := js.AccountInfo(ctx) |
| 994 | if err != nil { |
| 995 | t.Fatalf("Unexpected error: %v", err) |
| 996 | } |
| 997 | |
| 998 | if info.Streams != 1 { |
| 999 | t.Fatalf("Invalid number of streams; want: 1; got: %d", info.Streams) |
| 1000 | } |
| 1001 | }) |
| 1002 | |
| 1003 | t.Run("account limits fields", func(t *testing.T) { |
| 1004 | srv := RunBasicJetStreamServer() |
| 1005 | defer shutdownJSServerAndRemoveStorage(t, srv) |
| 1006 | nc, err := nats.Connect(srv.ClientURL()) |
| 1007 | if err != nil { |
| 1008 | t.Fatalf("Unexpected error: %v", err) |
| 1009 | } |
| 1010 | defer nc.Close() |
| 1011 | |
| 1012 | ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second) |
| 1013 | defer cancel() |
| 1014 | js, err := jetstream.New(nc) |
| 1015 | if err != nil { |
| 1016 | t.Fatalf("Unexpected error: %v", err) |
| 1017 | } |
| 1018 | |
| 1019 | info, err := js.AccountInfo(ctx) |
| 1020 | if err != nil { |
| 1021 | t.Fatalf("Unexpected error: %v", err) |
| 1022 | } |
| 1023 | |
| 1024 | expectedLimits := jetstream.AccountLimits{ |
| 1025 | MaxMemory: -1, |
| 1026 | MaxStore: -1, |
| 1027 | MaxStreams: -1, |
| 1028 | MaxConsumers: -1, |
| 1029 | MaxAckPending: -1, |
| 1030 | MemoryMaxStreamBytes: -1, |
nothing calls this directly
no test coverage detected