Documentation
¶
Index ¶
- type Acquirer
- type Store
- func (s *Store) Delete(ctx context.Context, tenantID, engagementID shared.ID) error
- func (s *Store) DiscardUnpublished(ctx context.Context, item sourcepackage.Package) error
- func (s *Store) Get(ctx context.Context, tenantID, engagementID shared.ID) (sourcepackage.Package, error)
- func (s *Store) GetByVersion(ctx context.Context, tenantID, engID, versionID shared.ID) (sourcepackage.Package, error)
- func (s *Store) Materialize(ctx context.Context, locator string) (string, sourcepackage.Package, func() error, error)
- func (s *Store) Reuse(ctx context.Context, ...) (sourcepackage.Package, error)
- func (s *Store) Save(ctx context.Context, tenantID, engagementID shared.ID, filename, actor string, ...) (sourcepackage.Package, error)
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
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func NewStoreWithRepository ¶
func NewStoreWithRepository(objects ports.ObjectStore, repository ports.EngagementSourceRepository, maxBytes int64) *Store
func (*Store) DiscardUnpublished ¶
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) GetByVersion ¶
func (*Store) Materialize ¶
Click to show internal directories.
Click to hide internal directories.