alibaba / schedulerx-worker-go
File Size

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

Intro
Learn more...
File Size Overall
38% | 13% | 19% | 11% | 16%
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
go40% | 13% | 18% | 11% | 16%
proto0% | 0% | 61% | 18% | 20%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
internal41% | 13% | 18% | 11% | 15%
processor0% | 0% | 61% | 0% | 38%
config0% | 0% | 100% | 0% | 0%
logger0% | 0% | 0% | 100% | 0%
ROOT0% | 0% | 0% | 100% | 0%
example0% | 0% | 0% | 0% | 100%
tracer0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
worker.pb.go
in internal/proto/schedulerx
4533 502
server.pb.go
in internal/proto/schedulerx
2815 312
WireFormats.pb.go
in internal/proto/akka
1696 184
ContainerFormats.pb.go
in internal/proto/akka
921 100
map_task_master.go
in internal/master
883 38
ArteryControlFormats.pb.go
in internal/proto/akka
745 79
SystemMessageFormats.pb.go
in internal/proto/akka
516 50
broadcast_task_master.go
in internal/master
450 21
task_dao.go
in internal/master/persistence
406 20
client.go
in internal/openapi
392 31
proto
worker.proto
in internal/proto
365 -
task_master.go
in internal/master
338 35
job_instance_actor.go
in internal/actor
337 12
304 10
container_actor.go
in internal/actor
295 10
server_task_persistence.go
in internal/master/persistence
245 11
jobcontext.go
in processor/jobcontext
242 66
proto
server.proto
in internal/proto
234 -
job_instance_info.go
in internal/common
221 61
group_manager.go
in internal/discovery
217 13
214 40
map_job_processor.go
in processor/mapjob
212 7
task_actor.go
in internal/actor
211 6
akka_codec.go
in internal/remoting/codec
197 4
h2_persistence.go
in internal/master/persistence
192 16
common.pb.go
in internal/proto/schedulerx
185 17
sharding_task_master.go
in internal/master
181 9
proto
WireFormats.proto
in internal/proto
180 -
thread_container.go
in internal/container
172 8
standalone_task_master.go
in internal/master
168 7
job_instance_processor.go
in internal/actor
162 4
heartbeat.go
in internal/remoting
154 4
java_job_config.go
in internal/openapi
146 10
base_req_handler.go
in internal/batch
142 13
parallel_task_mater.go
in internal/master
134 3
logger.go
in logger
132 17
client.go
in root
132 7
discover.go
in internal/discovery
123 7
misc.go
in internal/utils
120 12
single_pool.go
in internal/remoting/pool
119 12
task_actor_processor.go
in internal/actor
113 4
task_progress_counter.go
in internal/common
99 20
handler.go
in internal/remoting
95 1
init.go
in internal/actor
95 1
thread_container_pool.go
in internal/container
93 10
93 2
heartbeat_processor.go
in internal/actor
92 4
task_snapshot.go
in internal/master/persistence
87 23
app_group_info.go
in internal/common
84 23
handshake.go
in internal/remoting
82 2
Files With Most Units (Top 50)
File# lines# units
worker.pb.go
in internal/proto/schedulerx
4533 502
server.pb.go
in internal/proto/schedulerx
2815 312
WireFormats.pb.go
in internal/proto/akka
1696 184
ContainerFormats.pb.go
in internal/proto/akka
921 100
ArteryControlFormats.pb.go
in internal/proto/akka
745 79
jobcontext.go
in processor/jobcontext
242 66
job_instance_info.go
in internal/common
221 61
SystemMessageFormats.pb.go
in internal/proto/akka
516 50
214 40
map_task_master.go
in internal/master
883 38
task_master.go
in internal/master
338 35
client.go
in internal/openapi
392 31
app_group_info.go
in internal/common
84 23
task_snapshot.go
in internal/master/persistence
87 23
broadcast_task_master.go
in internal/master
450 21
task_progress_counter.go
in internal/common
99 20
task_dao.go
in internal/master/persistence
406 20
logger.go
in logger
132 17
common.pb.go
in internal/proto/schedulerx
185 17
h2_persistence.go
in internal/master/persistence
192 16
worker_progress_counter.go
in internal/common
80 15
second_progress_detail.go
in internal/common
57 13
progress_history.go
in internal/common
49 13
base_req_handler.go
in internal/batch
142 13
group_manager.go
in internal/discovery
217 13
container_pool.go
in internal/container
52 13
process_result.go
in processor
54 12
misc.go
in internal/utils
120 12
single_pool.go
in internal/remoting/pool
119 12
channel.go
in internal/actor/common
55 12
job_instance_actor.go
in internal/actor
337 12
log_config_info.go
in internal/common
42 11
server_task_persistence.go
in internal/master/persistence
245 11
priority_queue.go
in internal/utils
66 10
task_info.go
in internal/common
38 10
thread_container_pool.go
in internal/container
93 10
container_actor.go
in internal/actor
295 10
304 10
java_job_config.go
in internal/openapi
146 10
sharding_task_status.go
in processor/taskstatus
42 9
map_task_xattrs.go
in internal/common
46 9
taskmaster_pool.go
in internal/masterpool
67 9
sharding_task_master.go
in internal/master
181 9
time_scheduler.go
in internal/master
67 9
time_plan_entry.go
in internal/master
37 9
thread_container.go
in internal/container
172 8
time_queue.go
in internal/master
58 8
type_info.go
in processor/taskstatus
30 7
map_job_processor.go
in processor/mapjob
212 7
client.go
in root
132 7
Files With Long Lines (Top 48)

