sourceupload

package
v0.2.1 Latest Latest
Warning

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

Go to latest
Published: Sep 26, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Acquirer

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

func NewAcquirer

func NewAcquirer(next ports.Acquirer, sources ports.EngagementSourceStore) *Acquirer

func (*Acquirer) Acquire

func (a *Acquirer) Acquire(ctx context.Context, request ports.AcquireRequest) (*ports.Workspace, error)

type Store

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

func NewStore

func NewStore(objects ports.ObjectStore, maxBytes int64) *Store

func NewStoreWithRepository

func NewStoreWithRepository(objects ports.ObjectStore, repository ports.EngagementSourceRepository, maxBytes int64) *Store

func (*Store) Delete

func (s *Store) Delete(ctx context.Context, tenantID, engagementID shared.ID) error

func (*Store) DiscardUnpublished

func (s *Store) DiscardUnpublished(ctx context.Context, item sourcepackage.Package) error

DiscardUnpublished is only for compensation after the enclosing transaction. A version owns one unguessable object key; reuse cannot create a new reference once its original binding is absent. Unknown transaction outcomes retain bytes.

func (*Store) Get

func (s *Store) Get(ctx context.Context, tenantID, engagementID shared.ID) (sourcepackage.Package, error)

func (*Store) GetByVersion

func (s *Store) GetByVersion(ctx context.Context, tenantID, engID, versionID shared.ID) (sourcepackage.Package, error)

func (*Store) Materialize

func (s *Store) Materialize(ctx context.Context, locator string) (string, sourcepackage.Package, func() error, error)

func (*Store) Reuse

func (s *Store) Reuse(ctx context.Context, tenantID, parentEngID, childEngID, expectedVersionID shared.ID, actor string, at time.Time) (sourcepackage.Package, error)

func (*Store) Save

func (s *Store) Save(ctx context.Context, tenantID, engagementID shared.ID, filename, actor string, createdAt time.Time, size int64, sha256hex string, src io.Reader) (sourcepackage.Package, error)

Jump to

Keyboard shortcuts

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