Index | Files

package stats

import ""

Package stats contains an in-memory StatReceiver that only stores sizes of received blobs but not their contents.


Package Files


type Receiver Uses

type Receiver struct {
    sync.Mutex // guards Have
    Have       map[blob.Ref]int64

Receiver is a dummy blobserver.StatReceiver that doesn't store anything; it just collects statistics.

TODO: we have another copy of this same type in pk-put/files.go. move them to a common place? well, the pk-put one is probably going away at some point.

func (*Receiver) EnumerateBlobs Uses

func (sr *Receiver) EnumerateBlobs(ctx context.Context, dest chan<- blob.SizedRef, after string, limit int) error

func (*Receiver) NumBlobs Uses

func (sr *Receiver) NumBlobs() int

func (*Receiver) ReceiveBlob Uses

func (sr *Receiver) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (sb blob.SizedRef, err error)

func (*Receiver) ReceiveRef Uses

func (sr *Receiver) ReceiveRef(br blob.Ref, size int64) (sb blob.SizedRef, err error)

func (*Receiver) RemoveBlobs Uses

func (sr *Receiver) RemoveBlobs(ctx context.Context, blobs []blob.Ref) error

func (*Receiver) Sizes Uses

func (sr *Receiver) Sizes() []int

Sizes returns the sorted blob sizes.

func (*Receiver) StatBlobs Uses

func (sr *Receiver) StatBlobs(ctx context.Context, blobs []blob.Ref, fn func(blob.SizedRef) error) error

func (*Receiver) SumBlobSize Uses

func (sr *Receiver) SumBlobSize() int64

Package stats imports 6 packages (graph) and is imported by 1 packages. Updated 2019-06-19. Refresh now. Tools for package owners.