public class org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData extends java.lang.Object implements org.apache.kafkaesque.common.protocol.ApiMessage
{
private short errorCode;
private java.lang.String principalType;
private java.lang.String principalName;
private long issueTimestampMs;
private long expiryTimestampMs;
private long maxTimestampMs;
private java.lang.String tokenId;
private byte[] hmac;
private int throttleTimeMs;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2;
public static final org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesque.common.protocol.Readable, short)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
org.apache.kafkaesque.common.protocol.Readable v;
short v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: void read(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
byte[] v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode> = 0;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType> = "";
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName> = "";
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs> = 0L;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs> = 0L;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs> = 0L;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId> = "";
v = <org.apache.kafkaesque.common.utils.Bytes: byte[] EMPTY>;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac> = v;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs> = 0;
return;
}
public short apiKey()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
return 38;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
return 2;
}
public void read(org.apache.kafkaesque.common.protocol.Readable, short)
{
byte[] v;
java.util.List v, v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v, v, v;
short v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
java.lang.RuntimeException v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.Readable v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode> = v;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field principalType was serialized as null");
throw v;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("string field principalType had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType> = v;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field principalName was serialized as null");
throw v;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("string field principalName had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs> = v;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: short readShort()>();
v = v;
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field tokenId was serialized as null");
throw v;
label:
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("string field tokenId had invalid length \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.lang.String readString(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId> = v;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
goto label;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readInt()>();
label:
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field hmac was serialized as null");
throw v;
label:
v = newarray (byte)[v];
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: void readArray(byte[])>(v);
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac> = v;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs> = v;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields> = null;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields> = v;
v = v + 1;
goto label;
label:
return;
}
public void write(org.apache.kafkaesque.common.protocol.Writable, org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.Writable v;
java.util.List v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v, v, v;
short v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: org.apache.kafkaesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 2 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 2 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeLong(long)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeLong(long)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeLong(long)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: byte[] getSerializedValue(java.lang.Object)>(v);
if v < 2 goto label;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeShort(short)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
if v < 2 goto label;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = lengthof v;
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = lengthof v;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByteArray(byte[])>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v < 2 goto label;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesque.common.protocol.Writable,int)>(v, 2147483647);
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
byte[] v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v, v, v;
java.lang.Integer v;
java.util.ArrayList v;
short v, v;
java.lang.Long v, v, v;
java.lang.Short v;
int v, v;
java.lang.String v, v, v;
boolean v, v;
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.List v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields> = null;
if v < 2 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Short getShort(java.lang.String)>("error_code");
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("principal_type");
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("principal_name");
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("issue_timestamp_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("expiry_timestamp_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("max_timestamp_ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("token_id");
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: byte[] getByteArray(java.lang.String)>("hmac");
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("throttle_time_ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs> = v;
if v < 2 goto label;
v = interfaceinvoke v.<java.util.NavigableMap: boolean isEmpty()>();
if v != 0 goto label;
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.NavigableMap: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields> = v;
v = interfaceinvoke v.<java.util.NavigableMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)
{
byte[] v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v, v, v;
java.lang.Integer v;
org.apache.kafkaesque.common.protocol.types.Schema v;
short v, v;
java.lang.Long v, v, v;
java.lang.Short v;
int v;
java.lang.String v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.TreeMap v, v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: short;
v = null;
if v < 2 goto label;
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = v;
label:
v = new org.apache.kafkaesque.common.protocol.types.Struct;
v = <org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode>;
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("error_code", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("principal_type", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("principal_name", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("issue_timestamp_ms", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("expiry_timestamp_ms", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("max_timestamp_ms", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("token_id", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct setByteArray(java.lang.String,byte[])>("hmac", v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("throttle_time_ms", v);
if v < 2 goto label;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("_tagged_fields", v);
label:
return v;
}
public int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short)
{
byte[] v, v, v, v, v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
short v;
java.lang.String v, v, v, v, v, v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
java.lang.RuntimeException v, v, v;
boolean v;
java.util.List v, v, v;
java.nio.charset.Charset v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'principalType\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 2 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = 2 + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = 2 + v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'principalName\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 2 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = v + v;
label:
v = v + 8;
v = v + 8;
v = v + 8;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
if v <= 32767 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("\'tokenId\' field is too long to be serialized");
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
virtualinvoke v.<org.apache.kafkaesque.common.protocol.ObjectSerializationCache: void cacheSerializedValue(java.lang.Object,byte[])>(v, v);
if v < 2 goto label;
v = lengthof v;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = v + v;
goto label;
label:
v = lengthof v;
v = v + 2;
v = v + v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = lengthof v;
if v < 2 goto label;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = lengthof v;
v = v + 1;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
v = v + 4;
label:
v = v + v;
v = v + 4;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v < 2 goto label;
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
byte[] v, v;
byte v, v, v;
boolean v, v, v, v, v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v, v, v, v, v, v;
short v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = staticinvoke <java.util.Arrays: boolean equals(byte[],byte[])>(v, v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs>;
if v == v goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
byte[] v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v, v, v, v, v, v, v, v, v;
short v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode>;
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
v = v >> 32;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
v = v >> 32;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
v = v >> 32;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = staticinvoke <java.util.Arrays: int hashCode(byte[])>(v);
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs>;
v = v + v;
return v;
}
public java.lang.String toString()
{
byte[] v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v, v, v;
short v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
v = virtualinvoke v.<java.lang.String: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\'\u0001\'");
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
v = staticinvoke <java.util.Arrays: java.lang.String toString(byte[])>(v);
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short,java.lang.String,java.lang.String,long,long,long,java.lang.String,java.lang.String,int)>(v, v, v, v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("CreateDelegationTokenResponseData(errorCode=\u, principalType=\u, principalName=\u, issueTimestampMs=\u, expiryTimestampMs=\u, maxTimestampMs=\u, tokenId=\u, hmac=\u, throttleTimeMs=\u)");
return v;
}
public short errorCode()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
short v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode>;
return v;
}
public java.lang.String principalType()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType>;
return v;
}
public java.lang.String principalName()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName>;
return v;
}
public long issueTimestampMs()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs>;
return v;
}
public long expiryTimestampMs()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs>;
return v;
}
public long maxTimestampMs()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs>;
return v;
}
public java.lang.String tokenId()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId>;
return v;
}
public byte[] hmac()
{
byte[] v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac>;
return v;
}
public int throttleTimeMs()
{
int v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs>;
return v;
}
public java.util.List unknownTaggedFields()
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
java.util.List v, v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
if v != null goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(0);
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setErrorCode(short)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
short v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: short;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: short errorCode> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setPrincipalType(java.lang.String)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalType> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setPrincipalName(java.lang.String)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String principalName> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setIssueTimestampMs(long)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: long;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long issueTimestampMs> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setExpiryTimestampMs(long)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: long;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long expiryTimestampMs> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setMaxTimestampMs(long)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
long v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: long;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: long maxTimestampMs> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setTokenId(java.lang.String)
{
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
java.lang.String v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: java.lang.String;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: java.lang.String tokenId> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setHmac(byte[])
{
byte[] v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: byte[];
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: byte[] hmac> = v;
return v;
}
public org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData setThrottleTimeMs(int)
{
int v;
org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData v;
v := @this: org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData;
v := @parameter: int;
v.<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: int throttleTimeMs> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection v;
java.lang.Object[] v;
org.apache.kafkaesque.common.protocol.types.Field[] v, v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[9];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The top-level error, or zero if there was no error.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("principal_type", v, "The principal type of the token owner.");
v[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("principal_name", v, "The name of the token owner.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("issue_timestamp_ms", v, "When this token was generated.");
v[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("expiry_timestamp_ms", v, "When this token expires.");
v[4] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("max_timestamp_ms", v, "The maximum lifetime of this token.");
v[5] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("token_id", v, "The token UUID.");
v[6] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType BYTES>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("hmac", v, "HMAC of the delegation token.");
v[7] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("throttle_time_ms", v, "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.");
v[8] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[10];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT16>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("error_code", v, "The top-level error, or zero if there was no error.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("principal_type", v, "The principal type of the token owner.");
v[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("principal_name", v, "The name of the token owner.");
v[2] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("issue_timestamp_ms", v, "When this token was generated.");
v[3] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("expiry_timestamp_ms", v, "When this token expires.");
v[4] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("max_timestamp_ms", v, "The maximum lifetime of this token.");
v[5] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_STRING>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("token_id", v, "The token UUID.");
v[6] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType COMPACT_BYTES>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("hmac", v, "HMAC of the delegation token.");
v[7] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("throttle_time_ms", v, "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.");
v[8] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[9] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2> = v;
v = newarray (org.apache.kafkaesque.common.protocol.types.Schema)[3];
v = <org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
<org.apache.kafkaesque.common.message.CreateDelegationTokenResponseData: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}