apache / pulsar-client-go
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 198 files with 24,362 lines of code.
    • 3 files changed more than 100 times (4,435 lines of code)
    • 2 files changed 51-100 times (823 lines of code)
    • 15 files changed 21-50 times (3,364 lines of code)
    • 41 files changed 6-20 times (7,739 lines of code)
    • 137 files changed 1-5 times (8,001 lines of code)
18% | 3% | 13% | 31% | 32%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 198 files with 24,362 lines of code.
    • 5 files changed by more than 25 contributors (5,258 lines of code)
    • 18 files changed by 11-25 contributors (4,059 lines of code)
    • 20 files changed by 6-10 contributors (5,313 lines of code)
    • 125 files changed by 2-5 contributors (8,470 lines of code)
    • 30 files changed by 1 contributor (1,262 lines of code)
21% | 16% | 21% | 34% | 5%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
go, txt, md, sh, yaml, proto, mod, gitignore, toml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
go18% | 3% | 14% | 29% | 34%
proto0% | 0% | 0% | 100% | 0%
toml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
pulsar27% | 5% | 20% | 26% | 20%
pulsaradmin0% | 0% | 0% | 46% | 53%
perf0% | 0% | 0% | 100% | 0%
oauth20% | 0% | 0% | 9% | 90%
ROOT0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
1424 62 2019-12-05 2025-03-17 130 55 cckellogg@gmail.com gunli@tencent.com
2101 99 2019-11-11 2025-03-10 110 50 mmerli@apache.org baodi@apache.org
connection.go
in pulsar/internal
 910 58 2019-05-07 2025-03-10 101 44 mmerli@apache.org gunli@tencent.com
715 35 2019-11-11 2024-11-19 70 26 cckellogg@gmail.com crossoverjie@gmail.com
consumer.go
in pulsar
 108 1 2019-03-27 2025-03-10 53 27 mmerli@apache.org baodi@apache.org
439 63 2019-05-05 2025-03-10 45 21 mmerli@apache.org baodi@apache.org
215 9 2019-11-18 2024-12-13 43 25 cckellogg@gmail.com crossoverjie@gmail.com
rpc_client.go
in pulsar/internal
 208 14 2019-05-07 2025-01-03 40 17 mmerli@apache.org baodi@apache.org
commands.go
in pulsar/internal
 272 15 2019-05-07 2024-12-19 38 18 mmerli@apache.org reugpro@gmail.com
client.go
in pulsar
 85 10 2019-03-27 2024-12-13 37 21 mmerli@apache.org crossoverjie@gmail.com
message.go
in pulsar
 88 5 2019-03-27 2025-03-15 36 17 mmerli@apache.org 843520313@qq.com
producer.go
in pulsar
 71 - 2019-03-27 2024-09-23 34 19 mmerli@apache.org crossoverjie@gmail.com
batch_builder.go
in pulsar/internal
 228 12 2019-05-07 2024-07-19 33 19 mmerli@apache.org zike@apache.org
lookup_service.go
in pulsar/internal
 301 17 2019-05-07 2024-11-01 31 16 mmerli@apache.org crossoverjie@gmail.com
connection_pool.go
in pulsar/internal
 139 6 2019-05-07 2025-01-03 30 16 mmerli@apache.org baodi@apache.org
419 32 2019-11-23 2024-11-06 29 18 cckellogg@gmail.com xyzinfernity@163.com
175 8 2020-01-06 2025-03-10 28 23 mmerli@apache.org baodi@apache.org
280 14 2019-12-05 2024-12-19 28 18 cckellogg@gmail.com reugpro@gmail.com
274 22 2019-11-15 2024-11-19 27 17 cckellogg@gmail.com xyzinfernity@163.com
error.go
in pulsar
 170 5 2019-03-27 2024-12-24 21 12 mmerli@apache.org reugpro@gmail.com
dlq_router.go
in pulsar
 135 6 2020-02-13 2024-12-09 20 14 mmerli@apache.org 843520313@qq.com
126 2 2019-05-04 2024-10-26 19 10 mmerli@apache.org xyzinfernity@163.com
reader.go
in pulsar
 37 - 2019-03-27 2025-03-10 18 14 mmerli@apache.org baodi@apache.org
connection_reader.go
in pulsar/internal
 101 5 2019-05-07 2024-11-19 17 10 mmerli@apache.org xyzinfernity@163.com
125 6 2019-05-04 2024-10-26 16 10 mmerli@apache.org xyzinfernity@163.com
http_client.go
in pulsar/internal
 292 18 2021-04-16 2024-11-15 15 10 freeznet@users.noreply.gith... nodeces@gmail.com
92 2 2019-05-04 2024-10-26 13 9 mmerli@apache.org xyzinfernity@163.com
data.go
in pulsaradmin/pkg/utils
 472 1 2023-03-09 2024-11-21 12 8 xuhuan@live.cn crossoverjie@gmail.com
schema.go
in pulsar
 523 69 2020-10-23 2024-07-03 12 13 rxl@apache.org 2491756+adrianiacobghiula@u...
zstd.go
in pulsar/internal/compression
 11 2 2019-05-07 2021-11-30 11 5 mmerli@apache.org reugpro@gmail.com
zstd_cgo.go
in pulsar/internal/compression
 53 7 2020-06-09 2024-10-26 11 5 mmerli@apache.org xyzinfernity@163.com
topic_name.go
in pulsar/internal
 88 5 2019-05-07 2022-05-24 11 8 mmerli@apache.org hantmac@outlook.com
proto
PulsarApi.proto
in pulsar/internal/pulsar_proto
 922 - 2020-06-23 2024-11-01 11 8 mmerli@apache.org crossoverjie@gmail.com
117 5 2020-09-09 2024-11-15 10 10 wuyinpost@gmail.com nodeces@gmail.com
104 5 2019-11-12 2024-10-26 9 7 mmerli@apache.org xyzinfernity@163.com
key_based_batch_builder.go
in pulsar/internal
 159 14 2020-12-01 2024-07-19 9 8 freeznet@users.noreply.gith... zike@apache.org
metrics.go
in pulsar/internal
 533 3 2020-12-01 2022-08-23 9 8 cckellogg@gmail.com pragkent@gmail.com
