Versions in this module Expand all Collapse all v1 v1.3.4 Feb 9, 2024 Changes in this version + const ManifestVersion + type ArchiveReader struct + func NewReader(ctx rcontext.RequestContext) *ArchiveReader + func (r *ArchiveReader) GetEntityId() string + func (r *ArchiveReader) GetNotUploadedMxcUris() []string + func (r *ArchiveReader) HasManifest() bool + func (r *ArchiveReader) ProcessFile(file io.ReadCloser, opts ProcessOpts) error + func (r *ArchiveReader) ProcessS3Files(opts ProcessOpts) error + func (r *ArchiveReader) TryGetManifestFrom(file io.ReadCloser) (bool, error) + type ArchiveWriter struct + func NewWriter(ctx rcontext.RequestContext, exportId string, entity string, partSize int64, ...) (*ArchiveWriter, error) + func (w *ArchiveWriter) AppendMedia(file io.ReadCloser, info MediaInfo) (string, error) + func (w *ArchiveWriter) Finish() error + type Manifest struct + CreatedTs int64 + EntityId string + Media map[string]*ManifestRecord + UserId string + Version ManifestVersionVal + type ManifestRecord struct + ArchivedName string + ContentType string + CreatedTs int64 + FileName string + MediaId string + Origin string + S3Url string + Sha256 string + SizeBytes int64 + Uploader string + type ManifestVersionVal int + const ManifestVersionV1 + const ManifestVersionV2 + type MediaInfo struct + ContentType string + CreationTs int64 + FileName string + MediaId string + Origin string + S3Url string + UserId string + type PartPersister func(part int, fileName string, data io.ReadCloser) error + type ProcessOpts struct + CheckUploadedOnly bool + LockedEntityId string + ProcessFunction func(record *ManifestRecord, f io.ReadCloser) error