storage

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Jul 14, 2022 License: BSD-3-Clause Imports: 18 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotSupported = errors.New("method call on storage engine not supported")

Functions

func Get 

func Get(ctx context.Context, engine Engine, u *URI) ([]byte, error)

func NewBytesReader 

func NewBytesReader(b []byte) *bytesReader

func Put 

func Put(ctx context.Context, engine Engine, u *URI, r io.Reader) error

func Size 

func Size(r Reader) (int64, error)

Types

type Engine 

type Engine interface {
	Get(context.Context, *URI) (Reader, error)
	Put(context.Context, *URI) (io.WriteCloser, error)
	PutIfNotExists(context.Context, *URI, []byte) error
	Delete(context.Context, *URI) error
	DeleteByPrefix(context.Context, *URI) error
	Exists(context.Context, *URI) (bool, error)
	Size(context.Context, *URI) (int64, error)
	List(context.Context, *URI) ([]Info, error)
}

type FileSystem 

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

func NewFileSystem 

func NewFileSystem() *FileSystem

func (*FileSystem) Delete 

func (f *FileSystem) Delete(_ context.Context, u *URI) error

func (*FileSystem) DeleteByPrefix 

func (f *FileSystem) DeleteByPrefix(_ context.Context, u *URI) error

func (*FileSystem) Exists 

func (f *FileSystem) Exists(_ context.Context, u *URI) (bool, error)

func (*FileSystem) Get 

func (f *FileSystem) Get(ctx context.Context, u *URI) (Reader, error)

func (*FileSystem) List 

func (f *FileSystem) List(ctx context.Context, u *URI) ([]Info, error)

func (*FileSystem) Put 

func (f *FileSystem) Put(_ context.Context, u *URI) (io.WriteCloser, error)

func (*FileSystem) PutIfNotExists 

func (f *FileSystem) PutIfNotExists(_ context.Context, u *URI, b []byte) error

func (*FileSystem) Size 

func (f *FileSystem) Size(_ context.Context, u *URI) (int64, error)

type HTTPEngine 

type HTTPEngine struct{}

func NewHTTP 

func NewHTTP() *HTTPEngine

func (*HTTPEngine) Delete 

func (*HTTPEngine) Delete(_ context.Context, u *URI) error

func (*HTTPEngine) DeleteByPrefix 

func (*HTTPEngine) DeleteByPrefix(_ context.Context, u *URI) error

func (*HTTPEngine) Exists 

func (*HTTPEngine) Exists(_ context.Context, u *URI) (bool, error)

func (*HTTPEngine) Get 

func (*HTTPEngine) Get(ctx context.Context, u *URI) (Reader, error)

func (*HTTPEngine) List 

func (*HTTPEngine) List(ctx context.Context, u *URI) ([]Info, error)

func (*HTTPEngine) Put 

func (*HTTPEngine) Put(_ context.Context, u *URI) (io.WriteCloser, error)

func (*HTTPEngine) PutIfNotExists 

func (*HTTPEngine) PutIfNotExists(context.Context, *URI, []byte) error

func (*HTTPEngine) Size 

func (*HTTPEngine) Size(_ context.Context, u *URI) (int64, error)

type Info 

type Info struct {
	Name string
	Size int64
}

type NopCloser 

type NopCloser struct {
	io.Writer
}

func (*NopCloser) Close 

func (*NopCloser) Close() error

type Reader 

type Reader interface {
	io.Reader
	io.ReaderAt
	io.Closer
}

type Router 

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

Router is an Engine that routes each function call to the correct sub-Engine based off the provided URI's scheme and its enablement.

func NewLocalEngine 

func NewLocalEngine() *Router

func NewRemoteEngine 

func NewRemoteEngine() *Router

func NewRouter 

func NewRouter() *Router

func (*Router) Delete 

func (r *Router) Delete(ctx context.Context, u *URI) error

func (*Router) DeleteByPrefix 

func (r *Router) DeleteByPrefix(ctx context.Context, u *URI) error

func (*Router) Enable 

func (r *Router) Enable(scheme Scheme)

func (*Router) Exists 

func (r *Router) Exists(ctx context.Context, u *URI) (bool, error)

func (*Router) Get 

func (r *Router) Get(ctx context.Context, u *URI) (Reader, error)

func (*Router) List 

func (r *Router) List(ctx context.Context, u *URI) ([]Info, error)

func (*Router) Put 

func (r *Router) Put(ctx context.Context, u *URI) (io.WriteCloser, error)

func (*Router) PutIfNotExists 

func (r *Router) PutIfNotExists(ctx context.Context, u *URI, b []byte) error

