Domů Procházet Nápověda
Registrovat se Přihlásit se
publics
/
sarama
0
0
Rozštěpit 0
Soubory Úkoly 0 Pull Requesty 0 Wiki

Bez popisu

Strom: fd2d940dbf
Větve Značky
sarama
Evan Huus fd2d940dbf Broker cleanup, make it really concurrency-safe před 13 roky
.gitignore 78d686d98d Initial commit před 13 roky
README.md 2de9a2dc0b README tweak před 13 roky
broker.go fd2d940dbf Broker cleanup, make it really concurrency-safe před 13 roky
client.go e34ddd043d Publish broker před 13 roky
consumer.go 0d4e4a2ea0 go fmt před 13 roky
encoder_decoder.go 2fa436eb05 Publish the Message type. Separate encoders. před 13 roky
errors.go cbc1273e08 checkpoint wip simplify errors slightly před 13 roky
fetch_request.go 19099f5e88 Implement fetch requests před 13 roky
fetch_response.go e5a0f9bc72 Remove unused code před 13 roky
message.go cc60a82a48 publish CompressionCodec type před 13 roky
message_set.go 2fa436eb05 Publish the Message type. Separate encoders. před 13 roky
metadata_cache.go fd2d940dbf Broker cleanup, make it really concurrency-safe před 13 roky
metadata_request.go 1e7b3a06da Publish metadata request/response structures, remove dead code před 13 roky
metadata_response.go b70312a188 Group metadata response structures together před 13 roky
offset_commit_request.go 77be473961 Add package declarations to stub files před 13 roky
offset_commit_response.go 77be473961 Add package declarations to stub files před 13 roky
offset_fetch_request.go 77be473961 Add package declarations to stub files před 13 roky
offset_fetch_response.go 77be473961 Add package declarations to stub files před 13 roky
offset_request.go 77be473961 Add package declarations to stub files před 13 roky
offset_response.go 77be473961 Add package declarations to stub files před 13 roky
packet_crcs.go 84d5cfc734 Finish improving errors před 13 roky
packet_decoder.go 0c69a97459 Slices can already be nil před 13 roky
packet_encoder.go ba2bf0685c Consistent encode and decode helper functions. před 13 roky
packet_lengths.go 84d5cfc734 Finish improving errors před 13 roky
partition_chooser.go 2fa436eb05 Publish the Message type. Separate encoders. před 13 roky
prep_encoder.go 0c69a97459 Slices can already be nil před 13 roky
produce_request.go ac861788b4 Make brokers request/response-type aware. před 13 roky
produce_response.go babe87c20f Simplify ProduceResponse structure with a map. před 13 roky
producer.go ac861788b4 Make brokers request/response-type aware. před 13 roky
real_decoder.go 0c69a97459 Slices can already be nil před 13 roky
real_encoder.go 0c69a97459 Slices can already be nil před 13 roky
request.go ac861788b4 Make brokers request/response-type aware. před 13 roky
response_header.go ba2bf0685c Consistent encode and decode helper functions. před 13 roky
utils.go 2fa436eb05 Publish the Message type. Separate encoders. před 13 roky

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.