Added OnError event to MetaObjectLock (#1585)

* Added OnError event to MetaObjectLock * Updated event name
kubernetes-client · Sep 27, 2024 · 541abb0 · 541abb0
1 parent 722f21c
commit 541abb0
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/KubernetesClient/LeaderElection/ResourceLock/MetaObjectLock.cs b/src/KubernetesClient/LeaderElection/ResourceLock/MetaObjectLock.cs
@@ -9,6 +9,11 @@ public abstract class MetaObjectLock<T> : ILock
         private readonly string identity;
         private T metaObjCache;
 
+        /// <summary>
+        /// OnHttpError is called when there is a http operation error.
+        /// </summary>
+        public event Action<HttpOperationException> OnHttpError;
+
         protected MetaObjectLock(IKubernetes client, string @namespace, string name, string identity)
         {
             this.client = client ?? throw new ArgumentNullException(nameof(client));
@@ -47,8 +52,9 @@ public async Task<bool> CreateAsync(LeaderElectionRecord record, CancellationTok
                 Interlocked.Exchange(ref metaObjCache, createdObj);
                 return true;
             }
-            catch (HttpOperationException)
+            catch (HttpOperationException e)
             {
+                OnHttpError?.Invoke(e);
                 // ignore
             }
 
@@ -79,8 +85,9 @@ public async Task<bool> UpdateAsync(LeaderElectionRecord record, CancellationTok
                 Interlocked.Exchange(ref metaObjCache, replacedObj);
                 return true;
             }
-            catch (HttpOperationException)
+            catch (HttpOperationException e)
             {
+                OnHttpError?.Invoke(e);
                 // ignore
             }