class Fog::Google::Pubsub::Mock
Public Class Methods
data()
click to toggle source
# File lib/fog/google/pubsub/mock.rb, line 11 def self.data @data ||= Hash.new do |hash, key| hash[key] = { :topics => {}, :subscriptions => {} } end end
new(options)
click to toggle source
# File lib/fog/google/pubsub/mock.rb, line 7 def initialize(options) shared_initialize(options[:google_project], GOOGLE_PUBSUB_API_VERSION, GOOGLE_PUBSUB_BASE_URL) end
reset()
click to toggle source
# File lib/fog/google/pubsub/mock.rb, line 20 def self.reset @data = nil end
Public Instance Methods
acknowledge_subscription(_subscription, _ack_ids)
click to toggle source
# File lib/fog/google/requests/pubsub/acknowledge_subscription.rb, line 23 def acknowledge_subscription(_subscription, _ack_ids) raise Fog::Errors::MockNotImplemented end
create_subscription(_subscription_name, _topic, _push_config = {}, _ack_deadline_seconds = nil)
click to toggle source
# File lib/fog/google/requests/pubsub/create_subscription.rb, line 31 def create_subscription(_subscription_name, _topic, _push_config = {}, _ack_deadline_seconds = nil) raise Fog::Errors::MockNotImplemented end
create_topic(_topic_name)
click to toggle source
# File lib/fog/google/requests/pubsub/create_topic.rb, line 17 def create_topic(_topic_name) raise Fog::Errors::MockNotImplemented end
data()
click to toggle source
# File lib/fog/google/pubsub/mock.rb, line 24 def data self.class.data[project] end
delete_subscription(_subscription_name)
click to toggle source
# File lib/fog/google/requests/pubsub/delete_subscription.rb, line 15 def delete_subscription(_subscription_name) raise Fog::Errors::MockNotImplemented end
delete_topic(_topic_name)
click to toggle source
# File lib/fog/google/requests/pubsub/delete_topic.rb, line 15 def delete_topic(_topic_name) raise Fog::Errors::MockNotImplemented end
get_subscription(_subscription_name)
click to toggle source
# File lib/fog/google/requests/pubsub/get_subscription.rb, line 15 def get_subscription(_subscription_name) raise Fog::Errors::MockNotImplemented end
get_topic(_topic_name)
click to toggle source
# File lib/fog/google/requests/pubsub/get_topic.rb, line 15 def get_topic(_topic_name) raise Fog::Errors::MockNotImplemented end
list_subscriptions(_project = nil)
click to toggle source
# File lib/fog/google/requests/pubsub/list_subscriptions.rb, line 23 def list_subscriptions(_project = nil) raise Fog::Errors::MockNotImplemented end
list_topics(_project = nil)
click to toggle source
# File lib/fog/google/requests/pubsub/list_topics.rb, line 23 def list_topics(_project = nil) raise Fog::Errors::MockNotImplemented end
publish_topic(_topic, _messages)
click to toggle source
# File lib/fog/google/requests/pubsub/publish_topic.rb, line 22 def publish_topic(_topic, _messages) raise Fog::Errors::MockNotImplemented end
pull_subscription(_subscription, _options = { :return_immediately => true, :max_messages => 10 })
click to toggle source
# File lib/fog/google/requests/pubsub/pull_subscription.rb, line 34 def pull_subscription(_subscription, _options = { :return_immediately => true, :max_messages => 10 }) raise Fog::Errors::MockNotImplemented end
reset_data()
click to toggle source
# File lib/fog/google/pubsub/mock.rb, line 28 def reset_data self.class.data.delete(project) end