bucket

Documentation

Index

• type Bucket
  • func Open(config Config) (*Bucket, error)
  • func OpenAll(buckets []Config) ([]*Bucket, error)
  • func OpenMedia(buckets []Config, mediaType string) ([]Bucket, error)
  • func (b *Bucket) List(lastSync time.Time) (objectCh chan *Object, err error)
  • func (b *Bucket) Presign(key string) *url.URL
  • func (b *Bucket) Rewrite(path string) string
• type Config
• type Object
• type RewriteRule

Types

type Bucket

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

func Open

func Open(config Config) (*Bucket, error)

Connect to the configured S3 bucket. Tested: Wasabi, Backblaze, Minio

func OpenAll

func OpenAll(buckets []Config) ([]*Bucket, error)

func OpenMedia

func OpenMedia(buckets []Config, mediaType string) ([]Bucket, error)

func (*Bucket) List

func (b *Bucket) List(lastSync time.Time) (objectCh chan *Object, err error)

func (*Bucket) Presign

func (b *Bucket) Presign(key string) *url.URL

Generate a presigned url which expires based on config settings.

func (*Bucket) Rewrite

func (b *Bucket) Rewrite(path string) string

type Config

type Config struct {
	Endpoint        string
	Region          string
	AccessKeyID     string
	SecretAccessKey string
	BucketName      string
	ObjectPrefix    string
	UseSSL          bool
	URLExpiration   time.Duration
	Media           string
	RewriteRules    []RewriteRule
}

type Object

type Object struct {
	Key          string
	Path         string // Key modified by rewrite rules
	ETag         string
	Size         int64
	LastModified time.Time
}

type RewriteRule

type RewriteRule struct {
	Pattern string
	Replace string
}