processpool

Documentation

Index

• func NewProcessReader(r io.ReadCloser, total int64, update chan<- v1.Update) io.ReadCloser
• type ProcessPool
  • func NewProcessPool(action string) *ProcessPool
  • func (p *ProcessPool) Close() error
  • func (p *ProcessPool) Progress(ref name.Reference) chan<- v1.Update
  • func (p *ProcessPool) Wait(ctx context.Context)

Functions

func NewProcessReader

func NewProcessReader(r io.ReadCloser, total int64, update chan<- v1.Update) io.ReadCloser

Types

type ProcessPool

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

func NewProcessPool

func NewProcessPool(action string) *ProcessPool

func (*ProcessPool) Close

func (p *ProcessPool) Close() error

func (*ProcessPool) Progress

func (p *ProcessPool) Progress(ref name.Reference) chan<- v1.Update

func (*ProcessPool) Wait

func (p *ProcessPool) Wait(ctx context.Context)