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

Keine Beschreibung

Struktur: c1b36d1a4f
Branches Tags
sarama
Evan Huus c1b36d1a4f Fetch Request/Response pair updated vor 12 Jahren
.gitignore 78d686d98d Initial commit vor 12 Jahren
README.md 2de9a2dc0b README tweak vor 12 Jahren
broker.go c1b36d1a4f Fetch Request/Response pair updated vor 12 Jahren
client.go e34ddd043d Publish broker vor 12 Jahren
consumer.go 0d4e4a2ea0 go fmt vor 12 Jahren
encoder_decoder.go 2fa436eb05 Publish the Message type. Separate encoders. vor 12 Jahren
errors.go 8db695793d A bit of docs vor 12 Jahren
fetch_request.go c1b36d1a4f Fetch Request/Response pair updated vor 12 Jahren
fetch_response.go c1b36d1a4f Fetch Request/Response pair updated vor 12 Jahren
message.go 8db695793d A bit of docs vor 12 Jahren
message_set.go 805772fbb8 Hide the fact that ProduceRequests use messageSets vor 12 Jahren
metadata_cache.go fd2d940dbf Broker cleanup, make it really concurrency-safe vor 12 Jahren
metadata_request.go 2694df2f96 Remove unused code vor 12 Jahren
metadata_response.go b70312a188 Group metadata response structures together 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 0c69a97459 Slices can already be nil vor 12 Jahren
packet_encoder.go ba2bf0685c Consistent encode and decode helper functions. vor 12 Jahren
packet_lengths.go 84d5cfc734 Finish improving errors vor 12 Jahren
partitioner.go 4aaecc7b0a s/PartitionChooser/Partitioner/ vor 12 Jahren
prep_encoder.go 0c69a97459 Slices can already be nil vor 12 Jahren
produce_request.go c1b36d1a4f Fetch Request/Response pair updated vor 12 Jahren
produce_response.go c1b36d1a4f Fetch Request/Response pair updated vor 12 Jahren
producer.go 805772fbb8 Hide the fact that ProduceRequests use messageSets vor 12 Jahren
real_decoder.go 0c69a97459 Slices can already be nil vor 12 Jahren
real_encoder.go 0c69a97459 Slices can already be nil vor 12 Jahren
request.go ac861788b4 Make brokers request/response-type aware. vor 12 Jahren
response_header.go ba2bf0685c Consistent encode and decode helper functions. vor 12 Jahren
utils.go 2fa436eb05 Publish the Message type. Separate encoders. vor 12 Jahren

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.