interactor

Documentation

Index

• type Blob
  • func NewBlob(logger log.Logger, repo domain.BlobRepository, storage domain.BlobStorage, ...) *Blob
  • func (u *Blob) Delete(ctx context.Context, id, service string) error
  • func (u *Blob) Get(ctx context.Context, id, service string) (*domain.Blob, error)
  • func (u *Blob) Store(ctx context.Context, ag *domain.BlobAggregate) (*domain.Blob, error)
• type BlobSAGA
  • func NewBlobSaga(logger log.Logger, repo domain.BlobRepository, storage domain.BlobStorage) *BlobSAGA
  • func (u *BlobSAGA) Failed(ctx context.Context, rootID, service string, snapshotJSON []byte) error

Types

type Blob

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

func NewBlob

func NewBlob(logger log.Logger, repo domain.BlobRepository, storage domain.BlobStorage, eventBus domain.BlobEvent) *Blob

func (*Blob) Delete

func (u *Blob) Delete(ctx context.Context, id, service string) error

func (*Blob) Get

func (u *Blob) Get(ctx context.Context, id, service string) (*domain.Blob, error)

func (*Blob) Store

func (u *Blob) Store(ctx context.Context, ag *domain.BlobAggregate) (*domain.Blob, error)

type BlobSAGA

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

func NewBlobSaga

func NewBlobSaga(logger log.Logger, repo domain.BlobRepository, storage domain.BlobStorage) *BlobSAGA

func (*BlobSAGA) Failed

func (u *BlobSAGA) Failed(ctx context.Context, rootID, service string, snapshotJSON []byte) error