Struct MemcacheFileStore

file_store/memcache/memcache.go:520–554

Keep all the writers in memory.

// Keep all the writers in memory.
type MemcacheFileStore struct {
	// Total number of bytes in flight right now. If this gets too
	// large we start turning writes to be synchronous to push back
	// against writers and protect our memory usage.
	total_cached_bytes int64

	mu sync.Mutex

	// For debugging.
	id         uint64
	ctx        context.Context
	config_obj *config_proto.Config
	wg         *sync.WaitGroup

	// The delegate will be used to actually read the data.
	delegate    api.FileStore
	concurrency *utils.Concurrency

	// Keep the writers in memory - they will be reaped by the reaper thread
	data_cache map[string]*MemcacheFileWriter

	// Minimum time between write and flush - this ensures quick
	// successive writes are merged into larger ones.
	min_age time.Duration

	// Maximum time a closed writer will be kept in memory.
	max_age time.Duration

	closed bool

	// Pool of flusher workers
	pool pond.Pool

	target_memory_use int64
}

func NewMemcacheFileStore(
	ctx context.Context,