storage

package

v0.0.0-...-65ad015 Latest Latest Go to latest Published: Nov 12, 2023 License: BSD-2-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/1235467/intertube

Documentation ¶

Index ¶

Variables
func Init(cfg Config)
func IsCacheEnabled() bool
type Config
type Retryer
- func (r Retryer) ShouldRetry(req *request.Request) bool
type S3Bucket
type S3Head
type StorageType

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	S3Region   = "us-west-2"
	S3Endpoint string

	S3AccessKeyID     string
	S3AccessKeySecret string

	// for R2
	CFAccountID string
)

Functions ¶

func Init ¶

func Init(cfg Config)

func IsCacheEnabled ¶

func IsCacheEnabled() bool

Types ¶

type Config ¶

type Config struct {
	Type StorageType

	FilesBucket   string
	UploadsBucket string
	CacheBucket   string

	Region   string
	Endpoint string

	AccessKeyID     string
	AccessKeySecret string

	// for R2
	CFAccountID string
}

type Retryer ¶

type Retryer struct {
	client.DefaultRetryer
}

func (Retryer) ShouldRetry ¶

func (r Retryer) ShouldRetry(req *request.Request) bool

type S3Bucket ¶

type S3Bucket struct {
	S3   *s3.S3
	Name string
	Type StorageType
}

var (
	FilesBucket   S3Bucket
	UploadsBucket S3Bucket
	CacheBucket   S3Bucket
)

func (S3Bucket) Copy ¶

func (b S3Bucket) Copy(dst, src string) error

func (S3Bucket) CopyFromBucket ¶

func (b S3Bucket) CopyFromBucket(dst string, srcBucket S3Bucket, src string, mime, contentDisp string) error

func (S3Bucket) Delete ¶

func (b S3Bucket) Delete(key string) error

func (S3Bucket) Exists ¶

func (b S3Bucket) Exists(key string) bool

func (S3Bucket) Get ¶

func (b S3Bucket) Get(key string) (io.ReadCloser, error)

func (S3Bucket) Head ¶

func (b S3Bucket) Head(key string) (S3Head, error)

func (S3Bucket) Keys ¶

func (b S3Bucket) Keys() ([]string, error)

func (S3Bucket) List ¶

func (b S3Bucket) List(prefix string) (map[string]S3Head, error)

func (S3Bucket) PresignGet ¶

func (b S3Bucket) PresignGet(key string, ttl time.Duration) (string, error)

func (S3Bucket) PresignPut ¶

func (b S3Bucket) PresignPut(key string, size int64, disp string, ttl time.Duration) (string, error)

func (S3Bucket) Put ¶

func (b S3Bucket) Put(contentType, key string, r io.ReadSeeker) error

type S3Head ¶

type S3Head struct {
	Type string
	Size int64
}

type StorageType ¶

type StorageType string

const (
	StorageTypeS3 StorageType = "s3"
	StorageTypeB2 StorageType = "b2"
	StorageTypeR2 StorageType = "r2"
)

Source Files ¶

View all Source files

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