namespace.go
in pulsaradmin/pkg/admin
 648 86 2023-03-09 2024-10-26 9 8 xuhuan@live.cn xyzinfernity@163.com
checksum.go
in pulsar/internal
 24 3 2019-05-07 2019-08-15 8 3 mmerli@apache.org ranxiaolong716@gmail.com
utils.go
in pulsar/internal
 58 4 2019-05-07 2024-02-01 8 7 mmerli@apache.org zike@apache.org
buffer.go
in pulsar/internal
 146 25 2019-05-07 2022-03-22 8 5 mmerli@apache.org shoothzj@gmail.com
oauth2.go
in pulsaradmin/pkg/admin/auth
 204 16 2023-03-14 2024-10-26 8 6 xuhuan@live.cn xyzinfernity@163.com
subscription.go
in pulsaradmin/pkg/admin
 233 19 2023-03-09 2024-10-24 8 5 xuhuan@live.cn baodi@apache.org
362 22 2023-02-27 2025-02-20 8 6 55571188+liangyepianzhou@us... miton18@users.noreply.githu...
noop.go
in pulsar/internal/compression
 33 6 2019-05-07 2024-10-26 7 3 mmerli@apache.org xyzinfernity@163.com
helper.go
in pulsar
 47 4 2019-11-11 2022-12-15 7 4 cckellogg@gmail.com nodeces@gmail.com
zlib.go
in pulsar/internal/compression
 49 6 2019-05-07 2020-07-07 7 2 mmerli@apache.org mmerli@apache.org
lz4.go
in pulsar/internal/compression
 71 7 2019-05-07 2025-03-07 7 2 mmerli@apache.org zike@apache.org
auth.go
in oauth2
 75 2 2020-07-15 2024-12-19 7 7 zhangyong1025.zy@gmail.com reugpro@gmail.com
admin.go
in pulsaradmin/pkg/admin
 84 5 2023-03-09 2024-06-25 7 4 xuhuan@live.cn labuladong@foxmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
1424 62 2019-12-05 2025-03-17 130 55 cckellogg@gmail.com gunli@tencent.com
2101 99 2019-11-11 2025-03-10 110 50 mmerli@apache.org baodi@apache.org
connection.go
in pulsar/internal
 910 58 2019-05-07 2025-03-10 101 44 mmerli@apache.org gunli@tencent.com
consumer.go
in pulsar
 108 1 2019-03-27 2025-03-10 53 27 mmerli@apache.org baodi@apache.org
715 35 2019-11-11 2024-11-19 70 26 cckellogg@gmail.com crossoverjie@gmail.com
215 9 2019-11-18 2024-12-13 43 25 cckellogg@gmail.com crossoverjie@gmail.com
175 8 2020-01-06 2025-03-10 28 23 mmerli@apache.org baodi@apache.org
439 63 2019-05-05 2025-03-10 45 21 mmerli@apache.org baodi@apache.org
client.go
in pulsar
 85 10 2019-03-27 2024-12-13 37 21 mmerli@apache.org crossoverjie@gmail.com
producer.go
in pulsar
 71 - 2019-03-27 2024-09-23 34 19 mmerli@apache.org crossoverjie@gmail.com
batch_builder.go
in pulsar/internal
 228 12 2019-05-07 2024-07-19 33 19 mmerli@apache.org zike@apache.org
commands.go
in pulsar/internal
 272 15 2019-05-07 2024-12-19 38 18 mmerli@apache.org reugpro@gmail.com
419 32 2019-11-23 2024-11-06 29 18 cckellogg@gmail.com xyzinfernity@163.com
280 14 2019-12-05 2024-12-19 28 18 cckellogg@gmail.com reugpro@gmail.com
rpc_client.go
in pulsar/internal
 208 14 2019-05-07 2025-01-03 40 17 mmerli@apache.org baodi@apache.org
message.go
in pulsar
 88 5 2019-03-27 2025-03-15 36 17 mmerli@apache.org 843520313@qq.com
274 22 2019-11-15 2024-11-19 27 17 cckellogg@gmail.com xyzinfernity@163.com
lookup_service.go
in pulsar/internal
 301 17 2019-05-07 2024-11-01 31 16 mmerli@apache.org crossoverjie@gmail.com
connection_pool.go
in pulsar/internal
 139 6 2019-05-07 2025-01-03 30 16 mmerli@apache.org baodi@apache.org
dlq_router.go
in pulsar
 135 6 2020-02-13 2024-12-09 20 14 mmerli@apache.org 843520313@qq.com
reader.go
in pulsar
 37 - 2019-03-27 2025-03-10 18 14 mmerli@apache.org baodi@apache.org
schema.go
in pulsar
 523 69 2020-10-23 2024-07-03 12 13 rxl@apache.org 2491756+adrianiacobghiula@u...
error.go
in pulsar
 170 5 2019-03-27 2024-12-24 21 12 mmerli@apache.org reugpro@gmail.com
126 2 2019-05-04 2024-10-26 19 10 mmerli@apache.org xyzinfernity@163.com
connection_reader.go
in pulsar/internal
 101 5 2019-05-07 2024-11-19 17 10 mmerli@apache.org xyzinfernity@163.com
125 6 2019-05-04 2024-10-26 16 10 mmerli@apache.org xyzinfernity@163.com
http_client.go
in pulsar/internal
 292 18 2021-04-16 2024-11-15 15 10 freeznet@users.noreply.gith... nodeces@gmail.com
117 5 2020-09-09 2024-11-15 10 10 wuyinpost@gmail.com nodeces@gmail.com
92 2 2019-05-04 2024-10-26 13 9 mmerli@apache.org xyzinfernity@163.com
data.go
in pulsaradmin/pkg/utils
 472 1 2023-03-09 2024-11-21 12 8 xuhuan@live.cn crossoverjie@gmail.com
proto
PulsarApi.proto
in pulsar/internal/pulsar_proto
 922 - 2020-06-23 2024-11-01 11 8 mmerli@apache.org crossoverjie@gmail.com
topic_name.go
in pulsar/internal
 88 5 2019-05-07 2022-05-24 11 8 mmerli@apache.org hantmac@outlook.com
