stats

Documentation

Overview

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

Index

• type Receiver
  • func (sr *Receiver) EnumerateBlobs(ctx context.Context, dest chan<- blob.SizedRef, after string, limit int) error
  • func (sr *Receiver) NumBlobs() int
  • func (sr *Receiver) ReceiveBlob(br blob.Ref, source io.Reader) (sb blob.SizedRef, err error)
  • func (sr *Receiver) ReceiveRef(br blob.Ref, size int64) (sb blob.SizedRef, err error)
  • func (sr *Receiver) RemoveBlobs(blobs []blob.Ref) error
  • func (sr *Receiver) Sizes() []int
  • func (sr *Receiver) StatBlobs(dest chan<- blob.SizedRef, blobs []blob.Ref) error
  • func (sr *Receiver) SumBlobSize() int64

Types

type Receiver

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 camput/files.go. move them to a common place? well, the camput one is probably going away at some point.

func (*Receiver) EnumerateBlobs

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

func (*Receiver) NumBlobs

func (sr *Receiver) NumBlobs() int

func (*Receiver) ReceiveBlob

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

func (*Receiver) ReceiveRef

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

func (*Receiver) RemoveBlobs

func (sr *Receiver) RemoveBlobs(blobs []blob.Ref) error

func (*Receiver) Sizes

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

Sizes returns the sorted blob sizes.

func (*Receiver) StatBlobs

func (sr *Receiver) StatBlobs(dest chan<- blob.SizedRef, blobs []blob.Ref) error

func (*Receiver) SumBlobSize

func (sr *Receiver) SumBlobSize() int64