testutil

Documentation

Index

• Constants
• func AssertManifestsEqual(t *testing.T, description string, ma distribution.Manifest, ...)
• func CreateAndUploadTestManifest(schemaVersion ManifestSchemaVersion, layerCount int, serverURL *url.URL, ...) (dgst digest.Digest, canonical, manifestConfig string, ...)
• func CreateRandomImage(namespace, name string) (*imageapi.Image, error)
• func CreateRandomTarFile() (rs io.ReadSeeker, dgst digest.Digest, err error)
• func GetFakeImageGetHandler(t *testing.T, imgs ...imageapi.Image) core.ReactionFunc
• func GetFakeImageStreamGetHandler(t *testing.T, iss ...imageapi.ImageStream) core.ReactionFunc
• func GetFakeImageStreamImageGetHandler(t *testing.T, iss *imageapi.ImageStream, imgs ...imageapi.Image) core.ReactionFunc
• func MakeSchema1Manifest(name, tag string, layers []distribution.Descriptor) (string, distribution.Manifest, error)
• func MakeSchema2Manifest(config distribution.Descriptor, layers []distribution.Descriptor) (string, distribution.Manifest, error)
• func NewBasicCredentialStore(username, password string) auth.CredentialStore
• func NewImageForManifest(repoName string, rawManifest string, manifestConfig string, ...) (*imageapi.Image, error)
• func RegisterImage(os *FakeOpenShift, image *imageapi.Image, namespace, name, tag string) error
• func RegisterRandomImage(os *FakeOpenShift, namespace, name, tag string) (*imageapi.Image, error)
• func TestNewImageStreamObject(namespace, name, tag, imageName, dockerImageReference string) *imageapi.ImageStream
• func UploadPayloadAsBlob(payload []byte, serverURL *url.URL, creds auth.CredentialStore, ...) (distribution.Descriptor, error)
• func UploadRandomTestBlob(serverURL *url.URL, creds auth.CredentialStore, repoName string) (distribution.Descriptor, []byte, error)
• func UploadTestBlobFromReader(dgst digest.Digest, reader io.ReadSeeker, serverURL *url.URL, ...) (distribution.Descriptor, []byte, error)
• type ConfigPayload
  • func MakeManifestConfig() (ConfigPayload, distribution.Descriptor, error)
• type FakeOpenShift
  • func NewFakeOpenShift() *FakeOpenShift
  • func NewFakeOpenShiftWithClient() (*FakeOpenShift, *testclient.Fake)
  • func (os *FakeOpenShift) AddReactorsTo(client *testclient.Fake)
  • func (os *FakeOpenShift) CreateImage(image *imageapi.Image) (*imageapi.Image, error)
  • func (os *FakeOpenShift) CreateImageStream(namespace string, is *imageapi.ImageStream) (*imageapi.ImageStream, error)
  • func (os *FakeOpenShift) CreateImageStreamMapping(group string, ism *imageapi.ImageStreamMapping) (*imageapi.ImageStreamMapping, error)
  • func (os *FakeOpenShift) GetImage(name string) (*imageapi.Image, error)
  • func (os *FakeOpenShift) GetImageStream(namespace, repo string) (*imageapi.ImageStream, error)
• type LayerPayload
  • func MakeRandomLayers(layerCount int) ([]distribution.Descriptor, []LayerPayload, error)
• type ManifestSchemaVersion
• type Payload
  • func CreateRandomManifest(schemaVersion ManifestSchemaVersion, layerCount int) (string, distribution.Manifest, *Payload, error)

Constants

const SampleImageManifestSchema1 = `` /* 1130-byte string literal not displayed */

Functions

func AssertManifestsEqual

func AssertManifestsEqual(t *testing.T, description string, ma distribution.Manifest, mb distribution.Manifest)

AssertManifestsEqual compares two manifests and returns if they are equal. Signatures of manifest schema 1 are not taken into account.

func CreateAndUploadTestManifest

func CreateAndUploadTestManifest(
	schemaVersion ManifestSchemaVersion,
	layerCount int,
	serverURL *url.URL,
	creds auth.CredentialStore,
	repoName, tag string,
) (dgst digest.Digest, canonical, manifestConfig string, manifest distribution.Manifest, err error)

CreateUploadTestManifest generates a random manifest blob and uploads it to the given repository. For this purpose, a given number of layers will be created and uploaded.

func CreateRandomImage

func CreateRandomImage(namespace, name string) (*imageapi.Image, error)

CreateRandomImage creates an image with a random content.

func CreateRandomTarFile

func CreateRandomTarFile() (rs io.ReadSeeker, dgst digest.Digest, err error)

createRandomTarFile creates a random tarfile, returning it as an io.ReadSeeker along with its digest. An error is returned if there is a problem generating valid content. Inspired by github.com/vendor/docker/distribution/testutil/tarfile.go.

func GetFakeImageGetHandler

func GetFakeImageGetHandler(t *testing.T, imgs ...imageapi.Image) core.ReactionFunc

GetFakeImageGetHandler returns a reaction function for use with fake os client returning one of given image objects if found.

func GetFakeImageStreamGetHandler

func GetFakeImageStreamGetHandler(t *testing.T, iss ...imageapi.ImageStream) core.ReactionFunc

GetFakeImageStreamGetHandler creates a test handler to be used as a reactor with core.Fake client that handles Get request on image stream resource. Matching is from given image stream list will be returned if found. Additionally, a shared image stream may be requested.

