Help us shape the future of Go! Take the 2026 Go Developer Survey

sourceupload

package
v0.2.4 Latest Latest
Warning

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

Go to latest
Published: Sep 28, 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