namespace.go
in pulsaradmin/pkg/admin
 648 86 2023-03-09 2024-10-26 9 8 xuhuan@live.cn xyzinfernity@163.com
metrics.go
in pulsar/internal
 533 3 2020-12-01 2022-08-23 9 8 cckellogg@gmail.com pragkent@gmail.com
key_based_batch_builder.go
in pulsar/internal
 159 14 2020-12-01 2024-07-19 9 8 freeznet@users.noreply.gith... zike@apache.org
104 5 2019-11-12 2024-10-26 9 7 mmerli@apache.org xyzinfernity@163.com
utils.go
in pulsar/internal
 58 4 2019-05-07 2024-02-01 8 7 mmerli@apache.org zike@apache.org
auth.go
in oauth2
 75 2 2020-07-15 2024-12-19 7 7 zhangyong1025.zy@gmail.com reugpro@gmail.com
oauth2.go
in pulsaradmin/pkg/admin/auth
 204 16 2023-03-14 2024-10-26 8 6 xuhuan@live.cn xyzinfernity@163.com
362 22 2023-02-27 2025-02-20 8 6 55571188+liangyepianzhou@us... miton18@users.noreply.githu...
topic.go
in pulsaradmin/pkg/admin
 540 72 2023-03-09 2024-06-12 7 6 xuhuan@live.cn crossoverjie@gmail.com
schema_util.go
in pulsaradmin/pkg/utils
 72 5 2023-03-09 2024-10-26 6 6 xuhuan@live.cn xyzinfernity@163.com
223 14 2022-03-31 2024-12-19 6 6 ziyao.wei.wzy@gmail.com reugpro@gmail.com
zstd_cgo.go
in pulsar/internal/compression
 53 7 2020-06-09 2024-10-26 11 5 mmerli@apache.org xyzinfernity@163.com
zstd.go
in pulsar/internal/compression
 11 2 2019-05-07 2021-11-30 11 5 mmerli@apache.org reugpro@gmail.com
subscription.go
in pulsaradmin/pkg/admin
 233 19 2023-03-09 2024-10-24 8 5 xuhuan@live.cn baodi@apache.org
buffer.go
in pulsar/internal
 146 25 2019-05-07 2022-03-22 8 5 mmerli@apache.org shoothzj@gmail.com
brokers.go
in pulsaradmin/pkg/admin
 127 13 2023-03-09 2024-06-25 7 5 xuhuan@live.cn labuladong@foxmail.com
client.go
in pulsaradmin/pkg/rest
 346 27 2023-03-09 2024-06-26 7 5 xuhuan@live.cn labuladong@foxmail.com
schema.go
in pulsaradmin/pkg/admin
 156 14 2023-03-09 2024-09-30 6 5 xuhuan@live.cn calin.dima@lego.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
service_uri.go
in pulsar/internal
 172 7 2021-03-09 2021-03-09 1 1 freeznet@users.noreply.gith... freeznet@users.noreply.gith...
oauth2.go
in pulsar/auth
 159 13 2023-01-03 2023-01-03 1 1 nodeces@gmail.com nodeces@gmail.com
wrapper_slog.go
in pulsar/log
 69 15 2024-07-05 2024-07-05 1 1 30929349+ivan-penchev@users... 30929349+ivan-penchev@users...
68 3 2020-10-09 2020-10-09 1 1 syk.levin@gmail.com syk.levin@gmail.com
tls.go
in pulsar/auth
 67 12 2023-01-03 2023-01-03 1 1 nodeces@gmail.com nodeces@gmail.com
memory.go
in oauth2/store
 61 5 2020-07-15 2020-07-15 1 1 zhangyong1025.zy@gmail.com zhangyong1025.zy@gmail.com
basic.go
in pulsar/auth
 54 10 2023-01-03 2023-01-03 1 1 nodeces@gmail.com nodeces@gmail.com
message_carrier_util.go
in pulsar/internal/pulsartracing
 53 5 2021-07-12 2021-07-12 1 1 84397028+maraiskruger1980@u... 84397028+maraiskruger1980@u...
provider.go
in pulsar/auth
 53 2 2023-01-03 2023-01-03 1 1 nodeces@gmail.com nodeces@gmail.com
clock.go
in oauth2/clock
 50 9 2020-07-15 2020-07-15 1 1 zhangyong1025.zy@gmail.com zhangyong1025.zy@gmail.com
channel_cond.go
in pulsar/internal
 45 5 2023-03-01 2023-03-01 1 1 baodi@apache.org baodi@apache.org
data_url.go
in oauth2
 42 1 2022-11-16 2022-11-16 1 1 nodeces@gmail.com nodeces@gmail.com
backoff.go
in pulsar/backoff
 41 6 2024-09-23 2024-09-23 1 1 crossoverjie@gmail.com crossoverjie@gmail.com
retry.go
in pulsar/internal
 37 1 2024-11-15 2024-11-15 1 1 nodeces@gmail.com nodeces@gmail.com
31 1 2020-07-15 2020-07-15 1 1 zhangyong1025.zy@gmail.com zhangyong1025.zy@gmail.com
logger.go
in pulsar/log
 28 - 2020-10-09 2020-10-09 1 1 oshohi@gmail.com oshohi@gmail.com
27 3 2020-07-15 2020-07-15 1 1 zhangyong1025.zy@gmail.com zhangyong1025.zy@gmail.com
span-enrichment.go
in pulsar/internal/pulsartracing
 27 3 2021-07-12 2021-07-12 1 1 84397028+maraiskruger1980@u... 84397028+maraiskruger1980@u...
25 - 2023-02-27 2023-05-06 3 1 55571188+liangyepianzhou@us... 55571188+liangyepianzhou@us...
version.go
in pulsar/internal
 25 1 2022-10-02 2022-10-02 1 1 paul.gier@datastax.com paul.gier@datastax.com
23 3 2020-07-14 2020-07-14 1 1 170574@qq.com 170574@qq.com
22 - 2023-08-15 2023-08-15 1 1 wander4096@gmail.com wander4096@gmail.com
19 1 2023-06-28 2023-06-28 1 1 crossoverjie@gmail.com crossoverjie@gmail.com
compression.go
in pulsar/internal/compression
 15 - 2019-05-07 2020-06-22 6 1 mmerli@apache.org mmerli@apache.org
