Restructre AppSetting and address comments.

This commit is contained in:
arijitad
2020-07-23 10:00:16 +05:30
parent 80b19f918b
commit 01b6f1129c
28 changed files with 245 additions and 243 deletions
+2 -2
View File
@@ -95,7 +95,7 @@ func BenchmarkTCPOutput(b *testing.B) {
}
func TestStickyDisable(t *testing.T) {
tcpOutput := TCPOutput{config: &TCPOutputConfig{sticky: false}}
tcpOutput := TCPOutput{config: &TCPOutputConfig{Sticky: false}}
for i := 0; i < 1000; i++ {
index := tcpOutput.getBufferIndex(getTestBytes())
@@ -111,7 +111,7 @@ func TestBufferDistribution(t *testing.T) {
percentDistributionErrorRange := 20
buffer := make([]int, numberOfWorkers)
tcpOutput := TCPOutput{config: &TCPOutputConfig{sticky: true}}
tcpOutput := TCPOutput{config: &TCPOutputConfig{Sticky: true}}
for i := 0; i < numberOfMessages; i++ {
buffer[tcpOutput.getBufferIndex(getTestBytes())]++
}