projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch '14399-azure-list-retry'
[arvados.git]
/
services
/
keepstore
/
config.go
diff --git
a/services/keepstore/config.go
b/services/keepstore/config.go
index 2bd989de30c1bffc020777ba1ecbb895591570cf..43a2191111376fbf86c6943ffffff6c22668aa38 100644
(file)
--- a/
services/keepstore/config.go
+++ b/
services/keepstore/config.go
@@
-13,6
+13,7
@@
import (
"time"
"git.curoverse.com/arvados.git/sdk/go/arvados"
"time"
"git.curoverse.com/arvados.git/sdk/go/arvados"
+ "github.com/prometheus/client_golang/prometheus"
"github.com/sirupsen/logrus"
)
"github.com/sirupsen/logrus"
)
@@
-81,7
+82,7
@@
func DefaultConfig() *Config {
// Start should be called exactly once: after setting all public
// fields, and before using the config.
// Start should be called exactly once: after setting all public
// fields, and before using the config.
-func (cfg *Config) Start() error {
+func (cfg *Config) Start(
reg *prometheus.Registry
) error {
if cfg.Debug {
log.Level = logrus.DebugLevel
cfg.debugLogf = log.Printf
if cfg.Debug {
log.Level = logrus.DebugLevel
cfg.debugLogf = log.Printf
@@
-143,8
+144,9
@@
func (cfg *Config) Start() error {
return fmt.Errorf("no volumes found")
}
}
return fmt.Errorf("no volumes found")
}
}
+ vm := newVolumeMetricsVecs(reg)
for _, v := range cfg.Volumes {
for _, v := range cfg.Volumes {
- if err := v.Start(); err != nil {
+ if err := v.Start(
vm
); err != nil {
return fmt.Errorf("volume %s: %s", v, err)
}
log.Printf("Using volume %v (writable=%v)", v, v.Writable())
return fmt.Errorf("volume %s: %s", v, err)
}
log.Printf("Using volume %v (writable=%v)", v, v.Writable())
@@
-165,7
+167,7
@@
func (vl *VolumeList) UnmarshalJSON(data []byte) error {
for _, factory := range VolumeTypes {
t := factory().Type()
if _, ok := typeMap[t]; ok {
for _, factory := range VolumeTypes {
t := factory().Type()
if _, ok := typeMap[t]; ok {
- log.Fatal
("volume type %+q is claimed by multiple VolumeTypes"
)
+ log.Fatal
f("volume type %+q is claimed by multiple VolumeTypes", t
)
}
typeMap[t] = factory
}
}
typeMap[t] = factory
}