MCPcopy Create free account

hub / github.com/Azure/peerd / functions

Functions350 in github.com/Azure/peerd

↓ 2 callersMethodpreadRemote
preadRemote reads the file.
pkg/discovery/content/reader/reader.go:227
↓ 2 callersFunctionreadFromStart
readFromStart reads the entire file from the beginning.
pkg/cache/item.go:69
↓ 2 callersFunctionregisterRoutes
registerRoutes registers the routes for the HTTP server.
pkg/handlers/root.go:74
↓ 2 callersMethodremoteRequest
remoteRequest creates a new HTTP request to a remote server.
pkg/discovery/content/reader/reader.go:269
↓ 2 callersFunctionrun
(ctx context.Context, args *Arguments)
cmd/proxy/main.go:61
↓ 2 callersFunctionserverCommand
(ctx context.Context, args *ServerCmd)
cmd/proxy/main.go:76
↓ 1 callersMethodActive
Active should be called to indicate that the node is active in the cluster.
pkg/k8s/events/interface.go:14
↓ 1 callersMethodActive
Active should be called to indicate that the instance is active in the cluster.
pkg/k8s/events/events.go:87
↓ 1 callersFunctionBlobUrl
BlobUrl extracts the blob URL from the incoming request URL.
pkg/context/context.go:109
↓ 1 callersMethodClose
()
pkg/discovery/routing/mocks/router.go:53
↓ 1 callersMethodConnected
Connected should be called to indicate that the node is connected to the cluster.
pkg/k8s/events/interface.go:11
↓ 1 callersMethodConnected
Connected should be called to indicate that the instance is connected to the cluster.
pkg/k8s/events/events.go:92
↓ 1 callersMethodDisconnected
Disconnected should be called to indicate that the node is disconnected from the cluster.
pkg/k8s/events/interface.go:17
↓ 1 callersMethodDisconnected
Disconnected should be called to indicate that the instance is disconnected from the cluster.
pkg/k8s/events/events.go:97
↓ 1 callersMethodFailed
Failed should be called to indicate that the node has failed.
pkg/k8s/events/interface.go:20
↓ 1 callersMethodFailed
Failed should be called to indicate that the instance has failed.
pkg/k8s/events/events.go:102
↓ 1 callersMethodFindProvidersAsync
FindProvidersAsync implements routing.ContentRouting.
pkg/discovery/routing/router_test.go:219
↓ 1 callersMethodInitializing
Initializing should be called to indicate that the node is initializing.
pkg/k8s/events/interface.go:8
↓ 1 callersMethodInitializing
Initializing should be called to indicate that the instance is initializing.
pkg/k8s/events/events.go:107
↓ 1 callersMethodLookupKey
(key string)
pkg/discovery/routing/mocks/router.go:86
↓ 1 callersMethodNet
Net implements routing.Router.
pkg/discovery/routing/mocks/router.go:24
↓ 1 callersFunctionNewRouter
NewRouter creates a new Router.
pkg/discovery/routing/router.go:71
↓ 1 callersMethodPeerstore
Peerstore returns the mocked peerstore of this host.
pkg/peernet/mocks/host.go:63
↓ 1 callersMethodProvide
Provide advertises the given keys to the network.
pkg/discovery/routing/router.go:217
↓ 1 callersMethodProvide
(ctx context.Context, keys []string)
pkg/discovery/routing/mocks/router.go:77
↓ 1 callersFunctionRandom
(ctx context.Context, secrets string, n int, proxyHost string)
tests/random/random.go:33
↓ 1 callersFunctionRangeStartIndex
RangeStartIndex returns the start index of a byte range specified in the given range header value. It expects the range value to be in the format "byt
pkg/context/context.go:115
↓ 1 callersMethodReadAt
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.
pkg/files/store/interface.go:37
↓ 1 callersMethodResolveWithNegativeCacheCallback
ResolveWithNegativeCacheCallback is like Resolve but it also returns a function callback that can be used to cache that a key could not be resolved.
pkg/discovery/routing/router.go:159
↓ 1 callersMethodResolveWithNegativeCacheCallback
ResolveWithNegativeCacheCallback is like Resolve but it also returns a function callback that can be used to cache that a key could not be resolved.
pkg/discovery/routing/interface.go:21
↓ 1 callersMethodResolveWithNegativeCacheCallback
ResolveWithNegativeCacheCallback implements Router.
pkg/discovery/routing/mocks/router.go:29
↓ 1 callersFunctionScanner
(ctx context.Context)
tests/scanner/scanner.go:28
↓ 1 callersFunctionSetOutboundHeaders
SetOutboundHeaders sets the mandatory headers for all outbound requests.
pkg/context/context.go:87
↓ 1 callersMethodSwap
Swap swaps the elements at indexes i and j
tests/random/math/reverse.go:24
↓ 1 callersFunctiondelay
(l *zerolog.Logger)
tests/random/random.go:267
↓ 1 callersFunctiondownloadSASURL
downloadSASURL downloads a SAS URL and returns the number of bytes downloaded.
tests/random/random.go:189
↓ 1 callersFunctiondownloadSASURLs
downloadSASURLs downloads the SAS URLs in a group and measures the download speed
tests/random/random.go:138
↓ 1 callersFunctiongetP2pSasUrls
getP2pSasUrls returns the SAS URLs for the p2p network
tests/random/random.go:129
↓ 1 callersFunctionmeasure
(bar *progressbar.ProgressBar, startTime time.Time, l *zerolog.Logger, byteThroughputHist *prometheus.Histogra
tests/scanner/scanner.go:86
↓ 1 callersFunctionnewRandomStringN
newRandomStringN creates a new random string of length n.
pkg/files/store/main_test.go:50
↓ 1 callersMethodpeerRequest
perRequest will create a new request to a peer.
pkg/discovery/content/reader/reader.go:264
↓ 1 callersMethodprefetch
prefetch tries to prefetch the specified parts of the file in chunks of cacheBlockSize. It can silently fail.
pkg/files/store/file.go:38
↓ 1 callersMethodprefetch
prefetch prefetches files.
pkg/files/store/store.go:149
↓ 1 callersFunctionrandomBytesN
(n int)
pkg/files/store/file_test.go:227
↓ 1 callersFunctionrun
(ctx context.Context, args *Arguments)
tests/cmd/main.go:36
↓ 1 callersFunctionsetup
()
pkg/cache/main_test.go:25
↓ 1 callersFunctionsetup
()
pkg/files/store/main_test.go:31
↓ 1 callersFunctionsetup
()
pkg/handlers/files/main_test.go:24
↓ 1 callersFunctionsleep
sleep generates a random sleep duration between 3 and 25 milliseconds and pauses the execution for that duration.
tests/random/random.go:260
↓ 1 callersFunctionsleep
(l *zerolog.Logger)
tests/scanner/scanner.go:104
↓ 1 callersFunctionteardown
teardown removes the cache directory.
pkg/cache/main_test.go:36
↓ 1 callersFunctionteardown
teardown removes the cache directory.
pkg/files/store/main_test.go:41
↓ 1 callersFunctionteardown
teardown removes the cache directory.
pkg/handlers/files/main_test.go:34
↓ 1 callersFunctionwaitForSet
()
pkg/cache/filecache.go:146
MethodAddAddr
(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)
pkg/peernet/mocks/peerstore.go:21
MethodAddAddrs
(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)
pkg/peernet/mocks/peerstore.go:25
MethodAddPrivKey
(peer.ID, crypto.PrivKey)
pkg/peernet/mocks/peerstore.go:29
MethodAddProtocols
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:33
MethodAddPubKey
(peer.ID, crypto.PubKey)
pkg/peernet/mocks/peerstore.go:37
MethodAddrStream
(context.Context, peer.ID)
pkg/peernet/mocks/peerstore.go:41
MethodAddrs
(p peer.ID)
pkg/peernet/mocks/peerstore.go:45
MethodAddrs
()
pkg/peernet/mocks/host.go:25
MethodAnnotatedEventf
AnnotatedEventf implements record.EventRecorder.
pkg/k8s/events/events_test.go:167
FunctionBenchmarkParseDigestFromAzureUrl
(b *testing.B)
pkg/urlparser/azure_test.go:78
FunctionBenchmarkSyncMap
(b *testing.B)
pkg/cache/syncmap_test.go:105
MethodClearAddrs
(p peer.ID)
pkg/peernet/mocks/peerstore.go:49
MethodClose
()
pkg/peernet/mocks/peerstore.go:53
MethodClose
()
pkg/peernet/mocks/host.go:29
MethodClose
Close closes the router.
pkg/discovery/routing/router.go:154
MethodClose
Close implements host.Host.
pkg/discovery/routing/router_test.go:250
MethodConnManager
()
pkg/peernet/mocks/host.go:33
MethodConnManager
ConnManager implements host.Host.
pkg/discovery/routing/router_test.go:255
MethodConnect
(ctx context.Context, pi peer.AddrInfo)
pkg/peernet/mocks/host.go:37
MethodConnect
Connect implements host.Host.
pkg/discovery/routing/router_test.go:260
MethodDefaultTLSConfig
DefaultTLSConfig creates a TLS config to use for this server. This config does not require client certificate verification and is reusable.
pkg/peernet/network.go:52
MethodEvent
Event implements record.EventRecorder.
pkg/k8s/events/events_test.go:172
MethodEventBus
()
pkg/peernet/mocks/host.go:41
MethodEventBus
EventBus implements host.Host.
pkg/discovery/routing/router_test.go:265
MethodExists
Exists checks if the file exists in the cache.
pkg/cache/filecache.go:32
MethodFirstSupportedProtocol
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:57
MethodFstat
Fstat returns the size of the file.
pkg/files/store/interface.go:31
MethodFstatRemote
FstatRemote implements remote.Reader.
pkg/files/files_test.go:67
MethodFstatRemote
FstatRemote stats a remote file.
pkg/discovery/content/reader/reader.go:79
MethodFstatRemote
FstatRemote implements remote.Reader.
pkg/discovery/content/reader/mocks/reader.go:19
MethodGet
(p peer.ID, key string)
pkg/peernet/mocks/peerstore.go:61
MethodGetOrCreate
GetOrCreate gets the cached value if available, otherwise fetches it.
pkg/cache/filecache.go:50
MethodGetProtocols
(peer.ID)
pkg/peernet/mocks/peerstore.go:65
MethodHTTPClientFor
HTTPClientFor returns a single use HTTP client for the given peer. The client does not verify the peer's certificate.
pkg/peernet/network.go:58
MethodKey
Key tries to find the cache key for the requested content or returns empty.
pkg/files/store/store.go:126
MethodLatencyEWMA
(peer.ID)
pkg/peernet/mocks/peerstore.go:69
MethodLeader
Leader gets the address of the elected leader.
pkg/k8s/election/election.go:45
MethodLog
Log implements remote.Reader.
pkg/files/files_test.go:72
MethodLog
Log implements remote.Reader.
pkg/discovery/content/reader/mocks/reader.go:24
MethodMux
()
pkg/peernet/mocks/host.go:50
MethodMux
Mux implements host.Host.
pkg/discovery/routing/router_test.go:275
MethodNet
Transport returns the transport.
pkg/discovery/routing/router.go:149
MethodNetwork
()
pkg/peernet/mocks/host.go:54
MethodNetwork
Network implements host.Host.
pkg/discovery/routing/router_test.go:280
MethodNewStream
(ctx context.Context, p peer.ID, pids ...protocol.ID)
pkg/peernet/mocks/host.go:58
MethodNewStream
NewStream implements host.Host.
pkg/discovery/routing/router_test.go:285
← previousnext →101–200 of 350, ranked by callers