diff --git a/reporters/kamon-apm-reporter/src/main/java/kamino/IngestionV1.java b/reporters/kamon-apm-reporter/src/main/java/kamino/IngestionV1.java index def776ba1..e39bfd76e 100644 --- a/reporters/kamon-apm-reporter/src/main/java/kamino/IngestionV1.java +++ b/reporters/kamon-apm-reporter/src/main/java/kamino/IngestionV1.java @@ -1,19 +1,3 @@ -/* - * Copyright 2013-2020 The Kamon Project - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - // Generated by the protocol buffer compiler. DO NOT EDIT! // source: ingestion.v1.proto @@ -76,6 +60,8 @@ public final int getNumber() { } /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated @@ -83,6 +69,10 @@ public static InstrumentType valueOf(int value) { return forNumber(value); } + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ public static InstrumentType forNumber(int value) { switch (value) { case 0: return COUNTER; @@ -168,6 +158,8 @@ public final int getNumber() { } /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated @@ -175,6 +167,10 @@ public static Plan valueOf(int value) { return forNumber(value); } + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ public static Plan forNumber(int value) { switch (value) { case 1: return METRIC_ONLY; @@ -290,6 +286,8 @@ public final int getNumber() { } /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated @@ -297,6 +295,10 @@ public static IngestionStatus valueOf(int value) { return forNumber(value); } + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ public static IngestionStatus forNumber(int value) { switch (value) { case 0: return OK; @@ -416,6 +418,8 @@ public final int getNumber() { } /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated @@ -423,6 +427,10 @@ public static SpanKind valueOf(int value) { return forNumber(value); } + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ public static SpanKind forNumber(int value) { switch (value) { case 0: return UNKNOWN; @@ -518,6 +526,8 @@ public final int getNumber() { } /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated @@ -525,6 +535,10 @@ public static SpanPosition valueOf(int value) { return forNumber(value); } + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ public static SpanPosition forNumber(int value) { switch (value) { case 0: return POSITION_UNKNOWN; @@ -601,6 +615,8 @@ public final int getNumber() { } /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated @@ -608,6 +624,10 @@ public static LinkKind valueOf(int value) { return forNumber(value); } + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ public static LinkKind forNumber(int value) { switch (value) { case 1: return FOLLOWS_FROM; @@ -666,10 +686,12 @@ public interface MetricBatchOrBuilder extends /** * required .Interval interval = 1; + * @return Whether the interval field is set. */ boolean hasInterval(); /** * required .Interval interval = 1; + * @return The interval. */ kamino.IngestionV1.Interval getInterval(); /** @@ -679,56 +701,68 @@ public interface MetricBatchOrBuilder extends /** * required string apiKey = 2; + * @return Whether the apiKey field is set. */ boolean hasApiKey(); /** * required string apiKey = 2; + * @return The apiKey. */ java.lang.String getApiKey(); /** * required string apiKey = 2; + * @return The bytes for apiKey. */ com.google.protobuf.ByteString getApiKeyBytes(); /** * required string service = 3; + * @return Whether the service field is set. */ boolean hasService(); /** * required string service = 3; + * @return The service. */ java.lang.String getService(); /** * required string service = 3; + * @return The bytes for service. */ com.google.protobuf.ByteString getServiceBytes(); /** * required string host = 4; + * @return Whether the host field is set. */ boolean hasHost(); /** * required string host = 4; + * @return The host. */ java.lang.String getHost(); /** * required string host = 4; + * @return The bytes for host. */ com.google.protobuf.ByteString getHostBytes(); /** * required string instance = 5; + * @return Whether the instance field is set. */ boolean hasInstance(); /** * required string instance = 5; + * @return The instance. */ java.lang.String getInstance(); /** * required string instance = 5; + * @return The bytes for instance. */ com.google.protobuf.ByteString getInstanceBytes(); @@ -759,31 +793,70 @@ kamino.IngestionV1.MetricOrBuilder getMetricsOrBuilder( /** * optional .Plan plan = 7; + * @return Whether the plan field is set. */ boolean hasPlan(); /** * optional .Plan plan = 7; + * @return The plan. */ kamino.IngestionV1.Plan getPlan(); /** * optional string agent = 8; + * @return Whether the agent field is set. */ boolean hasAgent(); /** * optional string agent = 8; + * @return The agent. */ java.lang.String getAgent(); /** * optional string agent = 8; + * @return The bytes for agent. */ com.google.protobuf.ByteString getAgentBytes(); + + /** + * map<string, string> environmentTags = 9; + */ + int getEnvironmentTagsCount(); + /** + * map<string, string> environmentTags = 9; + */ + boolean containsEnvironmentTags( + java.lang.String key); + /** + * Use {@link #getEnvironmentTagsMap()} instead. + */ + @java.lang.Deprecated + java.util.Map + getEnvironmentTags(); + /** + * map<string, string> environmentTags = 9; + */ + java.util.Map + getEnvironmentTagsMap(); + /** + * map<string, string> environmentTags = 9; + */ + + java.lang.String getEnvironmentTagsOrDefault( + java.lang.String key, + java.lang.String defaultValue); + /** + * map<string, string> environmentTags = 9; + */ + + java.lang.String getEnvironmentTagsOrThrow( + java.lang.String key); } /** * Protobuf type {@code MetricBatch} */ - public static final class MetricBatch extends + public static final class MetricBatch extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:MetricBatch) MetricBatchOrBuilder { @@ -897,6 +970,19 @@ private MetricBatch( agent_ = bs; break; } + case 74: { + if (!((mutable_bitField0_ & 0x00000100) != 0)) { + environmentTags_ = com.google.protobuf.MapField.newMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + mutable_bitField0_ |= 0x00000100; + } + com.google.protobuf.MapEntry + environmentTags__ = input.readMessage( + EnvironmentTagsDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry); + environmentTags_.getMutableMap().put( + environmentTags__.getKey(), environmentTags__.getValue()); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -924,6 +1010,18 @@ private MetricBatch( return kamino.IngestionV1.internal_static_MetricBatch_descriptor; } + @SuppressWarnings({"rawtypes"}) + @java.lang.Override + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 9: + return internalGetEnvironmentTags(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -937,19 +1035,24 @@ private MetricBatch( private kamino.IngestionV1.Interval interval_; /** * required .Interval interval = 1; + * @return Whether the interval field is set. */ + @java.lang.Override public boolean hasInterval() { return ((bitField0_ & 0x00000001) != 0); } /** * required .Interval interval = 1; + * @return The interval. */ + @java.lang.Override public kamino.IngestionV1.Interval getInterval() { return interval_ == null ? kamino.IngestionV1.Interval.getDefaultInstance() : interval_; } /** * required .Interval interval = 1; */ + @java.lang.Override public kamino.IngestionV1.IntervalOrBuilder getIntervalOrBuilder() { return interval_ == null ? kamino.IngestionV1.Interval.getDefaultInstance() : interval_; } @@ -958,13 +1061,17 @@ public kamino.IngestionV1.IntervalOrBuilder getIntervalOrBuilder() { private volatile java.lang.Object apiKey_; /** * required string apiKey = 2; + * @return Whether the apiKey field is set. */ + @java.lang.Override public boolean hasApiKey() { return ((bitField0_ & 0x00000002) != 0); } /** * required string apiKey = 2; + * @return The apiKey. */ + @java.lang.Override public java.lang.String getApiKey() { java.lang.Object ref = apiKey_; if (ref instanceof java.lang.String) { @@ -981,7 +1088,9 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 2; + * @return The bytes for apiKey. */ + @java.lang.Override public com.google.protobuf.ByteString getApiKeyBytes() { java.lang.Object ref = apiKey_; @@ -1000,13 +1109,17 @@ public java.lang.String getApiKey() { private volatile java.lang.Object service_; /** * required string service = 3; + * @return Whether the service field is set. */ + @java.lang.Override public boolean hasService() { return ((bitField0_ & 0x00000004) != 0); } /** * required string service = 3; + * @return The service. */ + @java.lang.Override public java.lang.String getService() { java.lang.Object ref = service_; if (ref instanceof java.lang.String) { @@ -1023,7 +1136,9 @@ public java.lang.String getService() { } /** * required string service = 3; + * @return The bytes for service. */ + @java.lang.Override public com.google.protobuf.ByteString getServiceBytes() { java.lang.Object ref = service_; @@ -1042,13 +1157,17 @@ public java.lang.String getService() { private volatile java.lang.Object host_; /** * required string host = 4; + * @return Whether the host field is set. */ + @java.lang.Override public boolean hasHost() { return ((bitField0_ & 0x00000008) != 0); } /** * required string host = 4; + * @return The host. */ + @java.lang.Override public java.lang.String getHost() { java.lang.Object ref = host_; if (ref instanceof java.lang.String) { @@ -1065,7 +1184,9 @@ public java.lang.String getHost() { } /** * required string host = 4; + * @return The bytes for host. */ + @java.lang.Override public com.google.protobuf.ByteString getHostBytes() { java.lang.Object ref = host_; @@ -1084,13 +1205,17 @@ public java.lang.String getHost() { private volatile java.lang.Object instance_; /** * required string instance = 5; + * @return Whether the instance field is set. */ + @java.lang.Override public boolean hasInstance() { return ((bitField0_ & 0x00000010) != 0); } /** * required string instance = 5; + * @return The instance. */ + @java.lang.Override public java.lang.String getInstance() { java.lang.Object ref = instance_; if (ref instanceof java.lang.String) { @@ -1107,7 +1232,9 @@ public java.lang.String getInstance() { } /** * required string instance = 5; + * @return The bytes for instance. */ + @java.lang.Override public com.google.protobuf.ByteString getInstanceBytes() { java.lang.Object ref = instance_; @@ -1127,12 +1254,14 @@ public java.lang.String getInstance() { /** * repeated .Metric metrics = 6; */ + @java.lang.Override public java.util.List getMetricsList() { return metrics_; } /** * repeated .Metric metrics = 6; */ + @java.lang.Override public java.util.List getMetricsOrBuilderList() { return metrics_; @@ -1140,18 +1269,21 @@ public java.util.List getMetricsList() { /** * repeated .Metric metrics = 6; */ + @java.lang.Override public int getMetricsCount() { return metrics_.size(); } /** * repeated .Metric metrics = 6; */ + @java.lang.Override public kamino.IngestionV1.Metric getMetrics(int index) { return metrics_.get(index); } /** * repeated .Metric metrics = 6; */ + @java.lang.Override public kamino.IngestionV1.MetricOrBuilder getMetricsOrBuilder( int index) { return metrics_.get(index); @@ -1161,14 +1293,16 @@ public kamino.IngestionV1.MetricOrBuilder getMetricsOrBuilder( private int plan_; /** * optional .Plan plan = 7; + * @return Whether the plan field is set. */ - public boolean hasPlan() { + @java.lang.Override public boolean hasPlan() { return ((bitField0_ & 0x00000020) != 0); } /** * optional .Plan plan = 7; + * @return The plan. */ - public kamino.IngestionV1.Plan getPlan() { + @java.lang.Override public kamino.IngestionV1.Plan getPlan() { @SuppressWarnings("deprecation") kamino.IngestionV1.Plan result = kamino.IngestionV1.Plan.valueOf(plan_); return result == null ? kamino.IngestionV1.Plan.METRIC_ONLY : result; @@ -1178,13 +1312,17 @@ public kamino.IngestionV1.Plan getPlan() { private volatile java.lang.Object agent_; /** * optional string agent = 8; + * @return Whether the agent field is set. */ + @java.lang.Override public boolean hasAgent() { return ((bitField0_ & 0x00000040) != 0); } /** * optional string agent = 8; + * @return The agent. */ + @java.lang.Override public java.lang.String getAgent() { java.lang.Object ref = agent_; if (ref instanceof java.lang.String) { @@ -1201,7 +1339,9 @@ public java.lang.String getAgent() { } /** * optional string agent = 8; + * @return The bytes for agent. */ + @java.lang.Override public com.google.protobuf.ByteString getAgentBytes() { java.lang.Object ref = agent_; @@ -1216,6 +1356,87 @@ public java.lang.String getAgent() { } } + public static final int ENVIRONMENTTAGS_FIELD_NUMBER = 9; + private static final class EnvironmentTagsDefaultEntryHolder { + static final com.google.protobuf.MapEntry< + java.lang.String, java.lang.String> defaultEntry = + com.google.protobuf.MapEntry + .newDefaultInstance( + kamino.IngestionV1.internal_static_MetricBatch_EnvironmentTagsEntry_descriptor, + com.google.protobuf.WireFormat.FieldType.STRING, + "", + com.google.protobuf.WireFormat.FieldType.STRING, + ""); + } + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> environmentTags_; + private com.google.protobuf.MapField + internalGetEnvironmentTags() { + if (environmentTags_ == null) { + return com.google.protobuf.MapField.emptyMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + } + return environmentTags_; + } + + public int getEnvironmentTagsCount() { + return internalGetEnvironmentTags().getMap().size(); + } + /** + * map<string, string> environmentTags = 9; + */ + + @java.lang.Override + public boolean containsEnvironmentTags( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + return internalGetEnvironmentTags().getMap().containsKey(key); + } + /** + * Use {@link #getEnvironmentTagsMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getEnvironmentTags() { + return getEnvironmentTagsMap(); + } + /** + * map<string, string> environmentTags = 9; + */ + @java.lang.Override + + public java.util.Map getEnvironmentTagsMap() { + return internalGetEnvironmentTags().getMap(); + } + /** + * map<string, string> environmentTags = 9; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> environmentTags = 9; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrThrow( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -1284,6 +1505,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (((bitField0_ & 0x00000040) != 0)) { com.google.protobuf.GeneratedMessageV3.writeString(output, 8, agent_); } + com.google.protobuf.GeneratedMessageV3 + .serializeStringMapTo( + output, + internalGetEnvironmentTags(), + EnvironmentTagsDefaultEntryHolder.defaultEntry, + 9); unknownFields.writeTo(output); } @@ -1320,6 +1547,16 @@ public int getSerializedSize() { if (((bitField0_ & 0x00000040) != 0)) { size += com.google.protobuf.GeneratedMessageV3.computeStringSize(8, agent_); } + for (java.util.Map.Entry entry + : internalGetEnvironmentTags().getMap().entrySet()) { + com.google.protobuf.MapEntry + environmentTags__ = EnvironmentTagsDefaultEntryHolder.defaultEntry.newBuilderForType() + .setKey(entry.getKey()) + .setValue(entry.getValue()) + .build(); + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(9, environmentTags__); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -1371,6 +1608,8 @@ public boolean equals(final java.lang.Object obj) { if (!getAgent() .equals(other.getAgent())) return false; } + if (!internalGetEnvironmentTags().equals( + other.internalGetEnvironmentTags())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -1414,6 +1653,10 @@ public int hashCode() { hash = (37 * hash) + AGENT_FIELD_NUMBER; hash = (53 * hash) + getAgent().hashCode(); } + if (!internalGetEnvironmentTags().getMap().isEmpty()) { + hash = (37 * hash) + ENVIRONMENTTAGS_FIELD_NUMBER; + hash = (53 * hash) + internalGetEnvironmentTags().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -1521,6 +1764,28 @@ public static final class Builder extends return kamino.IngestionV1.internal_static_MetricBatch_descriptor; } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 9: + return internalGetEnvironmentTags(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMutableMapField( + int number) { + switch (number) { + case 9: + return internalGetMutableEnvironmentTags(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -1573,6 +1838,7 @@ public Builder clear() { bitField0_ = (bitField0_ & ~0x00000040); agent_ = ""; bitField0_ = (bitField0_ & ~0x00000080); + internalGetMutableEnvironmentTags().clear(); return this; } @@ -1642,6 +1908,8 @@ public kamino.IngestionV1.MetricBatch buildPartial() { to_bitField0_ |= 0x00000040; } result.agent_ = agent_; + result.environmentTags_ = internalGetEnvironmentTags(); + result.environmentTags_.makeImmutable(); result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -1748,6 +2016,8 @@ public Builder mergeFrom(kamino.IngestionV1.MetricBatch other) { agent_ = other.agent_; onChanged(); } + internalGetMutableEnvironmentTags().mergeFrom( + other.internalGetEnvironmentTags()); this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -1806,12 +2076,14 @@ public Builder mergeFrom( kamino.IngestionV1.Interval, kamino.IngestionV1.Interval.Builder, kamino.IngestionV1.IntervalOrBuilder> intervalBuilder_; /** * required .Interval interval = 1; + * @return Whether the interval field is set. */ public boolean hasInterval() { return ((bitField0_ & 0x00000001) != 0); } /** * required .Interval interval = 1; + * @return The interval. */ public kamino.IngestionV1.Interval getInterval() { if (intervalBuilder_ == null) { @@ -1922,12 +2194,14 @@ public kamino.IngestionV1.IntervalOrBuilder getIntervalOrBuilder() { private java.lang.Object apiKey_ = ""; /** * required string apiKey = 2; + * @return Whether the apiKey field is set. */ public boolean hasApiKey() { return ((bitField0_ & 0x00000002) != 0); } /** * required string apiKey = 2; + * @return The apiKey. */ public java.lang.String getApiKey() { java.lang.Object ref = apiKey_; @@ -1945,6 +2219,7 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 2; + * @return The bytes for apiKey. */ public com.google.protobuf.ByteString getApiKeyBytes() { @@ -1961,6 +2236,8 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 2; + * @param value The apiKey to set. + * @return This builder for chaining. */ public Builder setApiKey( java.lang.String value) { @@ -1974,6 +2251,7 @@ public Builder setApiKey( } /** * required string apiKey = 2; + * @return This builder for chaining. */ public Builder clearApiKey() { bitField0_ = (bitField0_ & ~0x00000002); @@ -1983,6 +2261,8 @@ public Builder clearApiKey() { } /** * required string apiKey = 2; + * @param value The bytes for apiKey to set. + * @return This builder for chaining. */ public Builder setApiKeyBytes( com.google.protobuf.ByteString value) { @@ -1998,12 +2278,14 @@ public Builder setApiKeyBytes( private java.lang.Object service_ = ""; /** * required string service = 3; + * @return Whether the service field is set. */ public boolean hasService() { return ((bitField0_ & 0x00000004) != 0); } /** * required string service = 3; + * @return The service. */ public java.lang.String getService() { java.lang.Object ref = service_; @@ -2021,6 +2303,7 @@ public java.lang.String getService() { } /** * required string service = 3; + * @return The bytes for service. */ public com.google.protobuf.ByteString getServiceBytes() { @@ -2037,6 +2320,8 @@ public java.lang.String getService() { } /** * required string service = 3; + * @param value The service to set. + * @return This builder for chaining. */ public Builder setService( java.lang.String value) { @@ -2050,6 +2335,7 @@ public Builder setService( } /** * required string service = 3; + * @return This builder for chaining. */ public Builder clearService() { bitField0_ = (bitField0_ & ~0x00000004); @@ -2059,6 +2345,8 @@ public Builder clearService() { } /** * required string service = 3; + * @param value The bytes for service to set. + * @return This builder for chaining. */ public Builder setServiceBytes( com.google.protobuf.ByteString value) { @@ -2074,12 +2362,14 @@ public Builder setServiceBytes( private java.lang.Object host_ = ""; /** * required string host = 4; + * @return Whether the host field is set. */ public boolean hasHost() { return ((bitField0_ & 0x00000008) != 0); } /** * required string host = 4; + * @return The host. */ public java.lang.String getHost() { java.lang.Object ref = host_; @@ -2097,6 +2387,7 @@ public java.lang.String getHost() { } /** * required string host = 4; + * @return The bytes for host. */ public com.google.protobuf.ByteString getHostBytes() { @@ -2113,6 +2404,8 @@ public java.lang.String getHost() { } /** * required string host = 4; + * @param value The host to set. + * @return This builder for chaining. */ public Builder setHost( java.lang.String value) { @@ -2126,6 +2419,7 @@ public Builder setHost( } /** * required string host = 4; + * @return This builder for chaining. */ public Builder clearHost() { bitField0_ = (bitField0_ & ~0x00000008); @@ -2135,6 +2429,8 @@ public Builder clearHost() { } /** * required string host = 4; + * @param value The bytes for host to set. + * @return This builder for chaining. */ public Builder setHostBytes( com.google.protobuf.ByteString value) { @@ -2150,12 +2446,14 @@ public Builder setHostBytes( private java.lang.Object instance_ = ""; /** * required string instance = 5; + * @return Whether the instance field is set. */ public boolean hasInstance() { return ((bitField0_ & 0x00000010) != 0); } /** * required string instance = 5; + * @return The instance. */ public java.lang.String getInstance() { java.lang.Object ref = instance_; @@ -2173,6 +2471,7 @@ public java.lang.String getInstance() { } /** * required string instance = 5; + * @return The bytes for instance. */ public com.google.protobuf.ByteString getInstanceBytes() { @@ -2189,6 +2488,8 @@ public java.lang.String getInstance() { } /** * required string instance = 5; + * @param value The instance to set. + * @return This builder for chaining. */ public Builder setInstance( java.lang.String value) { @@ -2202,6 +2503,7 @@ public Builder setInstance( } /** * required string instance = 5; + * @return This builder for chaining. */ public Builder clearInstance() { bitField0_ = (bitField0_ & ~0x00000010); @@ -2211,6 +2513,8 @@ public Builder clearInstance() { } /** * required string instance = 5; + * @param value The bytes for instance to set. + * @return This builder for chaining. */ public Builder setInstanceBytes( com.google.protobuf.ByteString value) { @@ -2466,13 +2770,16 @@ public kamino.IngestionV1.Metric.Builder addMetricsBuilder( private int plan_ = 1; /** * optional .Plan plan = 7; + * @return Whether the plan field is set. */ - public boolean hasPlan() { + @java.lang.Override public boolean hasPlan() { return ((bitField0_ & 0x00000040) != 0); } /** * optional .Plan plan = 7; + * @return The plan. */ + @java.lang.Override public kamino.IngestionV1.Plan getPlan() { @SuppressWarnings("deprecation") kamino.IngestionV1.Plan result = kamino.IngestionV1.Plan.valueOf(plan_); @@ -2480,6 +2787,8 @@ public kamino.IngestionV1.Plan getPlan() { } /** * optional .Plan plan = 7; + * @param value The plan to set. + * @return This builder for chaining. */ public Builder setPlan(kamino.IngestionV1.Plan value) { if (value == null) { @@ -2492,6 +2801,7 @@ public Builder setPlan(kamino.IngestionV1.Plan value) { } /** * optional .Plan plan = 7; + * @return This builder for chaining. */ public Builder clearPlan() { bitField0_ = (bitField0_ & ~0x00000040); @@ -2503,12 +2813,14 @@ public Builder clearPlan() { private java.lang.Object agent_ = ""; /** * optional string agent = 8; + * @return Whether the agent field is set. */ public boolean hasAgent() { return ((bitField0_ & 0x00000080) != 0); } /** * optional string agent = 8; + * @return The agent. */ public java.lang.String getAgent() { java.lang.Object ref = agent_; @@ -2526,6 +2838,7 @@ public java.lang.String getAgent() { } /** * optional string agent = 8; + * @return The bytes for agent. */ public com.google.protobuf.ByteString getAgentBytes() { @@ -2542,6 +2855,8 @@ public java.lang.String getAgent() { } /** * optional string agent = 8; + * @param value The agent to set. + * @return This builder for chaining. */ public Builder setAgent( java.lang.String value) { @@ -2555,6 +2870,7 @@ public Builder setAgent( } /** * optional string agent = 8; + * @return This builder for chaining. */ public Builder clearAgent() { bitField0_ = (bitField0_ & ~0x00000080); @@ -2564,6 +2880,8 @@ public Builder clearAgent() { } /** * optional string agent = 8; + * @param value The bytes for agent to set. + * @return This builder for chaining. */ public Builder setAgentBytes( com.google.protobuf.ByteString value) { @@ -2575,6 +2893,134 @@ public Builder setAgentBytes( onChanged(); return this; } + + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> environmentTags_; + private com.google.protobuf.MapField + internalGetEnvironmentTags() { + if (environmentTags_ == null) { + return com.google.protobuf.MapField.emptyMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + } + return environmentTags_; + } + private com.google.protobuf.MapField + internalGetMutableEnvironmentTags() { + onChanged();; + if (environmentTags_ == null) { + environmentTags_ = com.google.protobuf.MapField.newMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + } + if (!environmentTags_.isMutable()) { + environmentTags_ = environmentTags_.copy(); + } + return environmentTags_; + } + + public int getEnvironmentTagsCount() { + return internalGetEnvironmentTags().getMap().size(); + } + /** + * map<string, string> environmentTags = 9; + */ + + @java.lang.Override + public boolean containsEnvironmentTags( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + return internalGetEnvironmentTags().getMap().containsKey(key); + } + /** + * Use {@link #getEnvironmentTagsMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getEnvironmentTags() { + return getEnvironmentTagsMap(); + } + /** + * map<string, string> environmentTags = 9; + */ + @java.lang.Override + + public java.util.Map getEnvironmentTagsMap() { + return internalGetEnvironmentTags().getMap(); + } + /** + * map<string, string> environmentTags = 9; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> environmentTags = 9; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrThrow( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + + public Builder clearEnvironmentTags() { + internalGetMutableEnvironmentTags().getMutableMap() + .clear(); + return this; + } + /** + * map<string, string> environmentTags = 9; + */ + + public Builder removeEnvironmentTags( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + internalGetMutableEnvironmentTags().getMutableMap() + .remove(key); + return this; + } + /** + * Use alternate mutation accessors instead. + */ + @java.lang.Deprecated + public java.util.Map + getMutableEnvironmentTags() { + return internalGetMutableEnvironmentTags().getMutableMap(); + } + /** + * map<string, string> environmentTags = 9; + */ + public Builder putEnvironmentTags( + java.lang.String key, + java.lang.String value) { + if (key == null) { throw new java.lang.NullPointerException(); } + if (value == null) { throw new java.lang.NullPointerException(); } + internalGetMutableEnvironmentTags().getMutableMap() + .put(key, value); + return this; + } + /** + * map<string, string> environmentTags = 9; + */ + + public Builder putAllEnvironmentTags( + java.util.Map values) { + internalGetMutableEnvironmentTags().getMutableMap() + .putAll(values); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -2634,26 +3080,30 @@ public interface IntervalOrBuilder extends /** * required int64 from = 1; + * @return Whether the from field is set. */ boolean hasFrom(); /** * required int64 from = 1; + * @return The from. */ long getFrom(); /** * required int64 to = 2; + * @return Whether the to field is set. */ boolean hasTo(); /** * required int64 to = 2; + * @return The to. */ long getTo(); } /** * Protobuf type {@code Interval} */ - public static final class Interval extends + public static final class Interval extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:Interval) IntervalOrBuilder { @@ -2743,13 +3193,17 @@ private Interval( private long from_; /** * required int64 from = 1; + * @return Whether the from field is set. */ + @java.lang.Override public boolean hasFrom() { return ((bitField0_ & 0x00000001) != 0); } /** * required int64 from = 1; + * @return The from. */ + @java.lang.Override public long getFrom() { return from_; } @@ -2758,13 +3212,17 @@ public long getFrom() { private long to_; /** * required int64 to = 2; + * @return Whether the to field is set. */ + @java.lang.Override public boolean hasTo() { return ((bitField0_ & 0x00000002) != 0); } /** * required int64 to = 2; + * @return The to. */ + @java.lang.Override public long getTo() { return to_; } @@ -3127,18 +3585,24 @@ public Builder mergeFrom( private long from_ ; /** * required int64 from = 1; + * @return Whether the from field is set. */ + @java.lang.Override public boolean hasFrom() { return ((bitField0_ & 0x00000001) != 0); } /** * required int64 from = 1; + * @return The from. */ + @java.lang.Override public long getFrom() { return from_; } /** * required int64 from = 1; + * @param value The from to set. + * @return This builder for chaining. */ public Builder setFrom(long value) { bitField0_ |= 0x00000001; @@ -3148,6 +3612,7 @@ public Builder setFrom(long value) { } /** * required int64 from = 1; + * @return This builder for chaining. */ public Builder clearFrom() { bitField0_ = (bitField0_ & ~0x00000001); @@ -3159,18 +3624,24 @@ public Builder clearFrom() { private long to_ ; /** * required int64 to = 2; + * @return Whether the to field is set. */ + @java.lang.Override public boolean hasTo() { return ((bitField0_ & 0x00000002) != 0); } /** * required int64 to = 2; + * @return The to. */ + @java.lang.Override public long getTo() { return to_; } /** * required int64 to = 2; + * @param value The to to set. + * @return This builder for chaining. */ public Builder setTo(long value) { bitField0_ |= 0x00000002; @@ -3180,6 +3651,7 @@ public Builder setTo(long value) { } /** * required int64 to = 2; + * @return This builder for chaining. */ public Builder clearTo() { bitField0_ = (bitField0_ & ~0x00000002); @@ -3246,14 +3718,17 @@ public interface MetricOrBuilder extends /** * required string name = 1; + * @return Whether the name field is set. */ boolean hasName(); /** * required string name = 1; + * @return The name. */ java.lang.String getName(); /** * required string name = 1; + * @return The bytes for name. */ com.google.protobuf.ByteString getNameBytes(); @@ -3294,26 +3769,30 @@ java.lang.String getTagsOrThrow( /** * required .InstrumentType instrumentType = 3; + * @return Whether the instrumentType field is set. */ boolean hasInstrumentType(); /** * required .InstrumentType instrumentType = 3; + * @return The instrumentType. */ kamino.IngestionV1.InstrumentType getInstrumentType(); /** * required bytes data = 4; + * @return Whether the data field is set. */ boolean hasData(); /** * required bytes data = 4; + * @return The data. */ com.google.protobuf.ByteString getData(); } /** * Protobuf type {@code Metric} */ - public static final class Metric extends + public static final class Metric extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:Metric) MetricOrBuilder { @@ -3444,13 +3923,17 @@ protected com.google.protobuf.MapField internalGetMapField( private volatile java.lang.Object name_; /** * required string name = 1; + * @return Whether the name field is set. */ + @java.lang.Override public boolean hasName() { return ((bitField0_ & 0x00000001) != 0); } /** * required string name = 1; + * @return The name. */ + @java.lang.Override public java.lang.String getName() { java.lang.Object ref = name_; if (ref instanceof java.lang.String) { @@ -3467,7 +3950,9 @@ public java.lang.String getName() { } /** * required string name = 1; + * @return The bytes for name. */ + @java.lang.Override public com.google.protobuf.ByteString getNameBytes() { java.lang.Object ref = name_; @@ -3512,6 +3997,7 @@ public int getTagsCount() { * map<string, string> tags = 2; */ + @java.lang.Override public boolean containsTags( java.lang.String key) { if (key == null) { throw new java.lang.NullPointerException(); } @@ -3520,6 +4006,7 @@ public boolean containsTags( /** * Use {@link #getTagsMap()} instead. */ + @java.lang.Override @java.lang.Deprecated public java.util.Map getTags() { return getTagsMap(); @@ -3527,6 +4014,7 @@ public java.util.Map getTags() { /** * map<string, string> tags = 2; */ + @java.lang.Override public java.util.Map getTagsMap() { return internalGetTags().getMap(); @@ -3534,6 +4022,7 @@ public java.util.Map getTagsMap() { /** * map<string, string> tags = 2; */ + @java.lang.Override public java.lang.String getTagsOrDefault( java.lang.String key, @@ -3546,6 +4035,7 @@ public java.lang.String getTagsOrDefault( /** * map<string, string> tags = 2; */ + @java.lang.Override public java.lang.String getTagsOrThrow( java.lang.String key) { @@ -3562,14 +4052,16 @@ public java.lang.String getTagsOrThrow( private int instrumentType_; /** * required .InstrumentType instrumentType = 3; + * @return Whether the instrumentType field is set. */ - public boolean hasInstrumentType() { + @java.lang.Override public boolean hasInstrumentType() { return ((bitField0_ & 0x00000002) != 0); } /** * required .InstrumentType instrumentType = 3; + * @return The instrumentType. */ - public kamino.IngestionV1.InstrumentType getInstrumentType() { + @java.lang.Override public kamino.IngestionV1.InstrumentType getInstrumentType() { @SuppressWarnings("deprecation") kamino.IngestionV1.InstrumentType result = kamino.IngestionV1.InstrumentType.valueOf(instrumentType_); return result == null ? kamino.IngestionV1.InstrumentType.COUNTER : result; @@ -3579,13 +4071,17 @@ public kamino.IngestionV1.InstrumentType getInstrumentType() { private com.google.protobuf.ByteString data_; /** * required bytes data = 4; + * @return Whether the data field is set. */ + @java.lang.Override public boolean hasData() { return ((bitField0_ & 0x00000004) != 0); } /** * required bytes data = 4; + * @return The data. */ + @java.lang.Override public com.google.protobuf.ByteString getData() { return data_; } @@ -4027,12 +4523,14 @@ public Builder mergeFrom( private java.lang.Object name_ = ""; /** * required string name = 1; + * @return Whether the name field is set. */ public boolean hasName() { return ((bitField0_ & 0x00000001) != 0); } /** * required string name = 1; + * @return The name. */ public java.lang.String getName() { java.lang.Object ref = name_; @@ -4050,6 +4548,7 @@ public java.lang.String getName() { } /** * required string name = 1; + * @return The bytes for name. */ public com.google.protobuf.ByteString getNameBytes() { @@ -4066,6 +4565,8 @@ public java.lang.String getName() { } /** * required string name = 1; + * @param value The name to set. + * @return This builder for chaining. */ public Builder setName( java.lang.String value) { @@ -4079,6 +4580,7 @@ public Builder setName( } /** * required string name = 1; + * @return This builder for chaining. */ public Builder clearName() { bitField0_ = (bitField0_ & ~0x00000001); @@ -4088,6 +4590,8 @@ public Builder clearName() { } /** * required string name = 1; + * @param value The bytes for name to set. + * @return This builder for chaining. */ public Builder setNameBytes( com.google.protobuf.ByteString value) { @@ -4130,6 +4634,7 @@ public int getTagsCount() { * map<string, string> tags = 2; */ + @java.lang.Override public boolean containsTags( java.lang.String key) { if (key == null) { throw new java.lang.NullPointerException(); } @@ -4138,6 +4643,7 @@ public boolean containsTags( /** * Use {@link #getTagsMap()} instead. */ + @java.lang.Override @java.lang.Deprecated public java.util.Map getTags() { return getTagsMap(); @@ -4145,6 +4651,7 @@ public java.util.Map getTags() { /** * map<string, string> tags = 2; */ + @java.lang.Override public java.util.Map getTagsMap() { return internalGetTags().getMap(); @@ -4152,6 +4659,7 @@ public java.util.Map getTagsMap() { /** * map<string, string> tags = 2; */ + @java.lang.Override public java.lang.String getTagsOrDefault( java.lang.String key, @@ -4164,6 +4672,7 @@ public java.lang.String getTagsOrDefault( /** * map<string, string> tags = 2; */ + @java.lang.Override public java.lang.String getTagsOrThrow( java.lang.String key) { @@ -4226,13 +4735,16 @@ public Builder putAllTags( private int instrumentType_ = 0; /** * required .InstrumentType instrumentType = 3; + * @return Whether the instrumentType field is set. */ - public boolean hasInstrumentType() { + @java.lang.Override public boolean hasInstrumentType() { return ((bitField0_ & 0x00000004) != 0); } /** * required .InstrumentType instrumentType = 3; + * @return The instrumentType. */ + @java.lang.Override public kamino.IngestionV1.InstrumentType getInstrumentType() { @SuppressWarnings("deprecation") kamino.IngestionV1.InstrumentType result = kamino.IngestionV1.InstrumentType.valueOf(instrumentType_); @@ -4240,6 +4752,8 @@ public kamino.IngestionV1.InstrumentType getInstrumentType() { } /** * required .InstrumentType instrumentType = 3; + * @param value The instrumentType to set. + * @return This builder for chaining. */ public Builder setInstrumentType(kamino.IngestionV1.InstrumentType value) { if (value == null) { @@ -4252,6 +4766,7 @@ public Builder setInstrumentType(kamino.IngestionV1.InstrumentType value) { } /** * required .InstrumentType instrumentType = 3; + * @return This builder for chaining. */ public Builder clearInstrumentType() { bitField0_ = (bitField0_ & ~0x00000004); @@ -4263,18 +4778,24 @@ public Builder clearInstrumentType() { private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; /** * required bytes data = 4; + * @return Whether the data field is set. */ + @java.lang.Override public boolean hasData() { return ((bitField0_ & 0x00000008) != 0); } /** * required bytes data = 4; + * @return The data. */ + @java.lang.Override public com.google.protobuf.ByteString getData() { return data_; } /** * required bytes data = 4; + * @param value The data to set. + * @return This builder for chaining. */ public Builder setData(com.google.protobuf.ByteString value) { if (value == null) { @@ -4287,6 +4808,7 @@ public Builder setData(com.google.protobuf.ByteString value) { } /** * required bytes data = 4; + * @return This builder for chaining. */ public Builder clearData() { bitField0_ = (bitField0_ & ~0x00000008); @@ -4353,56 +4875,68 @@ public interface NodeIdentityOrBuilder extends /** * required string service = 1; + * @return Whether the service field is set. */ boolean hasService(); /** * required string service = 1; + * @return The service. */ java.lang.String getService(); /** * required string service = 1; + * @return The bytes for service. */ com.google.protobuf.ByteString getServiceBytes(); /** * required string instance = 2; + * @return Whether the instance field is set. */ boolean hasInstance(); /** * required string instance = 2; + * @return The instance. */ java.lang.String getInstance(); /** * required string instance = 2; + * @return The bytes for instance. */ com.google.protobuf.ByteString getInstanceBytes(); /** * required string host = 3; + * @return Whether the host field is set. */ boolean hasHost(); /** * required string host = 3; + * @return The host. */ java.lang.String getHost(); /** * required string host = 3; + * @return The bytes for host. */ com.google.protobuf.ByteString getHostBytes(); /** * required string apiKey = 4; + * @return Whether the apiKey field is set. */ boolean hasApiKey(); /** * required string apiKey = 4; + * @return The apiKey. */ java.lang.String getApiKey(); /** * required string apiKey = 4; + * @return The bytes for apiKey. */ com.google.protobuf.ByteString getApiKeyBytes(); @@ -4427,7 +4961,7 @@ public interface NodeIdentityOrBuilder extends /** * Protobuf type {@code NodeIdentity} */ - public static final class NodeIdentity extends + public static final class NodeIdentity extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:NodeIdentity) NodeIdentityOrBuilder { @@ -4542,13 +5076,17 @@ private NodeIdentity( private volatile java.lang.Object service_; /** * required string service = 1; + * @return Whether the service field is set. */ + @java.lang.Override public boolean hasService() { return ((bitField0_ & 0x00000001) != 0); } /** * required string service = 1; + * @return The service. */ + @java.lang.Override public java.lang.String getService() { java.lang.Object ref = service_; if (ref instanceof java.lang.String) { @@ -4565,7 +5103,9 @@ public java.lang.String getService() { } /** * required string service = 1; + * @return The bytes for service. */ + @java.lang.Override public com.google.protobuf.ByteString getServiceBytes() { java.lang.Object ref = service_; @@ -4584,13 +5124,17 @@ public java.lang.String getService() { private volatile java.lang.Object instance_; /** * required string instance = 2; + * @return Whether the instance field is set. */ + @java.lang.Override public boolean hasInstance() { return ((bitField0_ & 0x00000002) != 0); } /** * required string instance = 2; + * @return The instance. */ + @java.lang.Override public java.lang.String getInstance() { java.lang.Object ref = instance_; if (ref instanceof java.lang.String) { @@ -4607,7 +5151,9 @@ public java.lang.String getInstance() { } /** * required string instance = 2; + * @return The bytes for instance. */ + @java.lang.Override public com.google.protobuf.ByteString getInstanceBytes() { java.lang.Object ref = instance_; @@ -4626,13 +5172,17 @@ public java.lang.String getInstance() { private volatile java.lang.Object host_; /** * required string host = 3; + * @return Whether the host field is set. */ + @java.lang.Override public boolean hasHost() { return ((bitField0_ & 0x00000004) != 0); } /** * required string host = 3; + * @return The host. */ + @java.lang.Override public java.lang.String getHost() { java.lang.Object ref = host_; if (ref instanceof java.lang.String) { @@ -4649,7 +5199,9 @@ public java.lang.String getHost() { } /** * required string host = 3; + * @return The bytes for host. */ + @java.lang.Override public com.google.protobuf.ByteString getHostBytes() { java.lang.Object ref = host_; @@ -4668,13 +5220,17 @@ public java.lang.String getHost() { private volatile java.lang.Object apiKey_; /** * required string apiKey = 4; + * @return Whether the apiKey field is set. */ + @java.lang.Override public boolean hasApiKey() { return ((bitField0_ & 0x00000008) != 0); } /** * required string apiKey = 4; + * @return The apiKey. */ + @java.lang.Override public java.lang.String getApiKey() { java.lang.Object ref = apiKey_; if (ref instanceof java.lang.String) { @@ -4691,7 +5247,9 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 4; + * @return The bytes for apiKey. */ + @java.lang.Override public com.google.protobuf.ByteString getApiKeyBytes() { java.lang.Object ref = apiKey_; @@ -5204,12 +5762,14 @@ public Builder mergeFrom( private java.lang.Object service_ = ""; /** * required string service = 1; + * @return Whether the service field is set. */ public boolean hasService() { return ((bitField0_ & 0x00000001) != 0); } /** * required string service = 1; + * @return The service. */ public java.lang.String getService() { java.lang.Object ref = service_; @@ -5227,6 +5787,7 @@ public java.lang.String getService() { } /** * required string service = 1; + * @return The bytes for service. */ public com.google.protobuf.ByteString getServiceBytes() { @@ -5243,6 +5804,8 @@ public java.lang.String getService() { } /** * required string service = 1; + * @param value The service to set. + * @return This builder for chaining. */ public Builder setService( java.lang.String value) { @@ -5256,6 +5819,7 @@ public Builder setService( } /** * required string service = 1; + * @return This builder for chaining. */ public Builder clearService() { bitField0_ = (bitField0_ & ~0x00000001); @@ -5265,6 +5829,8 @@ public Builder clearService() { } /** * required string service = 1; + * @param value The bytes for service to set. + * @return This builder for chaining. */ public Builder setServiceBytes( com.google.protobuf.ByteString value) { @@ -5280,12 +5846,14 @@ public Builder setServiceBytes( private java.lang.Object instance_ = ""; /** * required string instance = 2; + * @return Whether the instance field is set. */ public boolean hasInstance() { return ((bitField0_ & 0x00000002) != 0); } /** * required string instance = 2; + * @return The instance. */ public java.lang.String getInstance() { java.lang.Object ref = instance_; @@ -5303,6 +5871,7 @@ public java.lang.String getInstance() { } /** * required string instance = 2; + * @return The bytes for instance. */ public com.google.protobuf.ByteString getInstanceBytes() { @@ -5319,6 +5888,8 @@ public java.lang.String getInstance() { } /** * required string instance = 2; + * @param value The instance to set. + * @return This builder for chaining. */ public Builder setInstance( java.lang.String value) { @@ -5332,6 +5903,7 @@ public Builder setInstance( } /** * required string instance = 2; + * @return This builder for chaining. */ public Builder clearInstance() { bitField0_ = (bitField0_ & ~0x00000002); @@ -5341,6 +5913,8 @@ public Builder clearInstance() { } /** * required string instance = 2; + * @param value The bytes for instance to set. + * @return This builder for chaining. */ public Builder setInstanceBytes( com.google.protobuf.ByteString value) { @@ -5356,12 +5930,14 @@ public Builder setInstanceBytes( private java.lang.Object host_ = ""; /** * required string host = 3; + * @return Whether the host field is set. */ public boolean hasHost() { return ((bitField0_ & 0x00000004) != 0); } /** * required string host = 3; + * @return The host. */ public java.lang.String getHost() { java.lang.Object ref = host_; @@ -5379,6 +5955,7 @@ public java.lang.String getHost() { } /** * required string host = 3; + * @return The bytes for host. */ public com.google.protobuf.ByteString getHostBytes() { @@ -5395,6 +5972,8 @@ public java.lang.String getHost() { } /** * required string host = 3; + * @param value The host to set. + * @return This builder for chaining. */ public Builder setHost( java.lang.String value) { @@ -5408,6 +5987,7 @@ public Builder setHost( } /** * required string host = 3; + * @return This builder for chaining. */ public Builder clearHost() { bitField0_ = (bitField0_ & ~0x00000004); @@ -5417,6 +5997,8 @@ public Builder clearHost() { } /** * required string host = 3; + * @param value The bytes for host to set. + * @return This builder for chaining. */ public Builder setHostBytes( com.google.protobuf.ByteString value) { @@ -5432,12 +6014,14 @@ public Builder setHostBytes( private java.lang.Object apiKey_ = ""; /** * required string apiKey = 4; + * @return Whether the apiKey field is set. */ public boolean hasApiKey() { return ((bitField0_ & 0x00000008) != 0); } /** * required string apiKey = 4; + * @return The apiKey. */ public java.lang.String getApiKey() { java.lang.Object ref = apiKey_; @@ -5455,6 +6039,7 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 4; + * @return The bytes for apiKey. */ public com.google.protobuf.ByteString getApiKeyBytes() { @@ -5471,6 +6056,8 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 4; + * @param value The apiKey to set. + * @return This builder for chaining. */ public Builder setApiKey( java.lang.String value) { @@ -5484,6 +6071,7 @@ public Builder setApiKey( } /** * required string apiKey = 4; + * @return This builder for chaining. */ public Builder clearApiKey() { bitField0_ = (bitField0_ & ~0x00000008); @@ -5493,6 +6081,8 @@ public Builder clearApiKey() { } /** * required string apiKey = 4; + * @param value The bytes for apiKey to set. + * @return This builder for chaining. */ public Builder setApiKeyBytes( com.google.protobuf.ByteString value) { @@ -5647,10 +6237,12 @@ public interface HelloOrBuilder extends /** * required .NodeIdentity node = 1; + * @return Whether the node field is set. */ boolean hasNode(); /** * required .NodeIdentity node = 1; + * @return The node. */ kamino.IngestionV1.NodeIdentity getNode(); /** @@ -5660,37 +6252,45 @@ public interface HelloOrBuilder extends /** * required int64 time = 2; + * @return Whether the time field is set. */ boolean hasTime(); /** * required int64 time = 2; + * @return The time. */ long getTime(); /** * required string incarnation = 3; + * @return Whether the incarnation field is set. */ boolean hasIncarnation(); /** * required string incarnation = 3; + * @return The incarnation. */ java.lang.String getIncarnation(); /** * required string incarnation = 3; + * @return The bytes for incarnation. */ com.google.protobuf.ByteString getIncarnationBytes(); /** * required string version = 4; + * @return Whether the version field is set. */ boolean hasVersion(); /** * required string version = 4; + * @return The version. */ java.lang.String getVersion(); /** * required string version = 4; + * @return The bytes for version. */ com.google.protobuf.ByteString getVersionBytes(); @@ -5698,7 +6298,7 @@ public interface HelloOrBuilder extends /** * Protobuf type {@code Hello} */ - public static final class Hello extends + public static final class Hello extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:Hello) HelloOrBuilder { @@ -5810,19 +6410,24 @@ private Hello( private kamino.IngestionV1.NodeIdentity node_; /** * required .NodeIdentity node = 1; + * @return Whether the node field is set. */ + @java.lang.Override public boolean hasNode() { return ((bitField0_ & 0x00000001) != 0); } /** * required .NodeIdentity node = 1; + * @return The node. */ + @java.lang.Override public kamino.IngestionV1.NodeIdentity getNode() { return node_ == null ? kamino.IngestionV1.NodeIdentity.getDefaultInstance() : node_; } /** * required .NodeIdentity node = 1; */ + @java.lang.Override public kamino.IngestionV1.NodeIdentityOrBuilder getNodeOrBuilder() { return node_ == null ? kamino.IngestionV1.NodeIdentity.getDefaultInstance() : node_; } @@ -5831,13 +6436,17 @@ public kamino.IngestionV1.NodeIdentityOrBuilder getNodeOrBuilder() { private long time_; /** * required int64 time = 2; + * @return Whether the time field is set. */ + @java.lang.Override public boolean hasTime() { return ((bitField0_ & 0x00000002) != 0); } /** * required int64 time = 2; + * @return The time. */ + @java.lang.Override public long getTime() { return time_; } @@ -5846,13 +6455,17 @@ public long getTime() { private volatile java.lang.Object incarnation_; /** * required string incarnation = 3; + * @return Whether the incarnation field is set. */ + @java.lang.Override public boolean hasIncarnation() { return ((bitField0_ & 0x00000004) != 0); } /** * required string incarnation = 3; + * @return The incarnation. */ + @java.lang.Override public java.lang.String getIncarnation() { java.lang.Object ref = incarnation_; if (ref instanceof java.lang.String) { @@ -5869,7 +6482,9 @@ public java.lang.String getIncarnation() { } /** * required string incarnation = 3; + * @return The bytes for incarnation. */ + @java.lang.Override public com.google.protobuf.ByteString getIncarnationBytes() { java.lang.Object ref = incarnation_; @@ -5888,13 +6503,17 @@ public java.lang.String getIncarnation() { private volatile java.lang.Object version_; /** * required string version = 4; + * @return Whether the version field is set. */ + @java.lang.Override public boolean hasVersion() { return ((bitField0_ & 0x00000008) != 0); } /** * required string version = 4; + * @return The version. */ + @java.lang.Override public java.lang.String getVersion() { java.lang.Object ref = version_; if (ref instanceof java.lang.String) { @@ -5911,7 +6530,9 @@ public java.lang.String getVersion() { } /** * required string version = 4; + * @return The bytes for version. */ + @java.lang.Override public com.google.protobuf.ByteString getVersionBytes() { java.lang.Object ref = version_; @@ -6367,12 +6988,14 @@ public Builder mergeFrom( kamino.IngestionV1.NodeIdentity, kamino.IngestionV1.NodeIdentity.Builder, kamino.IngestionV1.NodeIdentityOrBuilder> nodeBuilder_; /** * required .NodeIdentity node = 1; + * @return Whether the node field is set. */ public boolean hasNode() { return ((bitField0_ & 0x00000001) != 0); } /** * required .NodeIdentity node = 1; + * @return The node. */ public kamino.IngestionV1.NodeIdentity getNode() { if (nodeBuilder_ == null) { @@ -6483,18 +7106,24 @@ public kamino.IngestionV1.NodeIdentityOrBuilder getNodeOrBuilder() { private long time_ ; /** * required int64 time = 2; + * @return Whether the time field is set. */ + @java.lang.Override public boolean hasTime() { return ((bitField0_ & 0x00000002) != 0); } /** * required int64 time = 2; + * @return The time. */ + @java.lang.Override public long getTime() { return time_; } /** * required int64 time = 2; + * @param value The time to set. + * @return This builder for chaining. */ public Builder setTime(long value) { bitField0_ |= 0x00000002; @@ -6504,6 +7133,7 @@ public Builder setTime(long value) { } /** * required int64 time = 2; + * @return This builder for chaining. */ public Builder clearTime() { bitField0_ = (bitField0_ & ~0x00000002); @@ -6515,12 +7145,14 @@ public Builder clearTime() { private java.lang.Object incarnation_ = ""; /** * required string incarnation = 3; + * @return Whether the incarnation field is set. */ public boolean hasIncarnation() { return ((bitField0_ & 0x00000004) != 0); } /** * required string incarnation = 3; + * @return The incarnation. */ public java.lang.String getIncarnation() { java.lang.Object ref = incarnation_; @@ -6538,6 +7170,7 @@ public java.lang.String getIncarnation() { } /** * required string incarnation = 3; + * @return The bytes for incarnation. */ public com.google.protobuf.ByteString getIncarnationBytes() { @@ -6554,6 +7187,8 @@ public java.lang.String getIncarnation() { } /** * required string incarnation = 3; + * @param value The incarnation to set. + * @return This builder for chaining. */ public Builder setIncarnation( java.lang.String value) { @@ -6567,6 +7202,7 @@ public Builder setIncarnation( } /** * required string incarnation = 3; + * @return This builder for chaining. */ public Builder clearIncarnation() { bitField0_ = (bitField0_ & ~0x00000004); @@ -6576,6 +7212,8 @@ public Builder clearIncarnation() { } /** * required string incarnation = 3; + * @param value The bytes for incarnation to set. + * @return This builder for chaining. */ public Builder setIncarnationBytes( com.google.protobuf.ByteString value) { @@ -6591,12 +7229,14 @@ public Builder setIncarnationBytes( private java.lang.Object version_ = ""; /** * required string version = 4; + * @return Whether the version field is set. */ public boolean hasVersion() { return ((bitField0_ & 0x00000008) != 0); } /** * required string version = 4; + * @return The version. */ public java.lang.String getVersion() { java.lang.Object ref = version_; @@ -6614,6 +7254,7 @@ public java.lang.String getVersion() { } /** * required string version = 4; + * @return The bytes for version. */ public com.google.protobuf.ByteString getVersionBytes() { @@ -6630,6 +7271,8 @@ public java.lang.String getVersion() { } /** * required string version = 4; + * @param value The version to set. + * @return This builder for chaining. */ public Builder setVersion( java.lang.String value) { @@ -6643,6 +7286,7 @@ public Builder setVersion( } /** * required string version = 4; + * @return This builder for chaining. */ public Builder clearVersion() { bitField0_ = (bitField0_ & ~0x00000008); @@ -6652,6 +7296,8 @@ public Builder clearVersion() { } /** * required string version = 4; + * @param value The bytes for version to set. + * @return This builder for chaining. */ public Builder setVersionBytes( com.google.protobuf.ByteString value) { @@ -6722,10 +7368,12 @@ public interface GoodbyeOrBuilder extends /** * required .NodeIdentity node = 1; + * @return Whether the node field is set. */ boolean hasNode(); /** * required .NodeIdentity node = 1; + * @return The node. */ kamino.IngestionV1.NodeIdentity getNode(); /** @@ -6735,17 +7383,19 @@ public interface GoodbyeOrBuilder extends /** * required int64 time = 2; + * @return Whether the time field is set. */ boolean hasTime(); /** * required int64 time = 2; + * @return The time. */ long getTime(); } /** * Protobuf type {@code Goodbye} */ - public static final class Goodbye extends + public static final class Goodbye extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:Goodbye) GoodbyeOrBuilder { @@ -6843,19 +7493,24 @@ private Goodbye( private kamino.IngestionV1.NodeIdentity node_; /** * required .NodeIdentity node = 1; + * @return Whether the node field is set. */ + @java.lang.Override public boolean hasNode() { return ((bitField0_ & 0x00000001) != 0); } /** * required .NodeIdentity node = 1; + * @return The node. */ + @java.lang.Override public kamino.IngestionV1.NodeIdentity getNode() { return node_ == null ? kamino.IngestionV1.NodeIdentity.getDefaultInstance() : node_; } /** * required .NodeIdentity node = 1; */ + @java.lang.Override public kamino.IngestionV1.NodeIdentityOrBuilder getNodeOrBuilder() { return node_ == null ? kamino.IngestionV1.NodeIdentity.getDefaultInstance() : node_; } @@ -6864,13 +7519,17 @@ public kamino.IngestionV1.NodeIdentityOrBuilder getNodeOrBuilder() { private long time_; /** * required int64 time = 2; + * @return Whether the time field is set. */ + @java.lang.Override public boolean hasTime() { return ((bitField0_ & 0x00000002) != 0); } /** * required int64 time = 2; + * @return The time. */ + @java.lang.Override public long getTime() { return time_; } @@ -7250,12 +7909,14 @@ public Builder mergeFrom( kamino.IngestionV1.NodeIdentity, kamino.IngestionV1.NodeIdentity.Builder, kamino.IngestionV1.NodeIdentityOrBuilder> nodeBuilder_; /** * required .NodeIdentity node = 1; + * @return Whether the node field is set. */ public boolean hasNode() { return ((bitField0_ & 0x00000001) != 0); } /** * required .NodeIdentity node = 1; + * @return The node. */ public kamino.IngestionV1.NodeIdentity getNode() { if (nodeBuilder_ == null) { @@ -7366,18 +8027,24 @@ public kamino.IngestionV1.NodeIdentityOrBuilder getNodeOrBuilder() { private long time_ ; /** * required int64 time = 2; + * @return Whether the time field is set. */ + @java.lang.Override public boolean hasTime() { return ((bitField0_ & 0x00000002) != 0); } /** * required int64 time = 2; + * @return The time. */ + @java.lang.Override public long getTime() { return time_; } /** * required int64 time = 2; + * @param value The time to set. + * @return This builder for chaining. */ public Builder setTime(long value) { bitField0_ |= 0x00000002; @@ -7387,6 +8054,7 @@ public Builder setTime(long value) { } /** * required int64 time = 2; + * @return This builder for chaining. */ public Builder clearTime() { bitField0_ = (bitField0_ & ~0x00000002); @@ -7453,56 +8121,68 @@ public interface SpanBatchOrBuilder extends /** * required string serviceName = 1; + * @return Whether the serviceName field is set. */ boolean hasServiceName(); /** * required string serviceName = 1; + * @return The serviceName. */ java.lang.String getServiceName(); /** * required string serviceName = 1; + * @return The bytes for serviceName. */ com.google.protobuf.ByteString getServiceNameBytes(); /** * required string apiKey = 2; + * @return Whether the apiKey field is set. */ boolean hasApiKey(); /** * required string apiKey = 2; + * @return The apiKey. */ java.lang.String getApiKey(); /** * required string apiKey = 2; + * @return The bytes for apiKey. */ com.google.protobuf.ByteString getApiKeyBytes(); /** * required string host = 3; + * @return Whether the host field is set. */ boolean hasHost(); /** * required string host = 3; + * @return The host. */ java.lang.String getHost(); /** * required string host = 3; + * @return The bytes for host. */ com.google.protobuf.ByteString getHostBytes(); /** * required string instance = 4; + * @return Whether the instance field is set. */ boolean hasInstance(); /** * required string instance = 4; + * @return The instance. */ java.lang.String getInstance(); /** * required string instance = 4; + * @return The bytes for instance. */ com.google.protobuf.ByteString getInstanceBytes(); @@ -7533,22 +8213,59 @@ kamino.IngestionV1.SpanOrBuilder getSpansOrBuilder( /** * optional string agent = 6; + * @return Whether the agent field is set. */ boolean hasAgent(); /** * optional string agent = 6; + * @return The agent. */ java.lang.String getAgent(); /** * optional string agent = 6; + * @return The bytes for agent. */ com.google.protobuf.ByteString getAgentBytes(); + + /** + * map<string, string> environmentTags = 7; + */ + int getEnvironmentTagsCount(); + /** + * map<string, string> environmentTags = 7; + */ + boolean containsEnvironmentTags( + java.lang.String key); + /** + * Use {@link #getEnvironmentTagsMap()} instead. + */ + @java.lang.Deprecated + java.util.Map + getEnvironmentTags(); + /** + * map<string, string> environmentTags = 7; + */ + java.util.Map + getEnvironmentTagsMap(); + /** + * map<string, string> environmentTags = 7; + */ + + java.lang.String getEnvironmentTagsOrDefault( + java.lang.String key, + java.lang.String defaultValue); + /** + * map<string, string> environmentTags = 7; + */ + + java.lang.String getEnvironmentTagsOrThrow( + java.lang.String key); } /** * Protobuf type {@code SpanBatch} */ - public static final class SpanBatch extends + public static final class SpanBatch extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:SpanBatch) SpanBatchOrBuilder { @@ -7636,6 +8353,19 @@ private SpanBatch( agent_ = bs; break; } + case 58: { + if (!((mutable_bitField0_ & 0x00000040) != 0)) { + environmentTags_ = com.google.protobuf.MapField.newMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + mutable_bitField0_ |= 0x00000040; + } + com.google.protobuf.MapEntry + environmentTags__ = input.readMessage( + EnvironmentTagsDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry); + environmentTags_.getMutableMap().put( + environmentTags__.getKey(), environmentTags__.getValue()); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -7663,6 +8393,18 @@ private SpanBatch( return kamino.IngestionV1.internal_static_SpanBatch_descriptor; } + @SuppressWarnings({"rawtypes"}) + @java.lang.Override + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 7: + return internalGetEnvironmentTags(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -7676,13 +8418,17 @@ private SpanBatch( private volatile java.lang.Object serviceName_; /** * required string serviceName = 1; + * @return Whether the serviceName field is set. */ + @java.lang.Override public boolean hasServiceName() { return ((bitField0_ & 0x00000001) != 0); } /** * required string serviceName = 1; + * @return The serviceName. */ + @java.lang.Override public java.lang.String getServiceName() { java.lang.Object ref = serviceName_; if (ref instanceof java.lang.String) { @@ -7699,7 +8445,9 @@ public java.lang.String getServiceName() { } /** * required string serviceName = 1; + * @return The bytes for serviceName. */ + @java.lang.Override public com.google.protobuf.ByteString getServiceNameBytes() { java.lang.Object ref = serviceName_; @@ -7718,13 +8466,17 @@ public java.lang.String getServiceName() { private volatile java.lang.Object apiKey_; /** * required string apiKey = 2; + * @return Whether the apiKey field is set. */ + @java.lang.Override public boolean hasApiKey() { return ((bitField0_ & 0x00000002) != 0); } /** * required string apiKey = 2; + * @return The apiKey. */ + @java.lang.Override public java.lang.String getApiKey() { java.lang.Object ref = apiKey_; if (ref instanceof java.lang.String) { @@ -7741,7 +8493,9 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 2; + * @return The bytes for apiKey. */ + @java.lang.Override public com.google.protobuf.ByteString getApiKeyBytes() { java.lang.Object ref = apiKey_; @@ -7760,13 +8514,17 @@ public java.lang.String getApiKey() { private volatile java.lang.Object host_; /** * required string host = 3; + * @return Whether the host field is set. */ + @java.lang.Override public boolean hasHost() { return ((bitField0_ & 0x00000004) != 0); } /** * required string host = 3; + * @return The host. */ + @java.lang.Override public java.lang.String getHost() { java.lang.Object ref = host_; if (ref instanceof java.lang.String) { @@ -7783,7 +8541,9 @@ public java.lang.String getHost() { } /** * required string host = 3; + * @return The bytes for host. */ + @java.lang.Override public com.google.protobuf.ByteString getHostBytes() { java.lang.Object ref = host_; @@ -7802,13 +8562,17 @@ public java.lang.String getHost() { private volatile java.lang.Object instance_; /** * required string instance = 4; + * @return Whether the instance field is set. */ + @java.lang.Override public boolean hasInstance() { return ((bitField0_ & 0x00000008) != 0); } /** * required string instance = 4; + * @return The instance. */ + @java.lang.Override public java.lang.String getInstance() { java.lang.Object ref = instance_; if (ref instanceof java.lang.String) { @@ -7825,7 +8589,9 @@ public java.lang.String getInstance() { } /** * required string instance = 4; + * @return The bytes for instance. */ + @java.lang.Override public com.google.protobuf.ByteString getInstanceBytes() { java.lang.Object ref = instance_; @@ -7845,12 +8611,14 @@ public java.lang.String getInstance() { /** * repeated .Span spans = 5; */ + @java.lang.Override public java.util.List getSpansList() { return spans_; } /** * repeated .Span spans = 5; */ + @java.lang.Override public java.util.List getSpansOrBuilderList() { return spans_; @@ -7858,18 +8626,21 @@ public java.util.List getSpansList() { /** * repeated .Span spans = 5; */ + @java.lang.Override public int getSpansCount() { return spans_.size(); } /** * repeated .Span spans = 5; */ + @java.lang.Override public kamino.IngestionV1.Span getSpans(int index) { return spans_.get(index); } /** * repeated .Span spans = 5; */ + @java.lang.Override public kamino.IngestionV1.SpanOrBuilder getSpansOrBuilder( int index) { return spans_.get(index); @@ -7879,13 +8650,17 @@ public kamino.IngestionV1.SpanOrBuilder getSpansOrBuilder( private volatile java.lang.Object agent_; /** * optional string agent = 6; + * @return Whether the agent field is set. */ + @java.lang.Override public boolean hasAgent() { return ((bitField0_ & 0x00000010) != 0); } /** * optional string agent = 6; + * @return The agent. */ + @java.lang.Override public java.lang.String getAgent() { java.lang.Object ref = agent_; if (ref instanceof java.lang.String) { @@ -7902,7 +8677,9 @@ public java.lang.String getAgent() { } /** * optional string agent = 6; + * @return The bytes for agent. */ + @java.lang.Override public com.google.protobuf.ByteString getAgentBytes() { java.lang.Object ref = agent_; @@ -7917,6 +8694,87 @@ public java.lang.String getAgent() { } } + public static final int ENVIRONMENTTAGS_FIELD_NUMBER = 7; + private static final class EnvironmentTagsDefaultEntryHolder { + static final com.google.protobuf.MapEntry< + java.lang.String, java.lang.String> defaultEntry = + com.google.protobuf.MapEntry + .newDefaultInstance( + kamino.IngestionV1.internal_static_SpanBatch_EnvironmentTagsEntry_descriptor, + com.google.protobuf.WireFormat.FieldType.STRING, + "", + com.google.protobuf.WireFormat.FieldType.STRING, + ""); + } + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> environmentTags_; + private com.google.protobuf.MapField + internalGetEnvironmentTags() { + if (environmentTags_ == null) { + return com.google.protobuf.MapField.emptyMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + } + return environmentTags_; + } + + public int getEnvironmentTagsCount() { + return internalGetEnvironmentTags().getMap().size(); + } + /** + * map<string, string> environmentTags = 7; + */ + + @java.lang.Override + public boolean containsEnvironmentTags( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + return internalGetEnvironmentTags().getMap().containsKey(key); + } + /** + * Use {@link #getEnvironmentTagsMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getEnvironmentTags() { + return getEnvironmentTagsMap(); + } + /** + * map<string, string> environmentTags = 7; + */ + @java.lang.Override + + public java.util.Map getEnvironmentTagsMap() { + return internalGetEnvironmentTags().getMap(); + } + /** + * map<string, string> environmentTags = 7; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> environmentTags = 7; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrThrow( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -7971,6 +8829,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (((bitField0_ & 0x00000010) != 0)) { com.google.protobuf.GeneratedMessageV3.writeString(output, 6, agent_); } + com.google.protobuf.GeneratedMessageV3 + .serializeStringMapTo( + output, + internalGetEnvironmentTags(), + EnvironmentTagsDefaultEntryHolder.defaultEntry, + 7); unknownFields.writeTo(output); } @@ -7994,10 +8858,20 @@ public int getSerializedSize() { } for (int i = 0; i < spans_.size(); i++) { size += com.google.protobuf.CodedOutputStream - .computeMessageSize(5, spans_.get(i)); - } - if (((bitField0_ & 0x00000010) != 0)) { - size += com.google.protobuf.GeneratedMessageV3.computeStringSize(6, agent_); + .computeMessageSize(5, spans_.get(i)); + } + if (((bitField0_ & 0x00000010) != 0)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(6, agent_); + } + for (java.util.Map.Entry entry + : internalGetEnvironmentTags().getMap().entrySet()) { + com.google.protobuf.MapEntry + environmentTags__ = EnvironmentTagsDefaultEntryHolder.defaultEntry.newBuilderForType() + .setKey(entry.getKey()) + .setValue(entry.getValue()) + .build(); + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(7, environmentTags__); } size += unknownFields.getSerializedSize(); memoizedSize = size; @@ -8041,6 +8915,8 @@ public boolean equals(final java.lang.Object obj) { if (!getAgent() .equals(other.getAgent())) return false; } + if (!internalGetEnvironmentTags().equals( + other.internalGetEnvironmentTags())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -8076,6 +8952,10 @@ public int hashCode() { hash = (37 * hash) + AGENT_FIELD_NUMBER; hash = (53 * hash) + getAgent().hashCode(); } + if (!internalGetEnvironmentTags().getMap().isEmpty()) { + hash = (37 * hash) + ENVIRONMENTTAGS_FIELD_NUMBER; + hash = (53 * hash) + internalGetEnvironmentTags().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -8183,6 +9063,28 @@ public static final class Builder extends return kamino.IngestionV1.internal_static_SpanBatch_descriptor; } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 7: + return internalGetEnvironmentTags(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMutableMapField( + int number) { + switch (number) { + case 7: + return internalGetMutableEnvironmentTags(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -8226,6 +9128,7 @@ public Builder clear() { } agent_ = ""; bitField0_ = (bitField0_ & ~0x00000020); + internalGetMutableEnvironmentTags().clear(); return this; } @@ -8283,6 +9186,8 @@ public kamino.IngestionV1.SpanBatch buildPartial() { to_bitField0_ |= 0x00000010; } result.agent_ = agent_; + result.environmentTags_ = internalGetEnvironmentTags(); + result.environmentTags_.makeImmutable(); result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -8383,6 +9288,8 @@ public Builder mergeFrom(kamino.IngestionV1.SpanBatch other) { agent_ = other.agent_; onChanged(); } + internalGetMutableEnvironmentTags().mergeFrom( + other.internalGetEnvironmentTags()); this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -8433,12 +9340,14 @@ public Builder mergeFrom( private java.lang.Object serviceName_ = ""; /** * required string serviceName = 1; + * @return Whether the serviceName field is set. */ public boolean hasServiceName() { return ((bitField0_ & 0x00000001) != 0); } /** * required string serviceName = 1; + * @return The serviceName. */ public java.lang.String getServiceName() { java.lang.Object ref = serviceName_; @@ -8456,6 +9365,7 @@ public java.lang.String getServiceName() { } /** * required string serviceName = 1; + * @return The bytes for serviceName. */ public com.google.protobuf.ByteString getServiceNameBytes() { @@ -8472,6 +9382,8 @@ public java.lang.String getServiceName() { } /** * required string serviceName = 1; + * @param value The serviceName to set. + * @return This builder for chaining. */ public Builder setServiceName( java.lang.String value) { @@ -8485,6 +9397,7 @@ public Builder setServiceName( } /** * required string serviceName = 1; + * @return This builder for chaining. */ public Builder clearServiceName() { bitField0_ = (bitField0_ & ~0x00000001); @@ -8494,6 +9407,8 @@ public Builder clearServiceName() { } /** * required string serviceName = 1; + * @param value The bytes for serviceName to set. + * @return This builder for chaining. */ public Builder setServiceNameBytes( com.google.protobuf.ByteString value) { @@ -8509,12 +9424,14 @@ public Builder setServiceNameBytes( private java.lang.Object apiKey_ = ""; /** * required string apiKey = 2; + * @return Whether the apiKey field is set. */ public boolean hasApiKey() { return ((bitField0_ & 0x00000002) != 0); } /** * required string apiKey = 2; + * @return The apiKey. */ public java.lang.String getApiKey() { java.lang.Object ref = apiKey_; @@ -8532,6 +9449,7 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 2; + * @return The bytes for apiKey. */ public com.google.protobuf.ByteString getApiKeyBytes() { @@ -8548,6 +9466,8 @@ public java.lang.String getApiKey() { } /** * required string apiKey = 2; + * @param value The apiKey to set. + * @return This builder for chaining. */ public Builder setApiKey( java.lang.String value) { @@ -8561,6 +9481,7 @@ public Builder setApiKey( } /** * required string apiKey = 2; + * @return This builder for chaining. */ public Builder clearApiKey() { bitField0_ = (bitField0_ & ~0x00000002); @@ -8570,6 +9491,8 @@ public Builder clearApiKey() { } /** * required string apiKey = 2; + * @param value The bytes for apiKey to set. + * @return This builder for chaining. */ public Builder setApiKeyBytes( com.google.protobuf.ByteString value) { @@ -8585,12 +9508,14 @@ public Builder setApiKeyBytes( private java.lang.Object host_ = ""; /** * required string host = 3; + * @return Whether the host field is set. */ public boolean hasHost() { return ((bitField0_ & 0x00000004) != 0); } /** * required string host = 3; + * @return The host. */ public java.lang.String getHost() { java.lang.Object ref = host_; @@ -8608,6 +9533,7 @@ public java.lang.String getHost() { } /** * required string host = 3; + * @return The bytes for host. */ public com.google.protobuf.ByteString getHostBytes() { @@ -8624,6 +9550,8 @@ public java.lang.String getHost() { } /** * required string host = 3; + * @param value The host to set. + * @return This builder for chaining. */ public Builder setHost( java.lang.String value) { @@ -8637,6 +9565,7 @@ public Builder setHost( } /** * required string host = 3; + * @return This builder for chaining. */ public Builder clearHost() { bitField0_ = (bitField0_ & ~0x00000004); @@ -8646,6 +9575,8 @@ public Builder clearHost() { } /** * required string host = 3; + * @param value The bytes for host to set. + * @return This builder for chaining. */ public Builder setHostBytes( com.google.protobuf.ByteString value) { @@ -8661,12 +9592,14 @@ public Builder setHostBytes( private java.lang.Object instance_ = ""; /** * required string instance = 4; + * @return Whether the instance field is set. */ public boolean hasInstance() { return ((bitField0_ & 0x00000008) != 0); } /** * required string instance = 4; + * @return The instance. */ public java.lang.String getInstance() { java.lang.Object ref = instance_; @@ -8684,6 +9617,7 @@ public java.lang.String getInstance() { } /** * required string instance = 4; + * @return The bytes for instance. */ public com.google.protobuf.ByteString getInstanceBytes() { @@ -8700,6 +9634,8 @@ public java.lang.String getInstance() { } /** * required string instance = 4; + * @param value The instance to set. + * @return This builder for chaining. */ public Builder setInstance( java.lang.String value) { @@ -8713,6 +9649,7 @@ public Builder setInstance( } /** * required string instance = 4; + * @return This builder for chaining. */ public Builder clearInstance() { bitField0_ = (bitField0_ & ~0x00000008); @@ -8722,6 +9659,8 @@ public Builder clearInstance() { } /** * required string instance = 4; + * @param value The bytes for instance to set. + * @return This builder for chaining. */ public Builder setInstanceBytes( com.google.protobuf.ByteString value) { @@ -8977,12 +9916,14 @@ public kamino.IngestionV1.Span.Builder addSpansBuilder( private java.lang.Object agent_ = ""; /** * optional string agent = 6; + * @return Whether the agent field is set. */ public boolean hasAgent() { return ((bitField0_ & 0x00000020) != 0); } /** * optional string agent = 6; + * @return The agent. */ public java.lang.String getAgent() { java.lang.Object ref = agent_; @@ -9000,6 +9941,7 @@ public java.lang.String getAgent() { } /** * optional string agent = 6; + * @return The bytes for agent. */ public com.google.protobuf.ByteString getAgentBytes() { @@ -9016,6 +9958,8 @@ public java.lang.String getAgent() { } /** * optional string agent = 6; + * @param value The agent to set. + * @return This builder for chaining. */ public Builder setAgent( java.lang.String value) { @@ -9029,6 +9973,7 @@ public Builder setAgent( } /** * optional string agent = 6; + * @return This builder for chaining. */ public Builder clearAgent() { bitField0_ = (bitField0_ & ~0x00000020); @@ -9038,6 +9983,8 @@ public Builder clearAgent() { } /** * optional string agent = 6; + * @param value The bytes for agent to set. + * @return This builder for chaining. */ public Builder setAgentBytes( com.google.protobuf.ByteString value) { @@ -9049,6 +9996,134 @@ public Builder setAgentBytes( onChanged(); return this; } + + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> environmentTags_; + private com.google.protobuf.MapField + internalGetEnvironmentTags() { + if (environmentTags_ == null) { + return com.google.protobuf.MapField.emptyMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + } + return environmentTags_; + } + private com.google.protobuf.MapField + internalGetMutableEnvironmentTags() { + onChanged();; + if (environmentTags_ == null) { + environmentTags_ = com.google.protobuf.MapField.newMapField( + EnvironmentTagsDefaultEntryHolder.defaultEntry); + } + if (!environmentTags_.isMutable()) { + environmentTags_ = environmentTags_.copy(); + } + return environmentTags_; + } + + public int getEnvironmentTagsCount() { + return internalGetEnvironmentTags().getMap().size(); + } + /** + * map<string, string> environmentTags = 7; + */ + + @java.lang.Override + public boolean containsEnvironmentTags( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + return internalGetEnvironmentTags().getMap().containsKey(key); + } + /** + * Use {@link #getEnvironmentTagsMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getEnvironmentTags() { + return getEnvironmentTagsMap(); + } + /** + * map<string, string> environmentTags = 7; + */ + @java.lang.Override + + public java.util.Map getEnvironmentTagsMap() { + return internalGetEnvironmentTags().getMap(); + } + /** + * map<string, string> environmentTags = 7; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> environmentTags = 7; + */ + @java.lang.Override + + public java.lang.String getEnvironmentTagsOrThrow( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + java.util.Map map = + internalGetEnvironmentTags().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + + public Builder clearEnvironmentTags() { + internalGetMutableEnvironmentTags().getMutableMap() + .clear(); + return this; + } + /** + * map<string, string> environmentTags = 7; + */ + + public Builder removeEnvironmentTags( + java.lang.String key) { + if (key == null) { throw new java.lang.NullPointerException(); } + internalGetMutableEnvironmentTags().getMutableMap() + .remove(key); + return this; + } + /** + * Use alternate mutation accessors instead. + */ + @java.lang.Deprecated + public java.util.Map + getMutableEnvironmentTags() { + return internalGetMutableEnvironmentTags().getMutableMap(); + } + /** + * map<string, string> environmentTags = 7; + */ + public Builder putEnvironmentTags( + java.lang.String key, + java.lang.String value) { + if (key == null) { throw new java.lang.NullPointerException(); } + if (value == null) { throw new java.lang.NullPointerException(); } + internalGetMutableEnvironmentTags().getMutableMap() + .put(key, value); + return this; + } + /** + * map<string, string> environmentTags = 7; + */ + + public Builder putAllEnvironmentTags( + java.util.Map values) { + internalGetMutableEnvironmentTags().getMutableMap() + .putAll(values); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -9108,23 +10183,28 @@ public interface MarkOrBuilder extends /** * required int64 instant = 1; + * @return Whether the instant field is set. */ boolean hasInstant(); /** * required int64 instant = 1; + * @return The instant. */ long getInstant(); /** * required string key = 2; + * @return Whether the key field is set. */ boolean hasKey(); /** * required string key = 2; + * @return The key. */ java.lang.String getKey(); /** * required string key = 2; + * @return The bytes for key. */ com.google.protobuf.ByteString getKeyBytes(); @@ -9132,7 +10212,7 @@ public interface MarkOrBuilder extends /** * Protobuf type {@code Mark} */ - public static final class Mark extends + public static final class Mark extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:Mark) MarkOrBuilder { @@ -9224,13 +10304,17 @@ private Mark( private long instant_; /** * required int64 instant = 1; + * @return Whether the instant field is set. */ + @java.lang.Override public boolean hasInstant() { return ((bitField0_ & 0x00000001) != 0); } /** * required int64 instant = 1; + * @return The instant. */ + @java.lang.Override public long getInstant() { return instant_; } @@ -9239,13 +10323,17 @@ public long getInstant() { private volatile java.lang.Object key_; /** * required string key = 2; + * @return Whether the key field is set. */ + @java.lang.Override public boolean hasKey() { return ((bitField0_ & 0x00000002) != 0); } /** * required string key = 2; + * @return The key. */ + @java.lang.Override public java.lang.String getKey() { java.lang.Object ref = key_; if (ref instanceof java.lang.String) { @@ -9262,7 +10350,9 @@ public java.lang.String getKey() { } /** * required string key = 2; + * @return The bytes for key. */ + @java.lang.Override public com.google.protobuf.ByteString getKeyBytes() { java.lang.Object ref = key_; @@ -9635,18 +10725,24 @@ public Builder mergeFrom( private long instant_ ; /** * required int64 instant = 1; + * @return Whether the instant field is set. */ + @java.lang.Override public boolean hasInstant() { return ((bitField0_ & 0x00000001) != 0); } /** * required int64 instant = 1; + * @return The instant. */ + @java.lang.Override public long getInstant() { return instant_; } /** * required int64 instant = 1; + * @param value The instant to set. + * @return This builder for chaining. */ public Builder setInstant(long value) { bitField0_ |= 0x00000001; @@ -9656,6 +10752,7 @@ public Builder setInstant(long value) { } /** * required int64 instant = 1; + * @return This builder for chaining. */ public Builder clearInstant() { bitField0_ = (bitField0_ & ~0x00000001); @@ -9667,12 +10764,14 @@ public Builder clearInstant() { private java.lang.Object key_ = ""; /** * required string key = 2; + * @return Whether the key field is set. */ public boolean hasKey() { return ((bitField0_ & 0x00000002) != 0); } /** * required string key = 2; + * @return The key. */ public java.lang.String getKey() { java.lang.Object ref = key_; @@ -9690,6 +10789,7 @@ public java.lang.String getKey() { } /** * required string key = 2; + * @return The bytes for key. */ public com.google.protobuf.ByteString getKeyBytes() { @@ -9706,6 +10806,8 @@ public java.lang.String getKey() { } /** * required string key = 2; + * @param value The key to set. + * @return This builder for chaining. */ public Builder setKey( java.lang.String value) { @@ -9719,6 +10821,7 @@ public Builder setKey( } /** * required string key = 2; + * @return This builder for chaining. */ public Builder clearKey() { bitField0_ = (bitField0_ & ~0x00000002); @@ -9728,6 +10831,8 @@ public Builder clearKey() { } /** * required string key = 2; + * @param value The bytes for key to set. + * @return This builder for chaining. */ public Builder setKeyBytes( com.google.protobuf.ByteString value) { @@ -9798,75 +10903,91 @@ public interface SpanOrBuilder extends /** * required string id = 1; + * @return Whether the id field is set. */ boolean hasId(); /** * required string id = 1; + * @return The id. */ java.lang.String getId(); /** * required string id = 1; + * @return The bytes for id. */ com.google.protobuf.ByteString getIdBytes(); /** * required string traceId = 2; + * @return Whether the traceId field is set. */ boolean hasTraceId(); /** * required string traceId = 2; + * @return The traceId. */ java.lang.String getTraceId(); /** * required string traceId = 2; + * @return The bytes for traceId. */ com.google.protobuf.ByteString getTraceIdBytes(); /** * required string parentId = 3; + * @return Whether the parentId field is set. */ boolean hasParentId(); /** * required string parentId = 3; + * @return The parentId. */ java.lang.String getParentId(); /** * required string parentId = 3; + * @return The bytes for parentId. */ com.google.protobuf.ByteString getParentIdBytes(); /** * required string operationName = 4; + * @return Whether the operationName field is set. */ boolean hasOperationName(); /** * required string operationName = 4; + * @return The operationName. */ java.lang.String getOperationName(); /** * required string operationName = 4; + * @return The bytes for operationName. */ com.google.protobuf.ByteString getOperationNameBytes(); /** * required int64 startMicros = 5; + * @return Whether the startMicros field is set. */ boolean hasStartMicros(); /** * required int64 startMicros = 5; + * @return The startMicros. */ long getStartMicros(); /** * required int64 endMicros = 6; + * @return Whether the endMicros field is set. */ boolean hasEndMicros(); /** * required int64 endMicros = 6; + * @return The endMicros. */ long getEndMicros(); @@ -9934,6 +11055,7 @@ kamino.IngestionV1.MarkOrBuilder getMarksOrBuilder( * * * optional bool hasError = 9; + * @return Whether the hasError field is set. */ boolean hasHasError(); /** @@ -9942,33 +11064,40 @@ kamino.IngestionV1.MarkOrBuilder getMarksOrBuilder( * * * optional bool hasError = 9; + * @return The hasError. */ boolean getHasError(); /** * optional bool wasDelayed = 10; + * @return Whether the wasDelayed field is set. */ boolean hasWasDelayed(); /** * optional bool wasDelayed = 10; + * @return The wasDelayed. */ boolean getWasDelayed(); /** * optional .SpanKind kind = 11; + * @return Whether the kind field is set. */ boolean hasKind(); /** * optional .SpanKind kind = 11; + * @return The kind. */ kamino.IngestionV1.SpanKind getKind(); /** * optional .SpanPosition position = 12; + * @return Whether the position field is set. */ boolean hasPosition(); /** * optional .SpanPosition position = 12; + * @return The position. */ kamino.IngestionV1.SpanPosition getPosition(); @@ -10033,7 +11162,7 @@ kamino.IngestionV1.LinkOrBuilder getLinksOrBuilder( /** * Protobuf type {@code Span} */ - public static final class Span extends + public static final class Span extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:Span) SpanOrBuilder { @@ -10253,13 +11382,17 @@ protected com.google.protobuf.MapField internalGetMapField( private volatile java.lang.Object id_; /** * required string id = 1; + * @return Whether the id field is set. */ + @java.lang.Override public boolean hasId() { return ((bitField0_ & 0x00000001) != 0); } /** * required string id = 1; + * @return The id. */ + @java.lang.Override public java.lang.String getId() { java.lang.Object ref = id_; if (ref instanceof java.lang.String) { @@ -10276,7 +11409,9 @@ public java.lang.String getId() { } /** * required string id = 1; + * @return The bytes for id. */ + @java.lang.Override public com.google.protobuf.ByteString getIdBytes() { java.lang.Object ref = id_; @@ -10295,13 +11430,17 @@ public java.lang.String getId() { private volatile java.lang.Object traceId_; /** * required string traceId = 2; + * @return Whether the traceId field is set. */ + @java.lang.Override public boolean hasTraceId() { return ((bitField0_ & 0x00000002) != 0); } /** * required string traceId = 2; + * @return The traceId. */ + @java.lang.Override public java.lang.String getTraceId() { java.lang.Object ref = traceId_; if (ref instanceof java.lang.String) { @@ -10318,7 +11457,9 @@ public java.lang.String getTraceId() { } /** * required string traceId = 2; + * @return The bytes for traceId. */ + @java.lang.Override public com.google.protobuf.ByteString getTraceIdBytes() { java.lang.Object ref = traceId_; @@ -10337,13 +11478,17 @@ public java.lang.String getTraceId() { private volatile java.lang.Object parentId_; /** * required string parentId = 3; + * @return Whether the parentId field is set. */ + @java.lang.Override public boolean hasParentId() { return ((bitField0_ & 0x00000004) != 0); } /** * required string parentId = 3; + * @return The parentId. */ + @java.lang.Override public java.lang.String getParentId() { java.lang.Object ref = parentId_; if (ref instanceof java.lang.String) { @@ -10360,7 +11505,9 @@ public java.lang.String getParentId() { } /** * required string parentId = 3; + * @return The bytes for parentId. */ + @java.lang.Override public com.google.protobuf.ByteString getParentIdBytes() { java.lang.Object ref = parentId_; @@ -10379,13 +11526,17 @@ public java.lang.String getParentId() { private volatile java.lang.Object operationName_; /** * required string operationName = 4; + * @return Whether the operationName field is set. */ + @java.lang.Override public boolean hasOperationName() { return ((bitField0_ & 0x00000008) != 0); } /** * required string operationName = 4; + * @return The operationName. */ + @java.lang.Override public java.lang.String getOperationName() { java.lang.Object ref = operationName_; if (ref instanceof java.lang.String) { @@ -10402,7 +11553,9 @@ public java.lang.String getOperationName() { } /** * required string operationName = 4; + * @return The bytes for operationName. */ + @java.lang.Override public com.google.protobuf.ByteString getOperationNameBytes() { java.lang.Object ref = operationName_; @@ -10421,13 +11574,17 @@ public java.lang.String getOperationName() { private long startMicros_; /** * required int64 startMicros = 5; + * @return Whether the startMicros field is set. */ + @java.lang.Override public boolean hasStartMicros() { return ((bitField0_ & 0x00000010) != 0); } /** * required int64 startMicros = 5; + * @return The startMicros. */ + @java.lang.Override public long getStartMicros() { return startMicros_; } @@ -10436,13 +11593,17 @@ public long getStartMicros() { private long endMicros_; /** * required int64 endMicros = 6; + * @return Whether the endMicros field is set. */ + @java.lang.Override public boolean hasEndMicros() { return ((bitField0_ & 0x00000020) != 0); } /** * required int64 endMicros = 6; + * @return The endMicros. */ + @java.lang.Override public long getEndMicros() { return endMicros_; } @@ -10477,6 +11638,7 @@ public int getTagsCount() { * map<string, string> tags = 7; */ + @java.lang.Override public boolean containsTags( java.lang.String key) { if (key == null) { throw new java.lang.NullPointerException(); } @@ -10485,6 +11647,7 @@ public boolean containsTags( /** * Use {@link #getTagsMap()} instead. */ + @java.lang.Override @java.lang.Deprecated public java.util.Map getTags() { return getTagsMap(); @@ -10492,6 +11655,7 @@ public java.util.Map getTags() { /** * map<string, string> tags = 7; */ + @java.lang.Override public java.util.Map getTagsMap() { return internalGetTags().getMap(); @@ -10499,6 +11663,7 @@ public java.util.Map getTagsMap() { /** * map<string, string> tags = 7; */ + @java.lang.Override public java.lang.String getTagsOrDefault( java.lang.String key, @@ -10511,6 +11676,7 @@ public java.lang.String getTagsOrDefault( /** * map<string, string> tags = 7; */ + @java.lang.Override public java.lang.String getTagsOrThrow( java.lang.String key) { @@ -10528,12 +11694,14 @@ public java.lang.String getTagsOrThrow( /** * repeated .Mark marks = 8; */ + @java.lang.Override public java.util.List getMarksList() { return marks_; } /** * repeated .Mark marks = 8; */ + @java.lang.Override public java.util.List getMarksOrBuilderList() { return marks_; @@ -10541,18 +11709,21 @@ public java.util.List getMarksList() { /** * repeated .Mark marks = 8; */ + @java.lang.Override public int getMarksCount() { return marks_.size(); } /** * repeated .Mark marks = 8; */ + @java.lang.Override public kamino.IngestionV1.Mark getMarks(int index) { return marks_.get(index); } /** * repeated .Mark marks = 8; */ + @java.lang.Override public kamino.IngestionV1.MarkOrBuilder getMarksOrBuilder( int index) { return marks_.get(index); @@ -10566,7 +11737,9 @@ public kamino.IngestionV1.MarkOrBuilder getMarksOrBuilder( * * * optional bool hasError = 9; + * @return Whether the hasError field is set. */ + @java.lang.Override public boolean hasHasError() { return ((bitField0_ & 0x00000040) != 0); } @@ -10576,7 +11749,9 @@ public boolean hasHasError() { * * * optional bool hasError = 9; + * @return The hasError. */ + @java.lang.Override public boolean getHasError() { return hasError_; } @@ -10585,13 +11760,17 @@ public boolean getHasError() { private boolean wasDelayed_; /** * optional bool wasDelayed = 10; + * @return Whether the wasDelayed field is set. */ + @java.lang.Override public boolean hasWasDelayed() { return ((bitField0_ & 0x00000080) != 0); } /** * optional bool wasDelayed = 10; + * @return The wasDelayed. */ + @java.lang.Override public boolean getWasDelayed() { return wasDelayed_; } @@ -10600,14 +11779,16 @@ public boolean getWasDelayed() { private int kind_; /** * optional .SpanKind kind = 11; + * @return Whether the kind field is set. */ - public boolean hasKind() { + @java.lang.Override public boolean hasKind() { return ((bitField0_ & 0x00000100) != 0); } /** * optional .SpanKind kind = 11; + * @return The kind. */ - public kamino.IngestionV1.SpanKind getKind() { + @java.lang.Override public kamino.IngestionV1.SpanKind getKind() { @SuppressWarnings("deprecation") kamino.IngestionV1.SpanKind result = kamino.IngestionV1.SpanKind.valueOf(kind_); return result == null ? kamino.IngestionV1.SpanKind.UNKNOWN : result; @@ -10617,14 +11798,16 @@ public kamino.IngestionV1.SpanKind getKind() { private int position_; /** * optional .SpanPosition position = 12; + * @return Whether the position field is set. */ - public boolean hasPosition() { + @java.lang.Override public boolean hasPosition() { return ((bitField0_ & 0x00000200) != 0); } /** * optional .SpanPosition position = 12; + * @return The position. */ - public kamino.IngestionV1.SpanPosition getPosition() { + @java.lang.Override public kamino.IngestionV1.SpanPosition getPosition() { @SuppressWarnings("deprecation") kamino.IngestionV1.SpanPosition result = kamino.IngestionV1.SpanPosition.valueOf(position_); return result == null ? kamino.IngestionV1.SpanPosition.POSITION_UNKNOWN : result; @@ -10660,6 +11843,7 @@ public int getMetricTagsCount() { * map<string, string> metricTags = 13; */ + @java.lang.Override public boolean containsMetricTags( java.lang.String key) { if (key == null) { throw new java.lang.NullPointerException(); } @@ -10668,6 +11852,7 @@ public boolean containsMetricTags( /** * Use {@link #getMetricTagsMap()} instead. */ + @java.lang.Override @java.lang.Deprecated public java.util.Map getMetricTags() { return getMetricTagsMap(); @@ -10675,6 +11860,7 @@ public java.util.Map getMetricTags() { /** * map<string, string> metricTags = 13; */ + @java.lang.Override public java.util.Map getMetricTagsMap() { return internalGetMetricTags().getMap(); @@ -10682,6 +11868,7 @@ public java.util.Map getMetricTagsMap() { /** * map<string, string> metricTags = 13; */ + @java.lang.Override public java.lang.String getMetricTagsOrDefault( java.lang.String key, @@ -10694,6 +11881,7 @@ public java.lang.String getMetricTagsOrDefault( /** * map<string, string> metricTags = 13; */ + @java.lang.Override public java.lang.String getMetricTagsOrThrow( java.lang.String key) { @@ -10711,12 +11899,14 @@ public java.lang.String getMetricTagsOrThrow( /** * repeated .Link links = 14; */ + @java.lang.Override public java.util.List getLinksList() { return links_; } /** * repeated .Link links = 14; */ + @java.lang.Override public java.util.List getLinksOrBuilderList() { return links_; @@ -10724,18 +11914,21 @@ public java.util.List getLinksList() { /** * repeated .Link links = 14; */ + @java.lang.Override public int getLinksCount() { return links_.size(); } /** * repeated .Link links = 14; */ + @java.lang.Override public kamino.IngestionV1.Link getLinks(int index) { return links_.get(index); } /** * repeated .Link links = 14; */ + @java.lang.Override public kamino.IngestionV1.LinkOrBuilder getLinksOrBuilder( int index) { return links_.get(index); @@ -11543,12 +12736,14 @@ public Builder mergeFrom( private java.lang.Object id_ = ""; /** * required string id = 1; + * @return Whether the id field is set. */ public boolean hasId() { return ((bitField0_ & 0x00000001) != 0); } /** * required string id = 1; + * @return The id. */ public java.lang.String getId() { java.lang.Object ref = id_; @@ -11566,6 +12761,7 @@ public java.lang.String getId() { } /** * required string id = 1; + * @return The bytes for id. */ public com.google.protobuf.ByteString getIdBytes() { @@ -11582,6 +12778,8 @@ public java.lang.String getId() { } /** * required string id = 1; + * @param value The id to set. + * @return This builder for chaining. */ public Builder setId( java.lang.String value) { @@ -11595,6 +12793,7 @@ public Builder setId( } /** * required string id = 1; + * @return This builder for chaining. */ public Builder clearId() { bitField0_ = (bitField0_ & ~0x00000001); @@ -11604,6 +12803,8 @@ public Builder clearId() { } /** * required string id = 1; + * @param value The bytes for id to set. + * @return This builder for chaining. */ public Builder setIdBytes( com.google.protobuf.ByteString value) { @@ -11619,12 +12820,14 @@ public Builder setIdBytes( private java.lang.Object traceId_ = ""; /** * required string traceId = 2; + * @return Whether the traceId field is set. */ public boolean hasTraceId() { return ((bitField0_ & 0x00000002) != 0); } /** * required string traceId = 2; + * @return The traceId. */ public java.lang.String getTraceId() { java.lang.Object ref = traceId_; @@ -11642,6 +12845,7 @@ public java.lang.String getTraceId() { } /** * required string traceId = 2; + * @return The bytes for traceId. */ public com.google.protobuf.ByteString getTraceIdBytes() { @@ -11658,6 +12862,8 @@ public java.lang.String getTraceId() { } /** * required string traceId = 2; + * @param value The traceId to set. + * @return This builder for chaining. */ public Builder setTraceId( java.lang.String value) { @@ -11671,6 +12877,7 @@ public Builder setTraceId( } /** * required string traceId = 2; + * @return This builder for chaining. */ public Builder clearTraceId() { bitField0_ = (bitField0_ & ~0x00000002); @@ -11680,6 +12887,8 @@ public Builder clearTraceId() { } /** * required string traceId = 2; + * @param value The bytes for traceId to set. + * @return This builder for chaining. */ public Builder setTraceIdBytes( com.google.protobuf.ByteString value) { @@ -11695,12 +12904,14 @@ public Builder setTraceIdBytes( private java.lang.Object parentId_ = ""; /** * required string parentId = 3; + * @return Whether the parentId field is set. */ public boolean hasParentId() { return ((bitField0_ & 0x00000004) != 0); } /** * required string parentId = 3; + * @return The parentId. */ public java.lang.String getParentId() { java.lang.Object ref = parentId_; @@ -11718,6 +12929,7 @@ public java.lang.String getParentId() { } /** * required string parentId = 3; + * @return The bytes for parentId. */ public com.google.protobuf.ByteString getParentIdBytes() { @@ -11734,6 +12946,8 @@ public java.lang.String getParentId() { } /** * required string parentId = 3; + * @param value The parentId to set. + * @return This builder for chaining. */ public Builder setParentId( java.lang.String value) { @@ -11747,6 +12961,7 @@ public Builder setParentId( } /** * required string parentId = 3; + * @return This builder for chaining. */ public Builder clearParentId() { bitField0_ = (bitField0_ & ~0x00000004); @@ -11756,6 +12971,8 @@ public Builder clearParentId() { } /** * required string parentId = 3; + * @param value The bytes for parentId to set. + * @return This builder for chaining. */ public Builder setParentIdBytes( com.google.protobuf.ByteString value) { @@ -11771,12 +12988,14 @@ public Builder setParentIdBytes( private java.lang.Object operationName_ = ""; /** * required string operationName = 4; + * @return Whether the operationName field is set. */ public boolean hasOperationName() { return ((bitField0_ & 0x00000008) != 0); } /** * required string operationName = 4; + * @return The operationName. */ public java.lang.String getOperationName() { java.lang.Object ref = operationName_; @@ -11794,6 +13013,7 @@ public java.lang.String getOperationName() { } /** * required string operationName = 4; + * @return The bytes for operationName. */ public com.google.protobuf.ByteString getOperationNameBytes() { @@ -11810,6 +13030,8 @@ public java.lang.String getOperationName() { } /** * required string operationName = 4; + * @param value The operationName to set. + * @return This builder for chaining. */ public Builder setOperationName( java.lang.String value) { @@ -11823,6 +13045,7 @@ public Builder setOperationName( } /** * required string operationName = 4; + * @return This builder for chaining. */ public Builder clearOperationName() { bitField0_ = (bitField0_ & ~0x00000008); @@ -11832,6 +13055,8 @@ public Builder clearOperationName() { } /** * required string operationName = 4; + * @param value The bytes for operationName to set. + * @return This builder for chaining. */ public Builder setOperationNameBytes( com.google.protobuf.ByteString value) { @@ -11847,18 +13072,24 @@ public Builder setOperationNameBytes( private long startMicros_ ; /** * required int64 startMicros = 5; + * @return Whether the startMicros field is set. */ + @java.lang.Override public boolean hasStartMicros() { return ((bitField0_ & 0x00000010) != 0); } /** * required int64 startMicros = 5; + * @return The startMicros. */ + @java.lang.Override public long getStartMicros() { return startMicros_; } /** * required int64 startMicros = 5; + * @param value The startMicros to set. + * @return This builder for chaining. */ public Builder setStartMicros(long value) { bitField0_ |= 0x00000010; @@ -11868,6 +13099,7 @@ public Builder setStartMicros(long value) { } /** * required int64 startMicros = 5; + * @return This builder for chaining. */ public Builder clearStartMicros() { bitField0_ = (bitField0_ & ~0x00000010); @@ -11879,18 +13111,24 @@ public Builder clearStartMicros() { private long endMicros_ ; /** * required int64 endMicros = 6; + * @return Whether the endMicros field is set. */ + @java.lang.Override public boolean hasEndMicros() { return ((bitField0_ & 0x00000020) != 0); } /** * required int64 endMicros = 6; + * @return The endMicros. */ + @java.lang.Override public long getEndMicros() { return endMicros_; } /** * required int64 endMicros = 6; + * @param value The endMicros to set. + * @return This builder for chaining. */ public Builder setEndMicros(long value) { bitField0_ |= 0x00000020; @@ -11900,6 +13138,7 @@ public Builder setEndMicros(long value) { } /** * required int64 endMicros = 6; + * @return This builder for chaining. */ public Builder clearEndMicros() { bitField0_ = (bitField0_ & ~0x00000020); @@ -11938,6 +13177,7 @@ public int getTagsCount() { * map<string, string> tags = 7; */ + @java.lang.Override public boolean containsTags( java.lang.String key) { if (key == null) { throw new java.lang.NullPointerException(); } @@ -11946,6 +13186,7 @@ public boolean containsTags( /** * Use {@link #getTagsMap()} instead. */ + @java.lang.Override @java.lang.Deprecated public java.util.Map getTags() { return getTagsMap(); @@ -11953,6 +13194,7 @@ public java.util.Map getTags() { /** * map<string, string> tags = 7; */ + @java.lang.Override public java.util.Map getTagsMap() { return internalGetTags().getMap(); @@ -11960,6 +13202,7 @@ public java.util.Map getTagsMap() { /** * map<string, string> tags = 7; */ + @java.lang.Override public java.lang.String getTagsOrDefault( java.lang.String key, @@ -11972,6 +13215,7 @@ public java.lang.String getTagsOrDefault( /** * map<string, string> tags = 7; */ + @java.lang.Override public java.lang.String getTagsOrThrow( java.lang.String key) { @@ -12278,7 +13522,9 @@ public kamino.IngestionV1.Mark.Builder addMarksBuilder( * * * optional bool hasError = 9; + * @return Whether the hasError field is set. */ + @java.lang.Override public boolean hasHasError() { return ((bitField0_ & 0x00000100) != 0); } @@ -12288,7 +13534,9 @@ public boolean hasHasError() { * * * optional bool hasError = 9; + * @return The hasError. */ + @java.lang.Override public boolean getHasError() { return hasError_; } @@ -12298,6 +13546,8 @@ public boolean getHasError() { * * * optional bool hasError = 9; + * @param value The hasError to set. + * @return This builder for chaining. */ public Builder setHasError(boolean value) { bitField0_ |= 0x00000100; @@ -12311,6 +13561,7 @@ public Builder setHasError(boolean value) { * * * optional bool hasError = 9; + * @return This builder for chaining. */ public Builder clearHasError() { bitField0_ = (bitField0_ & ~0x00000100); @@ -12322,18 +13573,24 @@ public Builder clearHasError() { private boolean wasDelayed_ ; /** * optional bool wasDelayed = 10; + * @return Whether the wasDelayed field is set. */ + @java.lang.Override public boolean hasWasDelayed() { return ((bitField0_ & 0x00000200) != 0); } /** * optional bool wasDelayed = 10; + * @return The wasDelayed. */ + @java.lang.Override public boolean getWasDelayed() { return wasDelayed_; } /** * optional bool wasDelayed = 10; + * @param value The wasDelayed to set. + * @return This builder for chaining. */ public Builder setWasDelayed(boolean value) { bitField0_ |= 0x00000200; @@ -12343,6 +13600,7 @@ public Builder setWasDelayed(boolean value) { } /** * optional bool wasDelayed = 10; + * @return This builder for chaining. */ public Builder clearWasDelayed() { bitField0_ = (bitField0_ & ~0x00000200); @@ -12354,13 +13612,16 @@ public Builder clearWasDelayed() { private int kind_ = 0; /** * optional .SpanKind kind = 11; + * @return Whether the kind field is set. */ - public boolean hasKind() { + @java.lang.Override public boolean hasKind() { return ((bitField0_ & 0x00000400) != 0); } /** * optional .SpanKind kind = 11; + * @return The kind. */ + @java.lang.Override public kamino.IngestionV1.SpanKind getKind() { @SuppressWarnings("deprecation") kamino.IngestionV1.SpanKind result = kamino.IngestionV1.SpanKind.valueOf(kind_); @@ -12368,6 +13629,8 @@ public kamino.IngestionV1.SpanKind getKind() { } /** * optional .SpanKind kind = 11; + * @param value The kind to set. + * @return This builder for chaining. */ public Builder setKind(kamino.IngestionV1.SpanKind value) { if (value == null) { @@ -12380,6 +13643,7 @@ public Builder setKind(kamino.IngestionV1.SpanKind value) { } /** * optional .SpanKind kind = 11; + * @return This builder for chaining. */ public Builder clearKind() { bitField0_ = (bitField0_ & ~0x00000400); @@ -12391,13 +13655,16 @@ public Builder clearKind() { private int position_ = 0; /** * optional .SpanPosition position = 12; + * @return Whether the position field is set. */ - public boolean hasPosition() { + @java.lang.Override public boolean hasPosition() { return ((bitField0_ & 0x00000800) != 0); } /** * optional .SpanPosition position = 12; + * @return The position. */ + @java.lang.Override public kamino.IngestionV1.SpanPosition getPosition() { @SuppressWarnings("deprecation") kamino.IngestionV1.SpanPosition result = kamino.IngestionV1.SpanPosition.valueOf(position_); @@ -12405,6 +13672,8 @@ public kamino.IngestionV1.SpanPosition getPosition() { } /** * optional .SpanPosition position = 12; + * @param value The position to set. + * @return This builder for chaining. */ public Builder setPosition(kamino.IngestionV1.SpanPosition value) { if (value == null) { @@ -12417,6 +13686,7 @@ public Builder setPosition(kamino.IngestionV1.SpanPosition value) { } /** * optional .SpanPosition position = 12; + * @return This builder for chaining. */ public Builder clearPosition() { bitField0_ = (bitField0_ & ~0x00000800); @@ -12455,6 +13725,7 @@ public int getMetricTagsCount() { * map<string, string> metricTags = 13; */ + @java.lang.Override public boolean containsMetricTags( java.lang.String key) { if (key == null) { throw new java.lang.NullPointerException(); } @@ -12463,6 +13734,7 @@ public boolean containsMetricTags( /** * Use {@link #getMetricTagsMap()} instead. */ + @java.lang.Override @java.lang.Deprecated public java.util.Map getMetricTags() { return getMetricTagsMap(); @@ -12470,6 +13742,7 @@ public java.util.Map getMetricTags() { /** * map<string, string> metricTags = 13; */ + @java.lang.Override public java.util.Map getMetricTagsMap() { return internalGetMetricTags().getMap(); @@ -12477,6 +13750,7 @@ public java.util.Map getMetricTagsMap() { /** * map<string, string> metricTags = 13; */ + @java.lang.Override public java.lang.String getMetricTagsOrDefault( java.lang.String key, @@ -12489,6 +13763,7 @@ public java.lang.String getMetricTagsOrDefault( /** * map<string, string> metricTags = 13; */ + @java.lang.Override public java.lang.String getMetricTagsOrThrow( java.lang.String key) { @@ -12846,17 +14121,19 @@ public interface IngestionResponseOrBuilder extends /** * required .IngestionStatus status = 1; + * @return Whether the status field is set. */ boolean hasStatus(); /** * required .IngestionStatus status = 1; + * @return The status. */ kamino.IngestionV1.IngestionStatus getStatus(); } /** * Protobuf type {@code IngestionResponse} */ - public static final class IngestionResponse extends + public static final class IngestionResponse extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:IngestionResponse) IngestionResponseOrBuilder { @@ -12949,14 +14226,16 @@ private IngestionResponse( private int status_; /** * required .IngestionStatus status = 1; + * @return Whether the status field is set. */ - public boolean hasStatus() { + @java.lang.Override public boolean hasStatus() { return ((bitField0_ & 0x00000001) != 0); } /** * required .IngestionStatus status = 1; + * @return The status. */ - public kamino.IngestionV1.IngestionStatus getStatus() { + @java.lang.Override public kamino.IngestionV1.IngestionStatus getStatus() { @SuppressWarnings("deprecation") kamino.IngestionV1.IngestionStatus result = kamino.IngestionV1.IngestionStatus.valueOf(status_); return result == null ? kamino.IngestionV1.IngestionStatus.OK : result; @@ -13285,13 +14564,16 @@ public Builder mergeFrom( private int status_ = 0; /** * required .IngestionStatus status = 1; + * @return Whether the status field is set. */ - public boolean hasStatus() { + @java.lang.Override public boolean hasStatus() { return ((bitField0_ & 0x00000001) != 0); } /** * required .IngestionStatus status = 1; + * @return The status. */ + @java.lang.Override public kamino.IngestionV1.IngestionStatus getStatus() { @SuppressWarnings("deprecation") kamino.IngestionV1.IngestionStatus result = kamino.IngestionV1.IngestionStatus.valueOf(status_); @@ -13299,6 +14581,8 @@ public kamino.IngestionV1.IngestionStatus getStatus() { } /** * required .IngestionStatus status = 1; + * @param value The status to set. + * @return This builder for chaining. */ public Builder setStatus(kamino.IngestionV1.IngestionStatus value) { if (value == null) { @@ -13311,6 +14595,7 @@ public Builder setStatus(kamino.IngestionV1.IngestionStatus value) { } /** * required .IngestionStatus status = 1; + * @return This builder for chaining. */ public Builder clearStatus() { bitField0_ = (bitField0_ & ~0x00000001); @@ -13377,37 +14662,45 @@ public interface LinkOrBuilder extends /** * required .LinkKind kind = 1; + * @return Whether the kind field is set. */ boolean hasKind(); /** * required .LinkKind kind = 1; + * @return The kind. */ kamino.IngestionV1.LinkKind getKind(); /** * required string traceId = 2; + * @return Whether the traceId field is set. */ boolean hasTraceId(); /** * required string traceId = 2; + * @return The traceId. */ java.lang.String getTraceId(); /** * required string traceId = 2; + * @return The bytes for traceId. */ com.google.protobuf.ByteString getTraceIdBytes(); /** * required string spanId = 3; + * @return Whether the spanId field is set. */ boolean hasSpanId(); /** * required string spanId = 3; + * @return The spanId. */ java.lang.String getSpanId(); /** * required string spanId = 3; + * @return The bytes for spanId. */ com.google.protobuf.ByteString getSpanIdBytes(); @@ -13415,7 +14708,7 @@ public interface LinkOrBuilder extends /** * Protobuf type {@code Link} */ - public static final class Link extends + public static final class Link extends com.google.protobuf.GeneratedMessageV3 implements // @@protoc_insertion_point(message_implements:Link) LinkOrBuilder { @@ -13522,14 +14815,16 @@ private Link( private int kind_; /** * required .LinkKind kind = 1; + * @return Whether the kind field is set. */ - public boolean hasKind() { + @java.lang.Override public boolean hasKind() { return ((bitField0_ & 0x00000001) != 0); } /** * required .LinkKind kind = 1; + * @return The kind. */ - public kamino.IngestionV1.LinkKind getKind() { + @java.lang.Override public kamino.IngestionV1.LinkKind getKind() { @SuppressWarnings("deprecation") kamino.IngestionV1.LinkKind result = kamino.IngestionV1.LinkKind.valueOf(kind_); return result == null ? kamino.IngestionV1.LinkKind.FOLLOWS_FROM : result; @@ -13539,13 +14834,17 @@ public kamino.IngestionV1.LinkKind getKind() { private volatile java.lang.Object traceId_; /** * required string traceId = 2; + * @return Whether the traceId field is set. */ + @java.lang.Override public boolean hasTraceId() { return ((bitField0_ & 0x00000002) != 0); } /** * required string traceId = 2; + * @return The traceId. */ + @java.lang.Override public java.lang.String getTraceId() { java.lang.Object ref = traceId_; if (ref instanceof java.lang.String) { @@ -13562,7 +14861,9 @@ public java.lang.String getTraceId() { } /** * required string traceId = 2; + * @return The bytes for traceId. */ + @java.lang.Override public com.google.protobuf.ByteString getTraceIdBytes() { java.lang.Object ref = traceId_; @@ -13581,13 +14882,17 @@ public java.lang.String getTraceId() { private volatile java.lang.Object spanId_; /** * required string spanId = 3; + * @return Whether the spanId field is set. */ + @java.lang.Override public boolean hasSpanId() { return ((bitField0_ & 0x00000004) != 0); } /** * required string spanId = 3; + * @return The spanId. */ + @java.lang.Override public java.lang.String getSpanId() { java.lang.Object ref = spanId_; if (ref instanceof java.lang.String) { @@ -13604,7 +14909,9 @@ public java.lang.String getSpanId() { } /** * required string spanId = 3; + * @return The bytes for spanId. */ + @java.lang.Override public com.google.protobuf.ByteString getSpanIdBytes() { java.lang.Object ref = spanId_; @@ -14008,13 +15315,16 @@ public Builder mergeFrom( private int kind_ = 1; /** * required .LinkKind kind = 1; + * @return Whether the kind field is set. */ - public boolean hasKind() { + @java.lang.Override public boolean hasKind() { return ((bitField0_ & 0x00000001) != 0); } /** * required .LinkKind kind = 1; + * @return The kind. */ + @java.lang.Override public kamino.IngestionV1.LinkKind getKind() { @SuppressWarnings("deprecation") kamino.IngestionV1.LinkKind result = kamino.IngestionV1.LinkKind.valueOf(kind_); @@ -14022,6 +15332,8 @@ public kamino.IngestionV1.LinkKind getKind() { } /** * required .LinkKind kind = 1; + * @param value The kind to set. + * @return This builder for chaining. */ public Builder setKind(kamino.IngestionV1.LinkKind value) { if (value == null) { @@ -14034,6 +15346,7 @@ public Builder setKind(kamino.IngestionV1.LinkKind value) { } /** * required .LinkKind kind = 1; + * @return This builder for chaining. */ public Builder clearKind() { bitField0_ = (bitField0_ & ~0x00000001); @@ -14045,12 +15358,14 @@ public Builder clearKind() { private java.lang.Object traceId_ = ""; /** * required string traceId = 2; + * @return Whether the traceId field is set. */ public boolean hasTraceId() { return ((bitField0_ & 0x00000002) != 0); } /** * required string traceId = 2; + * @return The traceId. */ public java.lang.String getTraceId() { java.lang.Object ref = traceId_; @@ -14068,6 +15383,7 @@ public java.lang.String getTraceId() { } /** * required string traceId = 2; + * @return The bytes for traceId. */ public com.google.protobuf.ByteString getTraceIdBytes() { @@ -14084,6 +15400,8 @@ public java.lang.String getTraceId() { } /** * required string traceId = 2; + * @param value The traceId to set. + * @return This builder for chaining. */ public Builder setTraceId( java.lang.String value) { @@ -14097,6 +15415,7 @@ public Builder setTraceId( } /** * required string traceId = 2; + * @return This builder for chaining. */ public Builder clearTraceId() { bitField0_ = (bitField0_ & ~0x00000002); @@ -14106,6 +15425,8 @@ public Builder clearTraceId() { } /** * required string traceId = 2; + * @param value The bytes for traceId to set. + * @return This builder for chaining. */ public Builder setTraceIdBytes( com.google.protobuf.ByteString value) { @@ -14121,12 +15442,14 @@ public Builder setTraceIdBytes( private java.lang.Object spanId_ = ""; /** * required string spanId = 3; + * @return Whether the spanId field is set. */ public boolean hasSpanId() { return ((bitField0_ & 0x00000004) != 0); } /** * required string spanId = 3; + * @return The spanId. */ public java.lang.String getSpanId() { java.lang.Object ref = spanId_; @@ -14144,6 +15467,7 @@ public java.lang.String getSpanId() { } /** * required string spanId = 3; + * @return The bytes for spanId. */ public com.google.protobuf.ByteString getSpanIdBytes() { @@ -14160,6 +15484,8 @@ public java.lang.String getSpanId() { } /** * required string spanId = 3; + * @param value The spanId to set. + * @return This builder for chaining. */ public Builder setSpanId( java.lang.String value) { @@ -14173,6 +15499,7 @@ public Builder setSpanId( } /** * required string spanId = 3; + * @return This builder for chaining. */ public Builder clearSpanId() { bitField0_ = (bitField0_ & ~0x00000004); @@ -14182,6 +15509,8 @@ public Builder clearSpanId() { } /** * required string spanId = 3; + * @param value The bytes for spanId to set. + * @return This builder for chaining. */ public Builder setSpanIdBytes( com.google.protobuf.ByteString value) { @@ -14251,6 +15580,11 @@ public kamino.IngestionV1.Link getDefaultInstanceForType() { private static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_MetricBatch_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_MetricBatch_EnvironmentTagsEntry_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_MetricBatch_EnvironmentTagsEntry_fieldAccessorTable; private static final com.google.protobuf.Descriptors.Descriptor internal_static_Interval_descriptor; private static final @@ -14286,6 +15620,11 @@ public kamino.IngestionV1.Link getDefaultInstanceForType() { private static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_SpanBatch_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_SpanBatch_EnvironmentTagsEntry_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_SpanBatch_EnvironmentTagsEntry_fieldAccessorTable; private static final com.google.protobuf.Descriptors.Descriptor internal_static_Mark_descriptor; private static final @@ -14325,50 +15664,56 @@ public kamino.IngestionV1.Link getDefaultInstanceForType() { descriptor; static { java.lang.String[] descriptorData = { - "\n\022ingestion.v1.proto\"\251\001\n\013MetricBatch\022\033\n\010" + + "\n\022ingestion.v1.proto\"\235\002\n\013MetricBatch\022\033\n\010" + "interval\030\001 \002(\0132\t.Interval\022\016\n\006apiKey\030\002 \002(" + "\t\022\017\n\007service\030\003 \002(\t\022\014\n\004host\030\004 \002(\t\022\020\n\010inst" + "ance\030\005 \002(\t\022\030\n\007metrics\030\006 \003(\0132\007.Metric\022\023\n\004" + - "plan\030\007 \001(\0162\005.Plan\022\r\n\005agent\030\010 \001(\t\"$\n\010Inte" + - "rval\022\014\n\004from\030\001 \002(\003\022\n\n\002to\030\002 \002(\003\"\233\001\n\006Metri" + - "c\022\014\n\004name\030\001 \002(\t\022\037\n\004tags\030\002 \003(\0132\021.Metric.T" + - "agsEntry\022\'\n\016instrumentType\030\003 \002(\0162\017.Instr" + - "umentType\022\014\n\004data\030\004 \002(\014\032+\n\tTagsEntry\022\013\n\003" + - "key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"^\n\014NodeIden" + - "tity\022\017\n\007service\030\001 \002(\t\022\020\n\010instance\030\002 \002(\t\022" + - "\014\n\004host\030\003 \002(\t\022\016\n\006apiKey\030\004 \002(\t\022\r\n\005" + - "agent\030\005 \001(\t\"X\n\005Hello\022\033\n\004node\030\001 \002(\0132\r.Nod" + - "eIdentity\022\014\n\004time\030\002 \002(\003\022\023\n\013incarnation\030\003" + - " \002(\t\022\017\n\007version\030\004 \002(\t\"4\n\007Goodbye\022\033\n\004node" + - "\030\001 \002(\0132\r.NodeIdentity\022\014\n\004time\030\002 \002(\003\"u\n\tS" + - "panBatch\022\023\n\013serviceName\030\001 \002(\t\022\016\n\006apiKey\030" + - "\002 \002(\t\022\014\n\004host\030\003 \002(\t\022\020\n\010instance\030\004 \002(\t\022\024\n" + - "\005spans\030\005 \003(\0132\005.Span\022\r\n\005agent\030\006 \001(\t\"$\n\004Ma" + - "rk\022\017\n\007instant\030\001 \002(\003\022\013\n\003key\030\002 \002(\t\"\252\003\n\004Spa" + - "n\022\n\n\002id\030\001 \002(\t\022\017\n\007traceId\030\002 \002(\t\022\020\n\010parent" + - "Id\030\003 \002(\t\022\025\n\roperationName\030\004 \002(\t\022\023\n\013start" + - "Micros\030\005 \002(\003\022\021\n\tendMicros\030\006 \002(\003\022\035\n\004tags\030" + - "\007 \003(\0132\017.Span.TagsEntry\022\024\n\005marks\030\010 \003(\0132\005." + - "Mark\022\020\n\010hasError\030\t \001(\010\022\022\n\nwasDelayed\030\n \001" + - "(\010\022\027\n\004kind\030\013 \001(\0162\t.SpanKind\022\037\n\010position\030" + - "\014 \001(\0162\r.SpanPosition\022)\n\nmetricTags\030\r \003(\013" + - "2\025.Span.MetricTagsEntry\022\024\n\005links\030\016 \003(\0132\005" + - ".Link\032+\n\tTagsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value" + - "\030\002 \001(\t:\0028\001\0321\n\017MetricTagsEntry\022\013\n\003key\030\001 \001" + - "(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"5\n\021IngestionRespon" + - "se\022 \n\006status\030\001 \002(\0162\020.IngestionStatus\"@\n\004" + - "Link\022\027\n\004kind\030\001 \002(\0162\t.LinkKind\022\017\n\007traceId" + - "\030\002 \002(\t\022\016\n\006spanId\030\003 \002(\t*L\n\016InstrumentType" + - "\022\013\n\007COUNTER\020\000\022\t\n\005GAUGE\020\001\022\r\n\tHISTOGRAM\020\002\022" + - "\023\n\017MIN_MAX_COUNTER\020\003*+\n\004Plan\022\017\n\013METRIC_O" + - "NLY\020\001\022\022\n\016METRIC_TRACING\020\002*]\n\017IngestionSt" + - "atus\022\006\n\002OK\020\000\022\t\n\005ERROR\020\001\022\t\n\005STALE\020\002\022\020\n\014UN" + - "AUTHORIZED\020\003\022\013\n\007BLOCKED\020\004\022\r\n\tCORRUPTED\020\005" + - "*Y\n\010SpanKind\022\013\n\007UNKNOWN\020\000\022\n\n\006SERVER\020\001\022\n\n" + - "\006CLIENT\020\002\022\014\n\010PRODUCER\020\003\022\014\n\010CONSUMER\020\004\022\014\n" + - "\010INTERNAL\020\005*>\n\014SpanPosition\022\024\n\020POSITION_" + - "UNKNOWN\020\000\022\010\n\004ROOT\020\001\022\016\n\nLOCAL_ROOT\020\002*\034\n\010L" + - "inkKind\022\020\n\014FOLLOWS_FROM\020\001B\010\n\006kamino" + "plan\030\007 \001(\0162\005.Plan\022\r\n\005agent\030\010 \001(\t\022:\n\017envi" + + "ronmentTags\030\t \003(\0132!.MetricBatch.Environm" + + "entTagsEntry\0326\n\024EnvironmentTagsEntry\022\013\n\003" + + "key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"$\n\010Interval" + + "\022\014\n\004from\030\001 \002(\003\022\n\n\002to\030\002 \002(\003\"\233\001\n\006Metric\022\014\n" + + "\004name\030\001 \002(\t\022\037\n\004tags\030\002 \003(\0132\021.Metric.TagsE" + + "ntry\022\'\n\016instrumentType\030\003 \002(\0162\017.Instrumen" + + "tType\022\014\n\004data\030\004 \002(\014\032+\n\tTagsEntry\022\013\n\003key\030" + + "\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"^\n\014NodeIdentity" + + "\022\017\n\007service\030\001 \002(\t\022\020\n\010instance\030\002 \002(\t\022\014\n\004h" + + "ost\030\003 \002(\t\022\016\n\006apiKey\030\004 \002(\t\022\r\n\005agent\030\005 \001(\t" + + "\"X\n\005Hello\022\033\n\004node\030\001 \002(\0132\r.NodeIdentity\022\014" + + "\n\004time\030\002 \002(\003\022\023\n\013incarnation\030\003 \002(\t\022\017\n\007ver" + + "sion\030\004 \002(\t\"4\n\007Goodbye\022\033\n\004node\030\001 \002(\0132\r.No" + + "deIdentity\022\014\n\004time\030\002 \002(\003\"\347\001\n\tSpanBatch\022\023" + + "\n\013serviceName\030\001 \002(\t\022\016\n\006apiKey\030\002 \002(\t\022\014\n\004h" + + "ost\030\003 \002(\t\022\020\n\010instance\030\004 \002(\t\022\024\n\005spans\030\005 \003" + + "(\0132\005.Span\022\r\n\005agent\030\006 \001(\t\0228\n\017environmentT" + + "ags\030\007 \003(\0132\037.SpanBatch.EnvironmentTagsEnt" + + "ry\0326\n\024EnvironmentTagsEntry\022\013\n\003key\030\001 \001(\t\022" + + "\r\n\005value\030\002 \001(\t:\0028\001\"$\n\004Mark\022\017\n\007instant\030\001 " + + "\002(\003\022\013\n\003key\030\002 \002(\t\"\252\003\n\004Span\022\n\n\002id\030\001 \002(\t\022\017\n" + + "\007traceId\030\002 \002(\t\022\020\n\010parentId\030\003 \002(\t\022\025\n\roper" + + "ationName\030\004 \002(\t\022\023\n\013startMicros\030\005 \002(\003\022\021\n\t" + + "endMicros\030\006 \002(\003\022\035\n\004tags\030\007 \003(\0132\017.Span.Tag" + + "sEntry\022\024\n\005marks\030\010 \003(\0132\005.Mark\022\020\n\010hasError" + + "\030\t \001(\010\022\022\n\nwasDelayed\030\n \001(\010\022\027\n\004kind\030\013 \001(\016" + + "2\t.SpanKind\022\037\n\010position\030\014 \001(\0162\r.SpanPosi" + + "tion\022)\n\nmetricTags\030\r \003(\0132\025.Span.MetricTa" + + "gsEntry\022\024\n\005links\030\016 \003(\0132\005.Link\032+\n\tTagsEnt" + + "ry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\0321\n\017Me" + + "tricTagsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(" + + "\t:\0028\001\"5\n\021IngestionResponse\022 \n\006status\030\001 \002" + + "(\0162\020.IngestionStatus\"@\n\004Link\022\027\n\004kind\030\001 \002" + + "(\0162\t.LinkKind\022\017\n\007traceId\030\002 \002(\t\022\016\n\006spanId" + + "\030\003 \002(\t*L\n\016InstrumentType\022\013\n\007COUNTER\020\000\022\t\n" + + "\005GAUGE\020\001\022\r\n\tHISTOGRAM\020\002\022\023\n\017MIN_MAX_COUNT" + + "ER\020\003*+\n\004Plan\022\017\n\013METRIC_ONLY\020\001\022\022\n\016METRIC_" + + "TRACING\020\002*]\n\017IngestionStatus\022\006\n\002OK\020\000\022\t\n\005" + + "ERROR\020\001\022\t\n\005STALE\020\002\022\020\n\014UNAUTHORIZED\020\003\022\013\n\007" + + "BLOCKED\020\004\022\r\n\tCORRUPTED\020\005*Y\n\010SpanKind\022\013\n\007" + + "UNKNOWN\020\000\022\n\n\006SERVER\020\001\022\n\n\006CLIENT\020\002\022\014\n\010PRO" + + "DUCER\020\003\022\014\n\010CONSUMER\020\004\022\014\n\010INTERNAL\020\005*>\n\014S" + + "panPosition\022\024\n\020POSITION_UNKNOWN\020\000\022\010\n\004ROO" + + "T\020\001\022\016\n\nLOCAL_ROOT\020\002*\034\n\010LinkKind\022\020\n\014FOLLO" + + "WS_FROM\020\001B\010\n\006kamino" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -14379,7 +15724,13 @@ public kamino.IngestionV1.Link getDefaultInstanceForType() { internal_static_MetricBatch_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_MetricBatch_descriptor, - new java.lang.String[] { "Interval", "ApiKey", "Service", "Host", "Instance", "Metrics", "Plan", "Agent", }); + new java.lang.String[] { "Interval", "ApiKey", "Service", "Host", "Instance", "Metrics", "Plan", "Agent", "EnvironmentTags", }); + internal_static_MetricBatch_EnvironmentTagsEntry_descriptor = + internal_static_MetricBatch_descriptor.getNestedTypes().get(0); + internal_static_MetricBatch_EnvironmentTagsEntry_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_MetricBatch_EnvironmentTagsEntry_descriptor, + new java.lang.String[] { "Key", "Value", }); internal_static_Interval_descriptor = getDescriptor().getMessageTypes().get(1); internal_static_Interval_fieldAccessorTable = new @@ -14421,7 +15772,13 @@ public kamino.IngestionV1.Link getDefaultInstanceForType() { internal_static_SpanBatch_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_SpanBatch_descriptor, - new java.lang.String[] { "ServiceName", "ApiKey", "Host", "Instance", "Spans", "Agent", }); + new java.lang.String[] { "ServiceName", "ApiKey", "Host", "Instance", "Spans", "Agent", "EnvironmentTags", }); + internal_static_SpanBatch_EnvironmentTagsEntry_descriptor = + internal_static_SpanBatch_descriptor.getNestedTypes().get(0); + internal_static_SpanBatch_EnvironmentTagsEntry_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_SpanBatch_EnvironmentTagsEntry_descriptor, + new java.lang.String[] { "Key", "Value", }); internal_static_Mark_descriptor = getDescriptor().getMessageTypes().get(7); internal_static_Mark_fieldAccessorTable = new diff --git a/reporters/kamon-apm-reporter/src/main/protobuf/ingestion.v1.proto b/reporters/kamon-apm-reporter/src/main/protobuf/ingestion.v1.proto index 4816f64d5..9e49203ce 100644 --- a/reporters/kamon-apm-reporter/src/main/protobuf/ingestion.v1.proto +++ b/reporters/kamon-apm-reporter/src/main/protobuf/ingestion.v1.proto @@ -11,6 +11,7 @@ message MetricBatch { repeated Metric metrics = 6; optional Plan plan = 7; optional string agent = 8; + map environmentTags = 9; } message Interval { @@ -64,6 +65,7 @@ message SpanBatch { required string instance = 4; repeated Span spans = 5; optional string agent = 6; + map environmentTags = 7; } message Mark { diff --git a/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/KamonApm.scala b/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/KamonApm.scala index 9731bbb3f..0c642451a 100644 --- a/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/KamonApm.scala +++ b/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/KamonApm.scala @@ -96,6 +96,7 @@ class KamonApm(configPath: String) extends CombinedReporter { .setHost(env.host) .setInstance(env.instance) .setApiKey(_settings.apiKey) + .putAllEnvironmentTags(_settings.environmentTags) .addAllSpans(apmSpans.asJava) .build() @@ -126,6 +127,7 @@ class KamonApm(configPath: String) extends CombinedReporter { .setService(Kamon.environment.service) .setHost(Kamon.environment.host) .setInstance(Kamon.environment.instance) + .putAllEnvironmentTags(_settings.environmentTags) .addAllMetrics(allMetrics.asJava) .setPlan(plan) .build() diff --git a/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/package.scala b/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/package.scala index 748cd6e0c..3ff251800 100644 --- a/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/package.scala +++ b/reporters/kamon-apm-reporter/src/main/scala/kamon/apm/package.scala @@ -17,10 +17,11 @@ package kamon import java.time.Duration - import com.typesafe.config.Config import _root_.kamino.IngestionV1.Plan +import kamon.tag.Tag.unwrapValue import org.slf4j.LoggerFactory + import java.net.Proxy import java.util.regex.Pattern @@ -35,6 +36,9 @@ package object apm { if(apiKey.equals("none")) _logger.error("No API key defined in the kamon.apm.api-key setting") + val environmentTagsMap = new java.util.HashMap[String, String]() + Kamon.environment.tags.all().foreach(t => environmentTagsMap.put(t.key, String.valueOf(unwrapValue(t)))) + Settings ( apiKey = apiKey, plan = if(apmConfig.getBoolean("enable-tracing")) Plan.METRIC_TRACING else Plan.METRIC_ONLY, @@ -55,7 +59,8 @@ package object apm { case "system" => None case "socks" => Some(Proxy.Type.SOCKS) case "https" => Some(Proxy.Type.HTTP) - } + }, + environmentTags = environmentTagsMap ) } @@ -78,7 +83,8 @@ package object apm { clientBackoff: Duration, proxy: Option[Proxy.Type], proxyHost: String, - proxyPort: Int + proxyPort: Int, + environmentTags: java.util.Map[String, String] ) { def ingestionRoute = s"$ingestionApi/ingest" def bootMark = s"$ingestionApi/hello"