remote_transfer

package
v0.1.17 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 24, 2026 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrSkipped = newPkgError("skipped due to exclude objects option")

	ErrNeedsMerge = errors.Err409Conflict.Errorf(
		"import failed with conflicts, merging required",
	)
)

Functions

func CommitPlan

func CommitPlan(
	ctx interfaces.ActiveContext,
	local repo.LocalRepo,
	envBox env_box.Env,
	importerInterface repo.Importer,
	plan *import_plan.Plan,
) (err error)

func IsErrBloblessTypeSkipped

func IsErrBloblessTypeSkipped(err error) bool

func IsErrCrossPubKeyMerge

func IsErrCrossPubKeyMerge(err error) bool

func IsErrDeduped

func IsErrDeduped(err error) bool

func IsErrObjectIdTaiCollision

func IsErrObjectIdTaiCollision(err error) bool

func Make

func Make(
	options repo.ImporterOptions,
	storeOptions sku.StoreOptions,
	envRepo env_repo.Env,
	typedInventoryListBlobStore inventory_list_coders.Closet,
	indexObject sku.Index,
	storeExternalMergeCheckedOut store_workspace.MergeCheckedOut,
	storeObject sku.RepoStore,
	storeCommitter sku.StoreCommitter,
) repo.Importer

Types

type ErrBloblessTypeSkipped

type ErrBloblessTypeSkipped struct {
	ObjectId string
	TypeId   string
}

ErrBloblessTypeSkipped occurs when a type definition object with no blob digest, no pubkey, and no signature is encountered during import.

func (ErrBloblessTypeSkipped) Error

func (err ErrBloblessTypeSkipped) Error() string

func (ErrBloblessTypeSkipped) GetErrorType

func (err ErrBloblessTypeSkipped) GetErrorType() pkgErrDisamb

func (ErrBloblessTypeSkipped) Is

func (err ErrBloblessTypeSkipped) Is(target error) bool

type ErrCrossPubKeyMerge

type ErrCrossPubKeyMerge struct {
	ObjectId     string
	LocalPubKey  string
	RemotePubKey string
}

ErrCrossPubKeyMerge occurs when merging an object whose existing copy was created under a different repo public key and has no local workspace checkout.

func (ErrCrossPubKeyMerge) Error

func (err ErrCrossPubKeyMerge) Error() string

func (ErrCrossPubKeyMerge) GetErrorType

func (err ErrCrossPubKeyMerge) GetErrorType() pkgErrDisamb

func (ErrCrossPubKeyMerge) Is

func (err ErrCrossPubKeyMerge) Is(target error) bool

type ErrDeduped

type ErrDeduped struct {
	ObjectId string
	Digest   string
}

ErrDeduped occurs when an object is skipped because its metadata digest (excluding TAI) matches a previously imported object in this batch.

func (ErrDeduped) Error

func (err ErrDeduped) Error() string

func (ErrDeduped) GetErrorType

func (err ErrDeduped) GetErrorType() pkgErrDisamb

func (ErrDeduped) Is

func (err ErrDeduped) Is(target error) bool

type ErrObjectIdTaiCollision

type ErrObjectIdTaiCollision struct {
	ObjectId     string
	Tai          string
	LocalDigest  string
	RemoteDigest string
}

ErrObjectIdTaiCollision occurs when an object with the same ObjectId+TAI already exists in the index but has a different object digest.

func (ErrObjectIdTaiCollision) Error

func (err ErrObjectIdTaiCollision) Error() string

func (ErrObjectIdTaiCollision) GetErrorType

func (err ErrObjectIdTaiCollision) GetErrorType() pkgErrDisamb

func (ErrObjectIdTaiCollision) Is

func (err ErrObjectIdTaiCollision) Is(target error) bool

Source Files

  • commit_plan.go
  • committer.go
  • deduper.go
  • error_log.go
  • errors.go
  • import.go
  • main.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL