trace

Documentation

Overview

Package trace implements the blobserver interface which traces each and every call of the interface by calling the specified functions - then passing the call to the underlying storage.

Index

• type Storage
  • func (sto Storage) Close() error
  • func (sto Storage) EnumerateBlobs(ctx context.Context, dest chan<- blob.SizedRef, after string, limit int) error
  • func (sto Storage) Fetch(ctx context.Context, br blob.Ref) (io.ReadCloser, uint32, error)
  • func (sto Storage) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error)
  • func (sto Storage) RemoveBlobs(ctx context.Context, blobs []blob.Ref) error
  • func (sto Storage) ResetStorageGeneration() error
  • func (sto Storage) StatBlobs(ctx context.Context, blobs []blob.Ref, fn func(blob.SizedRef) error) error
  • func (sto Storage) StorageGeneration() (initTime time.Time, random string, err error)

Types

type Storage

type Storage struct {
	Storage                                           blobserver.Storage
	OnFetch, OnRemove, OnStat, OnEnumerate, OnReceive func([]blob.SizedRef, error)
}

func (Storage) Close

func (sto Storage) Close() error

func (Storage) EnumerateBlobs

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

func (Storage) Fetch

func (sto Storage) Fetch(ctx context.Context, br blob.Ref) (io.ReadCloser, uint32, error)

func (Storage) ReceiveBlob

func (sto Storage) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error)

func (Storage) RemoveBlobs

func (sto Storage) RemoveBlobs(ctx context.Context, blobs []blob.Ref) error

func (Storage) ResetStorageGeneration

func (sto Storage) ResetStorageGeneration() error

func (Storage) StatBlobs

func (sto Storage) StatBlobs(ctx context.Context, blobs []blob.Ref, fn func(blob.SizedRef) error) error

func (Storage) StorageGeneration

func (sto Storage) StorageGeneration() (initTime time.Time, random string, err error)