registry

Documentation

Index

• Variables
• func ExpandAndVerifyRegistryUrl(hostname string) (string, error)
• func ResolveRepositoryName(reposName string) (string, string, error)
• type ImgData
• type Registry
  • func NewRegistry(authConfig *auth.AuthConfig, factory *utils.HTTPRequestFactory, ...) (r *Registry, err error)
  • func (r *Registry) GetAuthConfig(withPasswd bool) *auth.AuthConfig
  • func (r *Registry) GetRemoteHistory(imgID, registry string, token []string) ([]string, error)
  • func (r *Registry) GetRemoteImageJSON(imgID, registry string, token []string) ([]byte, int, error)
  • func (r *Registry) GetRemoteImageLayer(imgID, registry string, token []string) (io.ReadCloser, error)
  • func (r *Registry) GetRemoteTags(registries []string, repository string, token []string) (map[string]string, error)
  • func (r *Registry) GetRepositoryData(remote string) (*RepositoryData, error)
  • func (r *Registry) LookupRemoteImage(imgID, registry string, token []string) bool
  • func (r *Registry) PushImageChecksumRegistry(imgData *ImgData, registry string, token []string) error
  • func (r *Registry) PushImageJSONIndex(remote string, imgList []*ImgData, validate bool, regs []string) (*RepositoryData, error)
  • func (r *Registry) PushImageJSONRegistry(imgData *ImgData, jsonRaw []byte, registry string, token []string) error
  • func (r *Registry) PushImageLayerRegistry(imgID string, layer io.Reader, registry string, token []string, jsonRaw []byte) (checksum string, checksumPayload string, err error)
  • func (r *Registry) PushRegistryTag(remote, revision, tag, registry string, token []string) error
  • func (r *Registry) SearchRepositories(term string) (*SearchResults, error)
• type RepositoryData
• type SearchResult
• type SearchResults

Variables

var (
	ErrAlreadyExists         = errors.New("Image already exists")
	ErrInvalidRepositoryName = errors.New("Invalid repository name (ex: \"registry.domain.tld/myrepos\")")
)

Functions

func ExpandAndVerifyRegistryUrl

func ExpandAndVerifyRegistryUrl(hostname string) (string, error)

this method expands the registry name as used in the prefix of a repo to a full url. if it already is a url, there will be no change. The registry is pinged to test if it http or https

func ResolveRepositoryName

func ResolveRepositoryName(reposName string) (string, string, error)

Resolves a repository name to a hostname + name

Types

type ImgData

type ImgData struct {
	ID              string `json:"id"`
	Checksum        string `json:"checksum,omitempty"`
	ChecksumPayload string `json:"-"`
	Tag             string `json:",omitempty"`
}

type Registry

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

func NewRegistry

func NewRegistry(authConfig *auth.AuthConfig, factory *utils.HTTPRequestFactory, indexEndpoint string) (r *Registry, err error)

func (*Registry) GetAuthConfig

func (r *Registry) GetAuthConfig(withPasswd bool) *auth.AuthConfig

func (*Registry) GetRemoteHistory

func (r *Registry) GetRemoteHistory(imgID, registry string, token []string) ([]string, error)

Retrieve the history of a given image from the Registry. Return a list of the parent's json (requested image included)

func (*Registry) GetRemoteImageJSON

func (r *Registry) GetRemoteImageJSON(imgID, registry string, token []string) ([]byte, int, error)

Retrieve an image from the Registry.

func (*Registry) GetRemoteImageLayer

func (r *Registry) GetRemoteImageLayer(imgID, registry string, token []string) (io.ReadCloser, error)

func (*Registry) GetRemoteTags

func (r *Registry) GetRemoteTags(registries []string, repository string, token []string) (map[string]string, error)

func (*Registry) GetRepositoryData

func (r *Registry) GetRepositoryData(remote string) (*RepositoryData, error)

func (*Registry) LookupRemoteImage

func (r *Registry) LookupRemoteImage(imgID, registry string, token []string) bool

Check if an image exists in the Registry TODO: This method should return the errors instead of masking them and returning false

func (*Registry) PushImageChecksumRegistry

func (r *Registry) PushImageChecksumRegistry(imgData *ImgData, registry string, token []string) error

func (*Registry) PushImageJSONIndex

func (r *Registry) PushImageJSONIndex(remote string, imgList []*ImgData, validate bool, regs []string) (*RepositoryData, error)

func (*Registry) PushImageJSONRegistry

func (r *Registry) PushImageJSONRegistry(imgData *ImgData, jsonRaw []byte, registry string, token []string) error

Push a local image to the registry

func (*Registry) PushImageLayerRegistry

func (r *Registry) PushImageLayerRegistry(imgID string, layer io.Reader, registry string, token []string, jsonRaw []byte) (checksum string, checksumPayload string, err error)

func (*Registry) PushRegistryTag

func (r *Registry) PushRegistryTag(remote, revision, tag, registry string, token []string) error

push a tag on the registry. Remote has the format '<user>/<repo>

func (*Registry) SearchRepositories

func (r *Registry) SearchRepositories(term string) (*SearchResults, error)

type RepositoryData

type RepositoryData struct {
	ImgList   map[string]*ImgData
	Endpoints []string
	Tokens    []string
}

type SearchResult

type SearchResult struct {
	StarCount   int    `json:"star_count"`
	IsOfficial  bool   `json:"is_official"`
	Name        string `json:"name"`
	IsTrusted   bool   `json:"is_trusted"`
	Description string `json:"description"`
}

type SearchResults

type SearchResults struct {
	Query      string         `json:"query"`
	NumResults int            `json:"num_results"`
	Results    []SearchResult `json:"results"`
}