cached

type CacheMissReason string

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

type FileBackedRunnerOption func(r *FileBackedRunner)

type FunctionRunner interface {
	// RunFunction runs the named composition function.
	RunFunction(ctx context.Context, name string, req *fnv1.RunFunctionRequest) (*fnv1.RunFunctionResponse, error)
}

type Metrics interface {
	// Hit records a cache hit.
	Hit(name string)

	// Miss records a cache miss.
	Miss(name string)

	// Error records a cache error.
	Error(name string)

	// Write records a cache write.
	Write(name string)

	// Delete records a cache delete, i.e. due to garbage collection.
	Delete(name string)

	// WroteBytes records bytes written to the cache.
	WroteBytes(name string, b int)

	// DeletedBytes records bytes deleted from the cache.
	DeletedBytes(name string, b int)

	// ReadDuration records the time taken by a cache hit.
	ReadDuration(name string, d time.Duration)

	// WriteDuration records the time taken to write to cache.
	WriteDuration(name string, d time.Duration)
}

type NopMetrics struct{}

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