Method recordLimits

util/github/client.go:580–607

(core github.Rate)

}

func (g *githubClient) recordLimits(core github.Rate) {
	limit := params.GithubRateLimit{
		Limit:     core.Limit,
		Used:      core.Used,
		Remaining: core.Remaining,
		Reset:     core.Reset.Unix(),
	}
	cache.SetCredentialsRateLimit(g.entity.Credentials.ID, limit)

	// Record Prometheus metrics
	credID := fmt.Sprintf("%d", g.entity.Credentials.ID)
	credName := g.entity.Credentials.Name
	endpoint := g.entity.Credentials.Endpoint.Name
	if endpoint == "" {
		endpoint = g.entity.Credentials.BaseURL
	}

	labels := map[string]string{
		"credential_name": credName,
		"credential_id":   credID,
		"endpoint":        endpoint,
	}

	metrics.GithubRateLimitLimit.With(labels).Set(float64(core.Limit))
	metrics.GithubRateLimitRemaining.With(labels).Set(float64(core.Remaining))
	metrics.GithubRateLimitUsed.With(labels).Set(float64(core.Used))
	metrics.GithubRateLimitResetTimestamp.With(labels).Set(float64(core.Reset.Unix()))
}

func NewRateLimitClient(ctx context.Context, credentials params.ForgeCredentials) (common.RateLimitClient, error) {
	httpClient, err := credentials.GetHTTPClient(ctx)