kafka->sarama

Evan Huus · Evan Huus · commit 4969d24fa1a9 · 2013-08-07T12:56:23.000-04:00
diff --git a/broker.go b/broker.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"io"
diff --git a/broker_test.go b/broker_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"
diff --git a/client.go b/client.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"sort"
diff --git a/client_test.go b/client_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"
diff --git a/consumer.go b/consumer.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // Consumer processes Kafka messages from a given topic and partition.
 // You MUST call Close() on a consumer to avoid leaks, it will not be garbage-collected automatically when
diff --git a/consumer_test.go b/consumer_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"
diff --git a/crc32_field.go b/crc32_field.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"
diff --git a/encoder_decoder.go b/encoder_decoder.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // Encoder is the interface that wraps the basic Encode method.
 // Anything implementing Encoder can be turned into bytes using Kafka's encoding rules.
diff --git a/errors.go b/errors.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "errors"
 
diff --git a/fetch_request.go b/fetch_request.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type fetchRequestBlock struct {
 	fetchOffset int64
diff --git a/fetch_request_test.go b/fetch_request_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/fetch_response.go b/fetch_response.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type FetchResponseBlock struct {
 	Err                 KError
diff --git a/fetch_response_test.go b/fetch_response_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"bytes"
diff --git a/length_field.go b/length_field.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "encoding/binary"
 
diff --git a/message.go b/message.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"bytes"
diff --git a/message_set.go b/message_set.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type MessageBlock struct {
 	Offset int64
diff --git a/metadata_request.go b/metadata_request.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type MetadataRequest struct {
 	Topics []string
diff --git a/metadata_request_test.go b/metadata_request_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/metadata_response.go b/metadata_response.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type PartitionMetadata struct {
 	Err      KError
diff --git a/metadata_response_test.go b/metadata_response_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/offset_commit_request.go b/offset_commit_request.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type offsetCommitRequestBlock struct {
 	offset   int64
diff --git a/offset_commit_request_test.go b/offset_commit_request_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/offset_commit_response.go b/offset_commit_response.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetCommitResponse struct {
 	ClientID string
diff --git a/offset_commit_response_test.go b/offset_commit_response_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/offset_fetch_request.go b/offset_fetch_request.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetFetchRequest struct {
 	ConsumerGroup string
diff --git a/offset_fetch_request_test.go b/offset_fetch_request_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/offset_fetch_response.go b/offset_fetch_response.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetFetchResponseBlock struct {
 	Offset   int64
diff --git a/offset_fetch_response_test.go b/offset_fetch_response_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/offset_request.go b/offset_request.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // OffsetTime is used in Offset Requests to ask for all messages before a certain time. Any positive int64
 // value will be interpreted as milliseconds, or use the special constants defined here.
diff --git a/offset_request_test.go b/offset_request_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/offset_response.go b/offset_response.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetResponseBlock struct {
 	Err     KError
diff --git a/offset_response_test.go b/offset_response_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/packet_decoder.go b/packet_decoder.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // PacketDecoder is the interface providing helpers for reading with Kafka's encoding rules.
 // Types implementing Decoder only need to worry about calling methods like GetString,
diff --git a/packet_encoder.go b/packet_encoder.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // PacketEncoder is the interface providing helpers for writing with Kafka's encoding rules.
 // Types implementing Encoder only need to worry about calling methods like PutString,
diff --git a/partitioner.go b/partitioner.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "math/rand"
 
diff --git a/partitioner_test.go b/partitioner_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/prep_encoder.go b/prep_encoder.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "math"
 
diff --git a/produce_request.go b/produce_request.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // RequiredAcks is used in Produce Requests to tell the broker how many replica acknowledgements
 // it must see before responding. Any positive int16 value is valid, or the constants defined here.
diff --git a/produce_request_test.go b/produce_request_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/produce_response.go b/produce_response.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type ProduceResponseBlock struct {
 	Err    KError
diff --git a/produce_response_test.go b/produce_response_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/producer.go b/producer.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // Producer publishes Kafka messages on a given topic. It routes messages to the correct broker, refreshing metadata as appropriate,
 // and parses responses for errors. A Producer itself does not need to be closed (thus no Close method) but you still need to close
diff --git a/producer_test.go b/producer_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"
diff --git a/real_decoder.go b/real_decoder.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"
diff --git a/real_encoder.go b/real_encoder.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "encoding/binary"
 
diff --git a/request.go b/request.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type requestEncoder interface {
 	encoder
diff --git a/request_test.go b/request_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"bytes"
diff --git a/response_header.go b/response_header.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "math"
 
diff --git a/response_header_test.go b/response_header_test.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 
diff --git a/sarama.go b/sarama.go
@@ -1,7 +1,7 @@
 /*
-Package kafka provides client libraries for the Kafka 0.8 protocol. The Client, Producer and Consumer objects are the core of the high-level API. The Broker and Request/Response objects permit more precise control.
+Package sarama provides client libraries for the Kafka 0.8 protocol. The Client, Producer and Consumer objects are the core of the high-level API. The Broker and Request/Response objects permit more precise control.
 
 The Request/Response objects and properties are mostly undocumented, as they line up exactly with the
 protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
 */
-package kafka
+package sarama
diff --git a/utils.go b/utils.go
@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // make []int32 sortable so we can sort partition numbers
 type int32Slice []int32

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package kafka`
	`1`	`+package sarama`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"io"`