services

Documentation

Index

• func GetAWSSession() (*session.Session, error)
• type AWS
  • func (a AWS) GetOIDPreSignedURL(oid string) (string, string, error)
  • func (a AWS) OIDExists(oid string) (bool, error)
  • func (a AWS) UploadOID(oid string, body io.ReadCloser) error
• type AWSService
  • func NewAWSService(bucket string, useAccelerate bool, presignEnabled bool, ...) (AWSService, error)
• type S3

Functions

func GetAWSSession

func GetAWSSession() (*session.Session, error)

Types

type AWS

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

func (AWS) GetOIDPreSignedURL

func (a AWS) GetOIDPreSignedURL(oid string) (string, string, error)

func (AWS) OIDExists

func (a AWS) OIDExists(oid string) (bool, error)

func (AWS) UploadOID

func (a AWS) UploadOID(oid string, body io.ReadCloser) error

type AWSService

type AWSService interface {
	OIDExists(oid string) (bool, error)
	GetOIDPreSignedURL(oid string) (string, string, error)
	UploadOID(oid string, body io.ReadCloser) error
}

func NewAWSService

func NewAWSService(bucket string, useAccelerate bool, presignEnabled bool, presignExpiration time.Duration) (AWSService, error)

type S3

type S3 interface {
	HeadObject(input *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)
	HeadObjectRequest(input *s3.HeadObjectInput) (req *request.Request, output *s3.HeadObjectOutput)
	GetObjectRequest(input *s3.GetObjectInput) (req *request.Request, output *s3.GetObjectOutput)
}