oss

package
v0.11.11 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2025 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppendWriter

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

func NewAppendWriter

func NewAppendWriter(ctx context.Context, cfg *Cfg) *AppendWriter

func (*AppendWriter) Close

func (w *AppendWriter) Close() error

func (*AppendWriter) Offset added in v0.11.0

func (w *AppendWriter) Offset() int64

func (*AppendWriter) ReadFrom added in v0.11.0

func (w *AppendWriter) ReadFrom(r io.Reader) (int64, error)

func (*AppendWriter) Write

func (w *AppendWriter) Write(p []byte) (int, error)

type BlockList

type BlockList struct {
	Latest []string `xml:"Latest"`
}

type Cfg

type Cfg struct {
	URL      string `json:"url"            yaml:"url"     validate:"required"`
	Ak       string `json:"ak"             yaml:"ak"`
	Sk       string `json:"sk"             yaml:"sk"`
	Region   string `json:"region"         yaml:"region"`
	Retry    int    `json:"retry"          yaml:"retry"   validate:"gte=1"`
	Timeout  int    `json:"timeout"        yaml:"timeout" validate:"gte=1"`
	Offset   int64  `json:"offset"         yaml:"offset"`
	PartSize int64  `json:"partSize"       yaml:"partSize"`
	Parallel int    `json:"parallel"       yaml:"parallel"`
}

type CompleteMultipartUpload

type CompleteMultipartUpload struct {
	Parts []*Part `xml:"Part"`
}

type InitiateMultipartUploadResult

type InitiateMultipartUploadResult struct {
	UploadID string `xml:"UploadId"`
}

type MultiPartWriter

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

func NewMultiPartWriter

func NewMultiPartWriter(ctx context.Context, cfg *Cfg) *MultiPartWriter

func (*MultiPartWriter) Close

func (w *MultiPartWriter) Close() error

func (*MultiPartWriter) ReadFrom added in v0.11.0

func (w *MultiPartWriter) ReadFrom(r io.Reader) (int64, error)

func (*MultiPartWriter) Write

func (w *MultiPartWriter) Write(p []byte) (int, error)

type Part

type Part struct {
	ETag       string `xml:"ETag"`
	PartNumber int    `xml:"PartNumber"`
}

type Reader

type Reader struct {
	*httpio.Reader
	// contains filtered or unexported fields
}

func NewReader

func NewReader(ctx context.Context, cfg *Cfg, opts ...httpc.Option) *Reader

Jump to

Keyboard shortcuts

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