Sha256: ec942e352e56f262f43f83b202d9f75432c9bc23776660571c2b13b7f0bc6bf9
Contents?: true
Size: 1.46 KB
Versions: 19
Compression:
Stored size: 1.46 KB
Contents
require 'json'
require 'msgpack'
module Datadog
# Encoding module that encodes data for the AgentTransport
module Encoding
# Encoder interface that provides the logic to encode traces and service
module Encoder
def content_type
raise NotImplementedError
end
# Encodes a list of traces, expecting a list of items where each items
# is a list of spans. Before dump the string in a serialized format all
# traces are normalized. The traces nesting is not changed.
def encode_traces(traces)
to_send = []
traces.each do |trace|
to_send << trace.map(&:to_hash)
end
encode(to_send)
end
# Defines the underlying format used during traces or services encoding.
# This method must be implemented and should only be used by the internal functions.
def encode(_)
raise NotImplementedError
end
end
# Encoder for the JSON format
module JSONEncoder
extend Encoder
CONTENT_TYPE = 'application/json'.freeze
module_function
def content_type
CONTENT_TYPE
end
def encode(obj)
JSON.dump(obj)
end
end
# Encoder for the Msgpack format
module MsgpackEncoder
extend Encoder
module_function
CONTENT_TYPE = 'application/msgpack'.freeze
def content_type
CONTENT_TYPE
end
def encode(obj)
MessagePack.pack(obj)
end
end
end
end
Version data entries
19 entries across 19 versions & 2 rubygems