gofmt98%

Gofmt formats Go programs. We run gofmt -s on your code, where -s is for the "simplify" command

• lib/util/disk/check_windows.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

• lib/output/writer/zmq4.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

• lib/output/writer/zmq4_stub.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

• lib/input/zmq4.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

• lib/output/zmq4.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

• lib/input/reader/zmq4.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

• lib/input/reader/zmq4_stub.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

• lib/util/disk/check.go
  • Line 1: warning: file is not gofmted with -s (gofmt)

go_vet100%

go vet examines Go source code and reports suspicious constructs, such as Printf calls whose arguments do not align with the format string.

No problems detected. Good job!

golint100%

Golint is a linter for Go source code.

No problems detected. Good job!

gocyclo86%

Gocyclo calculates cyclomatic complexities of functions in Go source code. The cyclomatic complexity of a function is calculated according to the following rules: 1 is the base complexity of a function +1 for each 'if', 'for', 'case', '&&' or '||' Go Report Card warns on functions with cyclomatic complexity > 15.

• lib/broker/try_test.go
  • Line 138: warning: cyclomatic complexity 25 of function TestTryHappyishPath() is high (> 15) (gocyclo)
  • Line 238: warning: cyclomatic complexity 19 of function TestTryAllFail() is high (> 15) (gocyclo)
  • Line 61: warning: cyclomatic complexity 18 of function TestTryHappyPath() is high (> 15) (gocyclo)

• lib/util/http/client/type.go
  • Line 451: warning: cyclomatic complexity 22 of function (*Type).Do() is high (> 15) (gocyclo)
  • Line 301: warning: cyclomatic complexity 19 of function (*Type).CreateRequest() is high (> 15) (gocyclo)
  • Line 123: warning: cyclomatic complexity 16 of function New() is high (> 15) (gocyclo)

• lib/broker/dynamic_fan_in_test.go
  • Line 117: warning: cyclomatic complexity 20 of function TestBasicDynamicFanIn() is high (> 15) (gocyclo)

• lib/buffer/single/mmap_cache_test.go
  • Line 120: warning: cyclomatic complexity 19 of function TestMmapCacheIndexes() is high (> 15) (gocyclo)
  • Line 32: warning: cyclomatic complexity 17 of function TestMmapCacheTracker() is high (> 15) (gocyclo)

• lib/input/reader/lines_test.go
  • Line 94: warning: cyclomatic complexity 19 of function TestReaderSinglePartMultiReaders() is high (> 15) (gocyclo)

• lib/output/broker_test.go
  • Line 141: warning: cyclomatic complexity 19 of function TestRoundRobinWithNanomsg() is high (> 15) (gocyclo)
  • Line 40: warning: cyclomatic complexity 18 of function TestBrokerWithNanomsg() is high (> 15) (gocyclo)

• lib/broker/fan_out.go
  • Line 113: warning: cyclomatic complexity 17 of function (*FanOut).loop() is high (> 15) (gocyclo)

• lib/config/refs.go
  • Line 137: warning: cyclomatic complexity 16 of function expandRefVal() is high (> 15) (gocyclo)

• lib/input/reader/kafka_balanced.go
  • Line 124: warning: cyclomatic complexity 21 of function NewKafkaBalanced() is high (> 15) (gocyclo)
  • Line 260: warning: cyclomatic complexity 17 of function (*KafkaBalanced).Connect() is high (> 15) (gocyclo)

• lib/output/writer/http_client_test.go
  • Line 134: warning: cyclomatic complexity 17 of function TestHTTPClientMultipart() is high (> 15) (gocyclo)

• lib/input/reader/kinesis.go
  • Line 123: warning: cyclomatic complexity 20 of function (*Kinesis).getIter() is high (> 15) (gocyclo)

• lib/input/http_client_test.go
  • Line 316: warning: cyclomatic complexity 19 of function TestHTTPClientGETMultipart() is high (> 15) (gocyclo)
  • Line 412: warning: cyclomatic complexity 18 of function TestHTTPClientGETMultipartLoop() is high (> 15) (gocyclo)
  • Line 220: warning: cyclomatic complexity 17 of function TestHTTPClientPOST() is high (> 15) (gocyclo)
  • Line 613: warning: cyclomatic complexity 16 of function TestHTTPClientStreamGETMultiRecover() is high (> 15) (gocyclo)

