MCPcopy Create free account
hub / github.com/compozy/agh / networkTaskStatusObserver

Struct networkTaskStatusObserver

internal/daemon/network_task_status_observer.go:27–38  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

25)
26
27type networkTaskStatusObserver struct {
28 network networkRuntime
29 tasks taskStore
30 prefs storepkg.NetworkPreferenceStore
31 logger *slog.Logger
32 now func() time.Time
33 ctx context.Context
34 cancel context.CancelFunc
35 wg sync.WaitGroup
36 queue chan taskpkg.EventRecord
37 timeout time.Duration
38}
39
40var _ taskpkg.EventObserver = (*networkTaskStatusObserver)(nil)
41

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected