s3box

package module

v0.1.1 Latest Latest Go to latest Published: Nov 1, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/regenttsui/s3box

Links

Open Source Insights

README ¶

s3box

Tools and code snippets for S3 and S3 compatible storage services, such as Ceph RGW.

Documentation ¶

Index ¶

func CurlGen(conf *aws.Config, method, url, body, md5 string, bodyType BodyType) string
type BodyType
type BoxClient
- func NewBoxClient(svc *s3.S3, httpClient *http.Client) *BoxClient
- func (bc *BoxClient) PostObject(bucketName, objKey, date, encodedPolicy, region, filePath string, ...) (*http.Response, error)
type BucketCleaner
- func NewBucketCleaner(svc *s3.S3) *BucketCleaner
- func (c *BucketCleaner) DeleteAllBuckets(containedStr string) error
- func (c *BucketCleaner) EmptyBucket(bucketName string, deleteWorkerNum, objChanCap int, ...) error
type Signer
- func NewSigner(config aws.Config, time time.Time) *Signer
- func (v2 *Signer) Sign(r *http.Request) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CurlGen ¶

func CurlGen(conf *aws.Config, method, url, body, md5 string, bodyType BodyType) string

CurlGen generate curl command to send s3 v2 request in terminal. It does not support ipv6 address, upload/download objects. The argument body should be an empty/json/xml string, url should be path style

Types ¶

type BodyType ¶

type BodyType int

const (
	NoBody BodyType = iota
	JSONBody
	XMLBody
	BinaryBody
)

type BoxClient ¶

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

func NewBoxClient ¶

func NewBoxClient(svc *s3.S3, httpClient *http.Client) *BoxClient

func (*BoxClient) PostObject ¶

func (bc *BoxClient) PostObject(bucketName, objKey, date, encodedPolicy, region, filePath string, fields map[string]string) (*http.Response, error)

PostObject use form to upload object, fields should include all the necessary and optional fields except for x-amz-signature

type BucketCleaner ¶

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

TODO modify print of result and error

func NewBucketCleaner ¶

func NewBucketCleaner(svc *s3.S3) *BucketCleaner

func (*BucketCleaner) DeleteAllBuckets ¶

func (c *BucketCleaner) DeleteAllBuckets(containedStr string) error

DeleteAllBuckets delete all buckets or all buckets contain a specified string of a user

func (*BucketCleaner) EmptyBucket ¶

func (c *BucketCleaner) EmptyBucket(bucketName string, deleteWorkerNum, objChanCap int, multiDel, deleteBucket bool) error

EmptyBucket is to empty objects in the bucket concurrently. objChanCap is the capacity of channel to store the objects from listObjs multiDel decides whether to delete multiple objects in a request

type Signer ¶

type Signer struct {
	Time        time.Time
	Credentials *credentials.Credentials
	Debug       aws.LogLevelType
	Logger      aws.Logger

	Query url.Values
	// contains filtered or unexported fields
}

func NewSigner ¶

func NewSigner(config aws.Config, time time.Time) *Signer

NewSigner returns a Signer pointer configured with the aws.Config and time.Time

func (*Signer) Sign ¶

func (v2 *Signer) Sign(r *http.Request) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
radosgw
utils

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