• lib/util/http/client/type_test.go
  • Line 240: warning: cyclomatic complexity 16 of function TestHTTPClientSendMultipart() is high (> 15) (gocyclo)

• lib/output/wrap_with_pipeline_test.go
  • Line 136: warning: cyclomatic complexity 16 of function TestBasicWrapPipelinesOrdering() is high (> 15) (gocyclo)

• lib/input/http_server_test.go
  • Line 36: warning: cyclomatic complexity 20 of function TestHTTPBasic() is high (> 15) (gocyclo)

• lib/buffer/memory_test.go
  • Line 35: warning: cyclomatic complexity 18 of function TestMemoryBuffer() is high (> 15) (gocyclo)

• cmd/benthos/main.go
  • Line 187: warning: cyclomatic complexity 52 of function bootstrap() is high (> 15) (gocyclo)
  • Line 356: warning: cyclomatic complexity 30 of function main() is high (> 15) (gocyclo)

• lib/pipeline/pool_test.go
  • Line 38: warning: cyclomatic complexity 25 of function TestPoolBasic() is high (> 15) (gocyclo)
  • Line 156: warning: cyclomatic complexity 20 of function TestPoolMultiMsgs() is high (> 15) (gocyclo)
  • Line 245: warning: cyclomatic complexity 19 of function TestPoolMultiThreads() is high (> 15) (gocyclo)

• lib/input/reader_test.go
  • Line 339: warning: cyclomatic complexity 22 of function TestReaderFailsReconnect() is high (> 15) (gocyclo)
  • Line 265: warning: cyclomatic complexity 20 of function TestReaderCanReconnect() is high (> 15) (gocyclo)
  • Line 528: warning: cyclomatic complexity 16 of function TestReaderSadPath() is high (> 15) (gocyclo)
  • Line 458: warning: cyclomatic complexity 16 of function TestReaderHappyPath() is high (> 15) (gocyclo)

• lib/output/retry.go
  • Line 193: warning: cyclomatic complexity 17 of function (*Retry).loop() is high (> 15) (gocyclo)

• cmd/serverless/benthos-lambda/main.go
  • Line 57: warning: cyclomatic complexity 20 of function init() is high (> 15) (gocyclo)

• lib/output/broker_out_common_test.go
  • Line 184: warning: cyclomatic complexity 18 of function TestBrokerConfigPluginDitto() is high (> 15) (gocyclo)

• lib/input/reader/files_test.go
  • Line 34: warning: cyclomatic complexity 17 of function TestFilesDirectory() is high (> 15) (gocyclo)

• lib/input/reader/amazon_s3.go
  • Line 237: warning: cyclomatic complexity 26 of function (*AmazonS3).readSQSEvents() is high (> 15) (gocyclo)

• lib/broker/fan_out_sequential_test.go
  • Line 194: warning: cyclomatic complexity 23 of function TestFanOutSequentialBlock() is high (> 15) (gocyclo)
  • Line 112: warning: cyclomatic complexity 23 of function TestFanOutSequentialAtLeastOnce() is high (> 15) (gocyclo)
  • Line 38: warning: cyclomatic complexity 18 of function TestBasicFanOutSequential() is high (> 15) (gocyclo)

• lib/input/broker_test.go
  • Line 203: warning: cyclomatic complexity 18 of function TestBrokerConfigPluginDitto() is high (> 15) (gocyclo)

• lib/output/writer/dynamodb.go
  • Line 221: warning: cyclomatic complexity 17 of function (*DynamoDB).Write() is high (> 15) (gocyclo)

• lib/broker/dynamic_fan_in.go
  • Line 218: warning: cyclomatic complexity 16 of function (*DynamicFanIn).managerLoop() is high (> 15) (gocyclo)

• lib/pipeline/processor_test.go
  • Line 75: warning: cyclomatic complexity 31 of function TestProcessorPipeline() is high (> 15) (gocyclo)
  • Line 319: warning: cyclomatic complexity 27 of function TestProcessorMultiMsgsOddSync() is high (> 15) (gocyclo)
  • Line 234: warning: cyclomatic complexity 21 of function TestProcessorMultiMsgs() is high (> 15) (gocyclo)

• lib/output/retry_test.go
  • Line 120: warning: cyclomatic complexity 23 of function TestRetrySadPath() is high (> 15) (gocyclo)

• lib/input/reader/redis_streams.go
  • Line 227: warning: cyclomatic complexity 17 of function (*RedisStreams).Read() is high (> 15) (gocyclo)

