blast

package

v0.0.0-...-0125c53 Latest Latest Go to latest Published: Nov 30, 2023 License: MIT Imports: 20 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/studio1767/s3blast

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewHasher(iChan <-chan string) (<-chan *Result, error)
func NewScanner(root string, ignoredot bool, maxfiles int) (<-chan string, error)
func NewWorker(wg *sync.WaitGroup, client *s3.Client, reducedRedundancy bool, ...) error
type ReadCounter
- func NewReadCounter(in io.Reader) ReadCounter
type Result
type Summarizer
- func NewSummarizer(wg *sync.WaitGroup, verbose bool) (*Summarizer, chan<- *Result)

Constants ¶

View Source

const (
	UPLOADED action = iota
	UPDATED
	MATCHED
	FAILED
)

Variables ¶

This section is empty.

Functions ¶

func NewHasher ¶

func NewHasher(iChan <-chan string) (<-chan *Result, error)

func NewScanner ¶

func NewScanner(root string, ignoredot bool, maxfiles int) (<-chan string, error)

func NewWorker ¶

func NewWorker(wg *sync.WaitGroup, client *s3.Client, reducedRedundancy bool, bucket, prefix string, srcprefix string, iChan <-chan *Result, oChan chan<- *Result) error

Types ¶

type ReadCounter ¶

type ReadCounter interface {
	Read(p []byte) (int, error)

	TotalReads() uint
	TotalBytes() uint64
}

func NewReadCounter ¶

func NewReadCounter(in io.Reader) ReadCounter

type Result ¶

type Result struct {
	Action action
	Path   string
	Hash   string
	Size   uint64
	Error  error
}

type Summarizer ¶

type Summarizer struct {
	StartTime     time.Time
	EndTime       time.Time
	TotalFiles    uint64
	TotalUploaded uint64
	TotalUpdated  uint64
	TotalMatched  uint64
	TotalFailed   uint64
	TotalBytes    uint64
	// contains filtered or unexported fields
}

func NewSummarizer ¶

func NewSummarizer(wg *sync.WaitGroup, verbose bool) (*Summarizer, chan<- *Result)

func (*Summarizer) ExitStatus ¶

func (s *Summarizer) ExitStatus() int

func (*Summarizer) Report ¶

func (s *Summarizer) Report()

func (*Summarizer) Run ¶

func (s *Summarizer) Run()

Source Files ¶

View all Source files

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