test

Documentation

Index

• type Blob
  • func (tb *Blob) AssertMatches(t *testing.T, sb *blobref.SizedBlobRef)
  • func (tb *Blob) BlobRef() *blobref.BlobRef
  • func (tb *Blob) BlobRefSlice() []*blobref.BlobRef
  • func (tb *Blob) Reader() io.Reader
  • func (tb *Blob) Size() int64
• type FakeIndex
  • func NewFakeIndex() *FakeIndex
  • func (fi *FakeIndex) AddClaim(owner, permanode *blobref.BlobRef, claimType, attr, value string)
  • func (fi *FakeIndex) AddMeta(blob *blobref.BlobRef, mime string, size int64)
  • func (fi *FakeIndex) AddSignerAttrValue(signer *blobref.BlobRef, attr, val string, latest *blobref.BlobRef)
  • func (fi *FakeIndex) EdgesTo(ref *blobref.BlobRef, opts *search.EdgesToOpts) ([]*search.Edge, error)
  • func (fi *FakeIndex) ExistingFileSchemas(bytesRef *blobref.BlobRef) ([]*blobref.BlobRef, error)
  • func (fi *FakeIndex) GetBlobMIMEType(blob *blobref.BlobRef) (mime string, size int64, err error)
  • func (fi *FakeIndex) GetFileInfo(fileRef *blobref.BlobRef) (*search.FileInfo, error)
  • func (fi *FakeIndex) GetImageInfo(fileRef *blobref.BlobRef) (*search.ImageInfo, error)
  • func (fi *FakeIndex) GetOwnerClaims(permaNode, owner *blobref.BlobRef) (search.ClaimList, error)
  • func (fi *FakeIndex) GetRecentPermanodes(dest chan *search.Result, owner *blobref.BlobRef, limit int) error
  • func (fi *FakeIndex) PathLookup(signer, base *blobref.BlobRef, suffix string, at time.Time) (*search.Path, error)
  • func (fi *FakeIndex) PathsLookup(signer, base *blobref.BlobRef, suffix string) ([]*search.Path, error)
  • func (fi *FakeIndex) PathsOfSignerTarget(signer, target *blobref.BlobRef) ([]*search.Path, error)
  • func (fi *FakeIndex) PermanodeOfSignerAttrValue(signer *blobref.BlobRef, attr, val string) (*blobref.BlobRef, error)
  • func (fi *FakeIndex) SearchPermanodesWithAttr(dest chan<- *blobref.BlobRef, request *search.PermanodeByAttrRequest) error
• type Fetcher
  • func (tf *Fetcher) AddBlob(b *Blob)
  • func (tf *Fetcher) BlobContents(br *blobref.BlobRef) (contents string, ok bool)
  • func (tf *Fetcher) Fetch(ref *blobref.BlobRef) (file blobref.ReadSeekCloser, size int64, err error)
  • func (tf *Fetcher) FetchStreaming(ref *blobref.BlobRef) (file io.ReadCloser, size int64, err error)
  • func (tf *Fetcher) ReceiveBlob(br *blobref.BlobRef, source io.Reader) (blobref.SizedBlobRef, error)
  • func (tf *Fetcher) StatBlobs(dest chan<- blobref.SizedBlobRef, blobs []*blobref.BlobRef, wait time.Duration) error

Types

type Blob

type Blob struct {
	Contents string // the contents of the blob
}

Blob is a utility class for unit tests.

func (*Blob) AssertMatches

func (tb *Blob) AssertMatches(t *testing.T, sb *blobref.SizedBlobRef)

func (*Blob) BlobRef

func (tb *Blob) BlobRef() *blobref.BlobRef

func (*Blob) BlobRefSlice

func (tb *Blob) BlobRefSlice() []*blobref.BlobRef

func (*Blob) Reader

func (tb *Blob) Reader() io.Reader

func (*Blob) Size

func (tb *Blob) Size() int64

type FakeIndex

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

