File tree Expand file tree Collapse file tree 3 files changed +10
-2
lines changed Expand file tree Collapse file tree 3 files changed +10
-2
lines changed Original file line number Diff line number Diff line change 99# Go
1010vendor
1111.cursor /
12- agents /
12+ agents /
13+ .serena /
Original file line number Diff line number Diff line change @@ -19,3 +19,10 @@ func IsClusterUnhealthy(err error) bool {
1919 }
2020 return false
2121}
22+
23+ func IsAuthError (err error ) bool {
24+ if restErr , ok := err .(rest.Error ); ok {
25+ return restErr .Code == 403
26+ }
27+ return false
28+ }
Original file line number Diff line number Diff line change @@ -157,7 +157,7 @@ func (m *PulsarFunctionManager) updateFunctions() {
157157 log .Printf ("Failed to get functions list: %v" , err )
158158
159159 // Check if this is a cluster health error and invoke callback if configured
160- if IsClusterUnhealthy (err ) && m .clusterErrorHandler != nil {
160+ if ( IsClusterUnhealthy (err ) || IsAuthError ( err ) ) && m .clusterErrorHandler != nil {
161161 go m .clusterErrorHandler (m , err )
162162 }
163163 return
You can’t perform that action at this time.
0 commit comments