progress

package

v1.0.12 Latest Latest Go to latest Published: Jan 21, 2026 License: Apache-2.0, Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/docker/model-runner

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewReader(r io.Reader, updates chan<- oci.Update) io.Reader
func NewReaderWithOffset(r io.Reader, updates chan<- oci.Update, initialOffset int64) io.Reader
func PullMsg(update oci.Update) string
func PushMsg(update oci.Update) string
func WriteError(w io.Writer, message string, mode oci.Mode) error
func WriteProgress(w io.Writer, msg string, imageSize, layerSize, current uint64, layerID string, ...) error
func WriteSuccess(w io.Writer, message string, mode oci.Mode) error
func WriteWarning(w io.Writer, message string, mode oci.Mode) error
type Reader
- func (pr *Reader) Read(p []byte) (int, error)
type Reporter
- func NewProgressReporter(w io.Writer, msgF progressF, imageSize int64, layer oci.Layer, mode oci.Mode) *Reporter
- func (r *Reporter) Updates() chan<- oci.Update
- func (r *Reporter) Wait() error

Constants ¶

View Source

const MinBytesForUpdate = 1024 * 1024 // 1MB

MinBytesForUpdate defines the minimum number of bytes that need to be transferred before sending a progress update

View Source

const UpdateInterval = 100 * time.Millisecond

UpdateInterval defines how often progress updates should be sent

Variables ¶

This section is empty.

Functions ¶

func NewReader ¶

func NewReader(r io.Reader, updates chan<- oci.Update) io.Reader

NewReader returns a reader that reports progress to the given channel while reading.

func NewReaderWithOffset ¶ added in v1.0.4

func NewReaderWithOffset(r io.Reader, updates chan<- oci.Update, initialOffset int64) io.Reader

NewReaderWithOffset returns a reader that reports progress starting from an initial offset. This is useful for resuming interrupted downloads.

func PullMsg ¶

func PullMsg(update oci.Update) string

func PushMsg ¶

func PushMsg(update oci.Update) string

func WriteProgress ¶

func WriteProgress(w io.Writer, msg string, imageSize, layerSize, current uint64, layerID string, mode oci.Mode) error

WriteProgress writes a progress update message

func WriteWarning ¶ added in v1.0.4

func WriteWarning(w io.Writer, message string, mode oci.Mode) error

WriteWarning writes a warning message

Types ¶

type Reader ¶

type Reader struct {
	Reader       io.Reader
	ProgressChan chan<- oci.Update
	Total        int64
}

Reader wraps an io.Reader to track reading progress

func (*Reader) Read ¶

func (pr *Reader) Read(p []byte) (int, error)

type Reporter ¶

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

func NewProgressReporter ¶

func NewProgressReporter(w io.Writer, msgF progressF, imageSize int64, layer oci.Layer, mode oci.Mode) *Reporter

func (*Reporter) Updates ¶

func (r *Reporter) Updates() chan<- oci.Update

Updates returns a channel for receiving progress Updates. It is the responsibility of the caller to close the channel when they are done sending Updates. Should only be called once per Reporter instance.

func (*Reporter) Wait ¶

func (r *Reporter) Wait() error

Wait waits for the progress Reporter to finish and returns any error encountered.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL