hasher

Documentation

Index

• Constants
• func Tee(reader io.Reader, hashFunc func() hash.Hash, metaName string, ...) io.Reader
• type BlockHash
  • func NewBlockHash(h hash.Hash, blockSize int) *BlockHash
  • func (b *BlockHash) Next(p []byte)
  • func (b *BlockHash) Reset()
  • func (b *BlockHash) Sum(p []byte) []byte
  • func (b *BlockHash) Write(p []byte) (n int, err error)
• type HashCloser
• type Reader
  • func (r *Reader) ExtractedMeta() (map[string]string, bool)
  • func (r *Reader) Read(p []byte) (n int, err error)

Constants

const (
	DefaultBlockSize = 10 * 1024 * 1024
)

Functions

func Tee

func Tee(reader io.Reader, hashFunc func() hash.Hash, metaName string, complete func(s string, hashes [][]byte)) io.Reader

Types

type BlockHash

type BlockHash struct {
	hash.Hash
	// contains filtered or unexported fields
}

BlockHash is a hash.Hash implementation that compute sub-hashes on each blocks of BlockSize and re-hash them together at the end. It is uses to provide a stable hashing algorithm for standard PUT Object requests vs Multipart Uploads. Bewre that this implies that the Multipart PartSize must be a multiple of this block size.

func NewBlockHash

func NewBlockHash(h hash.Hash, blockSize int) *BlockHash

func (*BlockHash) Next

func (b *BlockHash) Next(p []byte)

func (*BlockHash) Reset

func (b *BlockHash) Reset()

func (*BlockHash) Sum

func (b *BlockHash) Sum(p []byte) []byte

func (*BlockHash) Write

func (b *BlockHash) Write(p []byte) (n int, err error)

type HashCloser

type HashCloser interface {
	Close()
}

type Reader

type Reader struct {
	io.Reader
	hash.Hash
	// contains filtered or unexported fields
}

func (*Reader) ExtractedMeta

func (r *Reader) ExtractedMeta() (map[string]string, bool)

func (*Reader) Read

func (r *Reader) Read(p []byte) (n int, err error)