registry

Dec 11, 2024

Changes in this version

+ func GetTimeString(d time.Duration) string

+ func Logging(next http.Handler) http.Handler

+ type Artifact struct

+ Created time.Time

+ Filepath string

+ ID string

+ Size int64

+ type Registry interface

+ Artifacts func(repo, tag string) []string

+ GetArtifact func(repo, tag string) (*Artifact, error)

+ Load func(load_path string) error

+ PutArtifact func(repo string, tags []string, data []byte) error

+ Repos func() []string

+ Save func(save_path string) error

+ Tags func(repo string) []string

+ type RegistryServer struct

+ func NewRegistryServer(addr, data_root string) *RegistryServer

+ func (r *RegistryServer) ListenAndServe() error

+ func (r *RegistryServer) Shutdown() error

+ func (rs *RegistryServer) AgentListHandler(w http.ResponseWriter, r *http.Request)

+ func (rs *RegistryServer) GetHandler(w http.ResponseWriter, r *http.Request)

+ func (rs *RegistryServer) PutHandler(w http.ResponseWriter, r *http.Request)

+ type SimpleHistory struct

+ History map[string][]*Artifact

+ func NewSimpleHistory() *SimpleHistory

+ func (s *SimpleHistory) GetCurrent(tag string) *Artifact

+ func (s *SimpleHistory) Tags() []string

+ func (s *SimpleHistory) Update(tag string, art *Artifact) error

+ type SimpleRegistry struct

+ CurrRepos map[string]*SimpleHistory

+ DataRoot string

+ func NewSimpleRegistry(data_root string) *SimpleRegistry

+ func (s *SimpleRegistry) Artifacts(repo, tag string) []string

+ func (s *SimpleRegistry) GetArtifact(repo_name, tag string) (*Artifact, error)

+ func (s *SimpleRegistry) Load(load_path string) error

+ func (s *SimpleRegistry) PutArtifact(repo_name string, tags []string, data []byte) error

+ func (s *SimpleRegistry) Repos() []string

+ func (s *SimpleRegistry) Save(save_path string) error

+ func (s *SimpleRegistry) Tags(repo string) []string

+ type TagHistory interface

+ GetCurrent func(tag string) *Artifact

+ Tags func() []string

+ Update func(tag string, art *Artifact) error

+ type WrappedWriter struct

+ func (w *WrappedWriter) WriteHeader(status_code int)