registry

package
v0.0.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 29, 2022 License: MIT Imports: 17 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Registry

type Registry struct {
	ServiceAddress string            `json:"service_address"`
	Insecure       bool              `json:"insecure"`
	Username       string            `json:"username"`
	Password       string            `json:"password"`
	TokenHeader    map[string]string `json:"token_header"`
	Client         *http.Client
}

func NewRegistry

func NewRegistry(serviceAddress, username, password string, insecure bool) Registry

func (*Registry) AutoReadBody

func (r *Registry) AutoReadBody(e entity.Entity) (resp *http.Response, body []byte, err error)

func (*Registry) DeleteBlob

func (r *Registry) DeleteBlob(repositoryName, dgs string) (err error)

func (*Registry) DeleteBlobUpload

func (r *Registry) DeleteBlobUpload(repositoryName, uuid string) (err error)

func (*Registry) DeleteManifest

func (r *Registry) DeleteManifest(repositoryName, reference string) (err error)

func (*Registry) Do

func (r *Registry) Do(e entity.Entity) (resp *http.Response, err error)

func (*Registry) FetchBlob

func (r *Registry) FetchBlob(repositoryName, dgs string, followRedirects bool) (content []byte, err error)

func (*Registry) FetchBlobPart

func (r *Registry) FetchBlobPart(repositoryName, dgs string, start, end int, followRedirects bool) (content []byte, err error)

func (*Registry) GetBase

func (r *Registry) GetBase() (err error)

func (*Registry) GetBlob

func (r *Registry) GetBlob(repositoryName, dgs string) (exists bool, err error)

func (*Registry) GetBlobUpload

func (r *Registry) GetBlobUpload(repositoryName, uuid string) (uploadRange string, err error)

func (*Registry) GetBody

func (r *Registry) GetBody(e entity.Entity) (reader io.Reader, err error)

func (*Registry) GetCatalog

func (r *Registry) GetCatalog(query entity.CatalogQuery) (catalogResponse response.Catalog, err error)

func (*Registry) GetManifest

func (r *Registry) GetManifest(repositoryName, ref string) (manifest schema2.Manifest, err error)

func (*Registry) GetTags

func (r *Registry) GetTags(repositoryName string) (tags []string, err error)

func (*Registry) GetTokenHeader added in v0.0.5

func (r *Registry) GetTokenHeader(url string) (header map[string]string, err error)

TODO: if 401, auto call this function

func (*Registry) InitiateBlobUpload

func (r *Registry) InitiateBlobUpload(repositoryName, dgs string, binary []byte) (location, dockerUploadUUID string, err error)

func (*Registry) InitiateResumableBlobUpload

func (r *Registry) InitiateResumableBlobUpload(repositoryName string) (location, dockerUploadUUID string, err error)

func (*Registry) MountBlob

func (r *Registry) MountBlob(repositoryName, mount, from string) (location, dockerUploadUUID string, err error)

func (*Registry) NotCareBody

func (r *Registry) NotCareBody(e entity.Entity) (resp *http.Response, err error)

func (*Registry) PatchBlobUpload

func (r *Registry) PatchBlobUpload(repositoryName, uuid string, binary []byte, chunked bool, start, end int) (location, uploadRange string)

func (*Registry) PutBlobUpload

func (r *Registry) PutBlobUpload(repositoryName, loc, uuid, digest string, binary []byte) (location, contentRange string)

func (*Registry) PutManifest

func (r *Registry) PutManifest(repositoryName, reference string, manifest schema2.Manifest) (err error)

func (*Registry) TagsPaginated

func (r *Registry) TagsPaginated(repositoryName string, number, last int) (tags []string, err error)

func (*Registry) TamperingManifest added in v0.0.6

func (r *Registry) TamperingManifest(repositoryName, reference string, body io.Reader) (err error)

func (*Registry) Url

func (r *Registry) Url(e entity.Entity) string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL