apache / pulsar-client-go
File Size

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

Intro
Learn more...
File Size Overall
18% | 21% | 24% | 18% | 17%
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
go19% | 16% | 25% | 20% | 18%
proto0% | 100% | 0% | 0% | 0%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
pulsar20% | 23% | 25% | 15% | 15%
oauth20% | 0% | 19% | 46% | 34%
perf0% | 0% | 0% | 73% | 26%
Longest Files (Top 50)
File# lines# units
1836 89
1196 46
proto
PulsarApi.proto
in pulsar/internal/pulsar_proto
 902 -
connection.go
in pulsar/internal
 873 54
633 28
schema.go
in pulsar
 539 70
metrics.go
in pulsar/internal
 533 3
399 53
393 29
lookup_service.go
in pulsar/internal
 296 14
http_client.go
in pulsar/internal
 287 18
277 13
commands.go
in pulsar/internal
 272 15
266 18
255 12
250 11
batch_builder.go
in pulsar/internal
 221 12
219 8
219 14
213 18
athenz.go
in pulsar/auth
 211 12
205 17
fake_clock.go
in oauth2/clock/testing
 188 20
184 9
183 11
key_based_batch_builder.go
in pulsar/internal
 174 14
service_uri.go
in pulsar/internal
 172 7
error.go
in pulsar
 167 5
167 11
oauth2.go
in pulsar/auth
 159 13
keyring.go
in oauth2/store
 156 8
149 5
buffer.go
in pulsar/internal
 146 25
rpc_client.go
in pulsar/internal
 135 8
blocking_queue.go
in pulsar/internal
 127 10
126 2
connection_pool.go
in pulsar/internal
 125 5
125 6
115 5
dlq_router.go
in pulsar
 114 6
memory_limit_controller.go
in pulsar/internal
 111 12
107 5
connection_reader.go
in pulsar/internal
 104 5
104 5
service_name_resolver.go
in pulsar/internal
 94 8
93 4
wrapper_logrus.go
in pulsar/log
 93 23
92 2
topic_name.go
in pulsar/internal
 88 5
consumer.go
in pulsar
 87 -
Files With Most Units (Top 50)
File# lines# units
1836 89
schema.go
in pulsar
 539 70
connection.go
in pulsar/internal
 873 54
399 53
1196 46
393 29
633 28
buffer.go
in pulsar/internal
 146 25
log.go
in pulsar/log
 28 23
wrapper_logrus.go
in pulsar/log
 93 23
fake_clock.go
in oauth2/clock/testing
 188 20
213 18
266 18
http_client.go
in pulsar/internal
 287 18
205 17
commands.go
in pulsar/internal
 272 15
lookup_service.go
in pulsar/internal
 296 14
key_based_batch_builder.go
in pulsar/internal
 174 14
219 14
277 13
oauth2.go
in pulsar/auth
 159 13
255 12
athenz.go
in pulsar/auth
 211 12
token.go
in pulsar/auth
 84 12
tls.go
in pulsar/auth
 67 12
batch_builder.go
in pulsar/internal
 221 12
memory_limit_controller.go
in pulsar/internal
 111 12
250 11
167 11
183 11
basic.go
in pulsar/auth
 54 10
blocking_queue.go
in pulsar/internal
 127 10
client.go
in pulsar
 82 10
clock.go
in oauth2/clock
 50 9
184 9
disabled.go
in pulsar/auth
 33 9
keyring.go
in oauth2/store
 156 8
message_metadata.go
in pulsar/crypto
 85 8
219 8
message_carrier_adaptors.go
in pulsar/internal/pulsartracing
 47 8
rpc_client.go
in pulsar/internal
 135 8
service_name_resolver.go
in pulsar/internal
 94 8
service_uri.go
in pulsar/internal
 172 7
lz4.go
in pulsar/internal/compression
 71 7
zstd_cgo.go
in pulsar/internal/compression
 46 7
dlq_router.go
in pulsar
 114 6
