Keine Beschreibung

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

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.