kafka->sarama

broker.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"io"

broker_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"

client.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"sort"

client_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"

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

consumer_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"

crc32_field.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"

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.

errors.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "errors"
 

fetch_request.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type fetchRequestBlock struct {
 	fetchOffset int64

fetch_request_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

fetch_response.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type FetchResponseBlock struct {
 	Err                 KError

fetch_response_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"bytes"

length_field.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "encoding/binary"
 

message.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"bytes"

message_set.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type MessageBlock struct {
 	Offset int64

metadata_request.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type MetadataRequest struct {
 	Topics []string

metadata_request_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

metadata_response.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type PartitionMetadata struct {
 	Err      KError

metadata_response_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

offset_commit_request.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type offsetCommitRequestBlock struct {
 	offset   int64

offset_commit_request_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

offset_commit_response.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetCommitResponse struct {
 	ClientID string

offset_commit_response_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

offset_fetch_request.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetFetchRequest struct {
 	ConsumerGroup string

offset_fetch_request_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

offset_fetch_response.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetFetchResponseBlock struct {
 	Offset   int64

offset_fetch_response_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

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.

offset_request_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

offset_response.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type OffsetResponseBlock struct {
 	Err     KError

offset_response_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

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,

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,

partitioner.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "math/rand"
 

partitioner_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

prep_encoder.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "math"
 

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.

produce_request_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

produce_response.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type ProduceResponseBlock struct {
 	Err    KError

produce_response_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

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

producer_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"

real_decoder.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"encoding/binary"

real_encoder.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "encoding/binary"
 

request.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 type requestEncoder interface {
 	encoder

request_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import (
 	"bytes"

response_header.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "math"
 

response_header_test.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 import "testing"
 

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

utils.go

@@ -1,4 +1,4 @@
-package kafka
+package sarama
 
 // make []int32 sortable so we can sort partition numbers
 type int32Slice []int32