Versions in this module Expand all Collapse all v0 v0.3.1 Oct 17, 2018 v0.3.0 Oct 12, 2018 Changes in this version + func WithProgress(ctx context.Context, pw Writer) context.Context + 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()) + 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 FromContext(ctx context.Context, opts ...WriterOption) (Writer, bool, context.Context) + type WriterOption func(Writer) + func WithMetadata(key string, val interface{}) WriterOption
Go to main page