remotecache: explicit names for registry and local

Signed-off-by: CrazyMax <crazy-max@users.noreply.github.com>
This commit is contained in:
CrazyMax
2023-02-09 18:17:46 +01:00
parent b3bb356b86
commit cf4e1bb7d2
2 changed files with 18 additions and 2 deletions

View File

@@ -23,6 +23,14 @@ const (
contentStoreIDPrefix = "local:"
)
type exporter struct {
remotecache.Exporter
}
func (*exporter) Name() string {
return "exporting cache to client directory"
}
// ResolveCacheExporterFunc for "local" cache exporter.
func ResolveCacheExporterFunc(sm *session.Manager) remotecache.ResolveCacheExporterFunc {
return func(ctx context.Context, g session.Group, attrs map[string]string) (remotecache.Exporter, error) {
@@ -47,7 +55,7 @@ func ResolveCacheExporterFunc(sm *session.Manager) remotecache.ResolveCacheExpor
if err != nil {
return nil, err
}
return remotecache.NewExporter(cs, "", ociMediatypes, compressionConfig), nil
return &exporter{remotecache.NewExporter(cs, "", ociMediatypes, compressionConfig)}, nil
}
}

View File

@@ -40,6 +40,14 @@ const (
attrInsecure = "registry.insecure"
)
type exporter struct {
remotecache.Exporter
}
func (*exporter) Name() string {
return "exporting cache to registry"
}
func ResolveCacheExporterFunc(sm *session.Manager, hosts docker.RegistryHosts) remotecache.ResolveCacheExporterFunc {
return func(ctx context.Context, g session.Group, attrs map[string]string) (remotecache.Exporter, error) {
compressionConfig, err := compression.ParseAttributes(attrs)
@@ -74,7 +82,7 @@ func ResolveCacheExporterFunc(sm *session.Manager, hosts docker.RegistryHosts) r
if err != nil {
return nil, err
}
return remotecache.NewExporter(contentutil.FromPusher(pusher), refString, ociMediatypes, compressionConfig), nil
return &exporter{remotecache.NewExporter(contentutil.FromPusher(pusher), refString, ociMediatypes, compressionConfig)}, nil
}
}