Class: Droonga::Plugins::Dump::Request

Inherits:
Object
  • Object
show all
Defined in:
lib/droonga/plugins/dump.rb

Instance Method Summary collapse

Constructor Details

#initialize(message) ⇒ Request

Returns a new instance of Request.



52
53
54
# File 'lib/droonga/plugins/dump.rb', line 52

def initialize(message)
  @message = message
end

Instance Method Details

#datasetObject



64
65
66
# File 'lib/droonga/plugins/dump.rb', line 64

def dataset
  @message.raw["dataset"]
end

#idObject



60
61
62
# File 'lib/droonga/plugins/dump.rb', line 60

def id
  @message["id"]
end

#messages_per_secondsObject



72
73
74
75
76
77
78
79
# File 'lib/droonga/plugins/dump.rb', line 72

def messages_per_seconds
  request = (@message.request || {})
  minimum_messages_per_seconds = 10
  [
    minimum_messages_per_seconds,
    (request["messagesPerSecond"] || 10000).to_i,
  ].max
end

#need_dump?Boolean

Returns:

  • (Boolean)


56
57
58
# File 'lib/droonga/plugins/dump.rb', line 56

def need_dump?
  reply_to
end

#reply_toObject



68
69
70
# File 'lib/droonga/plugins/dump.rb', line 68

def reply_to
  (@message.raw["replyTo"] || {})["to"]
end