fscan

Documentation

Index

• func HashFilesProcessor(ctx context.Context, inStream <-chan *FileHashRequest) <-chan *FileHashResponse
• func PathGenerator(ctx context.Context, path string, hasher crypto.Hash) <-chan *FileHashRequest
• type FileHashRequest
• type FileHashResponse
  • func ProcessRequest(_ context.Context, request *FileHashRequest) *FileHashResponse

Functions

func HashFilesProcessor

func HashFilesProcessor(
	ctx context.Context,
	inStream <-chan *FileHashRequest,
) <-chan *FileHashResponse

func PathGenerator

func PathGenerator(
	ctx context.Context,
	path string,
	hasher crypto.Hash,
) <-chan *FileHashRequest

Types

type FileHashRequest

type FileHashRequest struct {
	Path   string
	Hasher crypto.Hash
}

type FileHashResponse

type FileHashResponse struct {
	FileHashRequest
	Size     int64
	Duration time.Duration
	Hash     []byte
	Err      error
}

func ProcessRequest

func ProcessRequest(
	_ context.Context,
	request *FileHashRequest,
) *FileHashResponse