base

package

v0.5.0 Latest Latest Go to latest Published: Oct 25, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zoumo/afs

Links

Open Source Insights

Documentation ¶

Overview ¶

Package base define base manager

Index ¶

func NewUploader(manager storage.Manager) storage.BatchUploader
type Manager
- func New(manager storage.Manager, scheme string, ...) *Manager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewUploader ¶

func NewUploader(manager storage.Manager) storage.BatchUploader

NewUploader creates a new batch uploader

Types ¶

type Manager ¶

type Manager struct {
	storage.Manager
	// contains filtered or unexported fields
}

Manager represents storager base manager

func New ¶

func New(manager storage.Manager, scheme string, provider func(ctx context.Context, baseURL string, options ...storage.Option) (storage.Storager, error), options []storage.Option) *Manager

New creates base storager base Manager

func (*Manager) BaseURL ¶ added in v0.5.0

func (m *Manager) BaseURL() string

Scheme returns scheme

func (*Manager) Close ¶

func (m *Manager) Close() error

Close closes storagers

func (*Manager) Create ¶

func (m *Manager) Create(ctx context.Context, URL string, mode os.FileMode, isDir bool, options ...storage.Option) error

Create creates a resource

func (*Manager) Delete ¶

func (m *Manager) Delete(ctx context.Context, URL string, options ...storage.Option) error

Delete deletes locations

func (*Manager) Download ¶

func (m *Manager) Download(ctx context.Context, object storage.Object, options ...storage.Option) (io.ReadCloser, error)

Download downloads content

func (*Manager) DownloadWithURL ¶

func (m *Manager) DownloadWithURL(ctx context.Context, URL string, options ...storage.Option) (io.ReadCloser, error)

DownloadWithURL downloads content

func (*Manager) Exists ¶

func (m *Manager) Exists(ctx context.Context, URL string, options ...storage.Option) (bool, error)

Exists checks if resource exsits

func (*Manager) IsAuthChanged ¶ added in v0.5.0

func (m *Manager) IsAuthChanged(ctx context.Context, baseURL string, options []storage.Option) bool

func (*Manager) List ¶

func (m *Manager) List(ctx context.Context, URL string, options ...storage.Option) ([]storage.Object, error)

List lists content for supplied URL

func (*Manager) Options ¶

func (m *Manager) Options(options []storage.Option) []storage.Option

Options returns base and supplied options

func (*Manager) Scheme ¶

func (m *Manager) Scheme() string

Scheme returns scheme

func (*Manager) Storager ¶

func (m *Manager) Storager(ctx context.Context, baseURL string, options []storage.Option) (storage.Storager, error)

Storager returns storager

func (*Manager) Upload ¶

func (m *Manager) Upload(ctx context.Context, URL string, mode os.FileMode, reader io.Reader, options ...storage.Option) error

Upload uploads content

Source Files ¶

View all Source files

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