func (*Router) Size 

func (r *Router) Size(ctx context.Context, u *URI) (int64, error)

type S3Engine 

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

func NewS3 

func NewS3() *S3Engine

func (*S3Engine) Delete 

func (s *S3Engine) Delete(ctx context.Context, u *URI) error

func (*S3Engine) DeleteByPrefix 

func (s *S3Engine) DeleteByPrefix(ctx context.Context, u *URI) error

func (*S3Engine) Exists 

func (s *S3Engine) Exists(ctx context.Context, u *URI) (bool, error)

func (*S3Engine) Get 

func (s *S3Engine) Get(ctx context.Context, u *URI) (Reader, error)

func (*S3Engine) List 

func (s *S3Engine) List(ctx context.Context, uri *URI) ([]Info, error)

func (*S3Engine) Put 

func (s *S3Engine) Put(ctx context.Context, u *URI) (io.WriteCloser, error)

func (*S3Engine) PutIfNotExists 

func (s *S3Engine) PutIfNotExists(context.Context, *URI, []byte) error

func (*S3Engine) Size 

func (s *S3Engine) Size(ctx context.Context, u *URI) (int64, error)

type Scheme 

type Scheme string
const (
	FileScheme  Scheme = "file"
	StdioScheme Scheme = "stdio"
	HTTPScheme  Scheme = "http"
	HTTPSScheme Scheme = "https"
	S3Scheme    Scheme = "s3"
)

type Seeker 

type Seeker struct {
	io.ReadSeeker
	Reader
}

func NewSeeker 

func NewSeeker(r Reader) (*Seeker, error)

NewSeeker provides a seeker implementation on top of Reader. Using a seeker is not optimal as cloud-oriented apps should use application-level framing to do readahead and so forth based that leverages knowledge of the data of the underlying storage objects. This seeker interface is provided for backward compat with libraries like parquet-go that are based on an io.ReadSeeker.

func (*Seeker) Read 

func (s *Seeker) Read(b []byte) (int, error)

Read resolves the ambiguous selector s.Read to s.ReadSeeker.Read.

type Sizer 

type Sizer interface {
	Size() (int64, error)
}

type StdioEngine 

type StdioEngine struct{}

func NewStdioEngine 

func NewStdioEngine() *StdioEngine

func (*StdioEngine) Delete 

func (*StdioEngine) Delete(ctx context.Context, u *URI) error

func (*StdioEngine) DeleteByPrefix 

func (*StdioEngine) DeleteByPrefix(ctx context.Context, u *URI) error

func (*StdioEngine) Exists 

func (*StdioEngine) Exists(_ context.Context, u *URI) (bool, error)

func (*StdioEngine) Get 

func (*StdioEngine) Get(_ context.Context, u *URI) (Reader, error)

func (*StdioEngine) List 

func (*StdioEngine) List(_ context.Context, _ *URI) ([]Info, error)

func (*StdioEngine) Put 

func (*StdioEngine) Put(ctx context.Context, u *URI) (io.WriteCloser, error)

func (*StdioEngine) PutIfNotExists 

func (*StdioEngine) PutIfNotExists(context.Context, *URI, []byte) error

func (*StdioEngine) Size 

func (*StdioEngine) Size(_ context.Context, u *URI) (int64, error)

type URI 

type URI url.URL

func MustParseURI 

func MustParseURI(path string) *URI

func ParseURI 

func ParseURI(path string) (*URI, error)

ParseURI parses the path using `url.Parse`. If the provided uri does not contain a scheme, the scheme is set to file. Relative paths are treated as files and resolved as absolute paths using filepath.Abs. If path is an empty, a pointer to zero-valued URI is returned.

func (*URI) AppendPath 

func (p *URI) AppendPath(elem ...string) *URI

func (*URI) Filepath 

func (p *URI) Filepath() string

func (*URI) HasScheme 

func (u *URI) HasScheme(s Scheme) bool

func (*URI) IsZero 

func (u *URI) IsZero() bool

func (*URI) MarshalText 

func (u *URI) MarshalText() ([]byte, error)

func (*URI) MarshalZNG 

func (u *URI) MarshalZNG(mc *zson.MarshalZNGContext) (zed.Type, error)

func (*URI) RelPath 

func (u *URI) RelPath(target URI) string

func (URI) String 

func (u URI) String() string

func (*URI) UnmarshalText 

func (u *URI) UnmarshalText(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis
Package cache contains facilities for caching immutable files, typically for a cloud object store.
 Package cache contains facilities for caching immutable files, typically for a cloud object store.
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.