apache / eventmesh-go
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
13% | 0% | 24% | 30% | 31%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
go13% | 0% | 22% | 31% | 32%
xml0% | 0% | 100% | 0% | 0%
proto0% | 0% | 0% | 89% | 10%
yaml0% | 0% | 0% | 0% | 100%
yml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
runtime25% | 0% | 27% | 19% | 27%
log0% | 0% | 54% | 8% | 36%
style0% | 0% | 100% | 0% | 0%
plugin0% | 0% | 0% | 69% | 30%
config0% | 0% | 0% | 69% | 30%
pkg0% | 0% | 0% | 0% | 100%
configs0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
api0% | 0% | 0% | 0% | 100%
deployments0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
eventmesh-client.pb.go
in runtime/proto/pb
1271 128
363 46
eventmesh-client_grpc.pb.go
in runtime/proto/pb
355 34
323 -
roll_writer.go
in log/rollwriter
312 24
producer_processor.go
in runtime/core/protocol/grpc/producer
298 8
consumer_processor.go
in runtime/core/protocol/grpc/consumer
290 7
consumer_group_option.go
in runtime/core/protocol/grpc/consumer
234 24
message_request.go
in runtime/core/protocol/grpc/consumer
203 6
consumer_mesh.go
in runtime/core/protocol/grpc/consumer
199 9
nacos.go
in plugin/registry/nacos
199 13
broker.go
in plugin/connector/standalone
192 17
producer.go
in plugin/connector/rocketmq
183 17
cloudevents.go
in plugin/protocol/cloudevents
177 13
consumer_manager.go
in runtime/core/protocol/grpc/consumer
175 9
consumer.go
in plugin/connector/rocketmq
161 14
consumer.go
in plugin/connector/standalone
156 13
mock_naming_client_interface.go
in plugin/registry/nacos/mocks
138 24
proto
eventmesh-client.proto
in runtime/proto/pb
136 -
consumer_group_option.go
in runtime/core/protocol/grpc/consumer/mocks
135 24
consumer_service.go
in runtime/core/protocol/grpc/consumer
135 6
validator.go
in runtime/core/protocol/grpc/validator
126 5
metrics.go
in plugin/metrics/prometheus
116 12
config.go
in config
115 7
rocketmq_producer.go
in plugin/connector/rocketmq/client
114 10
mock_rocketmq_producer.go
in plugin/connector/rocketmq/mock
110 16
setup.go
in plugin
107 6
105 9
rocketmq_consumer.go
in plugin/connector/rocketmq/client
103 9
producer_service.go
in runtime/core/protocol/grpc/producer
101 4
config.go
in log
99 2
async_roll_writer.go
in log/rollwriter
98 5
consumer_manager.go
in runtime/core/protocol/grpc/consumer/mocks
90 16
consumer.go
in runtime/core/wrapper/mocks
89 16
mock_rocketmq_consumer.go
in plugin/connector/rocketmq/mock
88 16
producer_mesh.go
in runtime/core/protocol/grpc/producer
82 8
producer.go
in plugin/connector/standalone
80 12
message_handler.go
in runtime/core/protocol/grpc/consumer
77 4
rocketmq_message_reader.go
in plugin/connector/rocketmq/convert
74 7
server.go
in runtime
73 2
grpc.go
in runtime/emserver
73 3
73 -
73 7
connector.go
in plugin/connector
72 -
consumer.go
in runtime/core/wrapper
65 8
consumer_group_client.go
in runtime/core/protocol/grpc/consumer
64 2
producer_service.go
in runtime/proto/pb/mocks
63 10
consumer_service.go
in runtime/core/protocol/grpc/mocks
62 10
consumer_service.go
in runtime/proto/pb/mocks
62 10
logger.go
in log
62 1
Files With Most Units (Top 50)
File# lines# units
eventmesh-client.pb.go
in runtime/proto/pb
1271 128
363 46
eventmesh-client_grpc.pb.go
in runtime/proto/pb
355 34
consumer_group_option.go
in runtime/core/protocol/grpc/consumer/mocks
135 24
consumer_group_option.go
in runtime/core/protocol/grpc/consumer
234 24
mock_naming_client_interface.go
in plugin/registry/nacos/mocks
138 24
roll_writer.go
in log/rollwriter
312 24
broker.go
in plugin/connector/standalone
192 17
producer.go
in plugin/connector/rocketmq
183 17
consumer.go
in runtime/core/wrapper/mocks
89 16
consumer_manager.go
in runtime/core/protocol/grpc/consumer/mocks
90 16
mock_rocketmq_consumer.go
in plugin/connector/rocketmq/mock
88 16
mock_rocketmq_producer.go
in plugin/connector/rocketmq/mock
110 16
log.go
in log
57 15
consumer.go
in plugin/connector/rocketmq
161 14
cloudevents.go
in plugin/protocol/cloudevents
177 13
consumer.go
in plugin/connector/standalone
156 13
nacos.go
in plugin/registry/nacos
199 13
metrics.go
in plugin/metrics/prometheus
116 12
producer.go
in plugin/connector/standalone
80 12
consumer_service.go
in runtime/core/protocol/grpc/mocks
62 10
producer_service.go
in runtime/proto/pb/mocks
63 10
consumer_service.go
in runtime/proto/pb/mocks
62 10
rocketmq_producer.go
in plugin/connector/rocketmq/client
114 10
consumer_manager.go
in runtime/core/protocol/grpc/consumer
175 9
consumer_mesh.go
in runtime/core/protocol/grpc/consumer
199 9
rocketmq_consumer.go
in plugin/connector/rocketmq/client
103 9
105 9
consumer.go
in runtime/core/wrapper
65 8
producer_processor.go
in runtime/core/protocol/grpc/producer
298 8
producer_mesh.go
in runtime/core/protocol/grpc/producer
82 8
config.go
in config
115 7
consumer_processor.go
in runtime/core/protocol/grpc/consumer
290 7
rocketmq_message_writer.go
in plugin/connector/rocketmq/convert
52 7
rocketmq_message_reader.go
in plugin/connector/rocketmq/convert
74 7
73 7
producer.go
in runtime/core/wrapper
52 6
consumer_service.go
in runtime/core/protocol/grpc/consumer
135 6
message_request.go
in runtime/core/protocol/grpc/consumer
203 6
heartbeat_service.go
in runtime/proto/pb/mocks
41 6
mock_graceful.go
in runtime/emserver/mocks
40 6
setup.go
in plugin
107 6
factory.go
in plugin/connector/standalone
46 6
factory.go
in plugin/connector/rocketmq
58 6
producer_manager.go
in runtime/core/protocol/grpc/producer
58 5
validator.go
in runtime/core/protocol/grpc/validator
126 5
roll_writer_options.go
in log/rollwriter
34 5
async_roll_writer.go
in log/rollwriter
98 5
registry.go
in pkg/naming/registry
36 5
producer_service.go
in runtime/core/protocol/grpc/producer
101 4
Files With Long Lines (Top 27)

