Class StatelessMarshalerUtil

java.lang.Object

io.opentelemetry.exporter.internal.marshal.StatelessMarshalerUtil

public final class StatelessMarshalerUtil
extends Object

Marshaler utilities.

This class is internal and is hence not for public use. Its APIs are unstable and can change at any time.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	StatelessMarshalerUtil.Grouper<T>
private static class	StatelessMarshalerUtil.RepeatedElementPairSizeCalculator<K,V>
private static class	StatelessMarshalerUtil.RepeatedElementSizeCalculator<T>

Field Summary

Fields

Modifier and Type	Field	Description
private static final MarshalerContext.Key	ATTRIBUTES_SIZE_CALCULATOR_KEY
private static final MarshalerContext.Key	GROUPER_KEY
private static final int	MAX_INNER_LOOP_SIZE
private static final long	MOST_SIGNIFICANT_BIT_MASK

Constructor Summary

Constructors

Modifier	Constructor	Description
private	StatelessMarshalerUtil()

Method Summary

Modifier and Type	Method	Description
private static int	countNegative(byte[] bytes)	Returns the count of bytes with negative value.
private static int	encodedUtf8Length(String string)
private static int	encodedUtf8LengthGeneral(String string, int start)
private static void	encodeUtf8(CodedOutputStream output, String in)
(package private) static int	getUtf8Size(String string, boolean useUnsafe)
private static int	getUtf8Size(String string, MarshalerContext context)	Returns the size of utf8 encoded string in bytes.
static <T> Map<Resource, Map<InstrumentationScopeInfo, List<T>>>	groupByResourceAndScope(Collection<T> dataList, Function<T,Resource> getResource, Function<T, InstrumentationScopeInfo> getInstrumentationScope, MarshalerContext context)	Groups SDK items by resource and instrumentation scope.
private static int	sizeBytes(ProtoFieldInfo field, int length)	Returns the size of a bytes field.
static <K,V> int	sizeMessageWithContext(ProtoFieldInfo field, K key, V value, StatelessMarshaler2<K,V> marshaler, MarshalerContext context)	Returns the size of a message field.
static <T> int	sizeMessageWithContext(ProtoFieldInfo field, T element, StatelessMarshaler<T> marshaler, MarshalerContext context)	Returns the size of a message field.
static int	sizeRepeatedMessageWithContext(ProtoFieldInfo field, Attributes attributes, StatelessMarshaler2<AttributeKey<?>, Object> marshaler, MarshalerContext context)	Returns the size of a repeated message field.
static <T> int	sizeRepeatedMessageWithContext(ProtoFieldInfo field, Collection<? extends T> messages, StatelessMarshaler<T> marshaler, MarshalerContext context, MarshalerContext.Key key)	Returns the size of a repeated message field.
static <T> int	sizeRepeatedMessageWithContext(ProtoFieldInfo field, List<? extends T> messages, StatelessMarshaler<T> marshaler, MarshalerContext context)	Returns the size of a repeated message field.
static <K,V> int	sizeRepeatedMessageWithContext(ProtoFieldInfo field, Map<K,V> messages, StatelessMarshaler2<K,V> marshaler, MarshalerContext context, MarshalerContext.Key key)	Returns the size of a repeated message field.
static int	sizeStringWithContext(ProtoFieldInfo field, String value, MarshalerContext context)	Returns the size of a string field.
(package private) static void	writeUtf8(CodedOutputStream output, String string, int utf8Length, boolean useUnsafe)
(package private) static void	writeUtf8(CodedOutputStream output, String string, int utf8Length, MarshalerContext context)	Write utf8 encoded string to output stream.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

GROUPER_KEY

private static final MarshalerContext.Key GROUPER_KEY

ATTRIBUTES_SIZE_CALCULATOR_KEY

private static final MarshalerContext.Key ATTRIBUTES_SIZE_CALCULATOR_KEY

MAX_INNER_LOOP_SIZE

private static final int MAX_INNER_LOOP_SIZE

See Also:

• Constant Field Values

MOST_SIGNIFICANT_BIT_MASK

private static final long MOST_SIGNIFICANT_BIT_MASK

See Also:

• Constant Field Values

Constructor Details

StatelessMarshalerUtil

private StatelessMarshalerUtil()

Method Details

groupByResourceAndScope

