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)
- func WouldRedirectWhenCached(ctx rcontext.RequestContext, ds config.DatastoreConfig) (bool, error)
- type Kind
- type RedirectError
- type SizeEstimate
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 HasListedKind ¶
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)
func WouldRedirectWhenCached ¶ added in v1.3.5
func WouldRedirectWhenCached(ctx rcontext.RequestContext, ds config.DatastoreConfig) (bool, error)
Types ¶
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)
Source Files
Click to show internal directories.
Click to hide internal directories.