We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6533497 commit 4e05edcCopy full SHA for 4e05edc
pkg/mcp/pftools/manager.go
@@ -155,7 +155,7 @@ func (m *PulsarFunctionManager) updateFunctions() {
155
functions, err := m.getFunctionsList()
156
if err != nil {
157
log.Printf("Failed to get functions list: %v", err)
158
-
+
159
// Check if this is a cluster health error and invoke callback if configured
160
if IsClusterUnhealthy(err) && m.clusterErrorHandler != nil {
161
go m.clusterErrorHandler(m, err)
0 commit comments