Set sets a new entry or updates an existing one. Set adds or updates an entry in the SyncMap with the specified key. If the key already exists in the

Get retrieves the value associated with the given key from the SyncMap. It returns the value and a boolean indicating whether the key was found.

Close closes the router.

newRandomStringN creates a new random string of length n.

NewFilesStore creates a new store.

Log returns the logger with context for this reader.

Size gets the size of the file.

Fstat returns the size of the file.

NewReader creates a new remote reader.

Read reads up to len(p) bytes into p. It returns the number of bytes read (0 <= n <= len(p)) and any error encountered.

newItem creates a new cache item that is ready to be filled.

FromContext creates a new context from the given gin context.

ID implements host.Host.

New creates a new network interface for communicating with peers.

Fetchfile gets the content of a file from the given offset using a remote reader.

Leader gets the address of the elected leader.

NewPromMetrics creates a new instance of promMetrics.

NewSyncMap creates a new SyncMap with the specified maximum number of entries. If the maximum number of entries is less than or equal to 0, it will be

WithContext returns a new context with a metrics recorder.

Addrs implements host.Host.

Eventf implements record.EventRecorder.

FromContext returns the event recorder from the context.

GetOrCreate gets the cached value if available, otherwise downloads the file.

Handle handles a request for a file.

NewCache creates a new cache of files. cacheBlockSize is the fixed size of the cache block in bytes, and is used to evaluate the cost of each item in

PreadRemote is like pread but to a remote file.

ReadAt reads len(p) bytes from the File starting at byte offset off. It returns the number of bytes read and the error, if any.

Seek sets the current file offset.

doP2p tries to resolve the key in the p2p network and if successful, it will perform the operation on the peer, and return the result.

transportFor returns a single use transport for outbound connection to the given peer. The peer is expected to provide a valid certificate. If pid is

AlignDown will align down the x by align. For example: AlignDown(1, 2) = 0 AlignDown(29, 14) = 28

Copy creates a copy of the context that can be safely used outside the request's scope.

1 Mib FileChunkKey returns the p2p lookup key for the given chunk of a file.

FstatRemote stats a remote file.

Min64 returns the smaller of x or y.

New build a new LeaderElection instance with the given name.

New creates a new files handler.

NewMockReader creates a new mock reader for testing purposes.

NewRecorder creates a new event recorder.

NewSegments creates a new Segments object.

PutSize sets size of the file.

RecordUpstreamResponse records the time it takes for an upstream to respond for a key.

createContentId creates a deterministic content id from the given key.

All provides a channel of all segments.

FillCorrelationId fills the correlation ID in the context.

FromContext returns the metrics recorder from the context.

HTTPClientFor returns an HTTP client which authenticates the given peer. If pid is empty, the client should work for any peer.

Server creates a new HTTP server.

ID returns the peer ID of this host.

IsRequestFromAPeer indicates if the current request is from a peer.

Min returns the smaller of x or y.

Net returns the network interface.

Open opens the requested file and starts prefetching it. It also returns the size of the file.

Provide advertises content availability to the DHT network. Runs in a blocking loop, listening for blob identifiers on filesChan and advertising them

RecordPeerDiscovery records the time it takes to discover a peer.

RecordPeerResponse records the time it takes for a peer to respond for a key.

RecordRequest records the time it takes to process a request.

fill files the file with the given data.

getPodNamespace returns the namespace in which the pod is running or the default namespace. Ref: https://kubernetes.io/docs/tasks/run-application/acce

newEngine creates a new gin engine.

onNewLeader is called when a new leader is elected. It updates the leaderElection instance with the new leader's identity.

parseDigestFromAzureUrl parses the digest from the given blob url or returns an error.

writeAll writes the file.

DefaultTLSConfig creates a default TLS config. This config should not require client certificate verification.

Delete removes the entry with the specified key from the SyncMap. If the key does not exist, this method does nothing.

Exists checks if the given chunk of the file is already cached.

Key tries to find the cache key for the requested content or returns empty.

Len returns the length of the slice

Less returns true if the element at index i is greater than the element at index j

Log returns the logger with context for this reader.

Logger gets the logger with request specific fields.

Max64 returns the larger of x or y.

New returns a new Parser.

NewKubernetesInterface creates a new interface for k8s API server. The current runtime environment is first assumed to be a pod and its identity is us

ParseDigest parses the digest from the given URL. If none found, implementations should return an error.

PercentilesFloat64Reverse calculates the percentile of a slice of floats in reverse order. NOTE: The unit of each value of xs is 'bits' and the result

PrivKey generates a new private key for the given peer.

Provide provides the given keys to the network. This lets the k-closest peers to the key know that we are providing it.

RandomizedGroups groups the given collection randomly into groups of size n

Resolve resolves the given key to a peer address.

RoundTripperFor returns an HTTP round tripper which authenticates the given peer. If pid is empty, the round tripper should work for any peer.

RunOrDie runs the leader election.

Subscribe returns a channel that will be notified when a blob is added to the store.

WithContext returns a new context with an event recorder.

benchmark runs the benchmark and returns the measured download speeds.

bytes returns the file bytes.

drop deletes the underlying file.

fill fills the context with handler specific information.

fstatRemote stats the file.

leaderElectionConfig creates a new configuration for the leader election.

newHost creates a new Host from the given address.

newRandomString creates a new random string.

newRandomStringN creates a new random string of length n.

originRequest will create a new request to origin.