Почетна Преглед Помоћ
Регистрација Пријавите се
publics
/
sarama
0
0
Креирај огранак 0
Датотеке Дискусије 0 Захтеви за спајање 0 Вики

Нема описа

Дрво: 0d4e4a2ea0
Гране Ознаке
sarama
Evan Huus 0d4e4a2ea0 go fmt пре 12 година
.gitignore 78d686d98d Initial commit пре 12 година
README.md 2de9a2dc0b README tweak пре 12 година
broker.go 19132e333c Don't use buffered channels in the broker пре 12 година
broker_manager.go 91b0ddffd1 go files use snake_case пре 12 година
client.go eb4d0a37fb Correctly send client ID пре 12 година
consumer.go 0d4e4a2ea0 go fmt пре 12 година
encoder_decoder.go 91b0ddffd1 go files use snake_case пре 12 година
errors.go 4b9ba1b53c checkpoint wip broker recovery пре 12 година
fetch_request.go 77be473961 Add package declarations to stub files пре 12 година
fetch_response.go 77be473961 Add package declarations to stub files пре 12 година
message.go 0db1060be3 Checkpoint wip producing messages пре 12 година
message_set.go 2deb91d926 checkpoint wip message encoding/decoding пре 12 година
metadata_request.go 91b0ddffd1 go files use snake_case пре 12 година
metadata_response.go 77be473961 Add package declarations to stub files пре 12 година
offset_commit_request.go 77be473961 Add package declarations to stub files пре 12 година
offset_commit_response.go 77be473961 Add package declarations to stub files пре 12 година
offset_fetch_request.go 77be473961 Add package declarations to stub files пре 12 година
offset_fetch_response.go 77be473961 Add package declarations to stub files пре 12 година
offset_request.go 77be473961 Add package declarations to stub files пре 12 година
offset_response.go 77be473961 Add package declarations to stub files пре 12 година
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding пре 12 година
packet_decoder.go ca7a207750 finish basic message encoding/decoding пре 12 година
packet_encoder.go ca7a207750 finish basic message encoding/decoding пре 12 година
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding пре 12 година
partition_metadata.go 91b0ddffd1 go files use snake_case пре 12 година
prep_encoder.go ca7a207750 finish basic message encoding/decoding пре 12 година
produce_request.go 0d4e4a2ea0 go fmt пре 12 година
produce_response.go 77be473961 Add package declarations to stub files пре 12 година
producer.go 0d4e4a2ea0 go fmt пре 12 година
real_decoder.go ca7a207750 finish basic message encoding/decoding пре 12 година
real_encoder.go ca7a207750 finish basic message encoding/decoding пре 12 година
request.go 44d5d67f64 Move API defs to right file, fix error condition пре 12 година
topic_metadata.go 91b0ddffd1 go files use snake_case пре 12 година

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.