encryption.go
in pulsar
 13 - 2021-09-03 2021-10-09 2 1 prabhudas552@gmail.com prabhudas552@gmail.com
helper.go
in pulsar/internal
 11 2 2023-03-03 2023-03-03 1 1 zike@apache.org zike@apache.org
encryptor.go
in pulsar/internal/crypto
 7 - 2021-09-03 2021-09-03 1 1 prabhudas552@gmail.com prabhudas552@gmail.com
decryptor.go
in pulsar/internal/crypto
 7 - 2021-10-09 2021-10-09 1 1 prabhudas552@gmail.com prabhudas552@gmail.com
namespace_name.go
in pulsar/internal
 6 1 2021-06-17 2021-06-17 1 1 freeznet@users.noreply.gith... freeznet@users.noreply.gith...
crypto_key_reader.go
in pulsar/crypto
 5 - 2021-07-05 2021-07-05 1 1 prabhudas552@gmail.com prabhudas552@gmail.com
266 18 2020-10-23 2024-12-19 2 2 rxl@apache.org reugpro@gmail.com
227 24 2024-06-26 2024-11-06 2 2 crossoverjie@gmail.com xyzinfernity@163.com
fake_clock.go
in oauth2/clock/testing
 188 20 2020-07-15 2024-10-26 2 2 zhangyong1025.zy@gmail.com xyzinfernity@163.com
keyring.go
in oauth2/store
 157 8 2020-07-15 2024-12-19 3 2 zhangyong1025.zy@gmail.com reugpro@gmail.com
149 5 2020-07-15 2021-10-05 2 2 zhangyong1025.zy@gmail.com ewright@streamnative.io
service_name_resolver.go
in pulsar/internal
 94 8 2021-03-09 2021-08-10 2 2 freeznet@users.noreply.gith... yumizush@yahoo-corp.jp
93 4 2020-07-15 2021-10-05 2 2 zhangyong1025.zy@gmail.com ewright@streamnative.io
message_metadata.go
in pulsar/crypto
 85 8 2021-07-05 2021-10-13 2 2 prabhudas552@gmail.com cckellogg@gmail.com
lz4.go
in pulsar/internal/compression
 71 7 2019-05-07 2025-03-07 7 2 mmerli@apache.org zike@apache.org
zlib.go
in pulsar/internal/compression
 49 6 2019-05-07 2020-07-07 7 2 mmerli@apache.org mmerli@apache.org
message_carrier_adaptors.go
in pulsar/internal/pulsartracing
 47 8 2021-07-12 2024-10-26 2 2 84397028+maraiskruger1980@u... xyzinfernity@163.com
zstd_go.go
in pulsar/internal/compression
 45 6 2020-06-11 2024-10-26 5 2 mmerli@apache.org xyzinfernity@163.com
producer_encryptor.go
in pulsar/internal/crypto
 43 2 2021-09-03 2024-12-19 2 2 prabhudas552@gmail.com reugpro@gmail.com
client_handlers.go
in pulsar/internal
 38 5 2019-12-11 2020-01-16 2 2 jim_lambert@bose.com freeznet@users.noreply.gith...
consumer_decryptor.go
in pulsar/internal/crypto
 34 2 2021-10-09 2024-10-26 2 2 prabhudas552@gmail.com xyzinfernity@163.com
disabled.go
in pulsar/auth
 33 9 2023-01-03 2024-10-26 2 2 nodeces@gmail.com xyzinfernity@163.com
log.go
in pulsar/log
 28 23 2020-10-09 2024-10-26 2 2 oshohi@gmail.com xyzinfernity@163.com
consumer_interceptor.go
in pulsar/internal/pulsartracing
 28 4 2021-07-12 2024-10-26 2 2 84397028+maraiskruger1980@u... xyzinfernity@163.com
25 4 2021-07-05 2023-02-07 2 2 prabhudas552@gmail.com reugpro@gmail.com
table_view.go
in pulsar
 24 - 2022-03-31 2023-11-20 2 2 ziyao.wei.wzy@gmail.com oliver.muir@arenko.group
Correlations

File Size vs. Number of Changes: 198 points

