upload

Documentation

Index

• type ManifestSession
  • func (s ManifestSession) AddFiles(manifestId string, items []manifestFile.FileDTO, ...) *manifest.AddFilesStats
  • func (s ManifestSession) PackageTypeResolver(items []manifestFile.FileDTO) []manifestFile.FileDTO

Types

type ManifestSession

type ManifestSession struct {
	FileTableName string
	TableName     string
	Client        core2.DynamoDBAPI
	SNSClient     core2.SnsAPI
	SNSTopic      string
	S3Client      core2.S3API
}

func (ManifestSession) AddFiles

func (s ManifestSession) AddFiles(manifestId string, items []manifestFile.FileDTO, forceStatus *manifestFile.Status) *manifest.AddFilesStats

AddFiles manages the workers and defines the go routines to add files to upload db.

func (ManifestSession) PackageTypeResolver

func (s ManifestSession) PackageTypeResolver(items []manifestFile.FileDTO) []manifestFile.FileDTO