internal

type SimpleJoinerJob ¶

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

SimpleJoinerJob encapsulates a single joiner operation, providing the consumer with blockwise reads of data represented by a content addressed chunk tree.

Every chunk has a span length, which is a 64-bit integer in little-endian encoding stored as a prefix in the chunk itself. This represents the length of the data that reference represents.

If a chunk's span length is greater than swarm.ChunkSize, the chunk will be treated as an intermediate chunk, meaning the contents of the chunk are handled as references to other chunks which in turn are retrieved.

Otherwise it passes the data chunk to the io.Reader and blocks until the consumer reads the chunk.

The process is repeated until the readCount reaches the announced spanLength of the chunk.

func NewSimpleJoinerJob(ctx context.Context, getter storage.Getter, rootChunk swarm.Chunk) *SimpleJoinerJob

func (j *SimpleJoinerJob) Close() error

func (j *SimpleJoinerJob) Read(b []byte) (n int, err error)