swiftdriver

package
v0.0.0-...-5fe3b72 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SwiftCtxProviderName = "SwiftCtxProvider"
	SwiftEnvProviderName = "SwiftEnvProvider"
)
View Source
const (
	SwiftAccessKeyId     = "SWIFT_ACCESS_KEY_ID"
	SwiftSecretAccessKey = "SWIFT_SECRET_ACCESS_KEY"
)
View Source
const DefaultRegion = "us-east-1"

Variables

View Source
var (
	ErrSwiftAccessKeyIDNotFound     = fmt.Errorf("%s not found in environment", SwiftAccessKeyId)
	ErrSwiftSecretAccessKeyNotFound = fmt.Errorf("%s not found in environment", SwiftSecretAccessKey)
)

Functions

func CtxWithCredentials

func CtxWithCredentials(ctx context.Context, creds *SwiftCreds) context.Context

func CtxWithRegion

func CtxWithRegion(ctx context.Context, region string) context.Context

func CtxWithTimeout

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

func GetSwiftRegion

func GetSwiftRegion() string

func RegionFromCtx

func RegionFromCtx(ctx context.Context) (string, bool)

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)

type SwiftCreds

type SwiftCreds struct {
	AccessKeyId     string
	SecretAccessKey string
}

func CredentialsFromCtx

func CredentialsFromCtx(ctx context.Context) (*SwiftCreds, bool)

type SwiftCtxProvider

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

func NewSwiftCtxProvider

func NewSwiftCtxProvider(account string, creds *SwiftCreds) *SwiftCtxProvider

func (*SwiftCtxProvider) IsExpired

func (e *SwiftCtxProvider) IsExpired() bool

func (*SwiftCtxProvider) Retrieve

func (e *SwiftCtxProvider) Retrieve() (credentials.Value, error)

type SwiftEnvProvider

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

func NewSwiftEnvProvider

func NewSwiftEnvProvider(account string) *SwiftEnvProvider

func (*SwiftEnvProvider) IsExpired

func (e *SwiftEnvProvider) IsExpired() bool

func (*SwiftEnvProvider) Retrieve

func (e *SwiftEnvProvider) Retrieve() (credentials.Value, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL