Update generated classes after commit 55eda73 (#749)

Co-authored-by: masesdevelopers <[email protected]>
masesgroup · Nov 12, 2024 · 9ae6db4 · 9ae6db4
1 parent 55eda73
commit 9ae6db4
Show file tree

Hide file tree

Showing 22 changed files with 5,105 additions and 0 deletions.
diff --git a/...rc/main/java/org/mases/knet/generated/org/apache/kafka/metadata/FeatureLevelListener.java b/...rc/main/java/org/mases/knet/generated/org/apache/kafka/metadata/FeatureLevelListener.java
@@ -0,0 +1,79 @@
+/*
+*  Copyright 2024 MASES s.r.l.
+*
+*  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.
+*
+*  Refer to LICENSE for more information.
+*/
+
+/*
+*  This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+*/
+
+package org.mases.knet.generated.org.apache.kafka.metadata;
+
+public final class FeatureLevelListener implements org.mases.jcobridge.IJCListener, org.apache.kafka.metadata.FeatureLevelListener {
+    final org.mases.jcobridge.JCListener _internalListener;
+
+    public FeatureLevelListener(String key) throws org.mases.jcobridge.JCNativeException {
+        super();
+        _internalListener = new org.mases.jcobridge.JCListener(key);
+    }
+
+    public synchronized void release() {
+       _internalListener.release();
+    }
+
+    public synchronized void raiseEvent(String eventName) {
+       _internalListener.raiseEvent(eventName);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e) {
+       _internalListener.raiseEvent(eventName, e);
+    }
+
+    public synchronized void raiseEvent(String eventName, Object e, Object... objects) {
+       _internalListener.raiseEvent(eventName, e, objects);
+    }
+
+    public Object getEventData() {
+       return _internalListener.getEventData();
+    }
+
+    public boolean hasExtraData() {
+       return _internalListener.hasExtraData();
+    }
+
+    public int extraDataLength() {
+       return _internalListener.extraDataLength();
+    }
+
+    public Object[] extraData() {
+       return _internalListener.extraData();
+    }
+
+    public Object getReturnData() {
+       return _internalListener.getReturnData();
+    }
+
+    public void setReturnData(Object retData) {
+       _internalListener.setReturnData(retData);
+    }
+
+    //@Override
+    public void handle(java.lang.String arg0, short arg1) {
+        org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
+        raiseEvent("handle", eventDataExchange, arg0, arg1); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM");
+    }
+
+}
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Admin/AdminUtils.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Admin/AdminUtils.cs
@@ -0,0 +1,142 @@
+/*
+*  Copyright 2024 MASES s.r.l.
+*
+*  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.
+*
+*  Refer to LICENSE for more information.
+*/
+
+/*
+*  This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+*  using kafka-server-common-3.9.0.jar as reference
+*/
+
+using MASES.JCOBridge.C2JBridge;
+
+namespace Org.Apache.Kafka.Admin
+{
+    #region AdminUtils declaration
+    /// <summary>
+    /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/AdminUtils.html"/>
+    /// </summary>
+    public partial class AdminUtils : MASES.JCOBridge.C2JBridge.JVMBridgeBase<AdminUtils>
+    {
+        const string _bridgeClassName = "org.apache.kafka.admin.AdminUtils";
+        /// <summary>
+        /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
+        /// </summary>
+        public AdminUtils() { }
+        /// <summary>
+        /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
+        /// </summary>
+        public AdminUtils(params object[] args) : base(args) { }
+
+        private static readonly MASES.JCOBridge.C2JBridge.JVMInterop.IJavaType _LocalBridgeClazz = JVMBridgeBase.ClazzOf(_bridgeClassName);
+        private static MASES.JCOBridge.C2JBridge.JVMInterop.IJavaType LocalBridgeClazz => _LocalBridgeClazz ?? throw new global::System.InvalidOperationException($"Class {_bridgeClassName} was not found.");
+
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm"/>
+        /// </summary>
+        public override string BridgeClassName => _bridgeClassName;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeAbstract.htm"/>
+        /// </summary>
+        public override bool IsBridgeAbstract => false;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeCloseable.htm"/>
+        /// </summary>
+        public override bool IsBridgeCloseable => false;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeInterface.htm"/>
+        /// </summary>
+        public override bool IsBridgeInterface => false;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeStatic.htm"/>
+        /// </summary>
+        public override bool IsBridgeStatic => false;
+
+        // TODO: complete the class
+
+    }
+    #endregion
+
+    #region AdminUtils implementation
+    public partial class AdminUtils
+    {
+        #region Constructors
+
+        #endregion
+
+        #region Class/Interface conversion operators
+
+        #endregion
+
+        #region Fields
+        /// <summary>
+        /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/AdminUtils.html#ADMIN_CLIENT_ID"/>
+        /// </summary>
+        public static Java.Lang.String ADMIN_CLIENT_ID { get { if (!_ADMIN_CLIENT_IDReady) { _ADMIN_CLIENT_IDContent = SGetField<Java.Lang.String>(LocalBridgeClazz, "ADMIN_CLIENT_ID"); _ADMIN_CLIENT_IDReady = true; } return _ADMIN_CLIENT_IDContent; } }
+        private static Java.Lang.String _ADMIN_CLIENT_IDContent = default;
+        private static bool _ADMIN_CLIENT_IDReady = false; // this is used because in case of generics 
+
+        #endregion
+
+        #region Static methods
+        /// <summary>
+        /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/AdminUtils.html#getRackAlternatedBrokerList-java.util.Map-"/>
+        /// </summary>
+        /// <param name="arg0"><see cref="Java.Util.Map"/></param>
+        /// <returns><see cref="Java.Util.List"/></returns>
+        public static Java.Util.List<Java.Lang.Integer> GetRackAlternatedBrokerList(Java.Util.Map<Java.Lang.Integer, Java.Lang.String> arg0)
+        {
+            return SExecuteWithSignature<Java.Util.List<Java.Lang.Integer>>(LocalBridgeClazz, "getRackAlternatedBrokerList", "(Ljava/util/Map;)Ljava/util/List;", arg0);
+        }
+        /// <summary>
+        /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/AdminUtils.html#assignReplicasToBrokers-java.util.Collection-int-int-int-int-"/>
+        /// </summary>
+        /// <param name="arg0"><see cref="Java.Util.Collection"/></param>
+        /// <param name="arg1"><see cref="int"/></param>
+        /// <param name="arg2"><see cref="int"/></param>
+        /// <param name="arg3"><see cref="int"/></param>
+        /// <param name="arg4"><see cref="int"/></param>
+        /// <returns><see cref="Java.Util.Map"/></returns>
+        public static Java.Util.Map<Java.Lang.Integer, Java.Util.List<Java.Lang.Integer>> AssignReplicasToBrokers(Java.Util.Collection<Org.Apache.Kafka.Admin.BrokerMetadata> arg0, int arg1, int arg2, int arg3, int arg4)
+        {
+            return SExecuteWithSignature<Java.Util.Map<Java.Lang.Integer, Java.Util.List<Java.Lang.Integer>>>(LocalBridgeClazz, "assignReplicasToBrokers", "(Ljava/util/Collection;IIII)Ljava/util/Map;", arg0, arg1, arg2, arg3, arg4);
+        }
+        /// <summary>
+        /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/AdminUtils.html#assignReplicasToBrokers-java.util.Collection-int-int-"/>
+        /// </summary>
+        /// <param name="arg0"><see cref="Java.Util.Collection"/></param>
+        /// <param name="arg1"><see cref="int"/></param>
+        /// <param name="arg2"><see cref="int"/></param>
+        /// <returns><see cref="Java.Util.Map"/></returns>
+        public static Java.Util.Map<Java.Lang.Integer, Java.Util.List<Java.Lang.Integer>> AssignReplicasToBrokers(Java.Util.Collection<Org.Apache.Kafka.Admin.BrokerMetadata> arg0, int arg1, int arg2)
+        {
+            return SExecuteWithSignature<Java.Util.Map<Java.Lang.Integer, Java.Util.List<Java.Lang.Integer>>>(LocalBridgeClazz, "assignReplicasToBrokers", "(Ljava/util/Collection;II)Ljava/util/Map;", arg0, arg1, arg2);
+        }
+
+        #endregion
+
+        #region Instance methods
+
+        #endregion
+
+        #region Nested classes
+
+        #endregion
+
+        // TODO: complete the class
+    }
+    #endregion
+}
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Admin/BrokerMetadata.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Admin/BrokerMetadata.cs
@@ -0,0 +1,124 @@
+/*
+*  Copyright 2024 MASES s.r.l.
+*
+*  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.
+*
+*  Refer to LICENSE for more information.
+*/
+
+/*
+*  This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+*  using kafka-server-common-3.9.0.jar as reference
+*/
+
+using MASES.JCOBridge.C2JBridge;
+
+namespace Org.Apache.Kafka.Admin
+{
+    #region BrokerMetadata declaration
+    /// <summary>
+    /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/BrokerMetadata.html"/>
+    /// </summary>
+    public partial class BrokerMetadata : MASES.JCOBridge.C2JBridge.JVMBridgeBase<BrokerMetadata>
+    {
+        const string _bridgeClassName = "org.apache.kafka.admin.BrokerMetadata";
+        /// <summary>
+        /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
+        /// </summary>
+        public BrokerMetadata() { }
+        /// <summary>
+        /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
+        /// </summary>
+        public BrokerMetadata(params object[] args) : base(args) { }
+
+        private static readonly MASES.JCOBridge.C2JBridge.JVMInterop.IJavaType _LocalBridgeClazz = JVMBridgeBase.ClazzOf(_bridgeClassName);
+        private static MASES.JCOBridge.C2JBridge.JVMInterop.IJavaType LocalBridgeClazz => _LocalBridgeClazz ?? throw new global::System.InvalidOperationException($"Class {_bridgeClassName} was not found.");
+
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm"/>
+        /// </summary>
+        public override string BridgeClassName => _bridgeClassName;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeAbstract.htm"/>
+        /// </summary>
+        public override bool IsBridgeAbstract => false;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeCloseable.htm"/>
+        /// </summary>
+        public override bool IsBridgeCloseable => false;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeInterface.htm"/>
+        /// </summary>
+        public override bool IsBridgeInterface => false;
+        /// <summary>
+        /// <see href="https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeStatic.htm"/>
+        /// </summary>
+        public override bool IsBridgeStatic => false;
+
+        // TODO: complete the class
+
+    }
+    #endregion
+
+    #region BrokerMetadata implementation
+    public partial class BrokerMetadata
+    {
+        #region Constructors
+        /// <summary>
+        /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/BrokerMetadata.html#org.apache.kafka.admin.BrokerMetadata(int,java.util.Optional)"/>
+        /// </summary>
+        /// <param name="arg0"><see cref="int"/></param>
+        /// <param name="arg1"><see cref="Java.Util.Optional"/></param>
+        public BrokerMetadata(int arg0, Java.Util.Optional<Java.Lang.String> arg1)
+            : base(arg0, arg1)
+        {
+        }
+
+        #endregion
+
+        #region Class/Interface conversion operators
+
+        #endregion
+
+        #region Fields
+        /// <summary>
+        /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/BrokerMetadata.html#id"/>
+        /// </summary>
+        public int id { get { if (!_idReady) { _idContent = IGetField<int>("id"); _idReady = true; } return _idContent; } }
+        private int _idContent = default;
+        private bool _idReady = false; // this is used because in case of generics 
+        /// <summary>
+        /// <see href="https://www.javadoc.io/doc/org.apache.kafka/kafka-server-common/3.9.0/org/apache/kafka/admin/BrokerMetadata.html#rack"/>
+        /// </summary>
+        public Java.Util.Optional rack { get { if (!_rackReady) { _rackContent = IGetField<Java.Util.Optional>("rack"); _rackReady = true; } return _rackContent; } }
+        private Java.Util.Optional _rackContent = default;
+        private bool _rackReady = false; // this is used because in case of generics 
+
+        #endregion
+
+        #region Static methods
+
+        #endregion
+
+        #region Instance methods
+
+        #endregion
+
+        #region Nested classes
+
+        #endregion
+
+        // TODO: complete the class
+    }
+    #endregion
+}