Etusivu Tutki Apua
Rekisteröidy Kirjaudu sisään
publics
/
sarama
0
0
Fork 0
Tiedostot Ongelmat 0 Pull-pyynnöt 0 Wiki

Ei kuvausta

Puu: fc4945fdf9
Branchit Tagit
sarama
Evan Huus fc4945fdf9 Allowing details on encode/decode errors 13 vuotta sitten
.gitignore 78d686d98d Initial commit 13 vuotta sitten
README.md 2de9a2dc0b README tweak 13 vuotta sitten
broker.go 19132e333c Don't use buffered channels in the broker 13 vuotta sitten
broker_manager.go 6cc5972fbf Refactor broker manager a bit 13 vuotta sitten
client.go eb4d0a37fb Correctly send client ID 13 vuotta sitten
consumer.go 0d4e4a2ea0 go fmt 13 vuotta sitten
encoder_decoder.go 91b0ddffd1 go files use snake_case 13 vuotta sitten
errors.go fc4945fdf9 Allowing details on encode/decode errors 13 vuotta sitten
fetch_request.go 77be473961 Add package declarations to stub files 13 vuotta sitten
fetch_response.go 77be473961 Add package declarations to stub files 13 vuotta sitten
message.go 0db1060be3 Checkpoint wip producing messages 13 vuotta sitten
message_set.go 2deb91d926 checkpoint wip message encoding/decoding 13 vuotta sitten
metadata_request.go 91b0ddffd1 go files use snake_case 13 vuotta sitten
metadata_response.go 77be473961 Add package declarations to stub files 13 vuotta sitten
offset_commit_request.go 77be473961 Add package declarations to stub files 13 vuotta sitten
offset_commit_response.go 77be473961 Add package declarations to stub files 13 vuotta sitten
offset_fetch_request.go 77be473961 Add package declarations to stub files 13 vuotta sitten
offset_fetch_response.go 77be473961 Add package declarations to stub files 13 vuotta sitten
offset_request.go 77be473961 Add package declarations to stub files 13 vuotta sitten
offset_response.go 77be473961 Add package declarations to stub files 13 vuotta sitten
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding 13 vuotta sitten
packet_decoder.go ca7a207750 finish basic message encoding/decoding 13 vuotta sitten
packet_encoder.go ca7a207750 finish basic message encoding/decoding 13 vuotta sitten
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding 13 vuotta sitten
partition_metadata.go 91b0ddffd1 go files use snake_case 13 vuotta sitten
prep_encoder.go ca7a207750 finish basic message encoding/decoding 13 vuotta sitten
produce_request.go 7802d4de85 encode produce requests 13 vuotta sitten
produce_response.go 77be473961 Add package declarations to stub files 13 vuotta sitten
producer.go 0d4e4a2ea0 go fmt 13 vuotta sitten
real_decoder.go 1c4240b9cf Fix some offset calculation bugs 13 vuotta sitten
real_encoder.go 1c4240b9cf Fix some offset calculation bugs 13 vuotta sitten
request.go 44d5d67f64 Move API defs to right file, fix error condition 13 vuotta sitten
topic_metadata.go 91b0ddffd1 go files use snake_case 13 vuotta sitten

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.