workspacebundle

package

v2.11.4 Latest Latest Go to latest Published: Aug 3, 2026 License: GPL-3.0 Imports: 17 Imported by: 0

Details

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

Repository

github.com/dagucloud/dagu

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Digest(data []byte) string
func Extract(data []byte, dest string, desc Descriptor, limits Limits) error
func IsPathWithin(root, candidate string) bool
func NormalizeRelativePath(relPath string) (string, error)
func StoreDir(dataDir string) string
func ValidDigest(digest string) bool
func Verify(data []byte, digest string) error
type Client
type Descriptor
- func PackDirectory(root string, opts PackOptions) (*Descriptor, []byte, error)
type Limits
- func DefaultLimits() Limits
type PackOptions
type Store
- func NewStore(dir string, limits Limits) *Store

Constants ¶

View Source

const (
	DefaultMaxCompressedSize   int64 = 64 << 20
	DefaultMaxUncompressedSize int64 = 256 << 20
	DefaultMaxFiles                  = 8192
)

Variables ¶

This section is empty.

Functions ¶

func Digest ¶

func Digest(data []byte) string

func Extract ¶

func Extract(data []byte, dest string, desc Descriptor, limits Limits) error

func IsPathWithin ¶

func IsPathWithin(root, candidate string) bool

func NormalizeRelativePath ¶

func NormalizeRelativePath(relPath string) (string, error)

func StoreDir ¶

func StoreDir(dataDir string) string

func ValidDigest ¶

func ValidDigest(digest string) bool

func Verify ¶

func Verify(data []byte, digest string) error

Types ¶

type Client ¶

type Client interface {
	PutWorkspaceBundle(ctx context.Context, desc Descriptor, data []byte) error
	GetWorkspaceBundle(ctx context.Context, digest string) ([]byte, error)
}

type Descriptor ¶

type Descriptor struct {
	Digest      string
	Size        int64
	DAGPath     string
	OriginalRef string
	ResolvedRef string
}

func PackDirectory ¶

func PackDirectory(root string, opts PackOptions) (*Descriptor, []byte, error)

type Limits ¶

type Limits struct {
	MaxCompressedSize   int64
	MaxUncompressedSize int64
	MaxFiles            int
}

func DefaultLimits ¶

func DefaultLimits() Limits

type PackOptions ¶

type PackOptions struct {
	DAGPath     string
	OriginalRef string
	ResolvedRef string
	Limits      Limits
}

type Store ¶

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

func NewStore ¶

func NewStore(dir string, limits Limits) *Store

func (*Store) Get ¶

func (s *Store) Get(_ context.Context, digest string) ([]byte, error)

func (*Store) Has ¶

func (s *Store) Has(digest string) bool

func (*Store) Put ¶

func (s *Store) Put(_ context.Context, desc Descriptor, data []byte) error

Source Files ¶

View all Source files

bundle.go

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