store

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: May 12, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StateCreated   = "CREATED"
	StateUploaded  = "UPLOADED"
	StatePublished = "PUBLISHED"
	StateDecrypted = "DECRYPTED"
)

Variables

View Source
var (
	ErrDuplicateFile           = errors.New("duplicate file path")
	ErrFileNotRegistered       = errors.New("file not registered")
	ErrFileNotInCreatedState   = errors.New("file state is not in state created")
	ErrFileNotInUploadedState  = errors.New("file state is not in state uploaded")
	ErrFileNotInPublishedState = errors.New("file state is not in state published")
	ErrFileIsNotPublishable    = errors.New("file is not set as publishable")
	ErrNoFilesInCollection     = errors.New("no files found in collection")
	ErrCollectionIDAlreadySet  = errors.New("collection ID already set")
	ErrCollectionIDNotSet      = errors.New("collection ID not set")
)

Functions

This section is empty.

Types

type Store

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

func NewStore

func NewStore(collection mongo.MongoCollection, kafkaProducer kafka.IProducer, clk clock.Clock) *Store

func (*Store) GetFileMetadata

func (store *Store) GetFileMetadata(ctx context.Context, path string) (files.StoredRegisteredMetaData, error)

func (*Store) GetFilesMetadata

func (store *Store) GetFilesMetadata(ctx context.Context, collectionID string) ([]files.StoredRegisteredMetaData, error)

func (*Store) MarkCollectionPublished

func (store *Store) MarkCollectionPublished(ctx context.Context, collectionID string) error

func (*Store) MarkFileDecrypted

func (store *Store) MarkFileDecrypted(ctx context.Context, metaData files.FileEtagChange) error

func (*Store) MarkFilePublished

func (store *Store) MarkFilePublished(ctx context.Context, path string) error

func (*Store) MarkUploadComplete

func (store *Store) MarkUploadComplete(ctx context.Context, metaData files.FileEtagChange) error

func (*Store) RegisterFileUpload

func (store *Store) RegisterFileUpload(ctx context.Context, metaData files.StoredRegisteredMetaData) error

func (*Store) UpdateCollectionID

func (store *Store) UpdateCollectionID(ctx context.Context, path, collectionID string) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL