Начало Каталог Помощ
Регистрация Вход
publics
/
sarama
0
0
Разклонения 0
Файлове Задачи 0 Заявки за сливане 0 Уики

Няма описание

ИН на ревизия: cf32a3571e
Клонове Маркери
sarama
Evan Huus cf32a3571e Actually make channels for the broker to communicate over преди 12 години
.gitignore 78d686d98d Initial commit преди 12 години
README.md 2de9a2dc0b README tweak преди 12 години
broker.go cf32a3571e Actually make channels for the broker to communicate over преди 12 години
broker_manager.go 91b0ddffd1 go files use snake_case преди 12 години
client.go eb4d0a37fb Correctly send client ID преди 12 години
consumer.go ec1f0c8ea0 Initial checkpoint преди 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 f85973b6a3 go fmt преди 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 77be473961 Add package declarations to stub files преди 12 години
produce_response.go 77be473961 Add package declarations to stub files преди 12 години
producer.go ec1f0c8ea0 Initial checkpoint преди 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.