There are 27 files with lines longer than 120 characters. In total, there are 122 long lines.

File# lines# units# long lines
eventmesh-client.pb.go
in runtime/proto/pb
1271 128 15
eventmesh-client_grpc.pb.go
in runtime/proto/pb
355 34 14
consumer_group_option.go
in runtime/core/protocol/grpc/consumer/mocks
135 24 11
mock_naming_client_interface.go
in plugin/registry/nacos/mocks
138 24 11
producer_processor.go
in runtime/core/protocol/grpc/producer
298 8 9
mock_rocketmq_producer.go
in plugin/connector/rocketmq/mock
110 16 9
mock_rocketmq_consumer.go
in plugin/connector/rocketmq/mock
88 16 6
consumer_manager.go
in runtime/core/protocol/grpc/consumer/mocks
90 16 5
producer_service.go
in runtime/proto/pb/mocks
63 10 5
consumer.go
in runtime/core/wrapper/mocks
89 16 4
consumer_service.go
in runtime/core/protocol/grpc/mocks
62 10 4
consumer_service.go
in runtime/proto/pb/mocks
62 10 4
consumer_processor.go
in runtime/core/protocol/grpc/consumer
290 7 3
consumer_service.go
in runtime/core/protocol/grpc/consumer
135 6 3
consumer_mesh.go
in runtime/core/protocol/grpc/consumer
199 9 2
heartbeat_service.go
in runtime/proto/pb/mocks
41 6 2
cloudevents.go
in plugin/protocol/cloudevents
177 13 2
consumer.go
in plugin/connector/rocketmq
161 14 2
323 - 2
status_code.go
in pkg/common/protocol/grpc
48 2 2
producer.go
in runtime/core/wrapper
52 6 1
producer_mesh.go
in runtime/core/protocol/grpc/producer
82 8 1
emitter.go
in runtime/core/protocol/grpc/emitter/mocks
32 4 1
producer.go
in plugin/connector/standalone
80 12 1
rocketmq_consumer.go
in plugin/connector/rocketmq/client
103 9 1
rocketmq_producer.go
in plugin/connector/rocketmq/client
114 10 1
nacos.go
in plugin/registry/nacos
199 13 1
Correlations

