internal

Documentation

Index

• type Putter
• type SimpleSplitterJob
  • 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)

Types

type Putter

type Putter interface {
	Put(context.Context, penguin.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 PenguinHash 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

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

NewSimpleSplitterJob creates a new SimpleSplitterJob.

The spanLength is the length of the data that will be written.

func (*SimpleSplitterJob) Sum

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

Sum returns the Penguin hash of the data.

func (*SimpleSplitterJob) Write

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

Write adds data to the file splitter.