pulsar/auth/athenz.go x: 213 lines of code y: 4 # changes pulsar/producer_partition.go x: 1424 lines of code y: 130 # changes pulsar/message.go x: 88 lines of code y: 36 # changes pulsar/internal/connection.go x: 910 lines of code y: 101 # changes pulsar/consumer.go x: 108 lines of code y: 53 # changes pulsar/consumer_partition.go x: 2101 lines of code y: 110 # changes pulsar/impl_message.go x: 439 lines of code y: 45 # changes pulsar/reader.go x: 37 lines of code y: 18 # changes pulsar/reader_impl.go x: 175 lines of code y: 28 # changes pulsar/internal/compression/lz4.go x: 71 lines of code y: 7 # changes pulsar/transaction_coordinator_client.go x: 362 lines of code y: 8 # changes pulsar/internal/connection_pool.go x: 139 lines of code y: 30 # changes pulsar/internal/rpc_client.go x: 208 lines of code y: 40 # changes pulsar/error.go x: 170 lines of code y: 21 # changes oauth2/auth.go x: 75 lines of code y: 7 # changes oauth2/store/keyring.go x: 157 lines of code y: 3 # changes oauth2/store/store.go x: 13 lines of code y: 2 # changes pulsar/crypto/default_message_crypto.go x: 255 lines of code y: 4 # changes pulsar/internal/commands.go x: 272 lines of code y: 38 # changes pulsar/internal/crypto/producer_encryptor.go x: 43 lines of code y: 2 # changes pulsar/primitiveSerDe.go x: 266 lines of code y: 2 # changes pulsar/producer_impl.go x: 280 lines of code y: 28 # changes pulsar/table_view_impl.go x: 223 lines of code y: 6 # changes pulsar/transaction_impl.go x: 197 lines of code y: 5 # changes pulsar/client.go x: 85 lines of code y: 37 # changes pulsar/client_impl.go x: 215 lines of code y: 43 # changes pulsar/dlq_router.go x: 135 lines of code y: 20 # changes pulsaradmin/pkg/utils/data.go x: 472 lines of code y: 12 # changes pulsar/consumer_impl.go x: 715 lines of code y: 70 # changes pulsar/consumer_multitopic.go x: 274 lines of code y: 27 # changes pulsar/internal/connection_reader.go x: 101 lines of code y: 17 # changes pulsar/internal/http_client.go x: 292 lines of code y: 15 # changes pulsar/internal/retry.go x: 37 lines of code y: 1 # changes pulsar/retry_router.go x: 117 lines of code y: 10 # changes pulsar/ack_grouping_tracker.go x: 217 lines of code y: 6 # changes pulsar/consumer_regex.go x: 419 lines of code y: 29 # changes pulsar/consumer_zero_queue.go x: 227 lines of code y: 2 # changes pulsar/internal/lookup_service.go x: 301 lines of code y: 31 # changes pulsar/internal/pulsar_proto/PulsarApi.proto x: 922 lines of code y: 11 # changes oauth2/clock/testing/fake_clock.go x: 188 lines of code y: 2 # changes perf/perf-consumer.go x: 92 lines of code y: 13 # changes perf/perf-producer.go x: 126 lines of code y: 19 # changes perf/pulsar-perf-go.go x: 125 lines of code y: 16 # changes pulsar/auth/disabled.go x: 33 lines of code y: 2 # changes pulsar/auth/token.go x: 83 lines of code y: 3 # changes pulsar/internal/compression/noop.go x: 33 lines of code y: 7 # changes pulsar/internal/compression/zstd_cgo.go x: 53 lines of code y: 11 # changes pulsar/internal/compression/zstd_go.go x: 45 lines of code y: 5 # changes pulsar/internal/crypto/noop_decryptor.go x: 17 lines of code y: 2 # changes pulsar/internal/crypto/noop_encryptor.go x: 11 lines of code y: 2 # changes pulsar/internal/pulsartracing/consumer_interceptor.go x: 28 lines of code y: 2 # changes pulsar/internal/pulsartracing/message_carrier_adaptors.go x: 47 lines of code y: 2 # changes pulsar/internal/pulsartracing/producer_interceptor.go x: 29 lines of code y: 3 # changes pulsar/negative_acks_tracker.go x: 104 lines of code y: 9 # changes pulsaradmin/pkg/admin/auth/oauth2.go x: 204 lines of code y: 8 # changes pulsaradmin/pkg/admin/namespace.go x: 648 lines of code y: 9 # changes pulsaradmin/pkg/utils/schema_util.go x: 72 lines of code y: 6 # changes pulsaradmin/pkg/admin/subscription.go x: 233 lines of code y: 8 # changes pulsaradmin/pkg/admin/schema.go x: 156 lines of code y: 6 # changes pulsar/backoff/backoff.go x: 41 lines of code y: 1 # changes pulsar/producer.go x: 71 lines of code y: 34 # changes pulsar/default_router.go x: 66 lines of code y: 5 # changes pulsar/internal/memory_limit_controller.go x: 111 lines of code y: 3 # changes pulsaradmin/pkg/utils/message_id.go x: 60 lines of code y: 5 # changes pulsaradmin/pkg/utils/topic_name.go x: 109 lines of code y: 4 # changes oauth2/client_credentials_flow.go x: 124 lines of code y: 3 # changes oauth2/client_credentials_provider.go x: 55 lines of code y: 6 # changes pulsar/internal/batch_builder.go x: 228 lines of code y: 33 # changes pulsar/internal/key_based_batch_builder.go x: 159 lines of code y: 9 # changes pulsar/log/wrapper_slog.go x: 69 lines of code y: 1 # changes pulsar/schema.go x: 523 lines of code y: 12 # changes pulsaradmin/pkg/rest/client.go x: 346 lines of code y: 7 # changes pulsaradmin/pkg/admin/admin.go x: 84 lines of code y: 7 # changes pulsaradmin/pkg/admin/brokers.go x: 127 lines of code y: 7 # changes pulsaradmin/pkg/admin/topic.go x: 540 lines of code y: 7 # changes pulsaradmin/pkg/utils/sink_status.go x: 23 lines of code y: 4 # changes pulsaradmin/pkg/utils/function_state.go x: 8 lines of code y: 4 # changes pulsar/internal/utils.go x: 58 lines of code y: 8 # changes pulsaradmin/pkg/utils/topic_auto_creation_config.go x: 6 lines of code y: 4 # changes pulsar/table_view.go x: 24 lines of code y: 2 # changes pulsaradmin/alias.go x: 10 lines of code y: 3 # changes pulsaradmin/pkg/admin/auth/tls.go x: 77 lines of code y: 3 # changes pulsaradmin/pkg/admin/auth/token.go x: 66 lines of code y: 4 # changes pulsaradmin/pkg/admin/auth/transport.go x: 35 lines of code y: 4 # changes pulsaradmin/pkg/admin/broker_stats.go x: 65 lines of code y: 3 # changes pulsaradmin/pkg/admin/cluster.go x: 85 lines of code y: 3 # changes pulsaradmin/pkg/admin/config/api_version.go x: 22 lines of code y: 3 # changes pulsaradmin/pkg/admin/functions.go x: 463 lines of code y: 4 # changes pulsaradmin/pkg/admin/ns_isolation_policy.go x: 75 lines of code y: 3 # changes pulsaradmin/pkg/admin/packages.go x: 177 lines of code y: 4 # changes pulsaradmin/pkg/admin/resource_quotas.go x: 51 lines of code y: 3 # changes pulsaradmin/pkg/admin/sinks.go x: 298 lines of code y: 3 # changes pulsaradmin/pkg/admin/sources.go x: 300 lines of code y: 3 # changes pulsaradmin/pkg/admin/tenant.go x: 45 lines of code y: 3 # changes pulsaradmin/pkg/rest/errors.go x: 13 lines of code y: 3 # changes pulsaradmin/pkg/utils/auth_action.go x: 33 lines of code y: 3 # changes pulsaradmin/pkg/utils/backlog_quota.go x: 55 lines of code y: 3 # changes pulsaradmin/pkg/utils/broker_ns_isolation_data.go x: 7 lines of code y: 3 # changes pulsaradmin/pkg/utils/consumer_config.go x: 11 lines of code y: 6 # changes pulsaradmin/pkg/utils/dispatch_rate.go x: 23 lines of code y: 3 # changes pulsaradmin/pkg/utils/function_confg.go x: 53 lines of code y: 6 # changes pulsaradmin/pkg/utils/load_manage_report.go x: 99 lines of code y: 3 # changes pulsaradmin/pkg/utils/message.go x: 58 lines of code y: 4 # changes pulsaradmin/pkg/utils/namespace_name.go x: 53 lines of code y: 4 # changes pulsaradmin/pkg/utils/ns_isolation_data.go x: 62 lines of code y: 3 # changes pulsaradmin/pkg/utils/policies.go x: 59 lines of code y: 3 # changes pulsaradmin/pkg/utils/schema_strategy.go x: 38 lines of code y: 3 # changes pulsaradmin/pkg/utils/source_config.go x: 21 lines of code y: 5 # changes pulsaradmin/pkg/utils/window_confing.go x: 18 lines of code y: 4 # changes licenserc.toml x: 22 lines of code y: 1 # changes pulsar/internal/helper.go x: 11 lines of code y: 1 # changes pulsar/internal/channel_cond.go x: 45 lines of code y: 1 # changes pulsar/auth/basic.go x: 54 lines of code y: 1 # changes pulsar/auth/oauth2.go x: 159 lines of code y: 1 # changes pulsar/auth/provider.go x: 53 lines of code y: 1 # changes pulsar/auth/tls.go x: 67 lines of code y: 1 # changes pulsar/helper.go x: 47 lines of code y: 7 # changes pulsar/internal/version.go x: 25 lines of code y: 1 # changes pulsar/negative_backoff_policy.go x: 17 lines of code y: 3 # changes pulsar/log/wrapper_logrus.go x: 93 lines of code y: 3 # changes pulsar/internal/metrics.go x: 533 lines of code y: 9 # changes oauth2/authorization_tokenretriever.go x: 250 lines of code y: 3 # changes pulsar/internal/topic_name.go x: 88 lines of code y: 11 # changes pulsar/internal/buffer.go x: 146 lines of code y: 8 # changes pulsar/internal/compression/zstd.go x: 11 lines of code y: 11 # changes pulsar/crypto/encryption_key_Info.go x: 22 lines of code y: 2 # changes pulsar/crypto/message_crypto.go x: 7 lines of code y: 2 # changes pulsar/crypto/message_metadata.go x: 85 lines of code y: 2 # changes pulsar/internal/crypto/decryptor.go x: 7 lines of code y: 1 # changes oauth2/device_code_flow.go x: 149 lines of code y: 2 # changes oauth2/device_code_provider.go x: 93 lines of code y: 2 # changes pulsar/internal/blocking_queue.go x: 127 lines of code y: 3 # changes pulsar/internal/pulsartracing/span-enrichment.go x: 27 lines of code y: 1 # changes pulsar/internal/service_uri.go x: 172 lines of code y: 1 # changes oauth2/oidc_endpoint_provider.go x: 31 lines of code y: 1 # changes oauth2/store/memory.go x: 61 lines of code y: 1 # changes pulsar/internal/compression/compression.go x: 15 lines of code y: 6 # changes pulsar/internal/client_handlers.go x: 38 lines of code y: 2 # changes pulsar/internal/closable.go x: 4 lines of code y: 5 # changes pulsar/internal/checksum.go x: 24 lines of code y: 8 # changes pulsar/internal/hash.go x: 17 lines of code y: 5 # changes
130.0
# changes
  min: 1.0
  average: 8.67
  25th percentile: 2.0
  median: 3.0
  75th percentile: 7.0
  max: 130.0
