index

Documentation

Index

• type FSIndex
  • func NewFSIndex(name string, dirPath string, useSubdir bool, expectsBlobstoreIDs bool, ...) FSIndex
  • func (i FSIndex) Add(name, fingerprint, path, sha1 string) (string, string, error)
  • func (i FSIndex) Find(name, fingerprint string) (string, string, error)
• type FSIndexBlobs
  • func NewFSIndexBlobs(dirPath string, reporter Reporter, blobstore boshblob.Blobstore, ...) FSIndexBlobs
  • func (c FSIndexBlobs) Add(path, sha1 string) (string, string, error)
  • func (c FSIndexBlobs) Get(name string, blobID string, sha1 string) (string, error)
• type Index
• type IndexBlobs
• type Provider
  • func NewProvider(reporter Reporter, blobstore boshblob.Blobstore, ...) Provider
  • func (p Provider) DevAndFinalIndicies(dirPath string) (boshrel.ArchiveIndicies, boshrel.ArchiveIndicies)
• type Reporter

Types

type FSIndex

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

func NewFSIndex

func NewFSIndex(
	name string,
	dirPath string,
	useSubdir bool,
	expectsBlobstoreIDs bool,
	reporter Reporter,
	blobs IndexBlobs,
	fs boshsys.FileSystem,
) FSIndex

func (FSIndex) Add

func (i FSIndex) Add(name, fingerprint, path, sha1 string) (string, string, error)

func (FSIndex) Find

func (i FSIndex) Find(name, fingerprint string) (string, string, error)

type FSIndexBlobs

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

func NewFSIndexBlobs

func NewFSIndexBlobs(
	dirPath string,
	reporter Reporter,
	blobstore boshblob.Blobstore,
	sha1calc bicrypto.SHA1Calculator,
	fs boshsys.FileSystem,
) FSIndexBlobs

func (FSIndexBlobs) Add

func (c FSIndexBlobs) Add(path, sha1 string) (string, string, error)

Add adds file to cache and blobstore but does not guarantee that file have expected SHA1 when retrieved later.

func (FSIndexBlobs) Get

func (c FSIndexBlobs) Get(name string, blobID string, sha1 string) (string, error)

Get gurantees that returned file matches requested SHA1.

type Index

type Index interface {
	Find(name, version string) (string, string, error)
	Add(name, version, path, sha1 string) (string, string, error)
}

type IndexBlobs

type IndexBlobs interface {
	Get(name string, blobID string, sha1 string) (string, error)
	Add(path, sha1 string) (string, string, error)
}

type Provider

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

func NewProvider

func NewProvider(
	reporter Reporter,
	blobstore boshblob.Blobstore,
	sha1calc bicrypto.SHA1Calculator,
	fs boshsys.FileSystem,
) Provider

func (Provider) DevAndFinalIndicies

func (p Provider) DevAndFinalIndicies(dirPath string) (boshrel.ArchiveIndicies, boshrel.ArchiveIndicies)

type Reporter

type Reporter interface {
	IndexEntryStartedAdding(type_, desc string)
	IndexEntryFinishedAdding(type_, desc string, err error)

	IndexEntryDownloadStarted(type_, desc string)
	IndexEntryDownloadFinished(type_, desc string, err error)

	IndexEntryUploadStarted(type_, desc string)
	IndexEntryUploadFinished(type_, desc string, err error)
}