Function forEachDB

server-source-code/internal/queue/workers.go:69–81

forEachDB calls fn for the defaultDB and then for every context DB in the poolCache. When there is no poolCache (single-context), only defaultDB is processed. The tenantHost passed to fn is the domain (Entry.Host), matching TenantKey's prefix.

(ctx context.Context, defaultDB *database.DB, poolCache *hostctx.PoolCache, fn func(context.Context, *database.DB, string))

// When there is no poolCache (single-context), only defaultDB is processed.
// The tenantHost passed to fn is the domain (Entry.Host), matching TenantKey's prefix.
func forEachDB(ctx context.Context, defaultDB *database.DB, poolCache *hostctx.PoolCache, fn func(context.Context, *database.DB, string)) {
	fn(ctx, defaultDB, "")
	if poolCache == nil {
		return
	}
	for _, host := range poolCache.ListHosts() {
		d, err := poolCache.GetOrCreate(ctx, host)
		if err != nil || d == nil {
			continue
		}
		fn(ctx, d, host)
	}
}

// HostStatusMonitorHandler handles host-status-monitor jobs.
type HostStatusMonitorHandler struct {