zstd_go.go
in pulsar/internal/compression
 45 6
noop.go
in pulsar/internal/compression
 33 6
zlib.go
in pulsar/internal/compression
 49 6
125 6
Files With Long Lines (Top 10)

There are 10 files with lines longer than 120 characters. In total, there are 12 long lines.

File# lines# units# long lines
1196 46 2
producer_encryptor.go
in pulsar/internal/crypto
 43 2 2
633 28 1
107 5 1
metrics.go
in pulsar/internal
 533 3 1
lookup_service.go
in pulsar/internal
 296 14 1
zstd.go
in pulsar/internal/compression
 11 2 1
rpc_client.go
in pulsar/internal
 135 8 1
125 6 1
92 2 1
Correlations

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

pulsar/producer.go x: 32 commits (all time) y: 69 lines of code pulsar/internal/connection.go x: 101 commits (all time) y: 873 lines of code pulsar/consumer_partition.go x: 99 commits (all time) y: 1836 lines of code pulsar/producer_partition.go x: 110 commits (all time) y: 1196 lines of code pulsar/schema.go x: 9 commits (all time) y: 539 lines of code pulsar/single_partition_router.go x: 1 commits (all time) y: 19 lines of code pulsar/client.go x: 40 commits (all time) y: 82 lines of code pulsar/client_impl.go x: 36 commits (all time) y: 219 lines of code pulsar/internal/http_client.go x: 11 commits (all time) y: 287 lines of code perf/perf-consumer.go x: 18 commits (all time) y: 92 lines of code perf/pulsar-perf-go.go x: 19 commits (all time) y: 125 lines of code pulsar/consumer.go x: 49 commits (all time) y: 87 lines of code pulsar/consumer_impl.go x: 69 commits (all time) y: 633 lines of code pulsar/reader_impl.go x: 24 commits (all time) y: 184 lines of code pulsar/consumer_multitopic.go x: 26 commits (all time) y: 213 lines of code pulsar/consumer_regex.go x: 28 commits (all time) y: 393 lines of code pulsar/internal/batch_builder.go x: 39 commits (all time) y: 221 lines of code pulsar/internal/commands.go x: 49 commits (all time) y: 272 lines of code pulsar/internal/key_based_batch_builder.go x: 8 commits (all time) y: 174 lines of code pulsar/message.go x: 39 commits (all time) y: 84 lines of code pulsar/transaction.go x: 3 commits (all time) y: 25 lines of code pulsar/transaction_coordinator_client.go x: 3 commits (all time) y: 167 lines of code pulsar/transaction_impl.go x: 2 commits (all time) y: 183 lines of code pulsar/error.go x: 20 commits (all time) y: 167 lines of code pulsar/impl_message.go x: 52 commits (all time) y: 399 lines of code pulsar/internal/memory_limit_controller.go x: 2 commits (all time) y: 111 lines of code pulsar/dlq_router.go x: 13 commits (all time) y: 114 lines of code perf/perf-producer.go x: 24 commits (all time) y: 126 lines of code pulsar/ack_grouping_tracker.go x: 3 commits (all time) y: 205 lines of code pulsar/reader.go x: 14 commits (all time) y: 36 lines of code pulsar/internal/rpc_client.go x: 41 commits (all time) y: 135 lines of code pulsar/internal/connection_pool.go x: 32 commits (all time) y: 125 lines of code pulsar/auth/athenz.go x: 3 commits (all time) y: 211 lines of code pulsar/internal/helper.go x: 1 commits (all time) y: 11 lines of code pulsar/negative_acks_tracker.go x: 8 commits (all time) y: 104 lines of code pulsar/internal/channel_cond.go x: 1 commits (all time) y: 45 lines of code oauth2/client_credentials_provider.go x: 6 commits (all time) y: 54 lines of code pulsar/auth/token.go x: 2 commits (all time) y: 84 lines of code pulsar/crypto/default_crypto_Key_reader.go x: 2 commits (all time) y: 25 lines of code pulsar/retry_router.go x: 7 commits (all time) y: 107 lines of code pulsar/table_view_impl.go x: 2 commits (all time) y: 219 lines of code pulsar/auth/basic.go x: 1 commits (all time) y: 54 lines of code pulsar/auth/disabled.go x: 1 commits (all time) y: 33 lines of code pulsar/auth/oauth2.go x: 1 commits (all time) y: 159 lines of code pulsar/auth/tls.go x: 1 commits (all time) y: 67 lines of code pulsar/helper.go x: 7 commits (all time) y: 47 lines of code pulsar/internal/connection_reader.go x: 21 commits (all time) y: 104 lines of code pulsar/internal/lookup_service.go x: 32 commits (all time) y: 296 lines of code pulsar/internal/pulsar_proto/PulsarApi.proto x: 6 commits (all time) y: 902 lines of code pulsar/internal/utils.go x: 8 commits (all time) y: 58 lines of code oauth2/data_url.go x: 1 commits (all time) y: 42 lines of code pulsar/producer_impl.go x: 26 commits (all time) y: 277 lines of code pulsar/internal/version.go x: 1 commits (all time) y: 25 lines of code pulsar/internal/backoff.go x: 8 commits (all time) y: 30 lines of code pulsar/negative_backoff_policy.go x: 3 commits (all time) y: 17 lines of code pulsar/log/wrapper_logrus.go x: 3 commits (all time) y: 93 lines of code pulsar/internal/metrics.go x: 9 commits (all time) y: 533 lines of code oauth2/authorization_tokenretriever.go x: 3 commits (all time) y: 250 lines of code pulsar/internal/topic_name.go x: 15 commits (all time) y: 88 lines of code pulsar/internal/buffer.go x: 9 commits (all time) y: 146 lines of code oauth2/auth.go x: 5 commits (all time) y: 75 lines of code pulsar/default_router.go x: 4 commits (all time) y: 66 lines of code pulsar/internal/compression/zstd.go x: 11 commits (all time) y: 11 lines of code pulsar/internal/compression/zstd_cgo.go x: 9 commits (all time) y: 46 lines of code pulsar/crypto/crypto_failure_action.go x: 2 commits (all time) y: 10 lines of code pulsar/crypto/default_message_crypto.go x: 2 commits (all time) y: 255 lines of code pulsar/crypto/message_crypto.go x: 2 commits (all time) y: 7 lines of code pulsar/internal/crypto/decryptor.go x: 1 commits (all time) y: 7 lines of code oauth2/device_code_flow.go x: 2 commits (all time) y: 149 lines of code oauth2/device_code_provider.go x: 2 commits (all time) y: 93 lines of code pulsar/internal/service_name_resolver.go x: 2 commits (all time) y: 94 lines of code pulsar/internal/blocking_queue.go x: 3 commits (all time) y: 127 lines of code pulsar/internal/pulsartracing/producer_interceptor.go x: 2 commits (all time) y: 29 lines of code pulsar/internal/semaphore.go x: 3 commits (all time) y: 56 lines of code pulsar/internal/service_uri.go x: 1 commits (all time) y: 172 lines of code pulsar/batcher_builder.go x: 2 commits (all time) y: 21 lines of code oauth2/store/keyring.go x: 2 commits (all time) y: 156 lines of code pulsar/primitiveSerDe.go x: 1 commits (all time) y: 266 lines of code oauth2/clock/testing/fake_clock.go x: 1 commits (all time) y: 188 lines of code oauth2/store/memory.go x: 1 commits (all time) y: 61 lines of code pulsar/internal/compression/compression.go x: 6 commits (all time) y: 15 lines of code pulsar/internal/compression/lz4.go x: 7 commits (all time) y: 71 lines of code pulsar/internal/compression/noop.go x: 6 commits (all time) y: 33 lines of code pulsar/internal/compression/zstd_go.go x: 4 commits (all time) y: 45 lines of code pulsar/internal/client_handlers.go x: 2 commits (all time) y: 38 lines of code pulsar/internal/closable.go x: 6 commits (all time) y: 4 lines of code pulsar/internal/checksum.go x: 11 commits (all time) y: 24 lines of code pulsar/internal/hash.go x: 9 commits (all time) y: 17 lines of code
1836.0
lines of code
  min: 4.0
  average: 143.76
  25th percentile: 28.0
  median: 68.0
  75th percentile: 167.0
  max: 1836.0
