class LogStash::Outputs::Application_insights::State

Public Class Methods

instance() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 82
def self.instance
  @@instance
end

Private Class Methods

new() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 27
def initialize
  @bytes_in_memory = Concurrent::AtomicFixnum.new(0)
  @pending_commits = Concurrent::AtomicFixnum.new(0)
  @pending_notifications = Concurrent::AtomicFixnum.new(0)
end

Public Instance Methods

bytes_in_memory() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 34
def bytes_in_memory
  @bytes_in_memory.value
end
dec_pending_commits() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 64
def dec_pending_commits
  @pending_commits.decrement
end
dec_pending_notifications() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 74
def dec_pending_notifications
  @pending_notifications.decrement
end
dec_upload_bytesize( bytesize ) click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 54
def dec_upload_bytesize ( bytesize )
  @bytes_in_memory.decrement( bytesize )
end
inc_pending_commits() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 59
def inc_pending_commits
  @pending_commits.increment
end
inc_pending_notifications() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 69
def inc_pending_notifications
  @pending_notifications.increment
end
inc_upload_bytesize( bytesize ) click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 49
def inc_upload_bytesize ( bytesize )
  @bytes_in_memory.increment( bytesize )
end
pending_commits() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 39
def pending_commits
  @pending_commits.value
end
pending_notifications() click to toggle source
# File lib/logstash/outputs/application_insights/state.rb, line 44
def pending_notifications
  @pending_notifications.value
end