datastores

Documentation

Index

• func BufferTemp(datastore config.DatastoreConfig, contents io.ReadCloser) (string, int64, io.ReadCloser, error)
• func Download(ctx rcontext.RequestContext, ds config.DatastoreConfig, dsFileName string) (io.ReadSeekCloser, error)
• func DownloadOrRedirect(ctx rcontext.RequestContext, ds config.DatastoreConfig, dsFileName string) (io.ReadSeekCloser, error)
• func Get(ctx rcontext.RequestContext, dsId string) (config.DatastoreConfig, bool)
• func GetS3Url(ds config.DatastoreConfig, location string) (string, error)
• func GetUri(ds config.DatastoreConfig) (string, error)
• func HasListedKind(have []string, want Kind) bool
• func ListS3Files(ctx rcontext.RequestContext, ds config.DatastoreConfig) (<-chan minio.ObjectInfo, error)
• func ParseS3Url(s3url string) (config.DatastoreConfig, string, error)
• func Pick(ctx rcontext.RequestContext, kind Kind) (config.DatastoreConfig, error)
• func Remove(ctx rcontext.RequestContext, ds config.DatastoreConfig, location string) error
• func RemoveWithDsId(ctx rcontext.RequestContext, dsId string, location string) error
• func ResetS3Clients()
• func Upload(ctx rcontext.RequestContext, ds config.DatastoreConfig, data io.ReadCloser, ...) (string, error)
• type Kind
• type RedirectError
• type SizeEstimate
  • func SizeOfDsIdWithAge(ctx rcontext.RequestContext, dsId string, beforeTs int64) (*SizeEstimate, error)

Functions

func BufferTemp

func BufferTemp(datastore config.DatastoreConfig, contents io.ReadCloser) (string, int64, io.ReadCloser, error)

func Download

func Download(ctx rcontext.RequestContext, ds config.DatastoreConfig, dsFileName string) (io.ReadSeekCloser, error)

func DownloadOrRedirect

func DownloadOrRedirect(ctx rcontext.RequestContext, ds config.DatastoreConfig, dsFileName string) (io.ReadSeekCloser, error)

func Get

func Get(ctx rcontext.RequestContext, dsId string) (config.DatastoreConfig, bool)

func GetS3Url

func GetS3Url(ds config.DatastoreConfig, location string) (string, error)

func GetUri

func GetUri(ds config.DatastoreConfig) (string, error)

func HasListedKind

func HasListedKind(have []string, want Kind) bool

func ListS3Files

func ListS3Files(ctx rcontext.RequestContext, ds config.DatastoreConfig) (<-chan minio.ObjectInfo, error)

func ParseS3Url

func ParseS3Url(s3url string) (config.DatastoreConfig, string, error)

func Pick

func Pick(ctx rcontext.RequestContext, kind Kind) (config.DatastoreConfig, error)

func Remove

func Remove(ctx rcontext.RequestContext, ds config.DatastoreConfig, location string) error

func RemoveWithDsId

func RemoveWithDsId(ctx rcontext.RequestContext, dsId string, location string) error

func ResetS3Clients

func ResetS3Clients()

func Upload

func Upload(ctx rcontext.RequestContext, ds config.DatastoreConfig, data io.ReadCloser, size int64, contentType string, sha256hash string) (string, error)

Types

type Kind

type Kind string

const (
	LocalMediaKind  Kind = "local_media"
	RemoteMediaKind Kind = "remote_media"
	ThumbnailsKind  Kind = "thumbnails"
	ArchivesKind    Kind = "archives"
	AllKind         Kind = "all"
)

type RedirectError

type RedirectError struct {
	RedirectUrl string
	// contains filtered or unexported fields
}

type SizeEstimate

type SizeEstimate struct {
	ThumbnailsAffected      int64 `json:"thumbnails_affected"`
	ThumbnailHashesAffected int64 `json:"thumbnail_hashes_affected"`
	ThumbnailBytes          int64 `json:"thumbnail_bytes"`

	MediaAffected       int64 `json:"media_affected"`
	MediaHashesAffected int64 `json:"media_hashes_affected"`
	MediaBytes          int64 `json:"media_bytes"`

	TotalHashesAffected int64 `json:"total_hashes_affected"`
	TotalBytes          int64 `json:"total_bytes"`
}

func SizeOfDsIdWithAge

func SizeOfDsIdWithAge(ctx rcontext.RequestContext, dsId string, beforeTs int64) (*SizeEstimate, error)