0 110.0
commits (all time)
min: 1.0 | average: 11.74 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 11.0 | max: 110.0

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

pulsar/producer.go x: 17 contributors (all time) y: 69 lines of code pulsar/internal/connection.go x: 37 contributors (all time) y: 873 lines of code pulsar/consumer_partition.go x: 39 contributors (all time) y: 1836 lines of code pulsar/producer_partition.go x: 44 contributors (all time) y: 1196 lines of code pulsar/schema.go x: 9 contributors (all time) y: 539 lines of code pulsar/single_partition_router.go x: 1 contributors (all time) y: 19 lines of code pulsar/client.go x: 18 contributors (all time) y: 82 lines of code pulsar/client_impl.go x: 20 contributors (all time) y: 219 lines of code pulsar/internal/http_client.go x: 7 contributors (all time) y: 287 lines of code perf/perf-consumer.go x: 9 contributors (all time) y: 92 lines of code perf/pulsar-perf-go.go x: 9 contributors (all time) y: 125 lines of code pulsar/consumer.go x: 23 contributors (all time) y: 87 lines of code pulsar/consumer_impl.go x: 23 contributors (all time) y: 633 lines of code pulsar/reader_impl.go x: 18 contributors (all time) y: 184 lines of code pulsar/consumer_multitopic.go x: 16 contributors (all time) y: 213 lines of code pulsar/consumer_regex.go x: 16 contributors (all time) y: 393 lines of code pulsar/internal/batch_builder.go x: 18 contributors (all time) y: 221 lines of code pulsar/internal/commands.go x: 17 contributors (all time) y: 272 lines of code pulsar/internal/key_based_batch_builder.go x: 7 contributors (all time) y: 174 lines of code pulsar/message.go x: 16 contributors (all time) y: 84 lines of code pulsar/transaction.go x: 1 contributors (all time) y: 25 lines of code pulsar/transaction_coordinator_client.go x: 1 contributors (all time) y: 167 lines of code pulsar/transaction_impl.go x: 1 contributors (all time) y: 183 lines of code pulsar/error.go x: 9 contributors (all time) y: 167 lines of code pulsar/impl_message.go x: 19 contributors (all time) y: 399 lines of code pulsar/internal/memory_limit_controller.go x: 2 contributors (all time) y: 111 lines of code pulsar/dlq_router.go x: 10 contributors (all time) y: 114 lines of code perf/perf-producer.go x: 10 contributors (all time) y: 126 lines of code pulsar/ack_grouping_tracker.go x: 2 contributors (all time) y: 205 lines of code pulsar/reader.go x: 10 contributors (all time) y: 36 lines of code pulsar/internal/rpc_client.go x: 15 contributors (all time) y: 135 lines of code pulsar/internal/connection_pool.go x: 13 contributors (all time) y: 125 lines of code pulsar/auth/athenz.go x: 3 contributors (all time) y: 211 lines of code pulsar/internal/helper.go x: 1 contributors (all time) y: 11 lines of code pulsar/negative_acks_tracker.go x: 7 contributors (all time) y: 104 lines of code pulsar/internal/channel_cond.go x: 1 contributors (all time) y: 45 lines of code oauth2/client_credentials_provider.go x: 4 contributors (all time) y: 54 lines of code pulsar/auth/token.go x: 2 contributors (all time) y: 84 lines of code pulsar/crypto/default_crypto_Key_reader.go x: 2 contributors (all time) y: 25 lines of code pulsar/table_view_impl.go x: 2 contributors (all time) y: 219 lines of code pulsar/auth/basic.go x: 1 contributors (all time) y: 54 lines of code pulsar/auth/disabled.go x: 1 contributors (all time) y: 33 lines of code pulsar/auth/oauth2.go x: 1 contributors (all time) y: 159 lines of code pulsar/auth/tls.go x: 1 contributors (all time) y: 67 lines of code pulsar/helper.go x: 4 contributors (all time) y: 47 lines of code pulsar/internal/connection_reader.go x: 9 contributors (all time) y: 104 lines of code pulsar/internal/lookup_service.go x: 12 contributors (all time) y: 296 lines of code pulsar/internal/pulsar_proto/PulsarApi.proto x: 4 contributors (all time) y: 902 lines of code pulsar/internal/utils.go x: 6 contributors (all time) y: 58 lines of code oauth2/data_url.go x: 1 contributors (all time) y: 42 lines of code pulsar/producer_impl.go x: 16 contributors (all time) y: 277 lines of code pulsar/internal/backoff.go x: 6 contributors (all time) y: 30 lines of code pulsar/negative_backoff_policy.go x: 3 contributors (all time) y: 17 lines of code pulsar/log/wrapper_logrus.go x: 3 contributors (all time) y: 93 lines of code pulsar/internal/metrics.go x: 8 contributors (all time) y: 533 lines of code oauth2/authorization_tokenretriever.go x: 3 contributors (all time) y: 250 lines of code pulsar/internal/topic_name.go x: 8 contributors (all time) y: 88 lines of code pulsar/internal/buffer.go x: 5 contributors (all time) y: 146 lines of code oauth2/auth.go x: 5 contributors (all time) y: 75 lines of code pulsar/default_router.go x: 3 contributors (all time) y: 66 lines of code pulsar/internal/compression/zstd.go x: 5 contributors (all time) y: 11 lines of code pulsar/internal/compression/zstd_cgo.go x: 3 contributors (all time) y: 46 lines of code pulsar/crypto/crypto_failure_action.go x: 2 contributors (all time) y: 10 lines of code pulsar/crypto/default_message_crypto.go x: 2 contributors (all time) y: 255 lines of code pulsar/crypto/message_crypto.go x: 2 contributors (all time) y: 7 lines of code pulsar/internal/crypto/decryptor.go x: 1 contributors (all time) y: 7 lines of code oauth2/device_code_flow.go x: 2 contributors (all time) y: 149 lines of code oauth2/device_code_provider.go x: 2 contributors (all time) y: 93 lines of code pulsar/internal/service_name_resolver.go x: 2 contributors (all time) y: 94 lines of code pulsar/internal/blocking_queue.go x: 3 contributors (all time) y: 127 lines of code pulsar/internal/pulsartracing/producer_interceptor.go x: 2 contributors (all time) y: 29 lines of code pulsar/internal/semaphore.go x: 3 contributors (all time) y: 56 lines of code pulsar/batcher_builder.go x: 2 contributors (all time) y: 21 lines of code pulsar/primitiveSerDe.go x: 1 contributors (all time) y: 266 lines of code oauth2/clock/testing/fake_clock.go x: 1 contributors (all time) y: 188 lines of code oauth2/store/memory.go x: 1 contributors (all time) y: 61 lines of code pulsar/internal/compression/zlib.go x: 2 contributors (all time) y: 49 lines of code pulsar/internal/client_handlers.go x: 2 contributors (all time) y: 38 lines of code pulsar/internal/closable.go x: 3 contributors (all time) y: 4 lines of code pulsar/internal/checksum.go x: 3 contributors (all time) y: 24 lines of code
1836.0
lines of code
  min: 4.0
  average: 143.76
  25th percentile: 28.0
  median: 68.0
  75th percentile: 167.0
  max: 1836.0