func GetFakeImageStreamImageGetHandler

func GetFakeImageStreamImageGetHandler(t *testing.T, iss *imageapi.ImageStream, imgs ...imageapi.Image) core.ReactionFunc

GetFakeImageStreamImageGetHandler returns a reaction function for use with fake os client returning one of given imagestream image objects if found.

func MakeSchema1Manifest

func MakeSchema1Manifest(name, tag string, layers []distribution.Descriptor) (string, distribution.Manifest, error)

MakeSchema1Manifest constructs a schema 1 manifest from a given list of digests and returns the digest of the manifest github.com/docker/distribution/testutil

func MakeSchema2Manifest

func MakeSchema2Manifest(config distribution.Descriptor, layers []distribution.Descriptor) (string, distribution.Manifest, error)

MakeSchema2Manifest constructs a schema 2 manifest from a given list of digests and returns the digest of the manifest

func NewBasicCredentialStore

func NewBasicCredentialStore(username, password string) auth.CredentialStore

NewBasicCredentialStore returns a test credential store for use with registry token handler and/or basic handler.

func NewImageForManifest

func NewImageForManifest(repoName string, rawManifest string, manifestConfig string, managedByOpenShift bool) (*imageapi.Image, error)

NewImageManifest creates a new Image object for the given manifest string. Note that the manifest must contain signatures if it is of schema 1.

func RegisterImage

func RegisterImage(os *FakeOpenShift, image *imageapi.Image, namespace, name, tag string) error

RegisterImage adds image to the image stream namespace/name.

func RegisterRandomImage

func RegisterRandomImage(os *FakeOpenShift, namespace, name, tag string) (*imageapi.Image, error)

RegisterRandomImage adds image with a random content to the image stream namespace/name.

func TestNewImageStreamObject

func TestNewImageStreamObject(namespace, name, tag, imageName, dockerImageReference string) *imageapi.ImageStream

TestNewImageStreamObject returns a new image stream object filled with given values.

func UploadPayloadAsBlob

func UploadPayloadAsBlob(
	payload []byte,
	serverURL *url.URL,
	creds auth.CredentialStore,
	repoName string,
) (distribution.Descriptor, error)

UploadPayloadAsBlob uploads a given payload to the registry serving at the given URL.

func UploadRandomTestBlob

func UploadRandomTestBlob(
	serverURL *url.URL,
	creds auth.CredentialStore,
	repoName string,
) (distribution.Descriptor, []byte, error)

UploadRandomTestBlob generates a random tar file and uploads it to the given repository.

func UploadTestBlobFromReader

func UploadTestBlobFromReader(
	dgst digest.Digest,
	reader io.ReadSeeker,
	serverURL *url.URL,
	creds auth.CredentialStore,
	repoName string,
) (distribution.Descriptor, []byte, error)

UploadTestBlobFromReader uploads a testing blob read from the given reader to the registry located at the given URL.

Types

type ConfigPayload

type ConfigPayload []byte

func MakeManifestConfig

func MakeManifestConfig() (ConfigPayload, distribution.Descriptor, error)

type FakeOpenShift

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

FakeOpenShift is an in-mempory reactors for fake.Client.

func NewFakeOpenShift

func NewFakeOpenShift() *FakeOpenShift

NewFakeOpenShift constructs the fake OpenShift reactors.

func NewFakeOpenShiftWithClient

func NewFakeOpenShiftWithClient() (*FakeOpenShift, *testclient.Fake)

NewFakeOpenShiftWithClient constructs a fake client associated with the stateful fake in-memory OpenShift reactors. The fake OpenShift is available for direct interaction, so you can make buggy states.

func (*FakeOpenShift) AddReactorsTo

func (os *FakeOpenShift) AddReactorsTo(client *testclient.Fake)

AddReactorsTo binds the reactors to client.

func (*FakeOpenShift) CreateImage

func (os *FakeOpenShift) CreateImage(image *imageapi.Image) (*imageapi.Image, error)

func (*FakeOpenShift) CreateImageStream

func (os *FakeOpenShift) CreateImageStream(namespace string, is *imageapi.ImageStream) (*imageapi.ImageStream, error)

func (*FakeOpenShift) CreateImageStreamMapping

func (os *FakeOpenShift) CreateImageStreamMapping(group string, ism *imageapi.ImageStreamMapping) (*imageapi.ImageStreamMapping, error)

func (*FakeOpenShift) GetImage

func (os *FakeOpenShift) GetImage(name string) (*imageapi.Image, error)

func (*FakeOpenShift) GetImageStream

func (os *FakeOpenShift) GetImageStream(namespace, repo string) (*imageapi.ImageStream, error)

type LayerPayload

type LayerPayload []byte

func MakeRandomLayers

func MakeRandomLayers(layerCount int) ([]distribution.Descriptor, []LayerPayload, error)

type ManifestSchemaVersion

type ManifestSchemaVersion int

const (
	ManifestSchema1 ManifestSchemaVersion = 1
	ManifestSchema2 ManifestSchemaVersion = 2
)

type Payload

type Payload struct {
	Config ConfigPayload
	Layers []LayerPayload
}

func CreateRandomManifest

func CreateRandomManifest(schemaVersion ManifestSchemaVersion, layerCount int) (string, distribution.Manifest, *Payload, error)