services

Documentation

Index

• type AWS
  • func (a *AWS) GetDirectURL(oid string) string
  • func (a *AWS) LoadManifest(ctx context.Context) ([]string, bool, error)
  • func (a *AWS) OIDExists(ctx context.Context, oid string) (bool, error)
  • func (a *AWS) PresignObject(ctx context.Context, oid string, ttl time.Duration) (string, time.Time, error)
  • func (a *AWS) SaveManifest(ctx context.Context, oids []string) error
  • func (a *AWS) UploadOID(ctx context.Context, oid string, body io.ReadCloser) error
• type AWSService
  • func NewAWSService(ctx context.Context, bucket string, useAccelerate bool) (AWSService, error)

Types

type AWS

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

func (*AWS) GetDirectURL

func (a *AWS) GetDirectURL(oid string) string

func (*AWS) LoadManifest

func (a *AWS) LoadManifest(ctx context.Context) ([]string, bool, error)

func (*AWS) OIDExists

func (a *AWS) OIDExists(ctx context.Context, oid string) (bool, error)

func (*AWS) PresignObject

func (a *AWS) PresignObject(ctx context.Context, oid string, ttl time.Duration) (string, time.Time, error)

func (*AWS) SaveManifest

func (a *AWS) SaveManifest(ctx context.Context, oids []string) error

func (*AWS) UploadOID

func (a *AWS) UploadOID(ctx context.Context, oid string, body io.ReadCloser) error

type AWSService

type AWSService interface {
	OIDExists(ctx context.Context, oid string) (bool, error)
	GetDirectURL(oid string) string
	PresignObject(ctx context.Context, oid string, ttl time.Duration) (url string, expiresAt time.Time, err error)
	UploadOID(ctx context.Context, oid string, body io.ReadCloser) error
	LoadManifest(ctx context.Context) (oids []string, bootstrapped bool, err error)
	SaveManifest(ctx context.Context, oids []string) error
}

func NewAWSService

func NewAWSService(ctx context.Context, bucket string, useAccelerate bool) (AWSService, error)