0 44.0
contributors (all time)
min: 1.0 | average: 5.83 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 8.0 | max: 44.0

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

pulsar/producer.go x: 1 commits (30d) y: 69 lines of code pulsar/internal/connection.go x: 1 commits (30d) y: 873 lines of code pulsar/consumer_partition.go x: 3 commits (30d) y: 1836 lines of code pulsar/producer_partition.go x: 8 commits (30d) y: 1196 lines of code
1836.0
lines of code
  min: 69.0
  average: 993.5
  25th percentile: 270.0
  median: 1034.5
  75th percentile: 1676.0
  max: 1836.0
0 8.0
commits (30d)
min: 1.0 | average: 3.25 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 6.75 | max: 8.0

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

pulsar/producer.go x: 1 contributors (30d) y: 69 lines of code pulsar/internal/connection.go x: 1 contributors (30d) y: 873 lines of code pulsar/consumer_partition.go x: 2 contributors (30d) y: 1836 lines of code pulsar/producer_partition.go x: 3 contributors (30d) y: 1196 lines of code
1836.0
lines of code
  min: 69.0
  average: 993.5
  25th percentile: 270.0
  median: 1034.5
  75th percentile: 1676.0
  max: 1836.0
0 3.0
contributors (30d)
min: 1.0 | average: 1.75 | 25th percentile: 1.0 | median: 1.5 | 75th percentile: 2.75 | max: 3.0

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

