registry

type Artifact ¶

type Artifact struct {
	ID       string
	Filepath string
	Created  time.Time
	Size     int64
}

Artifact represents something to be added to a repo according to tags.

type Registry ¶

type Registry interface {
	GetArtifact(repo, tag string) (*Artifact, error)           // use (nil, nil) return for "not found" or nonexistent. reserve errors for connection errors or similar (i.e.  "this record might exist, but I can say for sure right now")
	PutArtifact(repo string, tags []string, data []byte) error //

	Save(save_path string) error // We require these, b/c the service needs to be reloadable for now
	Load(load_path string) error // ""

	// Hierarchical API Repos have tags which have artifacts
	Repos() []string
	Tags(repo string) []string
	Artifacts(repo, tag string) []string
}

Registry bundles tools for maintaining a core registry of agents. For now, only .tar.gz files are supported.

type RegistryServer ¶

type RegistryServer struct {
	Registry
	// contains filtered or unexported fields
}

RegistryServer hosts an embedded Registry object.

func NewRegistryServer(addr, data_root string) *RegistryServer

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

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

func (r *RegistryServer) ListenAndServe() error

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

func (r *RegistryServer) Shutdown() error

type SimpleHistory ¶

type SimpleHistory struct {
	History map[string][]*Artifact
}

SimpleHistory is a bare-bones implementation of TagHistory for a SimpleRegistry.

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 ¶

type SimpleRegistry struct {
	DataRoot  string
	CurrRepos map[string]*SimpleHistory // maps repo names to TagHistories
}

SimpleRegistry uses the local filesystem to do basic, safe-ish storage of artifacts. We want to be able to shutdown and restart without issue and that's what it should allow us to do.

Each SimpleRegistry has repos, which are simply just named SimpleHistory objects. Each repo (i.e., SimpleHistory) has many tags, and for each tag, many artifacts.

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 ¶

type TagHistory interface {
	GetCurrent(tag string) *Artifact
	Update(tag string, art *Artifact) error
	Tags() []string
}

TagHistory is a list of ids sorted oldest to newest (i.e. the "current" artifact for a tag is history[len(history)-1]).

type WrappedWriter ¶

type WrappedWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

WrappedWriter wraps an http.ResponseWriter for a registry server.

func (w *WrappedWriter) WriteHeader(status_code int)