internal

type Putter ¶

type Putter interface {
	Put(context.Context, boson.Chunk) ([]bool, error)
}

type SimpleSplitterJob ¶

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

SimpleSplitterJob encapsulated a single splitter operation, accepting blockwise writes of data whose length is defined in advance.

After the job is constructed, Write must be called with up to ChunkSize byte slices until the full data length has been written. The Sum should be called which will return the File AddrHash of the data.

Called Sum before the last Write, or Write after Sum has been called, may result in error and will may result in undefined result.

func NewSimpleSplitterJob(ctx context.Context, putter Putter, spanLength int64, toEncrypt bool) *SimpleSplitterJob

func (j *SimpleSplitterJob) Sum(b []byte) []byte

func (j *SimpleSplitterJob) Write(b []byte) (int, error)