s3fs

Documentation

Index

• type S3
  • func NewS3Fs(client *S3Client) *S3
  • func (s *S3) ListFolder()
  • func (s *S3) Name() string
  • func (s *S3) SetUriAndValidate(uri string) error
• type S3Client
  • func MustNewS3Client() *S3Client
  • func NewS3Client() (*S3Client, error)
  • func NewS3ClientForMock(svc s3iface.ClientAPI, uploader s3manageriface.UploaderAPI) *S3Client
  • func (c *S3Client) GetObject(ctx context.Context, bucket, key string) (*s3.GetObjectResponse, error)
  • func (c *S3Client) HeadBucket(bucket string) error
  • func (c *S3Client) HeadObject(bucket, key string) error
  • func (c *S3Client) ListObjects(ctx context.Context, bucket string, prefix string) <-chan string
  • func (c *S3Client) PutObject(ctx context.Context, bucket, key string, body io.ReadSeeker) (*s3.PutObjectResponse, error)
  • func (c *S3Client) Upload(ctx context.Context, bucket, key string, body io.Reader) (*s3manager.UploadOutput, error)
• type S3URI
  • func ParseS3URI(uri string) (s3uri *S3URI, err error)
  • func (u *S3URI) String() string

Types

type S3

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

func NewS3Fs

func NewS3Fs(client *S3Client) *S3

func (*S3) ListFolder

func (s *S3) ListFolder()

func (*S3) Name

func (s *S3) Name() string

func (*S3) SetUriAndValidate

func (s *S3) SetUriAndValidate(uri string) error

type S3Client

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

func MustNewS3Client

func MustNewS3Client() *S3Client

func NewS3Client

func NewS3Client() (*S3Client, error)

func NewS3ClientForMock

func NewS3ClientForMock(
	svc s3iface.ClientAPI, uploader s3manageriface.UploaderAPI,
) *S3Client

func (*S3Client) GetObject

func (c *S3Client) GetObject(
	ctx context.Context, bucket, key string,
) (*s3.GetObjectResponse, error)

func (*S3Client) HeadBucket

func (c *S3Client) HeadBucket(bucket string) error

func (*S3Client) HeadObject

func (c *S3Client) HeadObject(bucket, key string) error

func (*S3Client) ListObjects

func (c *S3Client) ListObjects(
	ctx context.Context, bucket string, prefix string,
) <-chan string

func (*S3Client) PutObject

func (c *S3Client) PutObject(
	ctx context.Context, bucket, key string, body io.ReadSeeker,
) (*s3.PutObjectResponse, error)

func (*S3Client) Upload

func (c *S3Client) Upload(
	ctx context.Context, bucket, key string, body io.Reader,
) (*s3manager.UploadOutput, error)

type S3URI

type S3URI struct {
	URI      string
	Bucket   string
	Key      string
	IsFolder bool
}

func ParseS3URI

func ParseS3URI(uri string) (s3uri *S3URI, err error)

func (*S3URI) String

func (u *S3URI) String() string