Skip to content

Commit

Permalink
run gofmt
Browse files Browse the repository at this point in the history
Signed-off-by: Your Name <[email protected]>
  • Loading branch information
akagami-harsh committed Feb 8, 2025
1 parent 8fefcfb commit b20f549
Show file tree
Hide file tree
Showing 4 changed files with 23 additions and 23 deletions.
8 changes: 4 additions & 4 deletions go/cache/lru_cache_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -119,16 +119,16 @@ func TestCapacityIsObeyed(t *testing.T) {
// Check various other stats
l := cache.Len()
assert.Equal(t, size, int64(l), "cache.Len() returned bad length: %v", l)

s := cache.UsedCapacity()
assert.Equal(t, size, s, "cache.UsedCapacity() returned bad size: %v", s)

c := cache.MaxCapacity()
assert.Equal(t, size, c, "cache.UsedCapacity() returned bad length: %v", c)

hits := cache.Hits()
assert.Zero(t, hits, "cache.Hits() returned hits when there should be none: %v", hits)

misses := cache.Misses()
assert.Zero(t, misses, "cache.Misses() returned misses when there should be none: %v", misses)
}
Expand Down
12 changes: 6 additions & 6 deletions go/event/event_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,8 +56,8 @@ func TestStaticListener(t *testing.T) {

triggered := false
AddListener(func(testEvent1) { triggered = true })
AddListener(func(testEvent2) {
assert.Fail(t, "wrong listener type triggered")
AddListener(func(testEvent2) {
assert.Fail(t, "wrong listener type triggered")
})
Dispatch(testEvent1{})
assert.True(t, triggered, "static listener failed to trigger")
Expand All @@ -68,8 +68,8 @@ func TestPointerListener(t *testing.T) {

testEvent := new(testEvent2)
AddListener(func(ev *testEvent2) { ev.triggered = true })
AddListener(func(testEvent2) {
assert.Fail(t, "non-pointer listener triggered on pointer type")
AddListener(func(testEvent2) {
assert.Fail(t, "non-pointer listener triggered on pointer type")
})
Dispatch(testEvent)
assert.True(t, testEvent.triggered, "pointer listener failed to trigger")
Expand All @@ -80,8 +80,8 @@ func TestInterfaceListener(t *testing.T) {

triggered := false
AddListener(func(testInterface1) { triggered = true })
AddListener(func(testInterface2) {
assert.Fail(t, "interface listener triggered on non-matching type")
AddListener(func(testInterface2) {
assert.Fail(t, "interface listener triggered on non-matching type")
})
Dispatch(testEvent1{})
assert.True(t, triggered, "interface listener failed to trigger")
Expand Down
2 changes: 1 addition & 1 deletion go/pools/resource_pool_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -534,7 +534,7 @@ func TestCreateFail(t *testing.T) {

_, err := p.Get(ctx)
assert.EqualError(t, err, "Failed", "Expecting Failed, received %v", err)
stats := p.StatsJSON()
expected := `{"Capacity": 5, "Available": 5, "Active": 0, "InUse": 0, "MaxCapacity": 5, "WaitCount": 0, "WaitTime": 0, "IdleTimeout": 1000000000, "IdleClosed": 0, "MaxLifetimeClosed": 0, "Exhausted": 0}`
assert.Equal(t, expected, stats)
Expand Down
24 changes: 12 additions & 12 deletions go/stats/statsd/statsd_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,11 +47,11 @@ func TestStatsdCounter(t *testing.T) {
if kv.Key == name {
sb.addExpVar(kv)
require.NoError(t, sb.statsdClient.Flush(), "Error flushing")

bytes := make([]byte, 4096)
n, err := server.Read(bytes)
require.NoError(t, err)

result := string(bytes[:n])
expected := "test.counter_name:1|c\n"
assert.Equal(t, expected, result)
Expand All @@ -72,11 +72,11 @@ func TestStatsdGauge(t *testing.T) {
found = true
sb.addExpVar(kv)
require.NoError(t, sb.statsdClient.Flush(), "Error flushing")

bytes := make([]byte, 4096)
n, err := server.Read(bytes)
require.NoError(t, err)

result := string(bytes[:n])
expected := "test.gauge_name:10|g\n"
assert.Equal(t, expected, result)
Expand All @@ -97,11 +97,11 @@ func TestStatsdGaugeFloat64(t *testing.T) {
found = true
sb.addExpVar(kv)
require.NoError(t, sb.statsdClient.Flush(), "Error flushing")

bytes := make([]byte, 4096)
n, err := server.Read(bytes)
require.NoError(t, err)

result := string(bytes[:n])
expected := "test.gauge_name_f64:3.14|g\n"
assert.Equal(t, expected, result)
Expand All @@ -123,11 +123,11 @@ func TestStatsdGaugeFunc(t *testing.T) {
found = true
sb.addExpVar(kv)
require.NoError(t, sb.statsdClient.Flush(), "Error flushing")

bytes := make([]byte, 4096)
n, err := server.Read(bytes)
require.NoError(t, err)

result := string(bytes[:n])
expected := "test.gauge_func_name:2|g\n"
assert.Equal(t, expected, result)
Expand Down Expand Up @@ -205,11 +205,11 @@ func TestStatsdCountersWithMultiLabels(t *testing.T) {
found = true
sb.addExpVar(kv)
require.NoError(t, sb.statsdClient.Flush(), "Error flushing")

bytes := make([]byte, 4096)
n, err := server.Read(bytes)
require.NoError(t, err)

result := string(bytes[:n])
expected := "test.counter_with_multiple_label_name:1|c|#label1:foo,label2:bar\n"
assert.Equal(t, expected, result)
Expand Down Expand Up @@ -404,11 +404,11 @@ func TestStatsdHistogram(t *testing.T) {
found = true
sb.addExpVar(kv)
require.NoError(t, sb.statsdClient.Flush(), "Error flushing")

bytes := make([]byte, 4096)
n, err := server.Read(bytes)
require.NoError(t, err)

result := string(bytes[:n])
expected := []string{
"test.histogram_name:2|h",
Expand Down

0 comments on commit b20f549

Please sign in to comment.