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 30
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