shareddownload

Documentation

Index

• type Callbacks
• type Manager
  • func NewDownloadManager(ctx context.Context, ns core.NamespaceRef, di database.Plugin, ...) (Manager, error)

Types

type Callbacks

type Callbacks interface {
	SharedStorageBatchDownloaded(payloadRef string, data []byte) (batchID *fftypes.UUID, err error)
	SharedStorageBlobDownloaded(hash fftypes.Bytes32, size int64, payloadRef string)
}

type Manager

type Manager interface {
	Start() error
	WaitStop()

	InitiateDownloadBatch(ctx context.Context, tx *fftypes.UUID, payloadRef string) error
	InitiateDownloadBlob(ctx context.Context, tx *fftypes.UUID, dataID *fftypes.UUID, payloadRef string) error
}

func NewDownloadManager

func NewDownloadManager(ctx context.Context, ns core.NamespaceRef, di database.Plugin, ss sharedstorage.Plugin, dx dataexchange.Plugin, om operations.Manager, cb Callbacks) (Manager, error)