0 2101.0
lines of code
min: 4.0 | average: 123.04 | 25th percentile: 21.75 | median: 53.0 | 75th percentile: 127.0 | max: 2101.0

Number of Contributors vs. Number of Changes: 198 points

pulsar/auth/athenz.go x: 4 # contributors y: 4 # changes pulsar/producer_partition.go x: 55 # contributors y: 130 # changes pulsar/message.go x: 17 # contributors y: 36 # changes pulsar/internal/connection.go x: 44 # contributors y: 101 # changes pulsar/consumer.go x: 27 # contributors y: 53 # changes pulsar/consumer_partition.go x: 50 # contributors y: 110 # changes pulsar/impl_message.go x: 21 # contributors y: 45 # changes pulsar/reader.go x: 14 # contributors y: 18 # changes pulsar/reader_impl.go x: 23 # contributors y: 28 # changes pulsar/internal/compression/lz4.go x: 2 # contributors y: 7 # changes pulsar/transaction_coordinator_client.go x: 6 # contributors y: 8 # changes pulsar/internal/connection_pool.go x: 16 # contributors y: 30 # changes pulsar/internal/rpc_client.go x: 17 # contributors y: 40 # changes pulsar/error.go x: 12 # contributors y: 21 # changes oauth2/auth.go x: 7 # contributors y: 7 # changes oauth2/store/keyring.go x: 2 # contributors y: 3 # changes oauth2/store/store.go x: 2 # contributors y: 2 # changes pulsar/internal/commands.go x: 18 # contributors y: 38 # changes pulsar/producer_impl.go x: 18 # contributors y: 28 # changes pulsar/table_view_impl.go x: 6 # contributors y: 6 # changes pulsar/transaction_impl.go x: 4 # contributors y: 5 # changes pulsar/client.go x: 21 # contributors y: 37 # changes pulsar/client_impl.go x: 25 # contributors y: 43 # changes pulsar/dlq_router.go x: 14 # contributors y: 20 # changes pulsaradmin/pkg/utils/data.go x: 8 # contributors y: 12 # changes pulsar/consumer_impl.go x: 26 # contributors y: 70 # changes pulsar/consumer_multitopic.go x: 17 # contributors y: 27 # changes pulsar/internal/connection_reader.go x: 10 # contributors y: 17 # changes pulsar/internal/http_client.go x: 10 # contributors y: 15 # changes pulsar/internal/retry.go x: 1 # contributors y: 1 # changes pulsar/retry_router.go x: 10 # contributors y: 10 # changes pulsar/ack_grouping_tracker.go x: 3 # contributors y: 6 # changes pulsar/consumer_regex.go x: 18 # contributors y: 29 # changes pulsar/internal/lookup_service.go x: 16 # contributors y: 31 # changes pulsar/internal/pulsar_proto/PulsarApi.proto x: 8 # contributors y: 11 # changes perf/perf-consumer.go x: 9 # contributors y: 13 # changes perf/perf-producer.go x: 10 # contributors y: 19 # changes perf/pulsar-perf-go.go x: 10 # contributors y: 16 # changes pulsar/auth/token.go x: 3 # contributors y: 3 # changes pulsar/internal/compression/noop.go x: 3 # contributors y: 7 # changes pulsar/internal/compression/zstd_cgo.go x: 5 # contributors y: 11 # changes pulsar/internal/compression/zstd_go.go x: 2 # contributors y: 5 # changes pulsar/negative_acks_tracker.go x: 7 # contributors y: 9 # changes pulsaradmin/pkg/admin/namespace.go x: 8 # contributors y: 9 # changes pulsaradmin/pkg/admin/subscription.go x: 5 # contributors y: 8 # changes pulsaradmin/pkg/admin/schema.go x: 5 # contributors y: 6 # changes pulsar/producer.go x: 19 # contributors y: 34 # changes pulsaradmin/pkg/utils/message_id.go x: 5 # contributors y: 5 # changes pulsar/internal/batch_builder.go x: 19 # contributors y: 33 # changes pulsar/schema.go x: 13 # contributors y: 12 # changes pulsaradmin/pkg/rest/client.go x: 5 # contributors y: 7 # changes pulsaradmin/pkg/admin/admin.go x: 4 # contributors y: 7 # changes pulsaradmin/pkg/admin/topic.go x: 6 # contributors y: 7 # changes pulsar/internal/utils.go x: 7 # contributors y: 8 # changes pulsaradmin/pkg/admin/auth/provider.go x: 3 # contributors y: 5 # changes pulsaradmin/pkg/admin/auth/token.go x: 3 # contributors y: 4 # changes pulsaradmin/pkg/utils/consumer_config.go x: 4 # contributors y: 6 # changes pulsar/transaction.go x: 1 # contributors y: 3 # changes pulsar/encryption.go x: 1 # contributors y: 2 # changes pulsar/internal/compression/compression.go x: 1 # contributors y: 6 # changes pulsar/internal/checksum.go x: 3 # contributors y: 8 # changes
130.0
# changes
  min: 1.0
  average: 8.67
  25th percentile: 2.0
  median: 3.0
  75th percentile: 7.0
  max: 130.0