There are 48 files with lines longer than 120 characters. In total, there are 402 long lines.

File# lines# units# long lines
worker.pb.go
in internal/proto/schedulerx
4533 502 77
map_task_master.go
in internal/master
883 38 58
server.pb.go
in internal/proto/schedulerx
2815 312 42
broadcast_task_master.go
in internal/master
450 21 19
task_actor.go
in internal/actor
211 6 18
container_actor.go
in internal/actor
295 10 16
304 10 15
map_job_processor.go
in processor/mapjob
212 7 11
job_instance_processor.go
in internal/actor
162 4 10
server_task_persistence.go
in internal/master/persistence
245 11 9
parallel_task_mater.go
in internal/master
134 3 9
job_instance_actor.go
in internal/actor
337 12 8
standalone_task_master.go
in internal/master
168 7 8
channel.go
in internal/actor/common
55 12 7
task_master.go
in internal/master
338 35 7
93 2 7
grid_task_master.go
in internal/master
66 4 7
group_manager.go
in internal/discovery
217 13 6
task_dao.go
in internal/master/persistence
406 20 6
thread_container.go
in internal/container
172 8 5
sharding_task_master.go
in internal/master
181 9 5
55 6 4
WireFormats.pb.go
in internal/proto/akka
1696 184 4
SystemMessageFormats.pb.go
in internal/proto/akka
516 50 4
80 3 3
task_push_req_handler.go
in internal/batch
46 3 3
akka_codec.go
in internal/remoting/codec
197 4 3
discover.go
in internal/discovery
123 7 3
heartbeat_processor.go
in internal/actor
92 4 3
h2_persistence.go
in internal/master/persistence
192 16 3
tms_status_req_handler.go
in internal/batch
36 2 2
heartbeat.go
in internal/remoting
154 4 2
heartbeat_actor.go
in internal/actor
77 4 2
26 2 2
client.go
in root
132 7 1
54 7 1
task_pull_req_handler.go
in internal/batch
34 3 1
14 2 1
handshake.go
in internal/remoting
82 2 1
handler.go
in internal/remoting
95 1 1
thread_container_pool.go
in internal/container
93 10 1
container_pool.go
in internal/container
52 13 1
task_persistence.go
in internal/master/persistence
18 - 1
utils.go
in internal/master/persistence
59 3 1
taskmaster.go
in internal/master/taskmaster
47 - 1
time_plan_entry.go
in internal/master
37 9 1
client.go
in internal/openapi
392 31 1
ArteryControlFormats.pb.go
in internal/proto/akka
745 79 1