Etusivu Tutki Apua
Rekisteröidy Kirjaudu sisään
publics
/
sarama
0
0
Fork 0
Tiedostot Ongelmat 0 Pull-pyynnöt 0 Wiki

Ei kuvausta

Puu: b0f42ffdf3
Branchit Tagit
sarama
Evan Huus b0f42ffdf3 go vet 12 vuotta sitten
.gitignore 78d686d98d Initial commit 12 vuotta sitten
README.md 2de9a2dc0b README tweak 12 vuotta sitten
broker.go b0f42ffdf3 go vet 12 vuotta sitten
client.go e34ddd043d Publish broker 12 vuotta sitten
consumer.go 0d4e4a2ea0 go fmt 12 vuotta sitten
encoder_decoder.go 91b0ddffd1 go files use snake_case 12 vuotta sitten
errors.go cbc1273e08 checkpoint wip simplify errors slightly 12 vuotta sitten
fetch_request.go 19099f5e88 Implement fetch requests 12 vuotta sitten
fetch_response.go 1862bd8823 Decode remaining parts of fetch responses 12 vuotta sitten
message.go 84d5cfc734 Finish improving errors 12 vuotta sitten
message_set.go 1862bd8823 Decode remaining parts of fetch responses 12 vuotta sitten
metadata_cache.go ded6c01f40 Broker simplification 12 vuotta sitten
metadata_request.go f77808b6db Requests produce decoders for their response now 12 vuotta sitten
metadata_response.go e34ddd043d Publish broker 12 vuotta sitten
offset_commit_request.go 77be473961 Add package declarations to stub files 12 vuotta sitten
offset_commit_response.go 77be473961 Add package declarations to stub files 12 vuotta sitten
offset_fetch_request.go 77be473961 Add package declarations to stub files 12 vuotta sitten
offset_fetch_response.go 77be473961 Add package declarations to stub files 12 vuotta sitten
offset_request.go 77be473961 Add package declarations to stub files 12 vuotta sitten
offset_response.go 77be473961 Add package declarations to stub files 12 vuotta sitten
packet_crcs.go 84d5cfc734 Finish improving errors 12 vuotta sitten
packet_decoder.go 1862bd8823 Decode remaining parts of fetch responses 12 vuotta sitten
packet_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 12 vuotta sitten
packet_lengths.go 84d5cfc734 Finish improving errors 12 vuotta sitten
partition_chooser.go daabaa3c99 Misc partition fixes, including making sure they're in the right order 12 vuotta sitten
partition_metadata.go fe73334510 Factor out common array encoding/decoding 12 vuotta sitten
prep_encoder.go 84d5cfc734 Finish improving errors 12 vuotta sitten
produce_request.go f77808b6db Requests produce decoders for their response now 12 vuotta sitten
produce_response.go eeb9b0926c More API slimming, publish ProduceResponse 12 vuotta sitten
producer.go ded6c01f40 Broker simplification 12 vuotta sitten
real_decoder.go 84d5cfc734 Finish improving errors 12 vuotta sitten
real_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 12 vuotta sitten
request.go f77808b6db Requests produce decoders for their response now 12 vuotta sitten
topic_metadata.go 91b0ddffd1 go files use snake_case 12 vuotta sitten
utils.go daabaa3c99 Misc partition fixes, including making sure they're in the right order 12 vuotta sitten

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.