Method Status

internal/daemon/memory_runtime.go:236–262

(context.Context)

}

func (e *daemonMemoryExtractor) Status(context.Context) (contract.MemoryExtractorStatusPayload, error) {
	if e == nil || e.runtime == nil {
		return contract.MemoryExtractorStatusPayload{Status: contract.MemoryExtractorStateStopped}, nil
	}
	stats := e.runtime.Stats()
	status := contract.MemoryExtractorStateIdle
	if stats.Closed {
		status = contract.MemoryExtractorStateStopped
	} else if stats.InFlightSessions > 0 || stats.QueuedSessions > 0 {
		status = contract.MemoryExtractorStateRunning
	}
	failureCount, err := e.failureCount()
	if err != nil {
		return contract.MemoryExtractorStatusPayload{}, err
	}
	return contract.MemoryExtractorStatusPayload{
		Status:                 status,
		QueuedSessions:         stats.QueuedSessions,
		InFlightSessions:       stats.InFlightSessions,
		ActiveProviderSessions: stats.ActiveProviderSessions,
		DroppedTurns:           intFromInt64(stats.DroppedTurns),
		CoalescedTurns:         intFromInt64(stats.CoalescedTurns),
		SkippedTurns:           intFromInt64(stats.SkippedTurns),
		BackpressuredSessions:  intFromInt64(stats.BackpressuredSessions),
		FailureCount:           failureCount,
	}, nil
}

func (e *daemonMemoryExtractor) ListFailures(context.Context) ([]contract.MemoryExtractorFailurePayload, error) {
	if e == nil {