client

Documentation

Index

• func NewSDK(c config.S3Cli) (*s3.S3, error)
• func Sign(req *request.Request)
• type S3Blobstore
  • func New(s3Client *s3.S3, s3cliConfig *config.S3Cli) (S3Blobstore, error)
  • func (client *S3Blobstore) Delete(dest string) error
  • func (client *S3Blobstore) Exists(dest string) (bool, error)
  • func (client *S3Blobstore) Get(src string, dest io.WriterAt) error
  • func (client *S3Blobstore) Put(src io.ReadSeeker, dest string) error
  • func (client *S3Blobstore) Sign(objectID string, action string, expiration time.Duration) (string, error)
• type SignURLProvider
  • func NewSignURLProvider(s3BlobstoreClient S3Blobstore, s3cliConfig *config.S3Cli) (SignURLProvider, error)
• type SwiftBlobstore
  • func NewSwiftClient(s3cliConfig *config.S3Cli) SwiftBlobstore
  • func (client *SwiftBlobstore) Sign(objectID string, action string, expiration time.Duration) (string, error)
  • func (client *SwiftBlobstore) SignedURL(action string, objectID string, expiration time.Duration) (string, error)

Functions

func NewSDK

func NewSDK(c config.S3Cli) (*s3.S3, error)

func Sign

func Sign(req *request.Request)

Sign requests with signature version 2.

Will sign the requests with the service config's Credentials object Signing is skipped if the credentials is the credentials.AnonymousCredentials object.

Types

type S3Blobstore

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

S3Blobstore encapsulates interactions with an S3 compatible blobstore

func New

func New(s3Client *s3.S3, s3cliConfig *config.S3Cli) (S3Blobstore, error)

New returns a BlobstoreClient if the configuration file backing configFile is valid

func (*S3Blobstore) Delete

func (client *S3Blobstore) Delete(dest string) error

Delete removes a blob from an S3 compatible blobstore. If the object does not exist, Delete does not return an error.

func (*S3Blobstore) Exists

func (client *S3Blobstore) Exists(dest string) (bool, error)

Exists checks if blob exists in an S3 compatible blobstore

func (*S3Blobstore) Get

func (client *S3Blobstore) Get(src string, dest io.WriterAt) error

Get fetches a blob from an S3 compatible blobstore Destination will be overwritten if exists

func (*S3Blobstore) Put

func (client *S3Blobstore) Put(src io.ReadSeeker, dest string) error

Put uploads a blob to an S3 compatible blobstore

func (*S3Blobstore) Sign

func (client *S3Blobstore) Sign(objectID string, action string, expiration time.Duration) (string, error)

Sign presigns URLs for a S3 compatible blobstore

type SignURLProvider

type SignURLProvider interface {
	Sign(action string, objectID string, expiration time.Duration) (string, error)
}

func NewSignURLProvider

func NewSignURLProvider(s3BlobstoreClient S3Blobstore, s3cliConfig *config.S3Cli) (SignURLProvider, error)

type SwiftBlobstore

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

func NewSwiftClient

func NewSwiftClient(s3cliConfig *config.S3Cli) SwiftBlobstore

func (*SwiftBlobstore) Sign

func (client *SwiftBlobstore) Sign(objectID string, action string, expiration time.Duration) (string, error)

func (*SwiftBlobstore) SignedURL

func (client *SwiftBlobstore) SignedURL(action string, objectID string, expiration time.Duration) (string, error)