lib/fluent/plugin/in_gcloud_pubsub.rb in fluent-plugin-gcloud-pubsub-custom-0.1.3 vs lib/fluent/plugin/in_gcloud_pubsub.rb in fluent-plugin-gcloud-pubsub-custom-0.1.4
- old
+ new
@@ -8,12 +8,12 @@
Fluent::Plugin.register_input('gcloud_pubsub', self)
config_param :tag, :string
config_param :project, :string, :default => nil
config_param :key, :string, :default => nil
- config_param :topic, :string, :default => nil
+ config_param :topic, :string
config_param :subscription, :string
- config_param :pull_interval, :integer, :default => 5
+ config_param :pull_interval, :float, :default => 5.0
config_param :max_messages, :integer, :default => 100
config_param :return_immediately, :bool, :default => true
config_param :format, :string, :default => 'json'
unless method_defined?(:log)