| 85 | } |
| 86 | |
| 87 | type JobV2 struct { |
| 88 | pluginName string |
| 89 | name string |
| 90 | moduleName string |
| 91 | fullName string |
| 92 | updateEvery int |
| 93 | autoDetectEvery int |
| 94 | autoDetectTries int |
| 95 | isStock bool |
| 96 | functionOnly bool |
| 97 | labels map[string]string |
| 98 | |
| 99 | *logger.Logger |
| 100 | |
| 101 | module collectorapi.CollectorV2 |
| 102 | |
| 103 | running atomic.Bool |
| 104 | |
| 105 | initialized bool |
| 106 | panicked atomic.Bool |
| 107 | |
| 108 | store metrix.CollectorStore |
| 109 | cycle metrix.CycleController |
| 110 | engine *chartengine.Engine |
| 111 | |
| 112 | prevRun time.Time |
| 113 | retries atomic.Int64 |
| 114 | |
| 115 | vnodeMu sync.RWMutex |
| 116 | vnode vnodes.VirtualNode |
| 117 | updVnode chan *vnodes.VirtualNode |
| 118 | |
| 119 | hostState jobV2HostState |
| 120 | |
| 121 | ctxMu sync.RWMutex |
| 122 | runCtx context.Context |
| 123 | cancelRun context.CancelFunc |
| 124 | |
| 125 | tick chan int |
| 126 | out io.Writer |
| 127 | buf *bytes.Buffer |
| 128 | api *netdataapi.API |
| 129 | |
| 130 | stopCtrl stopController |
| 131 | |
| 132 | runtimeService runtimecomp.Service |
| 133 | runtimeComponentName string |
| 134 | runtimeComponentRegistered bool |
| 135 | |
| 136 | skipTracker tickstate.SkipTracker |
| 137 | } |
| 138 | |
| 139 | type jobV2PreparedEmission struct { |
| 140 | attempt chartengine.PlanAttempt |
nothing calls this directly
no outgoing calls
no test coverage detected