kodofs

README

kodofs - http.FileSystem for kodo (qiniu object storage)

Documentation

Index

• Constants
• func Open(ctx context.Context, url string) (_ http.FileSystem, _ fsx.Closer, err error)
• func Register(bucketHostPairs ...string)
• func SetDebug(dbgFlags int)
• type Bucket
  • func New(accessKey, secretKey string, bucket string, host string, prepare PrepareOpen) *Bucket
  • func (b *Bucket) Open(name string) (f http.File, err error)
  • func (b *Bucket) ReaddirContext(ctx context.Context, dir string) (fis []fs.FileInfo, err error)
• type Credentials
  • func NewCredentials(accessKey, secretKey string) *Credentials
  • func (mac *Credentials) NewBucket(bucket string, host string, prepare PrepareOpen) *Bucket
• type PrepareOpen

Constants

const (
	DbgFlagNetwork = kodo.DbgFlagNetwork
	DbgFlagAll     = kodo.DbgFlagAll
)

const (
	Scheme = kodoutil.Scheme
)

Functions

func Open

func Open(ctx context.Context, url string) (_ http.FileSystem, _ fsx.Closer, err error)

Open a kodofs file system by url in form of "kodo:<bucketName>?<token>".

func Register

func Register(bucketHostPairs ...string)

Register registers (bucket, host) pairs for kodofs.

func SetDebug

func SetDebug(dbgFlags int)

Types

type Bucket

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

func New

func New(accessKey, secretKey string, bucket string, host string, prepare PrepareOpen) *Bucket

func (*Bucket) Open

func (b *Bucket) Open(name string) (f http.File, err error)

Open implements net/http.FileSystem.Open (https://pkg.go.dev/net/http#FileSystem).

func (*Bucket) ReaddirContext

func (b *Bucket) ReaddirContext(ctx context.Context, dir string) (fis []fs.FileInfo, err error)

type Credentials

type Credentials kodo.Credentials

func NewCredentials

func NewCredentials(accessKey, secretKey string) *Credentials

func (*Credentials) NewBucket

func (mac *Credentials) NewBucket(bucket string, host string, prepare PrepareOpen) *Bucket

type PrepareOpen

type PrepareOpen = func(name string) (ctx context.Context, opener xfs.HttpOpener)