Sha256: a5ea74d87f9f94b14a0aeb06b387f553e5125acbb0557bb6a567e85a355e2d32
Contents?: true
Size: 1.66 KB
Versions: 16
Compression:
Stored size: 1.66 KB
Contents
# typed: true
require 'json'
require 'msgpack'
module Datadog
module Core
# Encoding module that encodes data for the AgentTransport
module Encoding
# Encoder interface that provides the logic to encode traces and service
# @abstract
module Encoder
include Kernel # Ensure that kernel methods are always available (https://sorbet.org/docs/error-reference#7003)
def content_type
raise NotImplementedError
end
# Concatenates a list of elements previously encoded by +#encode+.
def join(encoded_elements)
raise NotImplementedError
end
# Serializes a single trace into a String suitable for network transmission.
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
def join(encoded_data)
"[#{encoded_data.join(',')}]"
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
def join(encoded_data)
packer = MessagePack::Packer.new
packer.write_array_header(encoded_data.size)
(packer.buffer.to_a + encoded_data).join
end
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems