s3driver

Documentation

Index

• Constants
• func CredentialsFromCtx(ctx context.Context) (*credentials.Credentials, bool)
• func CtxWithCredentials(ctx context.Context, creds *credentials.Credentials) context.Context
• func CtxWithTimeout(ctx context.Context, timeout time.Duration) context.Context
• func NewObjectWriter(svc s3iface.S3API, bucket, key, canonicalURL string) driver.ObjectWriter
• func RegisterDefaultDriver()
• func TimeoutFromCtx(ctx context.Context) (*time.Duration, bool)
• type Driver
  • func (d *Driver) Create(ctx context.Context, url string) (driver.ObjectWriter, error)
  • func (d *Driver) Name() string
  • func (d *Driver) Open(ctx context.Context, url string, size int64) (driver.Object, error)
  • func (d *Driver) Readdir(ctx context.Context, url string) ([]os.FileInfo, error)
  • func (d *Driver) Remove(ctx context.Context, url string) error
  • func (d *Driver) Stat(ctx context.Context, url string) (os.FileInfo, error)

Constants

const DefaultRegion = "us-east-1"

Functions

func CredentialsFromCtx

func CredentialsFromCtx(ctx context.Context) (*credentials.Credentials, bool)

func CtxWithCredentials

func CtxWithCredentials(ctx context.Context, creds *credentials.Credentials) context.Context

func CtxWithTimeout

func CtxWithTimeout(ctx context.Context, timeout time.Duration) context.Context

func NewObjectWriter

func NewObjectWriter(svc s3iface.S3API, bucket, key, canonicalURL string) driver.ObjectWriter

func RegisterDefaultDriver

func RegisterDefaultDriver()

func TimeoutFromCtx

func TimeoutFromCtx(ctx context.Context) (*time.Duration, bool)

Types

type Driver

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

func (*Driver) Create

func (d *Driver) Create(ctx context.Context, url string) (driver.ObjectWriter, error)

func (*Driver) Name

func (d *Driver) Name() string

func (*Driver) Open

func (d *Driver) Open(ctx context.Context, url string, size int64) (driver.Object, error)

func (*Driver) Readdir

func (d *Driver) Readdir(ctx context.Context, url string) ([]os.FileInfo, error)

func (*Driver) Remove

func (d *Driver) Remove(ctx context.Context, url string) error

func (*Driver) Stat

func (d *Driver) Stat(ctx context.Context, url string) (os.FileInfo, error)