• lib/message/part_with_context_test.go
  • Line 28: warning: cyclomatic complexity 16 of function TestPartWithContext() is high (> 15) (gocyclo)

• lib/input/http_server.go
  • Line 196: warning: cyclomatic complexity 23 of function (*HTTPServer).postHandler() is high (> 15) (gocyclo)

• lib/input/read_until.go
  • Line 203: warning: cyclomatic complexity 21 of function (*ReadUntil).loop() is high (> 15) (gocyclo)

• lib/output/writer_test.go
  • Line 316: warning: cyclomatic complexity 18 of function TestWriterCanReconnect() is high (> 15) (gocyclo)

• lib/input/reader/scale_proto_test.go
  • Line 38: warning: cyclomatic complexity 17 of function TestScaleProtoBasic() is high (> 15) (gocyclo)

• lib/input/reader/scale_proto.go
  • Line 128: warning: cyclomatic complexity 16 of function (*ScaleProto).Connect() is high (> 15) (gocyclo)

• lib/input/reader.go
  • Line 84: warning: cyclomatic complexity 30 of function (*Reader).loop() is high (> 15) (gocyclo)

• lib/broker/greedy_test.go
  • Line 59: warning: cyclomatic complexity 16 of function TestBasicGreedy() is high (> 15) (gocyclo)

• lib/message/mapper/type_test.go
  • Line 777: warning: cyclomatic complexity 32 of function TestTypeOverlayResult() is high (> 15) (gocyclo)

• lib/broker/dynamic_fan_out_test.go
  • Line 129: warning: cyclomatic complexity 30 of function TestDynamicFanOutChangeOutputs() is high (> 15) (gocyclo)
  • Line 263: warning: cyclomatic complexity 23 of function TestDynamicFanOutAtLeastOnce() is high (> 15) (gocyclo)
  • Line 53: warning: cyclomatic complexity 17 of function TestBasicDynamicFanOut() is high (> 15) (gocyclo)
  • Line 365: warning: cyclomatic complexity 16 of function TestDynamicFanOutShutDownFromErrorResponse() is high (> 15) (gocyclo)

• lib/broker/fan_out_test.go
  • Line 129: warning: cyclomatic complexity 24 of function TestFanOutAtLeastOnce() is high (> 15) (gocyclo)
  • Line 51: warning: cyclomatic complexity 19 of function TestBasicFanOut() is high (> 15) (gocyclo)

• lib/input/reader/preserver_test.go
  • Line 210: warning: cyclomatic complexity 17 of function TestPreserverBuffer() is high (> 15) (gocyclo)

• lib/input/file_test.go
  • Line 100: warning: cyclomatic complexity 17 of function TestFileMultiPart() is high (> 15) (gocyclo)

• lib/output/writer/kinesis.go
  • Line 201: warning: cyclomatic complexity 17 of function (*Kinesis).Write() is high (> 15) (gocyclo)

• lib/input/reader/amqp.go
  • Line 229: warning: cyclomatic complexity 16 of function setMetadata() is high (> 15) (gocyclo)

• lib/buffer/single_wrapper_test.go
  • Line 39: warning: cyclomatic complexity 40 of function TestBasicMemoryBuffer() is high (> 15) (gocyclo)

• lib/buffer/parallel_wrapper_test.go
  • Line 38: warning: cyclomatic complexity 40 of function TestParallelMemoryBuffer() is high (> 15) (gocyclo)

• lib/output/switch_test.go
  • Line 225: warning: cyclomatic complexity 27 of function TestSwitchWithConditions() is high (> 15) (gocyclo)
  • Line 404: warning: cyclomatic complexity 27 of function TestSwitchWithConditionsNoFallthrough() is high (> 15) (gocyclo)
  • Line 528: warning: cyclomatic complexity 25 of function TestSwitchAtLeastOnce() is high (> 15) (gocyclo)
  • Line 147: warning: cyclomatic complexity 20 of function TestSwitchNoRetries() is high (> 15) (gocyclo)
  • Line 622: warning: cyclomatic complexity 18 of function TestSwitchShutDownFromErrorResponse() is high (> 15) (gocyclo)
  • Line 75: warning: cyclomatic complexity 18 of function TestSwitchNoConditions() is high (> 15) (gocyclo)

