migratable

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Dec 10, 2025 License: MIT Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFileJob

func NewFileJob(
	src adapter.Adapter,
	dest adapter.Adapter,
	srcRegistry string,
	destRegistry string,
	artifactType types.ArtifactType,
	pkg types.Package,
	version types.Version,
	node *types.TreeNode,
	file *types.File,
	stats *types.TransferStats,
	mapping *types.RegistryMapping,
	config *types.Config,
	registry types.RegistryInfo,
) engine.Job

func NewPackageJob

func NewPackageJob(
	src adapter.Adapter,
	dest adapter.Adapter,
	srcRegistry string,
	sourcePackageHostname string,
	destRegistry string,
	artifactType types.ArtifactType,
	pkg types.Package,
	node *types.TreeNode,
	stats *types.TransferStats,
	mapping *types.RegistryMapping,
	config *types.Config,
	registry types.RegistryInfo,
) engine.Job

func NewRegistryJob

func NewRegistryJob(
	src adapter.Adapter,
	dest adapter.Adapter,
	srcRegistry string,
	sourcePackageHostname string,
	destRegistry string,
	artifactType types.ArtifactType,
	stats *types.TransferStats,
	mapping *types.RegistryMapping,
	config *types.Config,
) engine.Job

func NewVersionJob

func NewVersionJob(
	src adapter.Adapter,
	dest adapter.Adapter,
	srcRegistry string,
	destRegistry string,
	artifactType types.ArtifactType,
	pkg types.Package,
	version types.Version,
	node *types.TreeNode,
	stats *types.TransferStats,
	mapping *types.RegistryMapping,
	config *types.Config,
	registry types.RegistryInfo,
) engine.Job

func StreamUploadAsJSON

func StreamUploadAsJSON(upload *npm.PackageUpload) io.Reader

Types

type File

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

func (*File) Info

func (r *File) Info() string

func (*File) Migrate

func (r *File) Migrate(ctx context.Context) error

func (*File) ParseNPMetadata

func (r *File) ParseNPMetadata(
	err error,
	file io.ReadCloser,
	logger zerolog.Logger,
	tarballURL string,
	upload *npm.PackageUpload,
) (io.ReadCloser, error)

func (*File) Post

func (r *File) Post(ctx context.Context) error

func (*File) Pre

func (r *File) Pre(ctx context.Context) error

type Package

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

func (*Package) Info

func (r *Package) Info() string

func (*Package) Migrate

func (r *Package) Migrate(ctx context.Context) error

Migrate Create down stream packages and migrate them

func (*Package) Post

func (r *Package) Post(ctx context.Context) error

Post Any post processing work

func (*Package) Pre

func (r *Package) Pre(ctx context.Context) error

Pre Create package at destination if it doesn't exist

type Registry

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

func (*Registry) Info

func (r *Registry) Info() string

func (*Registry) Migrate

func (r *Registry) Migrate(ctx context.Context) error

Migrate Create down stream packages and migrate them

func (*Registry) Post

func (r *Registry) Post(ctx context.Context) error

Post Any post processing work

func (*Registry) Pre

func (r *Registry) Pre(ctx context.Context) error

Pre Create registry at destination if it doesn't exist

type Version

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

func (*Version) Info

func (r *Version) Info() string

func (*Version) Migrate

func (r *Version) Migrate(ctx context.Context) error

func (*Version) Post

func (r *Version) Post(ctx context.Context) error

Post Any post processing work

func (*Version) Pre

func (r *Version) Pre(ctx context.Context) error

Jump to

Keyboard shortcuts

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