-
Notifications
You must be signed in to change notification settings - Fork 4.7k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add prometheus metrics for dockerregistry
Signed-off-by: Gladkov Alexey <agladkov@redhat.com>
- Loading branch information
Showing
21 changed files
with
660 additions
and
29 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,2 @@ | ||
| // Package api describes routes and urls that extends the Registry JSON HTTP API. | ||
| package api |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| package api | ||
|
|
||
| import ( | ||
| "github.com/docker/distribution/reference" | ||
| ) | ||
|
|
||
| var ( | ||
| AdminPrefix = "/admin/" | ||
| ExtensionsPrefix = "/extensions/v2/" | ||
|
|
||
| AdminPath = "/blobs/{digest:" + reference.DigestRegexp.String() + "}" | ||
| SignaturesPath = "/{name:" + reference.NameRegexp.String() + "}/signatures/{digest:" + reference.DigestRegexp.String() + "}" | ||
| MetricsPath = "/metrics" | ||
| ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
140 changes: 140 additions & 0 deletions
140
pkg/dockerregistry/server/configuration/configuration.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,140 @@ | ||
| package configuration | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "errors" | ||
| "io" | ||
| "io/ioutil" | ||
| "os" | ||
| "reflect" | ||
| "strings" | ||
|
|
||
| "gopkg.in/yaml.v2" | ||
|
|
||
| "github.com/docker/distribution/configuration" | ||
| ) | ||
|
|
||
| var ( | ||
| // CurrentVersion is the most recent Version that can be parsed. | ||
| CurrentVersion = configuration.MajorMinorVersion(1, 0) | ||
|
|
||
| ErrUnsupportedVersion = errors.New("Unsupported openshift configuration version") | ||
| ) | ||
|
|
||
| type openshiftConfig struct { | ||
| Openshift Configuration | ||
| } | ||
|
|
||
| type Configuration struct { | ||
| Version configuration.Version `yaml:"version"` | ||
| Metrics Metrics `yaml:"metrics"` | ||
| } | ||
|
|
||
| type Metrics struct { | ||
| Enabled bool `yaml:"enabled"` | ||
| Secret string `yaml:"secret"` | ||
| } | ||
|
|
||
| type versionInfo struct { | ||
| Openshift struct { | ||
| Version *configuration.Version | ||
| } | ||
| } | ||
|
|
||
| // Parse parses an input configuration and returns docker configuration structure and | ||
| // openshift specific configuration. | ||
| // Environment variables may be used to override configuration parameters. | ||
| func Parse(rd io.Reader) (*configuration.Configuration, *Configuration, error) { | ||
| in, err := ioutil.ReadAll(rd) | ||
| if err != nil { | ||
| return nil, nil, err | ||
| } | ||
|
|
||
| // We don't want to change the version from the environment variables. | ||
| os.Unsetenv("REGISTRY_OPENSHIFT_VERSION") | ||
|
|
||
| openshiftEnv, err := popEnv("REGISTRY_OPENSHIFT_") | ||
| if err != nil { | ||
| return nil, nil, err | ||
| } | ||
|
|
||
| dockerConfig, err := configuration.Parse(bytes.NewBuffer(in)) | ||
| if err != nil { | ||
| return nil, nil, err | ||
| } | ||
|
|
||
| dockerEnv, err := popEnv("REGISTRY_") | ||
| if err != nil { | ||
| return nil, nil, err | ||
| } | ||
| if err := pushEnv(openshiftEnv); err != nil { | ||
| return nil, nil, err | ||
| } | ||
|
|
||
| config := openshiftConfig{} | ||
|
|
||
| vInfo := &versionInfo{} | ||
| if err := yaml.Unmarshal(in, &vInfo); err != nil { | ||
| return nil, nil, err | ||
| } | ||
|
|
||
| if vInfo.Openshift.Version != nil { | ||
| if *vInfo.Openshift.Version != CurrentVersion { | ||
| return nil, nil, ErrUnsupportedVersion | ||
| } | ||
| } else { | ||
| return dockerConfig, &config.Openshift, nil | ||
| } | ||
|
|
||
| p := configuration.NewParser("registry", []configuration.VersionedParseInfo{ | ||
| { | ||
| Version: dockerConfig.Version, | ||
| ParseAs: reflect.TypeOf(config), | ||
| ConversionFunc: func(c interface{}) (interface{}, error) { | ||
| return c, nil | ||
| }, | ||
| }, | ||
| }) | ||
|
|
||
| if err = p.Parse(in, &config); err != nil { | ||
| return nil, nil, err | ||
| } | ||
| if err := pushEnv(dockerEnv); err != nil { | ||
| return nil, nil, err | ||
| } | ||
|
|
||
| return dockerConfig, &config.Openshift, nil | ||
| } | ||
|
|
||
| type envVar struct { | ||
| name string | ||
| value string | ||
| } | ||
|
|
||
| func popEnv(prefix string) ([]envVar, error) { | ||
| var envVars []envVar | ||
|
|
||
| for _, env := range os.Environ() { | ||
| if !strings.HasPrefix(env, prefix) { | ||
| continue | ||
| } | ||
| envParts := strings.SplitN(env, "=", 2) | ||
| err := os.Unsetenv(envParts[0]) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| envVars = append(envVars, envVar{envParts[0], envParts[1]}) | ||
| } | ||
|
|
||
| return envVars, nil | ||
| } | ||
|
|
||
| func pushEnv(environ []envVar) error { | ||
| for _, env := range environ { | ||
| if err := os.Setenv(env.name, env.value); err != nil { | ||
| return err | ||
| } | ||
| } | ||
| return nil | ||
| } |
Oops, something went wrong.