bundle

package

v0.11.13 Latest Latest Go to latest Published: Apr 24, 2026 License: BSD-3-Clause Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cyverse/gocommands

Links

Open Source Insights

Documentation ¶

Index ¶

func EnsureStagingDirPath(fs *irodsclient_fs.FileSystem, stagingPath string) (bool, error)
func GetResourceServersForDir(fs *irodsclient_fs.FileSystem, targetDir string) ([]string, error)
func GetStagingDirInTargetPath(fs *irodsclient_fs.FileSystem, targetPath string) string
func IsSameResourceServer(fs *irodsclient_fs.FileSystem, path1 string, path2 string) (bool, error)
type Bundle
- func NewBundle(manager *BundleManager, index int64) *Bundle
type BundleEntry
type BundleManager
- func NewBundleManager(minFileNumInBundle int, maxFileNumInBundle int, maxBundleFileSize int64, ...) *BundleManager
type Tar
- func NewTar(targetPath string) *Tar
type TarEntry
type TarTrackerCallBack

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EnsureStagingDirPath ¶

func EnsureStagingDirPath(fs *irodsclient_fs.FileSystem, stagingPath string) (bool, error)

func GetResourceServersForDir ¶

func GetResourceServersForDir(fs *irodsclient_fs.FileSystem, targetDir string) ([]string, error)

func GetStagingDirInTargetPath ¶

func GetStagingDirInTargetPath(fs *irodsclient_fs.FileSystem, targetPath string) string

func IsSameResourceServer ¶

func IsSameResourceServer(fs *irodsclient_fs.FileSystem, path1 string, path2 string) (bool, error)

Types ¶

type Bundle ¶

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

func NewBundle ¶

func NewBundle(manager *BundleManager, index int64) *Bundle

func (*Bundle) Add ¶

func (bundle *Bundle) Add(entry BundleEntry) error

func (*Bundle) GetBundleFilename ¶

func (bundle *Bundle) GetBundleFilename() string

func (*Bundle) GetEntries ¶

func (bundle *Bundle) GetEntries() []BundleEntry

func (*Bundle) GetEntryNumber ¶

func (bundle *Bundle) GetEntryNumber() int

func (*Bundle) GetID ¶

func (bundle *Bundle) GetID() int64

func (*Bundle) GetIRODSDir ¶

func (bundle *Bundle) GetIRODSDir() string

func (*Bundle) GetManager ¶

func (bundle *Bundle) GetManager() *BundleManager

func (*Bundle) GetSize ¶

func (bundle *Bundle) GetSize() int64

func (*Bundle) IsEmpty ¶

func (bundle *Bundle) IsEmpty() bool

func (*Bundle) IsFull ¶

func (bundle *Bundle) IsFull() bool

func (*Bundle) IsSameDir ¶

func (bundle *Bundle) IsSameDir(entry BundleEntry) bool

func (*Bundle) IsSealed ¶

func (bundle *Bundle) IsSealed() bool

func (*Bundle) RequireTar ¶

func (bundle *Bundle) RequireTar() bool

func (*Bundle) Seal ¶

func (bundle *Bundle) Seal() error

type BundleEntry ¶

type BundleEntry struct {
	LocalPath      string
	TempPath       string
	IRODSPath      string
	Size           int64
	EncryptionMode encryption.EncryptionMode
}

type BundleManager ¶

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

func NewBundleManager ¶

func NewBundleManager(minFileNumInBundle int, maxFileNumInBundle int, maxBundleFileSize int64, localTempDirPath string, irodsStagingDirPath string) *BundleManager

func (*BundleManager) Add ¶

func (manager *BundleManager) Add(bundleEntry BundleEntry) error

func (*BundleManager) ClearIRODSBundles ¶

func (manager *BundleManager) ClearIRODSBundles(fs *irodsclient_fs.FileSystem, removeDir bool) error

func (*BundleManager) ClearLocalBundles ¶

func (manager *BundleManager) ClearLocalBundles() error

func (*BundleManager) DoneScheduling ¶

func (manager *BundleManager) DoneScheduling()

func (*BundleManager) GetBundles ¶

func (manager *BundleManager) GetBundles() []*Bundle

func (*BundleManager) GetIRODSStagingDirPath ¶

func (manager *BundleManager) GetIRODSStagingDirPath() string

func (*BundleManager) GetLocalTempDirPath ¶

func (manager *BundleManager) GetLocalTempDirPath() string

func (*BundleManager) IsBundleFilename ¶

func (manager *BundleManager) IsBundleFilename(p string) bool

type Tar ¶

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

func NewTar ¶

func NewTar(targetPath string) *Tar

func (*Tar) AddEntry ¶

func (t *Tar) AddEntry(sourcePath string, targetPath string) error

func (*Tar) CreateTarball ¶

func (t *Tar) CreateTarball(targetPath string, callback TarTrackerCallBack) error

func (*Tar) GetSize ¶

func (t *Tar) GetSize() int64

type TarEntry ¶

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

type TarTrackerCallBack ¶

type TarTrackerCallBack func(processed int64, total int64)

Source Files ¶

View all Source files

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