pulsar/producer.go x: 1 commits (90d) y: 69 lines of code pulsar/internal/connection.go x: 2 commits (90d) y: 873 lines of code pulsar/consumer_partition.go x: 5 commits (90d) y: 1836 lines of code pulsar/producer_partition.go x: 18 commits (90d) y: 1196 lines of code pulsar/schema.go x: 2 commits (90d) y: 539 lines of code pulsar/single_partition_router.go x: 1 commits (90d) y: 19 lines of code pulsar/client.go x: 1 commits (90d) y: 82 lines of code pulsar/client_impl.go x: 1 commits (90d) y: 219 lines of code pulsar/internal/http_client.go x: 1 commits (90d) y: 287 lines of code perf/perf-consumer.go x: 1 commits (90d) y: 92 lines of code perf/pulsar-perf-go.go x: 1 commits (90d) y: 125 lines of code pulsar/consumer_impl.go x: 1 commits (90d) y: 633 lines of code pulsar/reader_impl.go x: 1 commits (90d) y: 184 lines of code
1836.0
lines of code
  min: 19.0
  average: 445.79
  25th percentile: 85.75
  median: 201.5
  75th percentile: 693.0
  max: 1836.0
0 18.0
commits (90d)
min: 1.0 | average: 2.64 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 18.0

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

