repository_fetcher

Documentation

Index

• Variables
• type DockerRepositoryFetcher
  • func (fetcher *DockerRepositoryFetcher) Fetch(logger lager.Logger, repoURL *url.URL, tag string) (string, process.Env, []string, error)
• type Graph
• type InsecureRegistryError
  • func (err InsecureRegistryError) Error() string
• type Registry
• type RegistryProvider
  • func NewRepositoryProvider(defaultHostname string, insecureRegistries []string) RegistryProvider
• type RepositoryFetcher
  • func New(registry RegistryProvider, graph Graph) RepositoryFetcher
• type Retryable
  • func (retryable Retryable) Fetch(logger lager.Logger, repoName *url.URL, tag string) (string, process.Env, []string, error)

Variables

var RegistryNewEndpoint = registry.NewEndpoint

apes dockers registry.NewEndpoint

var RegistryNewSession = registry.NewSession

apes dockers registry.NewSession

Types

type DockerRepositoryFetcher

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

func (*DockerRepositoryFetcher) Fetch

func (fetcher *DockerRepositoryFetcher) Fetch(
	logger lager.Logger,
	repoURL *url.URL,
	tag string,
) (string, process.Env, []string, error)

type Graph

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

apes docker's *graph.Graph

type InsecureRegistryError

type InsecureRegistryError struct {
	Cause              error
	Endpoint           string
	InsecureRegistries []string
}

func (InsecureRegistryError) Error

func (err InsecureRegistryError) Error() string

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 RegistryProvider

type RegistryProvider interface {
	ProvideRegistry(hostname string) (Registry, error)
	ApplyDefaultHostname(hostname string) string
}

func NewRepositoryProvider

func NewRepositoryProvider(defaultHostname string, insecureRegistries []string) RegistryProvider

type RepositoryFetcher

type RepositoryFetcher interface {
	Fetch(logger lager.Logger, url *url.URL, tag string) (imageID string, envvars process.Env, volumes []string, err error)
}

func New

func New(registry RegistryProvider, graph Graph) RepositoryFetcher

type Retryable

type Retryable struct {
	RepositoryFetcher
}

func (Retryable) Fetch

func (retryable Retryable) Fetch(logger lager.Logger, repoName *url.URL, tag string) (string, process.Env, []string, error)