package info (click to toggle)
golang-github-shopify-sarama 1.20.1-1
  • links: PTS, VCS
  • area: main
  • in suites: buster, sid
  • size: 1,528 kB
  • sloc: sh: 106; makefile: 24

Folder: 1.20.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 52 examples
d d rwxr-xr-x 4,096 mocks
d d rwxr-xr-x 138 tools
d d rwxr-xr-x 4,096 vagrant
- - rw-r--r-- 294 .gitignore
- - rw-r--r-- 736 .travis.yml
- - rw-r--r-- 29,711 CHANGELOG.md
- - rw-r--r-- 1,051 LICENSE
- - rw-r--r-- 761 Makefile
- - rw-r--r-- 2,201 README.md
- - rw-r--r-- 528 Vagrantfile
- - rw-r--r-- 2,109 acl_bindings.go
- - rw-r--r-- 1,373 acl_create_request.go
- - rw-r--r-- 678 acl_create_request_test.go
- - rw-r--r-- 1,745 acl_create_response.go
- - rw-r--r-- 761 acl_create_response_test.go
- - rw-r--r-- 859 acl_delete_request.go
- - rw-r--r-- 1,443 acl_delete_request_test.go
- - rw-r--r-- 2,922 acl_delete_response.go
- - rw-r--r-- 856 acl_delete_response_test.go
- - rw-r--r-- 490 acl_describe_request.go
- - rw-r--r-- 684 acl_describe_request_test.go
- - rw-r--r-- 1,495 acl_describe_response.go
- - rw-r--r-- 937 acl_describe_response_test.go
- - rw-r--r-- 1,267 acl_filter.go
- - rw-r--r-- 1,557 acl_types.go
- - rw-r--r-- 1,022 add_offsets_to_txn_request.go
- - rw-r--r-- 421 add_offsets_to_txn_request_test.go
- - rw-r--r-- 826 add_offsets_to_txn_response.go
- - rw-r--r-- 342 add_offsets_to_txn_response_test.go
- - rw-r--r-- 1,521 add_partitions_to_txn_request.go
- - rw-r--r-- 543 add_partitions_to_txn_request_test.go
- - rw-r--r-- 2,044 add_partitions_to_txn_response.go
- - rw-r--r-- 585 add_partitions_to_txn_response_test.go
- - rw-r--r-- 10,610 admin.go
- - rw-r--r-- 12,111 admin_test.go
- - rw-r--r-- 2,283 alter_configs_request.go
- - rw-r--r-- 1,947 alter_configs_request_test.go
- - rw-r--r-- 1,857 alter_configs_response.go
- - rw-r--r-- 898 alter_configs_response_test.go
- - rw-r--r-- 426 api_versions_request.go
- - rw-r--r-- 241 api_versions_request_test.go
- - rw-r--r-- 1,651 api_versions_response.go
- - rw-r--r-- 871 api_versions_response_test.go
- - rw-r--r-- 30,211 async_producer.go
- - rw-r--r-- 31,984 async_producer_test.go
- - rw-r--r-- 3,984 balance_strategy.go
- - rw-r--r-- 3,160 balance_strategy_test.go
- - rw-r--r-- 23,305 broker.go
- - rw-r--r-- 9,772 broker_test.go
- - rw-r--r-- 27,506 client.go
- - rw-r--r-- 18,695 client_test.go
- - rw-r--r-- 4,962 client_tls_test.go
- - rw-r--r-- 1,518 compress.go
- - rw-r--r-- 25,512 config.go
- - rw-r--r-- 472 config_resource_type.go
- - rw-r--r-- 7,530 config_test.go
- - rw-r--r-- 24,598 consumer.go
- - rw-r--r-- 21,871 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-- 30,850 consumer_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-- 1,930 create_partitions_response.go
- - rw-r--r-- 1,428 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,051 create_topics_response.go
- - rw-r--r-- 905 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,766 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-- 16,922 errors.go
- - rw-r--r-- 3,679 fetch_request.go
- - rw-r--r-- 1,498 fetch_request_test.go
- - rw-r--r-- 8,049 fetch_response.go
- - rw-r--r-- 9,481 fetch_response_test.go
- - rw-r--r-- 1,111 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-- 7,666 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-- 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,555 message.go
- - rw-r--r-- 2,299 message_set.go
- - rw-r--r-- 8,544 message_test.go
- - rw-r--r-- 1,584 metadata_request.go
- - rw-r--r-- 2,228 metadata_request_test.go
- - rw-r--r-- 5,466 metadata_response.go
- - rw-r--r-- 9,133 metadata_response_test.go
- - rw-r--r-- 2,147 metrics.go
- - rw-r--r-- 5,253 metrics_test.go
- - rw-r--r-- 9,530 mockbroker.go
- - rw-r--r-- 20,166 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,025 offset_manager.go
- - rw-r--r-- 11,712 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,113 record.go
- - rw-r--r-- 4,245 record_batch.go
- - rw-r--r-- 8,442 record_test.go
- - rw-r--r-- 4,366 records.go
- - rw-r--r-- 2,528 records_test.go
- - rw-r--r-- 3,162 request.go
- - rw-r--r-- 3,378 request_test.go
- - rw-r--r-- 437 response_header.go
- - rw-r--r-- 481 response_header_test.go
- - rw-r--r-- 7,876 sarama.go
- - rw-r--r-- 593 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-- 4,947 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,428 utils.go
- - rw-r--r-- 1,012 utils_test.go
- - rw-r--r-- 272 zstd_cgo.go
- - rw-r--r-- 315 zstd_fallback.go