Startseite Erkunden Hilfe
Registrieren Anmelden
publics
/
sarama
0
0
Fork 0
Dateien Issues 0 Pull-Requests 0 Wiki

Keine Beschreibung

Struktur: 5fbffdc5fa
Branches Tags
sarama
Evan Huus 5fbffdc5fa stub creation of producer/consumer vor 13 Jahren
.gitignore 78d686d98d Initial commit vor 13 Jahren
README.md 2de9a2dc0b README tweak vor 13 Jahren
broker.go 19132e333c Don't use buffered channels in the broker vor 13 Jahren
broker_manager.go 91b0ddffd1 go files use snake_case vor 13 Jahren
client.go eb4d0a37fb Correctly send client ID vor 13 Jahren
consumer.go 5fbffdc5fa stub creation of producer/consumer vor 13 Jahren
encoder_decoder.go 91b0ddffd1 go files use snake_case vor 13 Jahren
errors.go 4b9ba1b53c checkpoint wip broker recovery vor 13 Jahren
fetch_request.go 77be473961 Add package declarations to stub files vor 13 Jahren
fetch_response.go 77be473961 Add package declarations to stub files vor 13 Jahren
message.go f85973b6a3 go fmt vor 13 Jahren
message_set.go 2deb91d926 checkpoint wip message encoding/decoding vor 13 Jahren
metadata_request.go 91b0ddffd1 go files use snake_case vor 13 Jahren
metadata_response.go 77be473961 Add package declarations to stub files vor 13 Jahren
offset_commit_request.go 77be473961 Add package declarations to stub files vor 13 Jahren
offset_commit_response.go 77be473961 Add package declarations to stub files vor 13 Jahren
offset_fetch_request.go 77be473961 Add package declarations to stub files vor 13 Jahren
offset_fetch_response.go 77be473961 Add package declarations to stub files vor 13 Jahren
offset_request.go 77be473961 Add package declarations to stub files vor 13 Jahren
offset_response.go 77be473961 Add package declarations to stub files vor 13 Jahren
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding vor 13 Jahren
packet_decoder.go ca7a207750 finish basic message encoding/decoding vor 13 Jahren
packet_encoder.go ca7a207750 finish basic message encoding/decoding vor 13 Jahren
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding vor 13 Jahren
partition_metadata.go 91b0ddffd1 go files use snake_case vor 13 Jahren
prep_encoder.go ca7a207750 finish basic message encoding/decoding vor 13 Jahren
produce_request.go 77be473961 Add package declarations to stub files vor 13 Jahren
produce_response.go 77be473961 Add package declarations to stub files vor 13 Jahren
producer.go 5fbffdc5fa stub creation of producer/consumer vor 13 Jahren
real_decoder.go ca7a207750 finish basic message encoding/decoding vor 13 Jahren
real_encoder.go ca7a207750 finish basic message encoding/decoding vor 13 Jahren
request.go 44d5d67f64 Move API defs to right file, fix error condition vor 13 Jahren
topic_metadata.go 91b0ddffd1 go files use snake_case vor 13 Jahren

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.