Documentation
¶
Index ¶
- type Provider
- func (m *Provider) DecEventWaiting(source string)
- func (m *Provider) DecGoroutineWaiting()
- func (m *Provider) IncBackoffTriggered(c string, d time.Duration)
- func (m *Provider) IncChildRestart(s, c string)
- func (m *Provider) IncCircuitBreakerTriggered(c string)
- func (m *Provider) IncContainerFailed(image string)
- func (m *Provider) IncContainerStarted(image string)
- func (m *Provider) IncContainerStopped(image string)
- func (m *Provider) IncCriticalSectionFinished(success bool)
- func (m *Provider) IncCriticalSectionStarted()
- func (m *Provider) IncEventEmitted(source string)
- func (m *Provider) IncEventRouted(topic string)
- func (m *Provider) IncEventWaiting(source string)
- func (m *Provider) IncForceExitTriggered()
- func (m *Provider) IncGoroutineFinished()
- func (m *Provider) IncGoroutinePanicked()
- func (m *Provider) IncGoroutineStarted()
- func (m *Provider) IncGoroutineWaiting()
- func (m *Provider) IncHandlerError(topic string, err error)
- func (m *Provider) IncHandlerExecuted(topic string)
- func (m *Provider) IncHookExecuted()
- func (m *Provider) IncHookPanicked()
- func (m *Provider) IncProcessFailed()
- func (m *Provider) IncProcessStarted()
- func (m *Provider) IncSignalReceived(sig string)
- func (m *Provider) IncSupervisorAdd(s string)
- func (m *Provider) IncSupervisorRemove(s string)
- func (m *Provider) IncSupervisorRestart(s, strategy string)
- func (m *Provider) IncTerminalUpgrade(success bool)
- func (m *Provider) IncWorkerFailed(wt string)
- func (m *Provider) IncWorkerStarted(wt string)
- func (m *Provider) IncWorkerStopped(wt string)
- func (m *Provider) ObserveContainerDuration(image string, d time.Duration)
- func (m *Provider) ObserveCriticalSectionDuration(d time.Duration)
- func (m *Provider) ObserveEventBlockDuration(source string, d time.Duration)
- func (m *Provider) ObserveGoroutineBlockDuration(d time.Duration)
- func (m *Provider) ObserveHandlerDuration(topic string, d time.Duration)
- func (m *Provider) ObserveHookDuration(d time.Duration)
- func (m *Provider) ObserveShutdownDuration(wt string, d time.Duration)
- func (m *Provider) ObserveWorkerDuration(wt string, d time.Duration)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Provider ¶
type Provider struct {
Mu sync.Mutex
Signals []string
Restarts map[string]int // Supervisor -> count
ChildRestarts map[string]int // Child -> count
Backoffs map[string]time.Duration
// Additional counters for verification
SupervisorAdds map[string]int
SupervisorRemoves map[string]int
WorkerStarts map[string]int
WorkerStops map[string]int
WorkerFails map[string]int
CircuitBreakerTriggers map[string]int
// Goroutine metrics
GoroutinesStarted int
GoroutinesFinished int
GoroutinesPanicked int
GoroutinesWaiting int
// Control Plane metrics
EventsEmitted map[string]int
EventsRouted map[string]int
HandlersExecuted map[string]int
HandlerErrors map[string]int
HandlerDurations map[string]time.Duration
// Critical Section metrics
CriticalSectionStarted int
CriticalSectionFinished int
CriticalSectionSuccesses int
CriticalSectionFailures int
CriticalSectionDuration time.Duration
EventBlockDurations map[string]time.Duration
EventsWaiting map[string]int
}
Provider matches metrics.Provider interface for testing. It is safe for concurrent use.
func (*Provider) DecEventWaiting ¶
func (*Provider) DecGoroutineWaiting ¶
func (m *Provider) DecGoroutineWaiting()
func (*Provider) IncBackoffTriggered ¶
func (*Provider) IncChildRestart ¶
func (*Provider) IncCircuitBreakerTriggered ¶
func (*Provider) IncContainerFailed ¶
func (*Provider) IncContainerStarted ¶
func (*Provider) IncContainerStopped ¶
func (*Provider) IncCriticalSectionFinished ¶
func (*Provider) IncCriticalSectionStarted ¶
func (m *Provider) IncCriticalSectionStarted()
func (*Provider) IncEventEmitted ¶
func (*Provider) IncEventRouted ¶
func (*Provider) IncEventWaiting ¶
func (*Provider) IncForceExitTriggered ¶
func (m *Provider) IncForceExitTriggered()
func (*Provider) IncGoroutineFinished ¶
func (m *Provider) IncGoroutineFinished()
func (*Provider) IncGoroutinePanicked ¶
func (m *Provider) IncGoroutinePanicked()
func (*Provider) IncGoroutineStarted ¶
func (m *Provider) IncGoroutineStarted()
func (*Provider) IncGoroutineWaiting ¶
func (m *Provider) IncGoroutineWaiting()
func (*Provider) IncHandlerError ¶
func (*Provider) IncHandlerExecuted ¶
func (*Provider) IncHookExecuted ¶
func (m *Provider) IncHookExecuted()
func (*Provider) IncHookPanicked ¶
func (m *Provider) IncHookPanicked()
func (*Provider) IncProcessFailed ¶
func (m *Provider) IncProcessFailed()
func (*Provider) IncProcessStarted ¶
func (m *Provider) IncProcessStarted()
func (*Provider) IncSignalReceived ¶
func (*Provider) IncSupervisorAdd ¶
func (*Provider) IncSupervisorRemove ¶
func (*Provider) IncSupervisorRestart ¶
func (*Provider) IncTerminalUpgrade ¶
func (*Provider) IncWorkerFailed ¶
func (*Provider) IncWorkerStarted ¶
func (*Provider) IncWorkerStopped ¶
func (*Provider) ObserveContainerDuration ¶
func (*Provider) ObserveCriticalSectionDuration ¶
func (*Provider) ObserveEventBlockDuration ¶
func (*Provider) ObserveGoroutineBlockDuration ¶
func (*Provider) ObserveHandlerDuration ¶
func (*Provider) ObserveHookDuration ¶
func (*Provider) ObserveShutdownDuration ¶
Source Files
Click to show internal directories.
Click to hide internal directories.