reader

Documentation

Index

• type FileReader
• type FileReaderService
  • func NewFileReaderService(ctx context.Context, logger logger.Logger, chunkSize int) *FileReaderService
  • func (r *FileReaderService) ReadAll(file *os.File) *model.Chunk
  • func (r *FileReaderService) ReadByChunks(file *os.File, offset int64) chan *model.Chunk

Types

type FileReader

type FileReader interface {
	// ReadAll - reads a whole file in a single chunk.
	ReadAll(file *os.File) *model.Chunk
	// ReadByChunks - reads a file by separated chunks and passed it into the channel.
	ReadByChunks(file *os.File, offset int64) chan *model.Chunk
}

type FileReaderService

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

func NewFileReaderService

func NewFileReaderService(ctx context.Context, logger logger.Logger, chunkSize int) *FileReaderService

func (*FileReaderService) ReadAll

func (r *FileReaderService) ReadAll(file *os.File) *model.Chunk

ReadAll - reads a whole file in a single chunk.

func (*FileReaderService) ReadByChunks

func (r *FileReaderService) ReadByChunks(file *os.File, offset int64) chan *model.Chunk

ReadByChunks - reads a file by separated chunks and passed it into the channel (chunk size is setting up through env. configuration).