mirror of
https://github.com/ClusterCockpit/cc-metric-store.git
synced 2026-03-13 03:57:30 +01:00
Run go fix tool. Refactor
This commit is contained in:
@@ -83,13 +83,11 @@ func runServer(ctx context.Context) error {
|
|||||||
errChan := make(chan error, 1)
|
errChan := make(chan error, 1)
|
||||||
|
|
||||||
// Start HTTP server
|
// Start HTTP server
|
||||||
wg.Add(1)
|
wg.Go(func() {
|
||||||
go func() {
|
|
||||||
defer wg.Done()
|
|
||||||
if err := srv.Start(ctx); err != nil {
|
if err := srv.Start(ctx); err != nil {
|
||||||
errChan <- err
|
errChan <- err
|
||||||
}
|
}
|
||||||
}()
|
})
|
||||||
|
|
||||||
// Handle shutdown signals
|
// Handle shutdown signals
|
||||||
wg.Add(1)
|
wg.Add(1)
|
||||||
|
|||||||
@@ -39,7 +39,7 @@ func authHandler(next http.Handler, publicKey ed25519.PublicKey) http.Handler {
|
|||||||
// In case expiration and so on are specified, the Parse function
|
// In case expiration and so on are specified, the Parse function
|
||||||
// already returns an error for expired tokens.
|
// already returns an error for expired tokens.
|
||||||
var err error
|
var err error
|
||||||
token, err = jwt.Parse(rawtoken, func(t *jwt.Token) (interface{}, error) {
|
token, err = jwt.Parse(rawtoken, func(t *jwt.Token) (any, error) {
|
||||||
if t.Method != jwt.SigningMethodEdDSA {
|
if t.Method != jwt.SigningMethodEdDSA {
|
||||||
return nil, errors.New("only Ed25519/EdDSA supported")
|
return nil, errors.New("only Ed25519/EdDSA supported")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -15,15 +15,15 @@ import (
|
|||||||
// BackendNodeProvider implements metricstore.NodeProvider by querying
|
// BackendNodeProvider implements metricstore.NodeProvider by querying
|
||||||
// the cc-backend /api/jobs/used_nodes endpoint.
|
// the cc-backend /api/jobs/used_nodes endpoint.
|
||||||
type BackendNodeProvider struct {
|
type BackendNodeProvider struct {
|
||||||
backendUrl string
|
backendURL string
|
||||||
client *http.Client
|
client *http.Client
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewBackendNodeProvider creates a new BackendNodeProvider that queries
|
// NewBackendNodeProvider creates a new BackendNodeProvider that queries
|
||||||
// the given cc-backend URL for used nodes information.
|
// the given cc-backend URL for used nodes information.
|
||||||
func NewBackendNodeProvider(backendUrl string) *BackendNodeProvider {
|
func NewBackendNodeProvider(backendURL string) *BackendNodeProvider {
|
||||||
return &BackendNodeProvider{
|
return &BackendNodeProvider{
|
||||||
backendUrl: backendUrl,
|
backendURL: backendURL,
|
||||||
client: &http.Client{
|
client: &http.Client{
|
||||||
Timeout: 10 * time.Second,
|
Timeout: 10 * time.Second,
|
||||||
},
|
},
|
||||||
@@ -33,7 +33,7 @@ func NewBackendNodeProvider(backendUrl string) *BackendNodeProvider {
|
|||||||
// GetUsedNodes returns a map of cluster names to sorted lists of unique hostnames
|
// GetUsedNodes returns a map of cluster names to sorted lists of unique hostnames
|
||||||
// that are currently in use by jobs that started before the given timestamp.
|
// that are currently in use by jobs that started before the given timestamp.
|
||||||
func (p *BackendNodeProvider) GetUsedNodes(ts int64) (map[string][]string, error) {
|
func (p *BackendNodeProvider) GetUsedNodes(ts int64) (map[string][]string, error) {
|
||||||
url := fmt.Sprintf("%s/api/jobs/used_nodes?ts=%d", p.backendUrl, ts)
|
url := fmt.Sprintf("%s/api/jobs/used_nodes?ts=%d", p.backendURL, ts)
|
||||||
|
|
||||||
resp, err := p.client.Get(url)
|
resp, err := p.client.Get(url)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user