• lib/stream/manager/api.go
  • Line 71: warning: cyclomatic complexity 25 of function (*Type).HandleStreamsCRUD() is high (> 15) (gocyclo)
  • Line 209: warning: cyclomatic complexity 22 of function (*Type).HandleStreamCRUD() is high (> 15) (gocyclo)

• lib/stream/manager/api_test.go
  • Line 147: warning: cyclomatic complexity 21 of function TestTypeAPIBasicOperations() is high (> 15) (gocyclo)
  • Line 477: warning: cyclomatic complexity 17 of function TestTypeAPISetStreams() is high (> 15) (gocyclo)

• lib/cache/file_test.go
  • Line 35: warning: cyclomatic complexity 16 of function TestFileCache() is high (> 15) (gocyclo)

• lib/broker/dynamic_fan_out.go
  • Line 217: warning: cyclomatic complexity 29 of function (*DynamicFanOut).loop() is high (> 15) (gocyclo)

• lib/output/writer.go
  • Line 77: warning: cyclomatic complexity 25 of function (*Writer).loop() is high (> 15) (gocyclo)

• cmd/tools/benthos_config_gen/main.go
  • Line 69: warning: cyclomatic complexity 23 of function envify() is high (> 15) (gocyclo)
  • Line 371: warning: cyclomatic complexity 16 of function main() is high (> 15) (gocyclo)

• lib/pipeline/pool.go
  • Line 63: warning: cyclomatic complexity 20 of function (*Pool).loop() is high (> 15) (gocyclo)

• lib/input/wrap_with_pipeline_test.go
  • Line 354: warning: cyclomatic complexity 29 of function TestBasicWrapDoubleProcessors() is high (> 15) (gocyclo)
  • Line 235: warning: cyclomatic complexity 29 of function TestBasicWrapProcessors() is high (> 15) (gocyclo)

• lib/processor/awk.go
  • Line 346: warning: cyclomatic complexity 20 of function (*AWK).ProcessMessage() is high (> 15) (gocyclo)

• lib/test/integration/nats_stream_test.go
  • Line 179: warning: cyclomatic complexity 19 of function testNATSStreamResumeDurable() is high (> 15) (gocyclo)

• lib/message/mapper/type.go
  • Line 401: warning: cyclomatic complexity 19 of function (*Type).MapResponses() is high (> 15) (gocyclo)
  • Line 260: warning: cyclomatic complexity 16 of function (*Type).MapRequests() is high (> 15) (gocyclo)

• lib/broker/round_robin_test.go
  • Line 60: warning: cyclomatic complexity 18 of function TestBasicRoundRobin() is high (> 15) (gocyclo)

• lib/processor/json.go
  • Line 339: warning: cyclomatic complexity 17 of function newCleanOperator() is high (> 15) (gocyclo)

• lib/broker/try.go
  • Line 98: warning: cyclomatic complexity 16 of function (*Try).loop() is high (> 15) (gocyclo)

• lib/processor/text.go
  • Line 268: warning: cyclomatic complexity 16 of function getTextOperator() is high (> 15) (gocyclo)

• lib/message/part_test.go
  • Line 30: warning: cyclomatic complexity 16 of function TestPartBasic() is high (> 15) (gocyclo)

• lib/output/switch.go
  • Line 324: warning: cyclomatic complexity 29 of function (*Switch).loop() is high (> 15) (gocyclo)

• lib/input/read_until_test.go
  • Line 144: warning: cyclomatic complexity 19 of function testReadUntilRetry() is high (> 15) (gocyclo)
  • Line 78: warning: cyclomatic complexity 16 of function testReadUntilBasic() is high (> 15) (gocyclo)

• lib/message/message_test.go
  • Line 376: warning: cyclomatic complexity 18 of function TestMessageSplitJSON() is high (> 15) (gocyclo)

• lib/stream/manager/type_test.go
  • Line 132: warning: cyclomatic complexity 16 of function TestTypeBasicOperations() is high (> 15) (gocyclo)

• lib/broker/fan_out_sequential.go
  • Line 115: warning: cyclomatic complexity 16 of function (*FanOutSequential).loop() is high (> 15) (gocyclo)

license100%

Checks whether your project has a LICENSE file.

No problems detected. Good job!

ineffassign100%

IneffAssign detects ineffectual assignments in Go code.

No problems detected. Good job!

misspell100%

Misspell Finds commonly misspelled English words

No problems detected. Good job!