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

Keine Beschreibung

Struktur: 087b16cf8b
Branches Tags
sarama
Evan Huus 087b16cf8b Publish Broker.Connect() but don't connect automatically when decoding. vor 13 Jahren
.gitignore 78d686d98d Initial commit vor 13 Jahren
README.md 2de9a2dc0b README tweak vor 13 Jahren
broker.go 087b16cf8b Publish Broker.Connect() but don't connect automatically when decoding. vor 13 Jahren
client.go e34ddd043d Publish broker vor 13 Jahren
consumer.go 0d4e4a2ea0 go fmt vor 13 Jahren
encoder_decoder.go 2fa436eb05 Publish the Message type. Separate encoders. vor 13 Jahren
errors.go cbc1273e08 checkpoint wip simplify errors slightly vor 13 Jahren
fetch_request.go 19099f5e88 Implement fetch requests vor 13 Jahren
fetch_response.go e5a0f9bc72 Remove unused code vor 13 Jahren
message.go 2fa436eb05 Publish the Message type. Separate encoders. vor 13 Jahren
message_set.go 2fa436eb05 Publish the Message type. Separate encoders. vor 13 Jahren
metadata_cache.go 087b16cf8b Publish Broker.Connect() but don't connect automatically when decoding. vor 13 Jahren
metadata_request.go 1e7b3a06da Publish metadata request/response structures, remove dead code vor 13 Jahren
metadata_response.go 1e7b3a06da Publish metadata request/response structures, remove dead code 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 84d5cfc734 Finish improving errors vor 13 Jahren
packet_decoder.go 0c69a97459 Slices can already be nil vor 13 Jahren
packet_encoder.go ba2bf0685c Consistent encode and decode helper functions. vor 13 Jahren
packet_lengths.go 84d5cfc734 Finish improving errors vor 13 Jahren
partition_chooser.go 2fa436eb05 Publish the Message type. Separate encoders. vor 13 Jahren
partition_metadata.go 1e7b3a06da Publish metadata request/response structures, remove dead code vor 13 Jahren
prep_encoder.go 0c69a97459 Slices can already be nil vor 13 Jahren
produce_request.go f77808b6db Requests produce decoders for their response now vor 13 Jahren
produce_response.go eeb9b0926c More API slimming, publish ProduceResponse vor 13 Jahren
producer.go 2fa436eb05 Publish the Message type. Separate encoders. vor 13 Jahren
real_decoder.go 0c69a97459 Slices can already be nil vor 13 Jahren
real_encoder.go 0c69a97459 Slices can already be nil vor 13 Jahren
request.go f77808b6db Requests produce decoders for their response now vor 13 Jahren
response_header.go ba2bf0685c Consistent encode and decode helper functions. vor 13 Jahren
topic_metadata.go 1e7b3a06da Publish metadata request/response structures, remove dead code vor 13 Jahren
utils.go 2fa436eb05 Publish the Message type. Separate encoders. vor 13 Jahren

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.