id: 1 unit: func() file: pkg/controller/broker/broker_controller.go start line: 119 end line: 344 size: 174 LOC McCabe index: 42 number of parameters: 1 id: 2 unit: func() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 109 end line: 289 size: 142 LOC McCabe index: 31 number of parameters: 1 id: 3 unit: func() file: pkg/controller/controller/dledger_controller.go start line: 113 end line: 230 size: 96 LOC McCabe index: 20 number of parameters: 1 id: 4 unit: func() file: pkg/controller/broker/broker_controller.go start line: 402 end line: 500 size: 91 LOC McCabe index: 5 number of parameters: 1 id: 5 unit: func() file: pkg/controller/nameservice/nameservice_controller.go start line: 166 end line: 259 size: 75 LOC McCabe index: 15 number of parameters: 1 id: 6 unit: func main() file: main.go start line: 60 end line: 132 size: 61 LOC McCabe index: 10 number of parameters: 0 id: 7 unit: func() file: pkg/controller/controller/dledger_controller.go start line: 233 end line: 300 size: 58 LOC McCabe index: 2 number of parameters: 1 id: 8 unit: func() file: pkg/controller/nameservice/nameservice_controller.go start line: 338 end line: 399 size: 54 LOC McCabe index: 2 number of parameters: 1 id: 9 unit: func() file: pkg/controller/console/console_controller.go start line: 109 end line: 180 size: 51 LOC McCabe index: 13 number of parameters: 1 id: 10 unit: func newDeploymentForCR() file: pkg/controller/console/console_controller.go start line: 183 end line: 221 size: 37 LOC McCabe index: 1 number of parameters: 1 id: 11 unit: func() file: pkg/tool/k8s.go start line: 80 end line: 122 size: 36 LOC McCabe index: 4 number of parameters: 1 id: 12 unit: func() file: pkg/controller/nameservice/nameservice_controller.go start line: 117 end line: 164 size: 35 LOC McCabe index: 9 number of parameters: 1 id: 13 unit: func NewK8sClient() file: pkg/tool/k8s.go start line: 45 end line: 76 size: 27 LOC McCabe index: 6 number of parameters: 0 id: 14 unit: func getVolumes() file: pkg/controller/broker/broker_controller.go start line: 551 end line: 576 size: 26 LOC McCabe index: 4 number of parameters: 1 id: 15 unit: func getENV() file: pkg/controller/controller/dledger_controller.go start line: 302 end line: 326 size: 25 LOC McCabe index: 3 number of parameters: 1 id: 16 unit: func() file: pkg/controller/controller/dledger_controller.go start line: 396 end line: 422 size: 25 LOC McCabe index: 1 number of parameters: 1 id: 17 unit: func getVolumes() file: pkg/controller/controller/dledger_controller.go start line: 355 end line: 379 size: 24 LOC McCabe index: 4 number of parameters: 1 id: 18 unit: func getVolumes() file: pkg/controller/nameservice/nameservice_controller.go start line: 272 end line: 295 size: 24 LOC McCabe index: 4 number of parameters: 1 id: 19 unit: func() file: pkg/controller/controller/dledger_controller.go start line: 424 end line: 447 size: 23 LOC McCabe index: 1 number of parameters: 1 id: 20 unit: func getENV() file: pkg/controller/broker/broker_controller.go start line: 502 end line: 522 size: 21 LOC McCabe index: 2 number of parameters: 3 id: 21 unit: func getConsumerGroupByTopic() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 326 end line: 347 size: 21 LOC McCabe index: 6 number of parameters: 2 id: 22 unit: func isConsumeFinished() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 427 end line: 447 size: 21 LOC McCabe index: 7 number of parameters: 3 id: 23 unit: func add() file: pkg/controller/broker/broker_controller.go start line: 71 end line: 95 size: 18 LOC McCabe index: 4 number of parameters: 2 id: 24 unit: func add() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 64 end line: 88 size: 18 LOC McCabe index: 4 number of parameters: 2 id: 25 unit: func buildUndoStopWriteCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 374 end line: 391 size: 18 LOC McCabe index: 1 number of parameters: 3 id: 26 unit: func buildAddRetryTopicToClusterCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 403 end line: 420 size: 18 LOC McCabe index: 1 number of parameters: 3 id: 27 unit: func add() file: pkg/controller/controller/dledger_controller.go start line: 66 end line: 90 size: 18 LOC McCabe index: 4 number of parameters: 2 id: 28 unit: func add() file: pkg/controller/nameservice/nameservice_controller.go start line: 70 end line: 94 size: 18 LOC McCabe index: 4 number of parameters: 2 id: 29 unit: func add() file: pkg/controller/console/console_controller.go start line: 63 end line: 87 size: 18 LOC McCabe index: 4 number of parameters: 2 id: 30 unit: func exec() file: pkg/controller/broker/broker_controller.go start line: 377 end line: 395 size: 16 LOC McCabe index: 3 number of parameters: 4 id: 31 unit: func buildStopClusterTopicWriteCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 486 end line: 501 size: 16 LOC McCabe index: 1 number of parameters: 3 id: 32 unit: func buildAddConsumerGroupToClusterCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 503 end line: 518 size: 16 LOC McCabe index: 1 number of parameters: 3 id: 33 unit: func undoDeleteConsumeGroup() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 313 end line: 324 size: 12 LOC McCabe index: 4 number of parameters: 3 id: 34 unit: func buildDeleteConsumeGroupCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 449 end line: 460 size: 12 LOC McCabe index: 1 number of parameters: 3 id: 35 unit: func buildDeleteSourceClusterTopicCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 462 end line: 473 size: 12 LOC McCabe index: 1 number of parameters: 3 id: 36 unit: func buildAddTopicToClusterCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 520 end line: 531 size: 12 LOC McCabe index: 1 number of parameters: 3 id: 37 unit: func buildOutputCommand() file: pkg/controller/broker/broker_controller.go start line: 365 end line: 375 size: 11 LOC McCabe index: 1 number of parameters: 2 id: 38 unit: func getCopyMetadataJsonCommand() file: pkg/controller/broker/broker_controller.go start line: 346 end line: 355 size: 10 LOC McCabe index: 2 number of parameters: 4 id: 39 unit: func getVolumeClaimTemplates() file: pkg/controller/broker/broker_controller.go start line: 524 end line: 533 size: 10 LOC McCabe index: 3 number of parameters: 1 id: 40 unit: func undoStopWrite() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 291 end line: 300 size: 10 LOC McCabe index: 3 number of parameters: 3 id: 41 unit: func undoDeleteTopic() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 302 end line: 311 size: 10 LOC McCabe index: 3 number of parameters: 3 id: 42 unit: func buildCheckConsumeProgressCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 475 end line: 484 size: 10 LOC McCabe index: 1 number of parameters: 2 id: 43 unit: func getVolumeClaimTemplates() file: pkg/controller/controller/dledger_controller.go start line: 328 end line: 337 size: 10 LOC McCabe index: 3 number of parameters: 1 id: 44 unit: func getVolumeClaimTemplates() file: pkg/controller/nameservice/nameservice_controller.go start line: 261 end line: 270 size: 10 LOC McCabe index: 3 number of parameters: 1 id: 45 unit: func getNameServers() file: pkg/controller/nameservice/nameservice_controller.go start line: 297 end line: 306 size: 10 LOC McCabe index: 4 number of parameters: 1 id: 46 unit: func buildTopicListCommand() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 393 end line: 401 size: 9 LOC McCabe index: 1 number of parameters: 1 id: 47 unit: func getRunningNameServersNum() file: pkg/controller/nameservice/nameservice_controller.go start line: 308 end line: 316 size: 9 LOC McCabe index: 3 number of parameters: 1 id: 48 unit: func buildInputCommand() file: pkg/controller/broker/broker_controller.go start line: 357 end line: 363 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 49 unit: func getPodSecurityContext() file: pkg/controller/broker/broker_controller.go start line: 535 end line: 541 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 50 unit: func getContainerSecurityContext() file: pkg/controller/broker/broker_controller.go start line: 543 end line: 549 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 51 unit: func getPodNames() file: pkg/controller/broker/broker_controller.go start line: 592 end line: 598 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 52 unit: func getPodSecurityContext() file: pkg/controller/controller/dledger_controller.go start line: 339 end line: 345 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 53 unit: func getContainerSecurityContext() file: pkg/controller/controller/dledger_controller.go start line: 347 end line: 353 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 54 unit: func getPodNames() file: pkg/controller/controller/dledger_controller.go start line: 388 end line: 394 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 55 unit: func getPodSecurityContext() file: pkg/controller/nameservice/nameservice_controller.go start line: 318 end line: 324 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 56 unit: func getContainerSecurityContext() file: pkg/controller/nameservice/nameservice_controller.go start line: 326 end line: 332 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 57 unit: func getPathSuffix() file: pkg/controller/broker/broker_controller.go start line: 578 end line: 583 size: 6 LOC McCabe index: 2 number of parameters: 3 id: 58 unit: func init() file: main.go start line: 53 end line: 58 size: 4 LOC McCabe index: 1 number of parameters: 0 id: 59 unit: func init() file: pkg/apis/rocketmq/v1alpha1/controller_types.go start line: 107 end line: 109 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 60 unit: func init() file: pkg/apis/rocketmq/v1alpha1/topictransfer_types.go start line: 72 end line: 74 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 61 unit: func init() file: pkg/apis/rocketmq/v1alpha1/nameservice_types.go start line: 105 end line: 107 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 62 unit: func init() file: pkg/apis/rocketmq/v1alpha1/console_types.go start line: 72 end line: 74 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 63 unit: func init() file: pkg/apis/rocketmq/v1alpha1/broker_types.go start line: 121 end line: 123 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 64 unit: func SetupWithManager() file: pkg/controller/broker/broker_controller.go start line: 61 end line: 63 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 65 unit: func newReconciler() file: pkg/controller/broker/broker_controller.go start line: 66 end line: 68 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 66 unit: func getBrokerName() file: pkg/controller/broker/broker_controller.go start line: 397 end line: 399 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 67 unit: func labelsForBroker() file: pkg/controller/broker/broker_controller.go start line: 587 end line: 589 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 68 unit: func SetupWithManager() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 54 end line: 56 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 69 unit: func newReconciler() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 59 end line: 61 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 70 unit: func isTopicListSuccess() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 349 end line: 351 size: 3 LOC McCabe index: 2 number of parameters: 1 id: 71 unit: func isCheckConsumeProcessCommandSuccess() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 353 end line: 355 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 72 unit: func isDeleteTopicCommandSuccess() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 357 end line: 359 size: 3 LOC McCabe index: 2 number of parameters: 1 id: 73 unit: func isUpdateTopicCommandSuccess() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 361 end line: 363 size: 3 LOC McCabe index: 2 number of parameters: 1 id: 74 unit: func isDeleteConsumerGroupSuccess() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 365 end line: 367 size: 3 LOC McCabe index: 2 number of parameters: 1 id: 75 unit: func isUpdateConsumerGroupSuccess() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 369 end line: 372 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 76 unit: func getClusterBrokerNames() file: pkg/controller/topictransfer/topictransfer_controller.go start line: 422 end line: 425 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 77 unit: func SetupWithManager() file: pkg/controller/controller/dledger_controller.go start line: 56 end line: 58 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 78 unit: func newReconciler() file: pkg/controller/controller/dledger_controller.go start line: 61 end line: 63 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 79 unit: func labelsForController() file: pkg/controller/controller/dledger_controller.go start line: 383 end line: 385 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 80 unit: func SetupWithManager() file: pkg/controller/nameservice/nameservice_controller.go start line: 60 end line: 62 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 81 unit: func newReconciler() file: pkg/controller/nameservice/nameservice_controller.go start line: 65 end line: 67 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 82 unit: func labelsForNameService() file: pkg/controller/nameservice/nameservice_controller.go start line: 334 end line: 336 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 83 unit: func SetupWithManager() file: pkg/controller/console/console_controller.go start line: 53 end line: 55 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 84 unit: func newReconciler() file: pkg/controller/console/console_controller.go start line: 58 end line: 60 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 85 unit: func BuildHeadlessSvcResourceName() file: pkg/tool/resource_name.go start line: 22 end line: 24 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 86 unit: func BuildSvcResourceName() file: pkg/tool/resource_name.go start line: 26 end line: 28 size: 3 LOC McCabe index: 1 number of parameters: 1