gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into dev

Browse Source
This commit is contained in:
Derek Collison
2022-12-02 15:53:38 -08:00
parent 3b9be19b2d c4c8761293
commit be1a5d4b58
3 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/jetstream_benchmark_consume_test.go
View File

@@ -256,10 +256,10 @@ func BenchmarkJetStreamConsume(b *testing.B) {
messageSize int
minMessages int
}{
{1, 1, 10, 1_000_000}, // Single node, 10B messages, ~10MiB minimum
{1, 1, 1024, 100_000}, // Single node, 1KB messages, ~100MiB minimum
{3, 3, 10, 1_000_000}, // Cluster, R3, 10B messages, ~10MiB minimum
{3, 3, 1024, 100_000}, // Cluster, R3, 1KB messages, ~100MiB minimum
{1, 1, 10, 100_000}, // Single node, 10B messages, ~1MiB minimum
{1, 1, 1024, 1_000}, // Single node, 1KB messages, ~1MiB minimum
{3, 3, 10, 100_000}, // Cluster, R3, 10B messages, ~1MiB minimum
{3, 3, 1024, 1_000}, // Cluster, R3, 1KB messages, ~1MiB minimum
}
//Each of the cases above is run with each of the consumer types

2
server/jetstream_benchmark_kv_test.go
View File

@@ -31,7 +31,7 @@ func BenchmarkJetStreamKV(b *testing.B) {
kvNamePrefix = "B_"
keyPrefix = "K_"
seed = 12345
minOps = 100_000
minOps = 1_000
)
runKVGet := func(b *testing.B, kvs []nats.KeyValue, keys []string) int {

8
server/jetstream_benchmark_publish_test.go
View File

@@ -140,10 +140,10 @@ func BenchmarkJetStreamPublish(b *testing.B) {
numSubjects int
minMessages int
}{
{1, 1, 10, 1, 1_000_000}, // Single node, 10B messages, ~10MB minimum
{1, 1, 1024, 1, 500_000}, // Single node, 1KB messages, ~500MB minimum
{3, 3, 10, 1, 500_000}, // 3-nodes cluster, R=3, 10B messages, ~5MB minimum
{3, 3, 1024, 1, 100_000}, // 3-nodes cluster, R=3, 10B messages, ~100MB minimum
{1, 1, 10, 1, 100_000}, // Single node, 10B messages, ~1MB minimum
{1, 1, 1024, 1, 1_000}, // Single node, 1KB messages, ~1MB minimum
{3, 3, 10, 1, 100_000}, // 3-nodes cluster, R=3, 10B messages, ~1MB minimum
{3, 3, 1024, 1, 1_000}, // 3-nodes cluster, R=3, 10B messages, ~1MB minimum
}
// All the cases above are run with each of the publisher cases below