Inicio Explorar Axuda
Rexistro Iniciar sesión
publics
/
sarama
0
0
Fork 0
Ficheiros Incidencias 0 Pull Requests 0 Wiki

Sen descrición

Árbore: cc60a82a48
Ramas Etiquetas
sarama
Evan Huus cc60a82a48 publish CompressionCodec type %!s(int64=13) %!d(string=hai) anos
.gitignore 78d686d98d Initial commit %!s(int64=13) %!d(string=hai) anos
README.md 2de9a2dc0b README tweak %!s(int64=13) %!d(string=hai) anos
broker.go 087b16cf8b Publish Broker.Connect() but don't connect automatically when decoding. %!s(int64=13) %!d(string=hai) anos
client.go e34ddd043d Publish broker %!s(int64=13) %!d(string=hai) anos
consumer.go 0d4e4a2ea0 go fmt %!s(int64=13) %!d(string=hai) anos
encoder_decoder.go 2fa436eb05 Publish the Message type. Separate encoders. %!s(int64=13) %!d(string=hai) anos
errors.go cbc1273e08 checkpoint wip simplify errors slightly %!s(int64=13) %!d(string=hai) anos
fetch_request.go 19099f5e88 Implement fetch requests %!s(int64=13) %!d(string=hai) anos
fetch_response.go e5a0f9bc72 Remove unused code %!s(int64=13) %!d(string=hai) anos
message.go cc60a82a48 publish CompressionCodec type %!s(int64=13) %!d(string=hai) anos
message_set.go 2fa436eb05 Publish the Message type. Separate encoders. %!s(int64=13) %!d(string=hai) anos
metadata_cache.go 087b16cf8b Publish Broker.Connect() but don't connect automatically when decoding. %!s(int64=13) %!d(string=hai) anos
metadata_request.go 1e7b3a06da Publish metadata request/response structures, remove dead code %!s(int64=13) %!d(string=hai) anos
metadata_response.go b70312a188 Group metadata response structures together %!s(int64=13) %!d(string=hai) anos
offset_commit_request.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_commit_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_fetch_request.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_fetch_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_request.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
offset_response.go 77be473961 Add package declarations to stub files %!s(int64=13) %!d(string=hai) anos
packet_crcs.go 84d5cfc734 Finish improving errors %!s(int64=13) %!d(string=hai) anos
packet_decoder.go 0c69a97459 Slices can already be nil %!s(int64=13) %!d(string=hai) anos
packet_encoder.go ba2bf0685c Consistent encode and decode helper functions. %!s(int64=13) %!d(string=hai) anos
packet_lengths.go 84d5cfc734 Finish improving errors %!s(int64=13) %!d(string=hai) anos
partition_chooser.go 2fa436eb05 Publish the Message type. Separate encoders. %!s(int64=13) %!d(string=hai) anos
prep_encoder.go 0c69a97459 Slices can already be nil %!s(int64=13) %!d(string=hai) anos
produce_request.go f77808b6db Requests produce decoders for their response now %!s(int64=13) %!d(string=hai) anos
produce_response.go babe87c20f Simplify ProduceResponse structure with a map. %!s(int64=13) %!d(string=hai) anos
producer.go 2fa436eb05 Publish the Message type. Separate encoders. %!s(int64=13) %!d(string=hai) anos
real_decoder.go 0c69a97459 Slices can already be nil %!s(int64=13) %!d(string=hai) anos
real_encoder.go 0c69a97459 Slices can already be nil %!s(int64=13) %!d(string=hai) anos
request.go f77808b6db Requests produce decoders for their response now %!s(int64=13) %!d(string=hai) anos
response_header.go ba2bf0685c Consistent encode and decode helper functions. %!s(int64=13) %!d(string=hai) anos
utils.go 2fa436eb05 Publish the Message type. Separate encoders. %!s(int64=13) %!d(string=hai) anos

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.