storage

Documentation

Index

• Constants
• Variables
• func CompleteBuckets(u *url.URL) ([]string, cobra.ShellCompDirective)
• func CompleteObjects(u *url.URL, exts []string, dirOnly bool) ([]string, cobra.ShellCompDirective)
• func IsB2(path string) bool
• func IsB2Dir(path string) bool
• func IsCloud(path string) bool
• func IsCloudDir(path string) bool
• func IsGCS(path string) bool
• func IsGCSDir(path string) bool
• func IsS3(path string) bool
• func IsS3Dir(path string) bool
• type B2
  • func NewB2(ctx context.Context) (*B2, error)
  • func (b *B2) GetObject(ctx context.Context, key string) (io.ReadCloser, error)
  • func (b *B2) ListBuckets(ctx context.Context) iter.Seq2[*Bucket, error]
  • func (b *B2) ListObjects(ctx context.Context, key string) iter.Seq2[*Object, error]
  • func (b *B2) PutObject(ctx context.Context, r io.Reader, key string) error
• type Bucket
• type Client
  • func NewClient(ctx context.Context, path string) (Client, error)
• type GCS
  • func NewGCS(ctx context.Context, scope, projectID string) (*GCS, error)
  • func (g *GCS) GetObject(ctx context.Context, key string) (io.ReadCloser, error)
  • func (g *GCS) ListBuckets(ctx context.Context) iter.Seq2[*Bucket, error]
  • func (g *GCS) ListObjects(ctx context.Context, key string) iter.Seq2[*Object, error]
  • func (g *GCS) PutObject(ctx context.Context, r io.Reader, key string) error
• type Object
• type S3
  • func NewS3(ctx context.Context) (*S3, error)
  • func (s *S3) GetObject(ctx context.Context, key string) (io.ReadCloser, error)
  • func (s *S3) ListBuckets(ctx context.Context) iter.Seq2[*Bucket, error]
  • func (s *S3) ListObjects(ctx context.Context, key string) iter.Seq2[*Object, error]
  • func (s *S3) PutObject(ctx context.Context, r io.Reader, key string) error

Constants

const B2Schema = "b2://"

const GCSSchema = "gs://"

const S3Schema = "s3://"

Variables

var ErrUnknownPrefix = errors.New("unknown prefix")

Functions

func CompleteBuckets

func CompleteBuckets(u *url.URL) ([]string, cobra.ShellCompDirective)

func CompleteObjects

func CompleteObjects(u *url.URL, exts []string, dirOnly bool) ([]string, cobra.ShellCompDirective)

func IsB2

func IsB2(path string) bool

func IsB2Dir

func IsB2Dir(path string) bool

func IsCloud

func IsCloud(path string) bool

func IsCloudDir

func IsCloudDir(path string) bool

func IsGCS

func IsGCS(path string) bool

func IsGCSDir

func IsGCSDir(path string) bool

func IsS3

func IsS3(path string) bool

func IsS3Dir

func IsS3Dir(path string) bool

Types

type B2

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

func NewB2

func NewB2(ctx context.Context) (*B2, error)

func (*B2) GetObject

func (b *B2) GetObject(ctx context.Context, key string) (io.ReadCloser, error)

func (*B2) ListBuckets

func (b *B2) ListBuckets(ctx context.Context) iter.Seq2[*Bucket, error]

func (*B2) ListObjects

func (b *B2) ListObjects(ctx context.Context, key string) iter.Seq2[*Object, error]

func (*B2) PutObject

func (b *B2) PutObject(ctx context.Context, r io.Reader, key string) error

type Bucket

type Bucket struct {
	Name string
}

type Client

type Client interface {
	ListBuckets(ctx context.Context) iter.Seq2[*Bucket, error]
	ListObjects(ctx context.Context, key string) iter.Seq2[*Object, error]
	PutObject(ctx context.Context, r io.Reader, key string) error
	GetObject(ctx context.Context, key string) (io.ReadCloser, error)
}

func NewClient

func NewClient(ctx context.Context, path string) (Client, error)

type GCS

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

func NewGCS

func NewGCS(ctx context.Context, scope, projectID string) (*GCS, error)

func (*GCS) GetObject

func (g *GCS) GetObject(ctx context.Context, key string) (io.ReadCloser, error)

func (*GCS) ListBuckets

func (g *GCS) ListBuckets(ctx context.Context) iter.Seq2[*Bucket, error]

func (*GCS) ListObjects

func (g *GCS) ListObjects(ctx context.Context, key string) iter.Seq2[*Object, error]

func (*GCS) PutObject

func (g *GCS) PutObject(ctx context.Context, r io.Reader, key string) error

type Object

type Object struct {
	Name         string
	IsDir        bool
	LastModified time.Time
	Size         int64
}

type S3

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

func NewS3

func NewS3(ctx context.Context) (*S3, error)

func (*S3) GetObject

func (s *S3) GetObject(ctx context.Context, key string) (io.ReadCloser, error)

func (*S3) ListBuckets

func (s *S3) ListBuckets(ctx context.Context) iter.Seq2[*Bucket, error]

func (*S3) ListObjects

func (s *S3) ListObjects(ctx context.Context, key string) iter.Seq2[*Object, error]

func (*S3) PutObject

func (s *S3) PutObject(ctx context.Context, r io.Reader, key string) error