public static <T>
Map<Resource, Map<InstrumentationScopeInfo, List<T>>> groupByResourceAndScope(Collection<T> dataList,
 Function<T,Resource> getResource,
 Function<T, InstrumentationScopeInfo> getInstrumentationScope,
 MarshalerContext context)

Groups SDK items by resource and instrumentation scope.

sizeStringWithContext

public static int sizeStringWithContext(ProtoFieldInfo field,
 @Nullable
 String value,
 MarshalerContext context)

Returns the size of a string field. This method adds elements to context, use together with Serializer.serializeStringWithContext(ProtoFieldInfo, String, MarshalerContext).

sizeBytes

private static int sizeBytes(ProtoFieldInfo field,
 int length)

Returns the size of a bytes field.

sizeRepeatedMessageWithContext

public static <T> int sizeRepeatedMessageWithContext(ProtoFieldInfo field,
 List<? extends T> messages,
 StatelessMarshaler<T> marshaler,
 MarshalerContext context)

Returns the size of a repeated message field. This method adds elements to context, use together with Serializer.serializeRepeatedMessageWithContext(ProtoFieldInfo, List, StatelessMarshaler, MarshalerContext).

sizeRepeatedMessageWithContext

public static <T> int sizeRepeatedMessageWithContext(ProtoFieldInfo field,
 Collection<? extends T> messages,
 StatelessMarshaler<T> marshaler,
 MarshalerContext context,
 MarshalerContext.Key key)

Returns the size of a repeated message field. This method adds elements to context, use together with Serializer.serializeRepeatedMessageWithContext(ProtoFieldInfo, Collection, StatelessMarshaler, MarshalerContext, MarshalerContext.Key).

sizeRepeatedMessageWithContext

public static <K,V> int sizeRepeatedMessageWithContext(ProtoFieldInfo field,
 Map<K,V> messages,
 StatelessMarshaler2<K,V> marshaler,
 MarshalerContext context,
 MarshalerContext.Key key)

Returns the size of a repeated message field. This method adds elements to context, use together with Serializer.serializeRepeatedMessageWithContext(ProtoFieldInfo, Map, StatelessMarshaler2, MarshalerContext, MarshalerContext.Key).

sizeRepeatedMessageWithContext

public static int sizeRepeatedMessageWithContext(ProtoFieldInfo field,
 Attributes attributes,
 StatelessMarshaler2<AttributeKey<?>, Object> marshaler,
 MarshalerContext context)

Returns the size of a repeated message field. This method adds elements to context, use together with Serializer.serializeRepeatedMessageWithContext(ProtoFieldInfo, Attributes, StatelessMarshaler2, MarshalerContext).

sizeMessageWithContext

public static <T> int sizeMessageWithContext(ProtoFieldInfo field,
 T element,
 StatelessMarshaler<T> marshaler,
 MarshalerContext context)

Returns the size of a message field. This method adds elements to context, use together with Serializer.serializeMessageWithContext(ProtoFieldInfo, Object, StatelessMarshaler, MarshalerContext).

sizeMessageWithContext

public static <K,V> int sizeMessageWithContext(ProtoFieldInfo field,
 K key,
 V value,
 StatelessMarshaler2<K,V> marshaler,
 MarshalerContext context)

Returns the size of a message field. This method adds elements to context, use together with Serializer.serializeMessageWithContext(ProtoFieldInfo, Object, Object, StatelessMarshaler2, MarshalerContext).

getUtf8Size

private static int getUtf8Size(String string,
 MarshalerContext context)

Returns the size of utf8 encoded string in bytes.

getUtf8Size

static int getUtf8Size(String string,
 boolean useUnsafe)

countNegative

private static int countNegative(byte[] bytes)

Returns the count of bytes with negative value.

encodedUtf8Length

private static int encodedUtf8Length(String string)

encodedUtf8LengthGeneral

private static int encodedUtf8LengthGeneral(String string,
 int start)

writeUtf8

static void writeUtf8(CodedOutputStream output,
 String string,
 int utf8Length,
 MarshalerContext context)
               throws IOException

Write utf8 encoded string to output stream.

Throws:

IOException

writeUtf8

static void writeUtf8(CodedOutputStream output,
 String string,
 int utf8Length,
 boolean useUnsafe)
               throws IOException

Throws:

IOException

encodeUtf8

private static void encodeUtf8(CodedOutputStream output,
 String in)
                        throws IOException

Throws:

IOException