task

package
v0.0.0-...-1b0f315 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 26, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AnalyticsOperator 

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

func NewAnalyticsOperator 

func NewAnalyticsOperator(
	fileStorage media.FileStorer,
	cacheStorage media.FileStorer,
) AnalyticsOperator

func (*AnalyticsOperator) SpaceUsage 

func (o *AnalyticsOperator) SpaceUsage() (*SpaceUsageResponse, error)

type ApiKeyOperator 

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

func NewApiKeyOperator 

func NewApiKeyOperator(apikeyStorage apikey.Storer) ApiKeyOperator

func (*ApiKeyOperator) Create 

func (t *ApiKeyOperator) Create(name string) (*apikey.ApiKey, error)

func (*ApiKeyOperator) Delete 

func (t *ApiKeyOperator) Delete(apiKey string) error

func (*ApiKeyOperator) GetAll 

func (t *ApiKeyOperator) GetAll() ([]apikey.ApiKey, error)

type ClearCacheTask 

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

func NewClearCacheTask 

func NewClearCacheTask(
	cacheStorage media.FileStorer,
	analyticsRecorder analytics.AnalyticsRecorder,
) ClearCacheTask

func (*ClearCacheTask) Clear 

func (c *ClearCacheTask) Clear(p media.Path) error

func (*ClearCacheTask) ClearAll 

func (c *ClearCacheTask) ClearAll() error

type ColorizeMediaTask 

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

func NewColorizeMediaTask 

func NewColorizeMediaTask(pluginManager *plugin.PluginManager) ColorizeMediaTask

func (*ColorizeMediaTask) Colorize 

func (t *ColorizeMediaTask) Colorize(path media.Path) (*media.Media, error)

type CopyMediaTask 

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

func NewCopyMediaTask 

func NewCopyMediaTask(
	fileStorage media.FileStorer,
	cacheStorage media.FileStorer,
	mediaStorage media.Storer,
) CopyMediaTask

func (*CopyMediaTask) Copy 

func (t *CopyMediaTask) Copy(src media.Path, dst media.Path) (*media.Media, error)

type DeleteMediaTask 

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

func NewDeleteMediaTask 

func NewDeleteMediaTask(
	fileStorage media.FileStorer,
	cacheStorage media.FileStorer,
	mediaStorage media.Storer,
	analyticsRecorder analytics.AnalyticsRecorder,
) DeleteMediaTask

func (*DeleteMediaTask) Delete 

func (t *DeleteMediaTask) Delete(path media.Path) error

func (*DeleteMediaTask) DeleteMultiple 

func (t *DeleteMediaTask) DeleteMultiple(paths []media.Path) error

type DownloadMediaTask 

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

func NewDownloadMediaTask 

func NewDownloadMediaTask(
	fileStorage media.FileStorer,
	cacheStorage media.FileStorer,
	mediaStorage media.Storer,
	namedTransformationStorage transform.Storer,
	analyticsRecorder analytics.AnalyticsRecorder,
) DownloadMediaTask

func (*DownloadMediaTask) Download 

func (t *DownloadMediaTask) Download(
	transformations string,
	path media.Path,
) (io.ReadCloser, *media.ContentType, error)

func (*DownloadMediaTask) DownloadMultiple 

func (d *DownloadMediaTask) DownloadMultiple(paths []media.Path) (media.Body, error)

type GetMediaTask 

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

func NewGetMediaTask 

func NewGetMediaTask(
	mediaStorage media.Storer,
	analyticsRecorder analytics.AnalyticsRecorder,
) GetMediaTask

func (*GetMediaTask) Get 

func (t *GetMediaTask) Get(path media.Path) (*media.Media, error)

func (*GetMediaTask) GetMultiple 

func (t *GetMediaTask) GetMultiple(
	path media.Path,
	offset int,
	limit int,
	sortBy string,
	asc bool,
) ([]media.Media, error)

type MoveMediaTask 

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

func NewMoveMediaTask 

func NewMoveMediaTask(
	fileStorage media.FileStorer,
	cacheStorage media.FileStorer, mediaStorage media.Storer,
) MoveMediaTask

func (*MoveMediaTask) Move 

func (t *MoveMediaTask) Move(src media.Path, dst media.Path) (*media.Media, error)

type NamedTransformationOperator 

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

func NewNamedTransformationOperator 

func NewNamedTransformationOperator(storage transform.Storer) NamedTransformationOperator

func (*NamedTransformationOperator) Create 

func (o *NamedTransformationOperator) Create(
	name string,
	transformationsStr string,
) (*transform.NamedTransformation, error)

func (*NamedTransformationOperator) Delete 

func (o *NamedTransformationOperator) Delete(name string) error

func (*NamedTransformationOperator) DeleteAll 

func (o *NamedTransformationOperator) DeleteAll() error

func (*NamedTransformationOperator) GetAll 

func (o *NamedTransformationOperator) GetAll() ([]transform.NamedTransformation, error)

func (*NamedTransformationOperator) Update 

func (o *NamedTransformationOperator) Update(
	name string,
	transformations string,
) (*transform.NamedTransformation, error)

type SpaceUsageResponse 

type SpaceUsageResponse struct {
	TotalSpaceUsage int64 `json:"total_space_usage"`
	FileSpaceUsage  int64 `json:"file_space_usage"`
	CacheSpaceSuage int64 `json:"cache_space_usage"`
}

type StorageUsageCollector 

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

func NewStorageUsageCollector 

func NewStorageUsageCollector(
	fileStorage media.FileStorer,
	cacheStorage media.FileStorer,
	analyticsRecorder analytics.AnalyticsRecorder,
) StorageUsageCollector

func (*StorageUsageCollector) Collect 

func (c *StorageUsageCollector) Collect()

func (*StorageUsageCollector) Stop 

func (c *StorageUsageCollector) Stop()

type TagMediaTask 

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

func NewTagMediaTask 

func NewTagMediaTask(fileStorage media.FileStorer, mediaStorage media.Storer) TagMediaTask

func (*TagMediaTask) Tag 

func (t *TagMediaTask) Tag(path media.Path) (*media.Media, error)

type TaskOperator 

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

func NewTaskOperator 

func NewTaskOperator(taskStorage scheduler.Storer) TaskOperator

type UploadMediaTask 

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

func NewUploadMediaTask 

func NewUploadMediaTask(
	fileStorage media.FileStorer,
	cacheStorage media.FileStorer,
	mediaStorage media.Storer,
	namedTransformationStorage transform.Storer,
) UploadMediaTask

func (*UploadMediaTask) Upload 

func (t *UploadMediaTask) Upload(
	path string,
	body io.Reader,
	contentType string,
	contentLength int64,
	transformations []string,
) (*media.Media, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.