- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for subscribe (0.15 sec)
-
cmd/consolelogger.go
// for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node. func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error { // Enable console logging for remote client.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
return s.iptablesConfigurator.CreateInpodRules(&HostProbeSNATIP) }); err != nil { log.Errorf("failed to update POD inpod: %s/%s %v", pod.Namespace, pod.Name, err) return err } log.Debug("notifying subscribed node proxies") if err := s.sendPodToZtunnelAndWaitForAck(ctx, pod, openNetns); err != nil { // we must return PartialAdd error here. the pod was injected with iptables rules,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/admin-handlers.go
}, nil) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // Publish bootstrap events that have already occurred before client could subscribe. if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) { go globalBootstrapTracer.Publish(ctx, globalTrace) } for _, peer := range peers { if peer == nil { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2)