首頁 探索 說明
註冊 登入
publics
/
sarama
0
0
複刻 0
檔案 問題管理 0 合併請求 0 Wiki

暫無描述

目錄樹: cf7a3109e5
分支列表 標籤列表
sarama
Evan Huus cf7a3109e5 Don't need to publish message format constant 13 年之前
.gitignore 78d686d98d Initial commit 13 年之前
README.md 2de9a2dc0b README tweak 13 年之前
broker.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
broker_manager.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
client.go eb4d0a37fb Correctly send client ID 13 年之前
consumer.go 0d4e4a2ea0 go fmt 13 年之前
encoder_decoder.go 91b0ddffd1 go files use snake_case 13 年之前
errors.go fc4945fdf9 Allowing details on encode/decode errors 13 年之前
fetch_request.go 19099f5e88 Implement fetch requests 13 年之前
fetch_response.go 1862bd8823 Decode remaining parts of fetch responses 13 年之前
message.go cf7a3109e5 Don't need to publish message format constant 13 年之前
message_set.go 1862bd8823 Decode remaining parts of fetch responses 13 年之前
metadata_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 年之前
metadata_response.go 77be473961 Add package declarations to stub files 13 年之前
offset_commit_request.go 77be473961 Add package declarations to stub files 13 年之前
offset_commit_response.go 77be473961 Add package declarations to stub files 13 年之前
offset_fetch_request.go 77be473961 Add package declarations to stub files 13 年之前
offset_fetch_response.go 77be473961 Add package declarations to stub files 13 年之前
offset_request.go 77be473961 Add package declarations to stub files 13 年之前
offset_response.go 77be473961 Add package declarations to stub files 13 年之前
packet_crcs.go 2deb91d926 checkpoint wip message encoding/decoding 13 年之前
packet_decoder.go 1862bd8823 Decode remaining parts of fetch responses 13 年之前
packet_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
packet_lengths.go 2deb91d926 checkpoint wip message encoding/decoding 13 年之前
partitionChooser.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
partition_metadata.go fe73334510 Factor out common array encoding/decoding 13 年之前
prep_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
produce_request.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 年之前
produce_response.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 年之前
producer.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
real_decoder.go 1862bd8823 Decode remaining parts of fetch responses 13 年之前
real_encoder.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
request.go b6d96975b7 Allow sending arbitrary messages from producer 13 年之前
response.go 39be3b4fee Refactor. Refresh topic metadata in more cases. 13 年之前
topic_metadata.go 91b0ddffd1 go files use snake_case 13 年之前

README.md

sarama

Sarama is a Go library for Apache Kafka 0.8.