0 55.0
# contributors
min: 1.0 | average: 5.49 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 5.0 | max: 55.0

Number of Contributors vs. File Size: 198 points

pulsar/auth/athenz.go x: 4 # contributors y: 213 lines of code pulsar/producer_partition.go x: 55 # contributors y: 1424 lines of code pulsar/message.go x: 17 # contributors y: 88 lines of code pulsar/internal/connection.go x: 44 # contributors y: 910 lines of code pulsar/consumer.go x: 27 # contributors y: 108 lines of code pulsar/consumer_partition.go x: 50 # contributors y: 2101 lines of code pulsar/impl_message.go x: 21 # contributors y: 439 lines of code pulsar/reader.go x: 14 # contributors y: 37 lines of code pulsar/reader_impl.go x: 23 # contributors y: 175 lines of code pulsar/internal/compression/lz4.go x: 2 # contributors y: 71 lines of code pulsar/transaction_coordinator_client.go x: 6 # contributors y: 362 lines of code pulsar/internal/connection_pool.go x: 16 # contributors y: 139 lines of code pulsar/internal/rpc_client.go x: 17 # contributors y: 208 lines of code pulsar/error.go x: 12 # contributors y: 170 lines of code oauth2/auth.go x: 7 # contributors y: 75 lines of code oauth2/store/keyring.go x: 2 # contributors y: 157 lines of code oauth2/store/store.go x: 2 # contributors y: 13 lines of code pulsar/crypto/default_message_crypto.go x: 4 # contributors y: 255 lines of code pulsar/internal/commands.go x: 18 # contributors y: 272 lines of code pulsar/internal/crypto/producer_encryptor.go x: 2 # contributors y: 43 lines of code pulsar/primitiveSerDe.go x: 2 # contributors y: 266 lines of code pulsar/producer_impl.go x: 18 # contributors y: 280 lines of code pulsar/table_view_impl.go x: 6 # contributors y: 223 lines of code pulsar/transaction_impl.go x: 4 # contributors y: 197 lines of code pulsar/client.go x: 21 # contributors y: 85 lines of code pulsar/client_impl.go x: 25 # contributors y: 215 lines of code pulsar/dlq_router.go x: 14 # contributors y: 135 lines of code pulsaradmin/pkg/utils/data.go x: 8 # contributors y: 472 lines of code pulsar/consumer_impl.go x: 26 # contributors y: 715 lines of code pulsar/consumer_multitopic.go x: 17 # contributors y: 274 lines of code pulsar/internal/connection_reader.go x: 10 # contributors y: 101 lines of code pulsar/internal/http_client.go x: 10 # contributors y: 292 lines of code pulsar/internal/retry.go x: 1 # contributors y: 37 lines of code pulsar/retry_router.go x: 10 # contributors y: 117 lines of code pulsar/ack_grouping_tracker.go x: 3 # contributors y: 217 lines of code pulsar/consumer_regex.go x: 18 # contributors y: 419 lines of code pulsar/consumer_zero_queue.go x: 2 # contributors y: 227 lines of code pulsar/internal/lookup_service.go x: 16 # contributors y: 301 lines of code pulsar/internal/pulsar_proto/PulsarApi.proto x: 8 # contributors y: 922 lines of code oauth2/clock/testing/fake_clock.go x: 2 # contributors y: 188 lines of code perf/perf-consumer.go x: 9 # contributors y: 92 lines of code perf/perf-producer.go x: 10 # contributors y: 126 lines of code pulsar/auth/disabled.go x: 2 # contributors y: 33 lines of code pulsar/auth/token.go x: 3 # contributors y: 83 lines of code pulsar/internal/compression/noop.go x: 3 # contributors y: 33 lines of code pulsar/internal/compression/zstd_cgo.go x: 5 # contributors y: 53 lines of code pulsar/internal/crypto/consumer_decryptor.go x: 2 # contributors y: 34 lines of code pulsar/internal/crypto/noop_decryptor.go x: 2 # contributors y: 17 lines of code pulsar/negative_acks_tracker.go x: 7 # contributors y: 104 lines of code pulsaradmin/pkg/admin/auth/oauth2.go x: 6 # contributors y: 204 lines of code pulsaradmin/pkg/admin/namespace.go x: 8 # contributors y: 648 lines of code pulsaradmin/pkg/utils/schema_util.go x: 6 # contributors y: 72 lines of code pulsaradmin/pkg/admin/subscription.go x: 5 # contributors y: 233 lines of code pulsaradmin/pkg/admin/schema.go x: 5 # contributors y: 156 lines of code pulsar/producer.go x: 19 # contributors y: 71 lines of code pulsar/default_router.go x: 4 # contributors y: 66 lines of code pulsar/internal/memory_limit_controller.go x: 3 # contributors y: 111 lines of code pulsaradmin/pkg/utils/message_id.go x: 5 # contributors y: 60 lines of code pulsaradmin/pkg/utils/topic_name.go x: 4 # contributors y: 109 lines of code oauth2/client_credentials_flow.go x: 3 # contributors y: 124 lines of code pulsar/internal/batch_builder.go x: 19 # contributors y: 228 lines of code pulsar/internal/key_based_batch_builder.go x: 8 # contributors y: 159 lines of code pulsar/log/wrapper_slog.go x: 1 # contributors y: 69 lines of code pulsar/schema.go x: 13 # contributors y: 523 lines of code pulsaradmin/pkg/rest/client.go x: 5 # contributors y: 346 lines of code pulsaradmin/pkg/admin/admin.go x: 4 # contributors y: 84 lines of code pulsaradmin/pkg/admin/brokers.go x: 5 # contributors y: 127 lines of code pulsaradmin/pkg/admin/topic.go x: 6 # contributors y: 540 lines of code pulsaradmin/pkg/utils/sink_status.go x: 4 # contributors y: 23 lines of code pulsaradmin/pkg/utils/function_state.go x: 4 # contributors y: 8 lines of code pulsar/internal/utils.go x: 7 # contributors y: 58 lines of code pulsaradmin/pkg/utils/utils.go x: 4 # contributors y: 25 lines of code pulsaradmin/alias.go x: 3 # contributors y: 10 lines of code pulsaradmin/pkg/admin/auth/provider.go x: 3 # contributors y: 68 lines of code pulsaradmin/pkg/admin/auth/tls.go x: 3 # contributors y: 77 lines of code pulsaradmin/pkg/admin/auth/token.go x: 3 # contributors y: 66 lines of code pulsaradmin/pkg/admin/auth/transport.go x: 3 # contributors y: 35 lines of code pulsaradmin/pkg/admin/config/api_version.go x: 3 # contributors y: 22 lines of code pulsaradmin/pkg/admin/functions.go x: 3 # contributors y: 463 lines of code pulsaradmin/pkg/admin/packages.go x: 4 # contributors y: 177 lines of code pulsaradmin/pkg/admin/resource_quotas.go x: 3 # contributors y: 51 lines of code pulsaradmin/pkg/admin/sinks.go x: 3 # contributors y: 298 lines of code pulsaradmin/pkg/admin/tenant.go x: 3 # contributors y: 45 lines of code pulsaradmin/pkg/utils/broker_ns_isolation_data.go x: 3 # contributors y: 7 lines of code pulsaradmin/pkg/utils/consumer_config.go x: 4 # contributors y: 11 lines of code pulsaradmin/pkg/utils/crypto_config.go x: 2 # contributors y: 8 lines of code pulsaradmin/pkg/utils/function_confg.go x: 4 # contributors y: 53 lines of code pulsaradmin/pkg/utils/load_manage_report.go x: 3 # contributors y: 99 lines of code pulsaradmin/pkg/utils/sink_config.go x: 4 # contributors y: 35 lines of code licenserc.toml x: 1 # contributors y: 22 lines of code pulsar/transaction.go x: 1 # contributors y: 25 lines of code pulsar/internal/helper.go x: 1 # contributors y: 11 lines of code pulsar/internal/channel_cond.go x: 1 # contributors y: 45 lines of code pulsar/auth/basic.go x: 1 # contributors y: 54 lines of code pulsar/auth/oauth2.go x: 1 # contributors y: 159 lines of code pulsar/helper.go x: 4 # contributors y: 47 lines of code pulsar/internal/metrics.go x: 8 # contributors y: 533 lines of code oauth2/authorization_tokenretriever.go x: 3 # contributors y: 250 lines of code pulsar/internal/topic_name.go x: 8 # contributors y: 88 lines of code pulsar/internal/buffer.go x: 5 # contributors y: 146 lines of code pulsar/internal/compression/zstd.go x: 5 # contributors y: 11 lines of code pulsar/crypto/message_metadata.go x: 2 # contributors y: 85 lines of code pulsar/internal/crypto/decryptor.go x: 1 # contributors y: 7 lines of code oauth2/device_code_provider.go x: 2 # contributors y: 93 lines of code pulsar/internal/blocking_queue.go x: 3 # contributors y: 127 lines of code pulsar/internal/service_uri.go x: 1 # contributors y: 172 lines of code oauth2/store/memory.go x: 1 # contributors y: 61 lines of code
2101.0
lines of code
  min: 4.0
  average: 123.04
  25th percentile: 21.75
  median: 53.0
  75th percentile: 127.0
  max: 2101.0
0 55.0
# contributors
min: 1.0 | average: 5.49 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 5.0 | max: 55.0