mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-15 17:51:15 +00:00
Code Activity

comments

Browse source
This commit is contained in:
postmannen 2024-03-10 08:24:49 +01:00
parent 118f6bab98
commit 19fc8665a8
2 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
process.go
View file

@ -180,8 +180,6 @@ func newProcess(ctx context.Context, server *server, subject Subject, processKin
// process to the processes map in the server structure.
func (p process) spawnWorker() {
// processName := processNameGet(p.subject.name(), p.processKind)
// Add prometheus metrics for the process.
if !p.isSubProcess {
p.metrics.promProcessesAllRunning.With(prometheus.Labels{"processName": string(p.processName)})

2
processes.go
View file

@ -376,7 +376,7 @@ func newStartup(server *server) *startup {
}
// subscriber will start a subscriber process. It takes the initial process, request method,
// and a procFunc as it's input arguments. If a procFunc os not needed, use the value nil.
// and a procFunc as it's input arguments. If a procFunc is not needed, use the value nil.
func (s *startup) subscriber(p process, m Method, pf func(ctx context.Context, procFuncCh chan Message) error) {
er := fmt.Errorf("starting %v subscriber: %#v", m, p.node)
p.errorKernel.logDebug(er)