registry

Documentation

Index

• func GetHTTPTransport(insecure ...bool) *http.Transport
• func UnMarshal(mediaType string, data []byte) (distribution.Manifest, distribution.Descriptor, error)
• type Registry
  • func NewRegistry(endpoint string, client *http.Client) (*Registry, error)
  • func (r *Registry) Catalog() ([]string, error)
  • func (r *Registry) Ping() error
• type Repository
  • func NewRepository(name, endpoint string, client *http.Client) (*Repository, error)
  • func (r *Repository) BlobExist(digest string) (bool, error)
  • func (r *Repository) DeleteBlob(digest string) error
  • func (r *Repository) DeleteManifest(digest string) error
  • func (r *Repository) DeleteTag(tag string) error
  • func (r *Repository) ListTag() ([]string, error)
  • func (r *Repository) ManifestExist(reference string) (digest string, exist bool, err error)
  • func (r *Repository) MountBlob(digest, from string) error
  • func (r *Repository) PullBlob(digest string) (size int64, data io.ReadCloser, err error)
  • func (r *Repository) PullManifest(reference string, acceptMediaTypes []string) (digest, mediaType string, payload []byte, err error)
  • func (r *Repository) PushBlob(digest string, size int64, data io.Reader) error
  • func (r *Repository) PushManifest(reference, mediaType string, payload []byte) (digest string, err error)
• type Transport
  • func NewTransport(transport http.RoundTripper, modifiers ...modifier.Modifier) *Transport
  • func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

Functions

func GetHTTPTransport

func GetHTTPTransport(insecure ...bool) *http.Transport

GetHTTPTransport returns HttpTransport based on insecure configuration

func UnMarshal

func UnMarshal(mediaType string, data []byte) (distribution.Manifest, distribution.Descriptor, error)

UnMarshal converts []byte to be distribution.Manifest

Types

type Registry

type Registry struct {
	Endpoint *url.URL
	// contains filtered or unexported fields
}

Registry holds information of a registry entity

func NewRegistry

func NewRegistry(endpoint string, client *http.Client) (*Registry, error)

NewRegistry returns an instance of registry

func (*Registry) Catalog

func (r *Registry) Catalog() ([]string, error)

Catalog ... 显示仓库的大概信息

func (*Registry) Ping

func (r *Registry) Ping() error

Ping ... 测试 registry 服务是否可用

type Repository

type Repository struct {
	Name     string
	Endpoint *url.URL
	// contains filtered or unexported fields
}

Repository holds information of a repository entity

func NewRepository

func NewRepository(name, endpoint string, client *http.Client) (*Repository, error)

NewRepository returns an instance of Repository

func (*Repository) BlobExist

func (r *Repository) BlobExist(digest string) (bool, error)

BlobExist ...

func (*Repository) DeleteBlob

func (r *Repository) DeleteBlob(digest string) error

DeleteBlob ...

func (*Repository) DeleteManifest

func (r *Repository) DeleteManifest(digest string) error

DeleteManifest ...

func (*Repository) DeleteTag

func (r *Repository) DeleteTag(tag string) error

DeleteTag ...

func (*Repository) ListTag

func (r *Repository) ListTag() ([]string, error)

ListTag ...

func (*Repository) ManifestExist

func (r *Repository) ManifestExist(reference string) (digest string, exist bool, err error)

ManifestExist ...

func (*Repository) MountBlob

func (r *Repository) MountBlob(digest, from string) error

MountBlob ...

func (*Repository) PullBlob

func (r *Repository) PullBlob(digest string) (size int64, data io.ReadCloser, err error)

PullBlob : client must close data if it is not nil

func (*Repository) PullManifest

func (r *Repository) PullManifest(reference string, acceptMediaTypes []string) (digest, mediaType string, payload []byte, err error)

PullManifest ...

func (*Repository) PushBlob

func (r *Repository) PushBlob(digest string, size int64, data io.Reader) error

PushBlob ...

func (*Repository) PushManifest

func (r *Repository) PushManifest(reference, mediaType string, payload []byte) (digest string, err error)

PushManifest ...

type Transport

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

Transport holds information about base transport and modifiers

func NewTransport

func NewTransport(transport http.RoundTripper, modifiers ...modifier.Modifier) *Transport

NewTransport ...

func (*Transport) RoundTrip

func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

RoundTrip ...