reader

Documentation

Index

• Variables
• func NewLinearReader(ctx context.Context, client *tg.Client, cache cache.Cacher, ...) (io.ReadCloser, error)
• type ChunkSource
• type LinearReader
  • func (r *LinearReader) Close() error
  • func (r *LinearReader) Read(p []byte) (int, error)
• type Range

Variables

var (
	ErrStreamAbandoned = errors.New("stream abandoned")
	ErrChunkTimeout    = errors.New("chunk fetch timed out")
)

Functions

func NewLinearReader

func NewLinearReader(ctx context.Context,
	client *tg.Client,
	cache cache.Cacher,
	file *schemas.FileOutFull,
	parts []types.Part,
	start,
	end int64,
	config *config.TGConfig,
	concurrency int,
) (io.ReadCloser, error)

Types

type ChunkSource

type ChunkSource interface {
	Chunk(ctx context.Context, offset int64, limit int64) ([]byte, error)
	ChunkSize(start, end int64) int64
}

type LinearReader

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

func (*LinearReader) Close

func (r *LinearReader) Close() error

func (*LinearReader) Read

func (r *LinearReader) Read(p []byte) (int, error)

type Range

type Range struct {
	Start, End int64
	PartNo     int64
}