module Qian
Constants
- VERSION
Attributes
disabled[RW]
kafka_config[RW]
logger_config[RW]
schema_path[RW]
schema_registry_url[RW]
Public Instance Methods
avro()
click to toggle source
返回 Avro Instance
@return [Avro]
# File lib/qian.rb, line 85 def avro @avro end
configure(&blk)
click to toggle source
设置 Qian
配置
@return []
# File lib/qian.rb, line 37 def configure(&blk) blk.yield(Qian) # # Setting up # @kafka ||= Kafka.new(kafka_config[:connection]) @avro ||= AvroTurf::Messaging.new( :registry_url => schema_registry_url, :schemas_path => schema_path) end
disabled?()
click to toggle source
是否禁用
@return [Boolean]
# File lib/qian.rb, line 54 def disabled? self.disabled end
kafka_producer()
click to toggle source
返回一个 Kafka Async Producer 实例
@return [Kafka::AsyncProducer]
# File lib/qian.rb, line 64 def kafka_producer return nil if disabled? @producer ||= @kafka.async_producer(kafka_config[:async_config]) end
logger()
click to toggle source
返回 Qian::Logger
@return [Qian::Logger]
# File lib/qian.rb, line 75 def logger @logger || Qian::Logger.new(kafka_producer) end
root()
click to toggle source
当前 Qian
lib 的路径
@return [Pathname]
# File lib/qian.rb, line 27 def root Pathname.new(File.expand_path(File.dirname(__FILE__))) end
shutdown()
click to toggle source
资源清理
@return [void]
# File lib/qian.rb, line 95 def shutdown # 关闭 Kafka Producer @producer.present? && @producer.shutdown end