package info (click to toggle)
golang-github-shopify-sarama 1.22.1-1
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, bullseye, sid, trixie
  • size: 1,728 kB
  • sloc: sh: 112; makefile: 43

Folder: 1.22.1-1

show hidden (1)
d .. (parent)
d d rwxr-xr-x 86 .github
d d rwxr-xr-x 104 .pc
d d rwxr-xr-x 4,096 debian
d d rwxr-xr-x 104 examples
d d rwxr-xr-x 4,096 mocks
d d rwxr-xr-x 4,096 tools
d d rwxr-xr-x 4,096 vagrant
- - rw-r--r-- 294 .gitignore
- - rw-r--r-- 806 .travis.yml
- - rw-r--r-- 33,588 CHANGELOG.md
- - rw-r--r-- 1,051 LICENSE
- - rw-r--r-- 1,083 Makefile
- - rw-r--r-- 2,202 README.md
- - rw-r--r-- 528 Vagrantfile
- - rw-r--r-- 2,730 acl_bindings.go
- - rw-r--r-- 1,621 acl_create_request.go
- - rw-r--r-- 1,448 acl_create_request_test.go
- - rw-r--r-- 1,855 acl_create_response.go
- - rw-r--r-- 761 acl_create_response_test.go
- - rw-r--r-- 1,085 acl_delete_request.go
- - rw-r--r-- 2,432 acl_delete_request_test.go
- - rw-r--r-- 3,145 acl_delete_response.go
- - rw-r--r-- 856 acl_delete_response_test.go
- - rw-r--r-- 726 acl_describe_request.go
- - rw-r--r-- 1,493 acl_describe_request_test.go
- - rw-r--r-- 1,657 acl_describe_response.go
- - rw-r--r-- 937 acl_describe_response_test.go
- - rw-r--r-- 1,646 acl_filter.go
- - rw-r--r-- 1,323 acl_types.go
- - rw-r--r-- 1,085 add_offsets_to_txn_request.go
- - rw-r--r-- 421 add_offsets_to_txn_request_test.go
- - rw-r--r-- 898 add_offsets_to_txn_response.go
- - rw-r--r-- 342 add_offsets_to_txn_response_test.go
- - rw-r--r-- 1,577 add_partitions_to_txn_request.go
- - rw-r--r-- 543 add_partitions_to_txn_request_test.go
- - rw-r--r-- 2,158 add_partitions_to_txn_response.go
- - rw-r--r-- 585 add_partitions_to_txn_response_test.go
- - rw-r--r-- 16,769 admin.go
- - rw-r--r-- 21,358 admin_test.go
- - rw-r--r-- 2,359 alter_configs_request.go
- - rw-r--r-- 1,947 alter_configs_request_test.go
- - rw-r--r-- 1,964 alter_configs_response.go
- - rw-r--r-- 898 alter_configs_response_test.go
- - rw-r--r-- 451 api_versions_request.go
- - rw-r--r-- 241 api_versions_request_test.go
- - rw-r--r-- 1,769 api_versions_response.go
- - rw-r--r-- 871 api_versions_response_test.go
- - rw-r--r-- 31,598 async_producer.go
- - rw-r--r-- 36,743 async_producer_test.go
- - rw-r--r-- 3,980 balance_strategy.go
- - rw-r--r-- 3,160 balance_strategy_test.go
- - rw-r--r-- 37,229 broker.go
- - rw-r--r-- 22,705 broker_test.go
- - rw-r--r-- 29,825 client.go
- - rw-r--r-- 22,442 client_test.go
- - rw-r--r-- 4,962 client_tls_test.go
- - rw-r--r-- 1,518 compress.go
- - rw-r--r-- 28,742 config.go
- - rw-r--r-- 591 config_resource_type.go
- - rw-r--r-- 9,845 config_test.go
- - rw-r--r-- 27,112 consumer.go
- - rw-r--r-- 22,724 consumer_group.go
- - rw-r--r-- 1,881 consumer_group_members.go
- - rw-r--r-- 1,974 consumer_group_members_test.go
- - rw-r--r-- 1,383 consumer_group_test.go
- - rw-r--r-- 797 consumer_metadata_request.go
- - rw-r--r-- 627 consumer_metadata_request_test.go
- - rw-r--r-- 1,760 consumer_metadata_response.go
- - rw-r--r-- 1,155 consumer_metadata_response_test.go
- - rw-r--r-- 37,159 consumer_test.go
- - rw-r--r-- 1,740 control_record.go
- - rw-r--r-- 15 control_record_test.go
- - rw-r--r-- 1,452 crc32_field.go
- - rw-r--r-- 2,279 create_partitions_request.go
- - rw-r--r-- 1,140 create_partitions_request_test.go
- - rw-r--r-- 2,102 create_partitions_response.go
- - rw-r--r-- 2,071 create_partitions_response_test.go
- - rw-r--r-- 3,310 create_topics_request.go
- - rw-r--r-- 1,035 create_topics_request_test.go
- - rw-r--r-- 2,214 create_topics_response.go
- - rw-r--r-- 1,494 create_topics_response_test.go
- - rw-r--r-- 1,240 decompress.go
- - rw-r--r-- 599 delete_groups_request.go
- - rw-r--r-- 811 delete_groups_request_test.go
- - rw-r--r-- 1,307 delete_groups_response.go
- - rw-r--r-- 1,567 delete_groups_response_test.go
- - rw-r--r-- 2,636 delete_records_request.go
- - rw-r--r-- 614 delete_records_request_test.go
- - rw-r--r-- 3,353 delete_records_response.go
- - rw-r--r-- 741 delete_records_response_test.go
- - rw-r--r-- 903 delete_topics_request.go
- - rw-r--r-- 611 delete_topics_request_test.go
- - rw-r--r-- 1,441 delete_topics_response.go
- - rw-r--r-- 592 delete_topics_response_test.go
- - rw-r--r-- 1,972 describe_configs_request.go
- - rw-r--r-- 2,849 describe_configs_request_test.go
- - rw-r--r-- 5,628 describe_configs_response.go
- - rw-r--r-- 4,049 describe_configs_response_test.go
- - rw-r--r-- 613 describe_groups_request.go
- - rw-r--r-- 833 describe_groups_request_test.go
- - rw-r--r-- 3,876 describe_groups_response.go
- - rw-r--r-- 2,783 describe_groups_response_test.go
- - rw-r--r-- 113 dev.yml
- - rw-r--r-- 1,938 encoder_decoder.go
- - rw-r--r-- 950 end_txn_request.go
- - rw-r--r-- 350 end_txn_request_test.go
- - rw-r--r-- 772 end_txn_response.go
- - rw-r--r-- 310 end_txn_response_test.go
- - rw-r--r-- 17,602 errors.go
- - rw-r--r-- 3,661 fetch_request.go
- - rw-r--r-- 1,498 fetch_request_test.go
- - rw-r--r-- 11,960 fetch_response.go
- - rw-r--r-- 9,481 fetch_response_test.go
- - rw-r--r-- 1,088 find_coordinator_request.go
- - rw-r--r-- 733 find_coordinator_request_test.go
- - rw-r--r-- 1,746 find_coordinator_response.go
- - rw-r--r-- 1,920 find_coordinator_response_test.go
- - rw-r--r-- 2,154 functional_client_test.go
- - rw-r--r-- 10,398 functional_consumer_group_test.go
- - rw-r--r-- 8,304 functional_consumer_test.go
- - rw-r--r-- 938 functional_offset_manager_test.go
- - rw-r--r-- 10,798 functional_producer_test.go
- - rw-r--r-- 3,498 functional_test.go
- - rw-r--r-- 770 go.mod
- - rw-r--r-- 3,808 go.sum
- - rw-r--r-- 830 heartbeat_request.go
- - rw-r--r-- 441 heartbeat_request_test.go
- - rw-r--r-- 536 heartbeat_response.go
- - rw-r--r-- 397 heartbeat_response_test.go
- - rw-r--r-- 878 init_producer_id_request.go
- - rw-r--r-- 528 init_producer_id_request_test.go
- - rw-r--r-- 1,058 init_producer_id_response.go
- - rw-r--r-- 650 init_producer_id_response_test.go
- - rw-r--r-- 3,437 join_group_request.go
- - rw-r--r-- 3,044 join_group_request_test.go
- - rw-r--r-- 2,454 join_group_response.go
- - rw-r--r-- 5,637 join_group_response_test.go
- - rw-r--r-- 711 leave_group_request.go
- - rw-r--r-- 347 leave_group_request_test.go
- - rw-r--r-- 548 leave_group_response.go
- - rw-r--r-- 696 leave_group_response_test.go
- - rw-r--r-- 1,838 length_field.go
- - rw-r--r-- 419 list_groups_request.go
- - rw-r--r-- 148 list_groups_request_test.go
- - rw-r--r-- 1,174 list_groups_response.go
- - rw-r--r-- 1,449 list_groups_response_test.go
- - rw-r--r-- 3,977 message.go
- - rw-r--r-- 2,299 message_set.go
- - rw-r--r-- 8,544 message_test.go
- - rw-r--r-- 1,492 metadata_request.go
- - rw-r--r-- 4,487 metadata_request_test.go
- - rw-r--r-- 5,517 metadata_response.go
- - rw-r--r-- 9,133 metadata_response_test.go
- - rw-r--r-- 1,795 metrics.go
- - rw-r--r-- 5,253 metrics_test.go
- - rw-r--r-- 9,530 mockbroker.go
- - rw-r--r-- 24,411 mockresponses.go
- - rw-r--r-- 5,325 offset_commit_request.go
- - rw-r--r-- 3,051 offset_commit_request_test.go
- - rw-r--r-- 2,140 offset_commit_response.go
- - rw-r--r-- 1,119 offset_commit_response_test.go
- - rw-r--r-- 2,104 offset_fetch_request.go
- - rw-r--r-- 1,683 offset_fetch_request_test.go
- - rw-r--r-- 3,671 offset_fetch_response.go
- - rw-r--r-- 2,346 offset_fetch_response_test.go
- - rw-r--r-- 15,283 offset_manager.go
- - rw-r--r-- 12,339 offset_manager_test.go
- - rw-r--r-- 3,079 offset_request.go
- - rw-r--r-- 1,528 offset_request_test.go
- - rw-r--r-- 3,313 offset_response.go
- - rw-r--r-- 3,174 offset_response_test.go
- - rw-r--r-- 2,340 packet_decoder.go
- - rw-r--r-- 2,361 packet_encoder.go
- - rw-r--r-- 7,506 partitioner.go
- - rw-r--r-- 7,767 partitioner_test.go
- - rw-r--r-- 2,779 prep_encoder.go
- - rw-r--r-- 7,330 produce_request.go
- - rw-r--r-- 2,802 produce_request_test.go
- - rw-r--r-- 3,724 produce_response.go
- - rw-r--r-- 3,945 produce_response_test.go
- - rw-r--r-- 8,176 produce_set.go
- - rw-r--r-- 8,886 produce_set_test.go
- - rw-r--r-- 6,420 real_decoder.go
- - rw-r--r-- 2,817 real_encoder.go
- - rw-r--r-- 2,230 record.go
- - rw-r--r-- 4,650 record_batch.go
- - rw-r--r-- 8,442 record_test.go
- - rw-r--r-- 4,842 records.go
- - rw-r--r-- 2,561 records_test.go
- - rw-r--r-- 3,226 request.go
- - rw-r--r-- 3,378 request_test.go
- - rw-r--r-- 495 response_header.go
- - rw-r--r-- 481 response_header_test.go
- - rw-r--r-- 8,261 sarama.go
- - rw-r--r-- 647 sasl_authenticate_request.go
- - rw-r--r-- 338 sasl_authenticate_request_test.go
- - rw-r--r-- 868 sasl_authenticate_response.go
- - rw-r--r-- 449 sasl_authenticate_response_test.go
- - rw-r--r-- 618 sasl_handshake_request.go
- - rw-r--r-- 308 sasl_handshake_request_test.go
- - rw-r--r-- 721 sasl_handshake_response.go
- - rw-r--r-- 598 sasl_handshake_response_test.go
- - rw-r--r-- 2,017 sync_group_request.go
- - rw-r--r-- 975 sync_group_request_test.go
- - rw-r--r-- 862 sync_group_response.go
- - rw-r--r-- 1,164 sync_group_response_test.go
- - rw-r--r-- 4,711 sync_producer.go
- - rw-r--r-- 6,513 sync_producer_test.go
- - rw-r--r-- 744 timestamp.go
- - rw-r--r-- 2,636 txn_offset_commit_request.go
- - rw-r--r-- 769 txn_offset_commit_request_test.go
- - rw-r--r-- 1,587 txn_offset_commit_response.go
- - rw-r--r-- 582 txn_offset_commit_response_test.go
- - rw-r--r-- 5,557 utils.go
- - rw-r--r-- 1,012 utils_test.go
- - rw-r--r-- 272 zstd_cgo.go
- - rw-r--r-- 315 zstd_fallback.go