File Size vs. Commits (all time): 9 points

plugin/connector/standalone/consumer.go x: 2 commits (all time) y: 156 lines of code runtime/core/protocol/grpc/consumer/consumer_manager.go x: 2 commits (all time) y: 175 lines of code runtime/core/protocol/grpc/producer/producer_processor.go x: 2 commits (all time) y: 298 lines of code runtime/core/protocol/grpc/consumer/consumer_processor.go x: 2 commits (all time) y: 290 lines of code plugin/connector/rocketmq/convert/rocketmq_message_reader.go x: 2 commits (all time) y: 74 lines of code plugin/protocol/cloudevents/cloudevents.go x: 3 commits (all time) y: 177 lines of code runtime/emserver/http.go x: 2 commits (all time) y: 52 lines of code log/writer_factory.go x: 2 commits (all time) y: 73 lines of code runtime/core/protocol/grpc/retry/retry.go x: 4 commits (all time) y: 14 lines of code
298.0
lines of code
  min: 14.0
  average: 145.44
  25th percentile: 62.5
  median: 156.0
  75th percentile: 233.5
  max: 298.0
0 4.0
commits (all time)
min: 2.0 | average: 2.33 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.5 | max: 4.0

File Size vs. Contributors (all time): 9 points

plugin/connector/standalone/consumer.go x: 2 contributors (all time) y: 156 lines of code runtime/core/protocol/grpc/consumer/consumer_manager.go x: 2 contributors (all time) y: 175 lines of code runtime/core/protocol/grpc/producer/producer_processor.go x: 2 contributors (all time) y: 298 lines of code runtime/core/protocol/grpc/consumer/consumer_processor.go x: 2 contributors (all time) y: 290 lines of code plugin/connector/rocketmq/convert/rocketmq_message_reader.go x: 2 contributors (all time) y: 74 lines of code plugin/protocol/cloudevents/cloudevents.go x: 2 contributors (all time) y: 177 lines of code runtime/emserver/http.go x: 2 contributors (all time) y: 52 lines of code log/writer_factory.go x: 2 contributors (all time) y: 73 lines of code runtime/core/protocol/grpc/retry/retry.go x: 3 contributors (all time) y: 14 lines of code
298.0
lines of code
  min: 14.0
  average: 145.44
  25th percentile: 62.5
  median: 156.0
  75th percentile: 233.5
  max: 298.0
0 3.0
contributors (all time)
min: 2.0 | average: 2.11 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 3.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".


File Size vs. Commits (90 days): 8 points

plugin/connector/standalone/consumer.go x: 1 commits (90d) y: 156 lines of code runtime/core/protocol/grpc/consumer/consumer_manager.go x: 1 commits (90d) y: 175 lines of code runtime/core/protocol/grpc/producer/producer_processor.go x: 1 commits (90d) y: 298 lines of code runtime/core/protocol/grpc/consumer/consumer_processor.go x: 1 commits (90d) y: 290 lines of code plugin/connector/rocketmq/convert/rocketmq_message_reader.go x: 1 commits (90d) y: 74 lines of code plugin/protocol/cloudevents/cloudevents.go x: 1 commits (90d) y: 177 lines of code runtime/emserver/http.go x: 2 commits (90d) y: 52 lines of code log/writer_factory.go x: 1 commits (90d) y: 73 lines of code
298.0
lines of code
  min: 52.0
  average: 161.88
  25th percentile: 73.25
  median: 165.5
  75th percentile: 261.75
  max: 298.0
0 2.0
commits (90d)
min: 1.0 | average: 1.13 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0

File Size vs. Contributors (90 days): 8 points

plugin/connector/standalone/consumer.go x: 1 contributors (90d) y: 156 lines of code runtime/core/protocol/grpc/consumer/consumer_manager.go x: 1 contributors (90d) y: 175 lines of code runtime/core/protocol/grpc/producer/producer_processor.go x: 1 contributors (90d) y: 298 lines of code runtime/core/protocol/grpc/consumer/consumer_processor.go x: 1 contributors (90d) y: 290 lines of code plugin/connector/rocketmq/convert/rocketmq_message_reader.go x: 1 contributors (90d) y: 74 lines of code plugin/protocol/cloudevents/cloudevents.go x: 1 contributors (90d) y: 177 lines of code runtime/emserver/http.go x: 2 contributors (90d) y: 52 lines of code log/writer_factory.go x: 1 contributors (90d) y: 73 lines of code
298.0
lines of code
  min: 52.0
  average: 161.88
  25th percentile: 73.25
  median: 165.5
  75th percentile: 261.75
  max: 298.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.13 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0