class Fluent::GcloudPubSub::Message
Attributes
attributes[R]
message[R]
Public Class Methods
new(message, attributes={})
click to toggle source
# File lib/fluent/plugin/gcloud_pubsub/client.rb, line 12 def initialize(message, attributes={}) @message = message @attributes = attributes end
Public Instance Methods
bytesize()
click to toggle source
# File lib/fluent/plugin/gcloud_pubsub/client.rb, line 17 def bytesize() attr_size = 0 @attributes.each do |key, val| attr_size += key.bytesize + val.bytesize end @message.bytesize + attr_size end