mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-16 19:14:41 -07:00
Updated benchmark formatting, added 128b payload
This commit is contained in:
@@ -75,7 +75,7 @@ func sizedString(sz int) string {
|
||||
// Publish subject for pub benchmarks.
|
||||
var psub = "a"
|
||||
|
||||
func Benchmark_____PubNo_Payload(b *testing.B) {
|
||||
func Benchmark_____Pub0b_Payload(b *testing.B) {
|
||||
benchPub(b, psub, "")
|
||||
}
|
||||
|
||||
@@ -91,6 +91,12 @@ func Benchmark____Pub32b_Payload(b *testing.B) {
|
||||
benchPub(b, psub, s)
|
||||
}
|
||||
|
||||
func Benchmark___Pub128B_Payload(b *testing.B) {
|
||||
b.StopTimer()
|
||||
s := sizedString(128)
|
||||
benchPub(b, psub, s)
|
||||
}
|
||||
|
||||
func Benchmark___Pub256B_Payload(b *testing.B) {
|
||||
b.StopTimer()
|
||||
s := sizedString(256)
|
||||
@@ -138,7 +144,7 @@ func drainConnection(b *testing.B, c net.Conn, ch chan bool, expected int) {
|
||||
}
|
||||
|
||||
// Benchmark the authorization code path.
|
||||
func Benchmark_AuthPubNo_Payload(b *testing.B) {
|
||||
func Benchmark_AuthPub0b_Payload(b *testing.B) {
|
||||
b.StopTimer()
|
||||
|
||||
srv, opts := RunServerWithConfig("./configs/authorization.conf")
|
||||
@@ -383,14 +389,14 @@ func routePubSub(b *testing.B, size int) {
|
||||
sub.Close()
|
||||
}
|
||||
|
||||
func Benchmark_RoutePubSub_NoPayload(b *testing.B) {
|
||||
func Benchmark___RoutedPubSub_0b(b *testing.B) {
|
||||
routePubSub(b, 2)
|
||||
}
|
||||
|
||||
func Benchmark_RoutePubSub_1K(b *testing.B) {
|
||||
func Benchmark___RoutedPubSub_1K(b *testing.B) {
|
||||
routePubSub(b, 1024)
|
||||
}
|
||||
|
||||
func Benchmark_RoutePubSub_100K(b *testing.B) {
|
||||
func Benchmark_RoutedPubSub_100K(b *testing.B) {
|
||||
routePubSub(b, 100*1024)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user