hit_tracker

package

v1.4.0 Latest Latest Go to latest Published: Nov 12, 2020 License: MIT Imports: 15 Imported by: 4

Details

View Source

const (
	Hit counterType = iota
	Miss
	Upload

	DownloadSizeBytes
	UploadSizeBytes

	DownloadUsec
	UploadUsec

	CachedActionExecUsec
)

This section is empty.

func CollectCacheStats(ctx context.Context, env environment.Env, iid string) *capb.CacheStats

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

func NewHitTracker(ctx context.Context, env environment.Env, remoteInstanceName string) *HitTracker

func (h *HitTracker) TrackACDownload(d *repb.Digest) *actionTimer

Example Usage:

ht := NewHitTracker(ctx, env, instanceName) dlt := ht.TrackACDownload(d) defer dlt.Close(actionResult) ... body of download logic ...

func (h *HitTracker) TrackACUpload(d *repb.Digest) *actionTimer

Example Usage:

ht := NewHitTracker(ctx, env, instanceName) ult := ht.TrackACUpload(d) defer ult.Close(actionResult) ... body of download logic ...

func (h *HitTracker) TrackCASDownload(d *repb.Digest) *transferTimer

Example Usage:

ht := NewHitTracker(ctx, env, instanceName) dlt := ht.TrackCASDownload(d) defer dlt.Close() ... body of download logic ...

func (h *HitTracker) TrackCASMiss(d *repb.Digest) error

Example Usage:

ht := NewHitTracker(ctx, env, instanceName)

if err := ht.TrackMiss(); err != nil {
  log.Printf("Error counting cache miss.")
}

func (h *HitTracker) TrackCASUpload(d *repb.Digest) *transferTimer

Example Usage:

ht := NewHitTracker(ctx, env, instanceName) ult := ht.TrackCASUpload(d) defer ult.Close() ... body of download logic ...

func (h *HitTracker) TrackEmptyCASHit() error