Merge pull request #6 from tarantool/rename-rocks-module

renamed project from 'tnt-kafka' to 'kafka' and refactored project layout
tarantool · May 22, 2019 · 36f10a8 · 36f10a8
2 parents 7ad6a9d + b43f3a2
commit 36f10a8
Show file tree

Hide file tree

Showing 29 changed files with 24 additions and 47 deletions.
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -1,6 +1,6 @@
 cmake_minimum_required(VERSION 2.8 FATAL_ERROR)
 
-project(tnt-kafka C)
+project(kafka C)
 
 set(CMAKE_MODULE_PATH "${CMAKE_CURRENT_SOURCE_DIR}/cmake" ${CMAKE_MODULE_PATH})
 
@@ -22,4 +22,4 @@ find_package(RdKafka)
 
 include_directories(${TARANTOOL_INCLUDE_DIRS})
 
-add_subdirectory(tnt-kafka)
+add_subdirectory(kafka)
diff --git a/README.md b/README.md
@@ -1,5 +1,5 @@
-tnt-kafka
-=========
+Tarantool kafka
+===============
 Full featured high performance kafka library for Tarantool based on [librdkafka](https://github.com/edenhill/librdkafka). 
 
 Can produce more then 150k messages per second and consume more then 140k messages per second.
@@ -8,7 +8,7 @@ Can produce more then 150k messages per second and consume more then 140k messag
 * Kafka producer and consumer implementations.
 * Fiber friendly.
 * Mostly errorless functions and methods. Error handling in Tarantool ecosystem is quite a mess, 
-some libraries throws lua native `error` while others throws `box.error` instead. `tnt-kafka` returns 
+some libraries throws lua native `error` while others throws `box.error` instead. `kafka` returns 
 non critical errors as strings which allows you to decide how to handle it.
 
 # Requirements 
@@ -22,7 +22,7 @@ non critical errors as strings which allows you to decide how to handle it.
 
 # Installation
 ```bash
-    tarantoolctl rocks install https://raw.githubusercontent.com/tarantool/tnt-kafka/master/rockspecs/tnt-kafka-scm-1.rockspec
+    tarantoolctl rocks install https://raw.githubusercontent.com/tarantool/tnt-kafka/master/rockspecs/kafka-scm-1.rockspec
 ```
 
 # Examples
@@ -34,7 +34,7 @@ non critical errors as strings which allows you to decide how to handle it.
     local fiber = require('fiber')
     local os = require('os')
     local log = require('log')
-    local tnt_kafka = require('tnt-kafka')
+    local tnt_kafka = require('kafka')
 
     local error_callback = function(err)
         log.error("got error: %s", err)
@@ -110,7 +110,7 @@ non critical errors as strings which allows you to decide how to handle it.
     local fiber = require('fiber')
     local os = require('os')
     local log = require('log')
-    local tnt_kafka = require('tnt-kafka')
+    local tnt_kafka = require('kafka')
 
     local error_callback = function(err)
         log.error("got error: %s", err)
@@ -197,7 +197,7 @@ non critical errors as strings which allows you to decide how to handle it.
 ```lua
     local os = require('os')
     local log = require('log')
-    local tnt_kafka = require('tnt-kafka')
+    local tnt_kafka = require('kafka')
 
     local error_callback = function(err)
         log.error("got error: %s", err)
@@ -244,7 +244,7 @@ non critical errors as strings which allows you to decide how to handle it.
     local fiber = require('fiber')
     local os = require('os')
     local log = require('log')
-    local tnt_kafka = require('tnt-kafka')
+    local tnt_kafka = require('kafka')
 
     local error_callback = function(err)
         log.error("got error: %s", err)
@@ -298,7 +298,6 @@ because `rd_kafka_destroy` sometimes hangs forever.
 
 # TODO
 * Ordered storage for offsets to prevent commits unprocessed messages
-* Add poll call for librdkafka logs and errors
 * Fix known issues
 * More examples
 * Better documentation

diff --git a/benchmarks/async_producer.lua b/benchmarks/async_producer.lua
@@ -3,7 +3,7 @@ local box = require('box')
 local os = require('os')
 local log = require('log')
 local clock = require('clock')
-local tnt_kafka = require('tnt-kafka')
+local tnt_kafka = require('kafka')
 
 box.cfg{}
 

diff --git a/benchmarks/auto_offset_store_consumer.lua b/benchmarks/auto_offset_store_consumer.lua
@@ -3,7 +3,7 @@ local log = require('log')
 local box = require('box')
 local os = require('os')
 local clock = require('clock')
-local tnt_kafka = require('tnt-kafka')
+local tnt_kafka = require('kafka')
 
 box.cfg{
     memtx_memory = 524288000, -- 500 MB

diff --git a/benchmarks/manual_offset_store_consumer.lua b/benchmarks/manual_offset_store_consumer.lua
@@ -3,7 +3,7 @@ local box = require('box')
 local os = require('os')
 local log = require('log')
 local clock = require('clock')
-local tnt_kafka = require('tnt-kafka')
+local tnt_kafka = require('kafka')
 
 box.cfg{
     memtx_memory = 524288000,

diff --git a/benchmarks/sync_producer.lua b/benchmarks/sync_producer.lua
@@ -3,7 +3,7 @@ local box = require('box')
 local log = require('log')
 local os = require('os')
 local clock = require('clock')
-local tnt_kafka = require('tnt-kafka')
+local tnt_kafka = require('kafka')
 
 box.cfg{
     memtx_memory = 524288000, -- 500 MB

diff --git a/tnt-kafka/CMakeLists.txt → kafka/CMakeLists.txt b/tnt-kafka/CMakeLists.txt → kafka/CMakeLists.txt
@@ -1,4 +1,4 @@
-include_directories(${CMAKE_SOURCE_DIR}/tnt-kafka)
+include_directories(${CMAKE_SOURCE_DIR}/kafka)
 
 add_library(tntkafka SHARED tnt_kafka.c callbacks.c consumer.c consumer_msg.c producer.c queue.c common.c)
 
@@ -10,5 +10,5 @@ endif(APPLE)
 target_link_libraries(tntkafka ${RDKAFKA_LIBRARY} pthread)
 
 set_target_properties(tntkafka PROPERTIES PREFIX "" OUTPUT_NAME "tntkafka")
-install(TARGETS tntkafka LIBRARY DESTINATION ${TARANTOOL_INSTALL_LIBDIR}/tnt-kafka)
-install(FILES init.lua DESTINATION ${TARANTOOL_INSTALL_LUADIR}/tnt-kafka)
+install(TARGETS tntkafka LIBRARY DESTINATION ${TARANTOOL_INSTALL_LIBDIR}/kafka)
+install(FILES init.lua DESTINATION ${TARANTOOL_INSTALL_LUADIR}/kafka)
diff --git a/tnt-kafka/callbacks.c → kafka/callbacks.c b/tnt-kafka/callbacks.c → kafka/callbacks.c
diff --git a/tnt-kafka/callbacks.h → kafka/callbacks.h b/tnt-kafka/callbacks.h → kafka/callbacks.h
diff --git a/tnt-kafka/common.c → kafka/common.c b/tnt-kafka/common.c → kafka/common.c
diff --git a/tnt-kafka/common.h → kafka/common.h b/tnt-kafka/common.h → kafka/common.h
diff --git a/tnt-kafka/consumer.c → kafka/consumer.c b/tnt-kafka/consumer.c → kafka/consumer.c
diff --git a/tnt-kafka/consumer.h → kafka/consumer.h b/tnt-kafka/consumer.h → kafka/consumer.h
diff --git a/tnt-kafka/consumer_msg.c → kafka/consumer_msg.c b/tnt-kafka/consumer_msg.c → kafka/consumer_msg.c
diff --git a/tnt-kafka/consumer_msg.h → kafka/consumer_msg.h b/tnt-kafka/consumer_msg.h → kafka/consumer_msg.h
diff --git a/tnt-kafka/init.lua → kafka/init.lua b/tnt-kafka/init.lua → kafka/init.lua
@@ -1,6 +1,6 @@
 local log = require("log")
 local fiber = require('fiber')
-local tnt_kafka = require("tnt-kafka.tntkafka")
+local tnt_kafka = require("kafka.tntkafka")
 
 local Consumer = {}
 

diff --git a/tnt-kafka/producer.c → kafka/producer.c b/tnt-kafka/producer.c → kafka/producer.c
diff --git a/tnt-kafka/producer.h → kafka/producer.h b/tnt-kafka/producer.h → kafka/producer.h
diff --git a/tnt-kafka/queue.c → kafka/queue.c b/tnt-kafka/queue.c → kafka/queue.c
diff --git a/tnt-kafka/queue.h → kafka/queue.h b/tnt-kafka/queue.h → kafka/queue.h
diff --git a/tnt-kafka/tnt_kafka.c → kafka/tnt_kafka.c b/tnt-kafka/tnt_kafka.c → kafka/tnt_kafka.c
diff --git a/tnt-kafka/tnt_kafka.h → kafka/tnt_kafka.h b/tnt-kafka/tnt_kafka.h → kafka/tnt_kafka.h
diff --git a/rockspecs/tnt-kafka-0.4.0-1.rockspec → rockspecs/kafka-0.4.0-1.rockspec b/rockspecs/tnt-kafka-0.4.0-1.rockspec → rockspecs/kafka-0.4.0-1.rockspec
@@ -1,4 +1,4 @@
-package = "tnt-kafka"
+package = "kafka"
 version = "0.4.0-1"
 source = {
     url = "git://github.com/tarantool/tnt-kafka.git",

diff --git a/rockspecs/tnt-kafka-0.4.1-1.rockspec → rockspecs/kafka-0.4.1-1.rockspec b/rockspecs/tnt-kafka-0.4.1-1.rockspec → rockspecs/kafka-0.4.1-1.rockspec
@@ -1,4 +1,4 @@
-package = "tnt-kafka"
+package = "kafka"
 version = "0.4.1-1"
 source = {
     url = "git://github.com/tarantool/tnt-kafka.git",

diff --git a/rockspecs/tnt-kafka-dev-1.rockspec → rockspecs/kafka-dev-1.rockspec b/rockspecs/tnt-kafka-dev-1.rockspec → rockspecs/kafka-dev-1.rockspec
@@ -1,4 +1,4 @@
-package = "tnt-kafka"
+package = "kafka"
 version = "dev-1"
 source = {
     url = "git://github.com/tarantool/tnt-kafka.git",

diff --git a/rockspecs/tnt-kafka-scm-1.rockspec → rockspecs/kafka-scm-1.rockspec b/rockspecs/tnt-kafka-scm-1.rockspec → rockspecs/kafka-scm-1.rockspec
@@ -1,4 +1,4 @@
-package = "tnt-kafka"
+package = "kafka"
 version = "scm-1"
 source = {
     url = "git://github.com/tarantool/tnt-kafka.git",

diff --git a/rockspecs/tnt-kafka-0.3.4-1.rockspec b/rockspecs/tnt-kafka-0.3.4-1.rockspec
diff --git a/tests/consumer.lua b/tests/consumer.lua
@@ -2,7 +2,7 @@ local box = require("box")
 local log = require("log")
 local os = require("os")
 local fiber = require('fiber')
-local tnt_kafka = require('tnt-kafka')
+local tnt_kafka = require('kafka')
 
 local consumer = nil
 local errors = {}

diff --git a/tests/producer.lua b/tests/producer.lua
@@ -2,7 +2,7 @@ local os = require('os')
 local box = require('box')
 local log = require('log')
 local fiber = require('fiber')
-local tnt_kafka = require('tnt-kafka')
+local tnt_kafka = require('kafka')
 
 local TOPIC_NAME = "test_producer"