Skip to content
Snippets Groups Projects
Unverified Commit 453fae60 authored by Kamil Trzcinski's avatar Kamil Trzcinski
Browse files

Rename tags to tagData

parent c6570d55
No related branches found
No related tags found
No related merge requests found
Loading
Loading
@@ -18,7 +18,7 @@ type repositoryData struct {
layers map[digest]int
manifests map[digest]int
manifestSignatures map[digest][]digest
tags map[string]*tag
tags map[string]*tagData
uploads []string
lock sync.Mutex
}
Loading
Loading
@@ -36,7 +36,7 @@ func newRepositoryData(name string) *repositoryData {
layers: make(map[digest]int),
manifests: make(map[digest]int),
manifestSignatures: make(map[digest][]digest),
tags: make(map[string]*tag),
tags: make(map[string]*tagData),
}
}
 
Loading
Loading
@@ -56,13 +56,13 @@ func (r *repositoryData) uploadPath(upload string) string {
return filepath.Join("repositories", r.name, "_uploads", upload, "link")
}
 
func (r *repositoryData) tag(name string) *tag {
func (r *repositoryData) tag(name string) *tagData {
r.lock.Lock()
defer r.lock.Unlock()
 
t := r.tags[name]
if t == nil {
t = &tag{
t = &tagData{
repository: r,
name: name,
}
Loading
Loading
Loading
Loading
@@ -10,7 +10,7 @@ import (
 
var deleteOldTagVersions = flag.Bool("delete-old-tag-versions", true, "Delete old tag versions")
 
type tag struct {
type tagData struct {
repository *repositoryData
name string
current digest
Loading
Loading
@@ -18,15 +18,15 @@ type tag struct {
lock sync.Mutex
}
 
func (t *tag) currentLinkPath() string {
func (t *tagData) currentLinkPath() string {
return filepath.Join("repositories", t.repository.name, "_manifests", "tags", t.name, "current", "link")
}
 
func (t *tag) versionLinkPath(version digest) string {
func (t *tagData) versionLinkPath(version digest) string {
return filepath.Join("repositories", t.repository.name, "_manifests", "tags", t.name, "index", version.path(), "link")
}
 
func (t *tag) mark(blobs blobsData, deletes deletesData) error {
func (t *tagData) mark(blobs blobsData, deletes deletesData) error {
if t.current.valid() {
t.repository.markManifest(t.current)
} else {
Loading
Loading
@@ -46,7 +46,7 @@ func (t *tag) mark(blobs blobsData, deletes deletesData) error {
return nil
}
 
func (t *tag) setCurrent(info fileInfo) error {
func (t *tagData) setCurrent(info fileInfo) error {
//INFO[0000] /test2/_manifests/tags/latest/current/link
 
link, err := readLink(t.currentLinkPath(), info.etag)
Loading
Loading
@@ -59,7 +59,7 @@ func (t *tag) setCurrent(info fileInfo) error {
return nil
}
 
func (t *tag) addVersion(args []string, info fileInfo) error {
func (t *tagData) addVersion(args []string, info fileInfo) error {
//INFO[0000] /test2/_manifests/tags/latest/index/sha256/af8338145978acd626bfb9e863fa446bebfc9f2660bee1af99ed29efc48d73b4/link
 
link, err := analyzeLink(args)
Loading
Loading
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment