Skip to content

Commit

Permalink
Address feedback
Browse files Browse the repository at this point in the history
  • Loading branch information
jhiemstrawisc committed Feb 1, 2024
1 parent 56b2d79 commit 992dfa2
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions web_ui/prometheus.go
Original file line number Diff line number Diff line change
Expand Up @@ -145,19 +145,18 @@ func runtimeInfo() (api_v1.RuntimeInfo, error) {

// Configure director's Prometheus scraper to use HTTP service discovery for origins/caches
func configDirectorPromScraper(ctx context.Context) (*config.ScrapeConfig, error) {
serverDiscoveryUrl, err := url.Parse(param.Server_ExternalWebUrl.GetString())
directorBaseUrl, err := url.Parse(param.Server_ExternalWebUrl.GetString())
if err != nil {
return nil, fmt.Errorf("parse external URL %v: %w", param.Server_ExternalWebUrl.GetString(), err)
}

promTokenCfg := utils.TokenConfig{
TokenProfile: utils.WLCG,
Lifetime: param.Monitoring_TokenExpiresIn.GetDuration(),
Issuer: serverDiscoveryUrl.String(),
Audience: []string{serverDiscoveryUrl.String()},
Issuer: directorBaseUrl.String(),
Audience: []string{directorBaseUrl.String()},
Version: "1.0",
Subject: "director",
// Claims: map[string]string{"scope": token_scopes.Pelican_DirectorServiceDiscovery.String()},
}
promTokenCfg.AddScopes([]token_scopes.TokenScope{token_scopes.Pelican_DirectorServiceDiscovery})

Expand All @@ -171,7 +170,7 @@ func configDirectorPromScraper(ctx context.Context) (*config.ScrapeConfig, error
TokenProfile: utils.WLCG,
Version: "1.0",
Lifetime: param.Monitoring_TokenExpiresIn.GetDuration(),
Issuer: serverDiscoveryUrl.String(),
Issuer: directorBaseUrl.String(),
Audience: []string{"prometheus"},
Subject: "director",
}
Expand All @@ -182,6 +181,7 @@ func configDirectorPromScraper(ctx context.Context) (*config.ScrapeConfig, error
return nil, errors.Wrap(err, "failed to create director scraping token")
}

serverDiscoveryUrl := directorBaseUrl
serverDiscoveryUrl.Path = "/api/v1.0/director/discoverServers"
scrapeConfig := config.DefaultScrapeConfig
scrapeConfig.JobName = "origin_cache_servers"
Expand Down

0 comments on commit 992dfa2

Please sign in to comment.