A FakeIndex implements parts of search.Index and provides methods to controls the results, such as AddMeta, AddClaim, AddSignerAttrValue.

func NewFakeIndex

func NewFakeIndex() *FakeIndex

func (*FakeIndex) AddClaim

func (fi *FakeIndex) AddClaim(owner, permanode *blobref.BlobRef, claimType, attr, value string)

func (*FakeIndex) AddMeta

func (fi *FakeIndex) AddMeta(blob *blobref.BlobRef, mime string, size int64)

func (*FakeIndex) AddSignerAttrValue

func (fi *FakeIndex) AddSignerAttrValue(signer *blobref.BlobRef, attr, val string, latest *blobref.BlobRef)

func (*FakeIndex) EdgesTo

func (fi *FakeIndex) EdgesTo(ref *blobref.BlobRef, opts *search.EdgesToOpts) ([]*search.Edge, error)

func (*FakeIndex) ExistingFileSchemas

func (fi *FakeIndex) ExistingFileSchemas(bytesRef *blobref.BlobRef) ([]*blobref.BlobRef, error)

func (*FakeIndex) GetBlobMIMEType

func (fi *FakeIndex) GetBlobMIMEType(blob *blobref.BlobRef) (mime string, size int64, err error)

func (*FakeIndex) GetFileInfo

func (fi *FakeIndex) GetFileInfo(fileRef *blobref.BlobRef) (*search.FileInfo, error)

func (*FakeIndex) GetImageInfo

func (fi *FakeIndex) GetImageInfo(fileRef *blobref.BlobRef) (*search.ImageInfo, error)

func (*FakeIndex) GetOwnerClaims

func (fi *FakeIndex) GetOwnerClaims(permaNode, owner *blobref.BlobRef) (search.ClaimList, error)

func (*FakeIndex) GetRecentPermanodes

func (fi *FakeIndex) GetRecentPermanodes(dest chan *search.Result, owner *blobref.BlobRef, limit int) error

func (*FakeIndex) PathLookup

func (fi *FakeIndex) PathLookup(signer, base *blobref.BlobRef, suffix string, at time.Time) (*search.Path, error)

func (*FakeIndex) PathsLookup

func (fi *FakeIndex) PathsLookup(signer, base *blobref.BlobRef, suffix string) ([]*search.Path, error)

func (*FakeIndex) PathsOfSignerTarget

func (fi *FakeIndex) PathsOfSignerTarget(signer, target *blobref.BlobRef) ([]*search.Path, error)

func (*FakeIndex) PermanodeOfSignerAttrValue

func (fi *FakeIndex) PermanodeOfSignerAttrValue(signer *blobref.BlobRef, attr, val string) (*blobref.BlobRef, error)

func (*FakeIndex) SearchPermanodesWithAttr

func (fi *FakeIndex) SearchPermanodesWithAttr(dest chan<- *blobref.BlobRef, request *search.PermanodeByAttrRequest) error

TODO(mpl): write real tests

type Fetcher

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

func (*Fetcher) AddBlob

func (tf *Fetcher) AddBlob(b *Blob)

func (*Fetcher) BlobContents

func (tf *Fetcher) BlobContents(br *blobref.BlobRef) (contents string, ok bool)

func (*Fetcher) Fetch

func (tf *Fetcher) Fetch(ref *blobref.BlobRef) (file blobref.ReadSeekCloser, size int64, err error)

func (*Fetcher) FetchStreaming

func (tf *Fetcher) FetchStreaming(ref *blobref.BlobRef) (file io.ReadCloser, size int64, err error)

func (*Fetcher) ReceiveBlob

func (tf *Fetcher) ReceiveBlob(br *blobref.BlobRef, source io.Reader) (blobref.SizedBlobRef, error)

func (*Fetcher) StatBlobs

func (tf *Fetcher) StatBlobs(dest chan<- blobref.SizedBlobRef, blobs []*blobref.BlobRef, wait time.Duration) error