Versions in this module Expand all Collapse all v0 v0.19.3 Oct 23, 2025 v0.19.0 Sep 30, 2025 Changes in this version + func OneOff(ctx context.Context, id string) func(err error) error + func WithProgress(ctx context.Context, pw Writer) context.Context + type Controller interface + Start func(context.Context) (context.Context, func(error)) + Status func(id string, action string) func() + type MultiReader struct + func NewMultiReader(pr Reader) *MultiReader + func (mr *MultiReader) Reader(ctx context.Context) Reader + type MultiWriter struct + func NewMultiWriter(opts ...WriterOption) *MultiWriter + func (ps *MultiWriter) Add(pw Writer) + func (ps *MultiWriter) Close() error + func (ps *MultiWriter) Delete(pw Writer) + func (ps *MultiWriter) Write(id string, v interface{}) error + func (ps *MultiWriter) WriteRawProgress(p *Progress) error + type Progress struct + ID string + Sys interface{} + Timestamp time.Time + func (p *Progress) Meta(key string) (interface{}, bool) + type Reader interface + Read func(context.Context) ([]*Progress, error) + func NewContext(ctx context.Context) (Reader, context.Context, func(error)) + type Status struct + Action string + Completed *time.Time + Current int + Started *time.Time + Total int + type Writer interface + Close func() error + Write func(id string, value interface{}) error + func NewFromContext(ctx context.Context, opts ...WriterOption) (Writer, bool, context.Context) + type WriterFactory func(ctx context.Context) (Writer, bool, context.Context) + func FromContext(ctx context.Context, opts ...WriterOption) WriterFactory + type WriterOption func(Writer) + func WithMetadata(key string, val interface{}) WriterOption
Go to main page