repository_fetcher

Documentation

Index

• type DockerRepositoryFetcher
  • func (fetcher *DockerRepositoryFetcher) Fetch(logger lager.Logger, repoName string, tag string) (string, []string, error)
• type Graph
• type Registry
• type RepositoryFetcher
  • func New(registry Registry, graph Graph) RepositoryFetcher
• type Retryable
  • func (retryable Retryable) Fetch(logger lager.Logger, repoName string, tag string) (string, []string, error)

Types

type DockerRepositoryFetcher

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

func (*DockerRepositoryFetcher) Fetch

func (fetcher *DockerRepositoryFetcher) Fetch(logger lager.Logger, repoName string, tag string) (string, []string, error)

type Graph

type Graph interface {
	Get(name string) (*image.Image, error)
	Exists(imageID string) bool
	Register(image *image.Image, imageJSON []byte, layer archive.ArchiveReader) error
}

apes docker's *graph.Graph

type Registry

type Registry interface {
	GetRepositoryData(repoName string) (*registry.RepositoryData, error)
	GetRemoteTags(registries []string, repository string, token []string) (map[string]string, error)
	GetRemoteHistory(imageID string, registry string, token []string) ([]string, error)

	GetRemoteImageJSON(imageID string, registry string, token []string) ([]byte, int, error)
	GetRemoteImageLayer(imageID string, registry string, token []string, size int64) (io.ReadCloser, error)
}

apes docker's *registry.Registry

type RepositoryFetcher

type RepositoryFetcher interface {
	Fetch(logger lager.Logger, repoName string, tag string) (imageID string, envvars []string, err error)
}

func New

func New(registry Registry, graph Graph) RepositoryFetcher

type Retryable

type Retryable struct {
	RepositoryFetcher
}

func (Retryable) Fetch

func (retryable Retryable) Fetch(logger lager.Logger, repoName string, tag string) (string, []string, error)