pulsar/producer.go x: 1 contributors (90d) y: 69 lines of code pulsar/internal/connection.go x: 2 contributors (90d) y: 873 lines of code pulsar/consumer_partition.go x: 4 contributors (90d) y: 1836 lines of code pulsar/producer_partition.go x: 7 contributors (90d) y: 1196 lines of code pulsar/schema.go x: 2 contributors (90d) y: 539 lines of code pulsar/single_partition_router.go x: 1 contributors (90d) y: 19 lines of code pulsar/client.go x: 1 contributors (90d) y: 82 lines of code pulsar/client_impl.go x: 1 contributors (90d) y: 219 lines of code pulsar/internal/http_client.go x: 1 contributors (90d) y: 287 lines of code perf/perf-consumer.go x: 1 contributors (90d) y: 92 lines of code perf/pulsar-perf-go.go x: 1 contributors (90d) y: 125 lines of code pulsar/consumer_impl.go x: 1 contributors (90d) y: 633 lines of code pulsar/reader_impl.go x: 1 contributors (90d) y: 184 lines of code
1836.0
lines of code
  min: 19.0
  average: 445.79
  25th percentile: 85.75
  median: 201.5
  75th percentile: 693.0
  max: 1836.0
0 7.0
contributors (90d)
min: 1.0 | average: 1.79 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 7.0