stream

Documentation

Index

• Constants
• type Pipeline
  • func NewPipeline(key []byte, processMode types.Processing) (*Pipeline, error)
  • func (p *Pipeline) Process(ctx context.Context, input io.Reader, output io.Writer, totalSize int64) error

Constants

const DefaultChunkSize = 256 * 1024

Types

type Pipeline

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

func NewPipeline

func NewPipeline(key []byte, processMode types.Processing) (*Pipeline, error)

func (*Pipeline) Process

func (p *Pipeline) Process(ctx context.Context, input io.Reader, output io.Writer, totalSize int64) error