MCPcopy Create free account

hub / github.com/Azure/peerd / functions

Functions350 in github.com/Azure/peerd

MethodOpen
Open opens the requested file and starts prefetching it.
pkg/files/store/store.go:86
MethodParseDigest
ParseDigest parses the digest from the given URL. If none found, returns an error.
pkg/urlparser/parser.go:23
MethodPeerInfo
(peer.ID)
pkg/peernet/mocks/peerstore.go:73
MethodPeers
()
pkg/peernet/mocks/peerstore.go:77
MethodPeersWithAddrs
()
pkg/peernet/mocks/peerstore.go:81
MethodPeersWithKeys
()
pkg/peernet/mocks/peerstore.go:85
MethodPeerstore
Peerstore implements host.Host.
pkg/discovery/routing/router_test.go:290
MethodPreadRemote
PreadRemote implements remote.Reader.
pkg/files/files_test.go:78
MethodPreadRemote
PreadRemote is like pread but to a remote file.
pkg/discovery/content/reader/reader.go:51
MethodPreadRemote
PreadRemote implements remote.Reader.
pkg/discovery/content/reader/mocks/reader.go:29
MethodProvide
Provide implements routing.ContentRouting.
pkg/discovery/routing/router_test.go:230
MethodPubKey
(peer.ID)
pkg/peernet/mocks/peerstore.go:99
MethodPut
(p peer.ID, key string, val interface{})
pkg/peernet/mocks/peerstore.go:103
MethodPutSize
PutSize puts the length of the file.
pkg/cache/filecache.go:135
MethodRead
Read reads up to len(p) bytes into p. It returns the number of bytes read (0 <= n <= len(p)) and any error encountered.
pkg/files/store/file.go:103
MethodRecordLatency
(peer.ID, time.Duration)
pkg/peernet/mocks/peerstore.go:107
MethodRecordPeerDiscovery
RecordPeerDiscovery records the duration of peer discovery for a given IP address.
pkg/metrics/prometheus.go:22
MethodRecordPeerResponse
RecordPeerResponse records the response time and count of a peer's operation. It calculates the speed (count/duration) and updates the Prometheus metr
pkg/metrics/prometheus.go:28
MethodRecordRequest
RecordRequest records the duration of a request for a specific method and handler. It updates the Prometheus metric for request duration.
pkg/metrics/prometheus.go:35
MethodRecordUpstreamResponse
RecordUpstreamResponse records the duration and count of an upstream response. It calculates the speed of the response and updates the corresponding P
pkg/metrics/prometheus.go:41
MethodRemovePeer
(peer.ID)
pkg/peernet/mocks/peerstore.go:111
MethodRemoveProtocols
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:115
MethodRemoveStreamHandler
(pid protocol.ID)
pkg/peernet/mocks/host.go:67
MethodRemoveStreamHandler
RemoveStreamHandler implements host.Host.
pkg/discovery/routing/router_test.go:295
MethodResolve
Resolve resolves the given key to a peer address.
pkg/discovery/routing/interface.go:18
MethodRoundTripperFor
RoundTripperFor returns a single use round tripper for the given peer. The peer is expected to provide a valid certificate. If pid is empty, the round
pkg/peernet/network.go:72
MethodRunOrDie
RunOrDie runs the leader election.
pkg/k8s/election/election.go:58
MethodSeek
Seek sets the current file offset.
pkg/files/store/interface.go:28
MethodSetAddr
(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)
pkg/peernet/mocks/peerstore.go:119
MethodSetAddrs
(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)
pkg/peernet/mocks/peerstore.go:123
MethodSetProtocols
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:127
MethodSetStreamHandler
(pid protocol.ID, handler network.StreamHandler)
pkg/peernet/mocks/host.go:71
MethodSetStreamHandler
SetStreamHandler implements host.Host.
pkg/discovery/routing/router_test.go:300
MethodSetStreamHandlerMatch
(protocol.ID, func(protocol.ID) bool, network.StreamHandler)
pkg/peernet/mocks/host.go:75
MethodSetStreamHandlerMatch
SetStreamHandlerMatch implements host.Host.
pkg/discovery/routing/router_test.go:305
MethodSize
Size gets the length of the file.
pkg/cache/filecache.go:124
MethodSubscribe
Subscribe returns a channel that will be notified when a blob is added to the store.
pkg/files/store/store.go:81
MethodSupportsProtocols
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:131
FunctionTestAlignDown
(t *testing.T)
pkg/math/segments_test.go:14
FunctionTestAll
(t *testing.T)
pkg/math/segments_test.go:74
FunctionTestBlobRoutesRegistered
(t *testing.T)
pkg/handlers/root_test.go:53
FunctionTestBlobUrl
(t *testing.T)
pkg/context/context_test.go:76
FunctionTestBytes
(t *testing.T)
pkg/cache/item_test.go:154
FunctionTestClose
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:95
FunctionTestContextCop
(t *testing.T)
pkg/context/context_test.go:219
FunctionTestDefaultTLSConfig
(t *testing.T)
pkg/peernet/network_test.go:22
FunctionTestDrop
(t *testing.T)
pkg/cache/item_test.go:191
FunctionTestEmptyConfigOutsidePod
(t *testing.T)
pkg/k8s/k8s_test.go:10
FunctionTestExists
(t *testing.T)
pkg/cache/filecache_test.go:36
FunctionTestExpectedEvents
(t *testing.T)
pkg/k8s/events/events_test.go:125
FunctionTestFetchFile
(t *testing.T)
pkg/files/files_test.go:31
FunctionTestFileChunkKey
(t *testing.T)
pkg/files/files_test.go:15
FunctionTestFill
(t *testing.T)
pkg/cache/item_test.go:118
FunctionTestFill
(t *testing.T)
pkg/handlers/files/handler_test.go:117
FunctionTestFillCorrelationId
(t *testing.T)
pkg/context/context_test.go:99
FunctionTestFillInvalidFetch
(t *testing.T)
pkg/cache/item_test.go:95
FunctionTestFromContext
(t *testing.T)
pkg/k8s/events/events_test.go:143
FunctionTestFromContext
(t *testing.T)
pkg/metrics/interface_test.go:30
FunctionTestFstat
(t *testing.T)
pkg/files/store/file_test.go:188
FunctionTestFstatRemote
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:98
FunctionTestFstatRemote
(t *testing.T)
pkg/discovery/content/reader/mocks/reader_test.go:21
FunctionTestFstatRemotePartialContent
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:141
FunctionTestGetKey
(t *testing.T)
pkg/cache/filecache_test.go:25
FunctionTestGetOrCreate
(t *testing.T)
pkg/cache/filecache_test.go:154
FunctionTestGetPodNamespace
(t *testing.T)
pkg/k8s/k8s_test.go:17
FunctionTestHTTPClientFor
(t *testing.T)
pkg/peernet/network_test.go:91
FunctionTestHandler
(t *testing.T)
pkg/handlers/root_test.go:36
FunctionTestID
(t *testing.T)
pkg/peernet/mocks/host_test.go:5
FunctionTestIsRequestFromPeer
(t *testing.T)
pkg/context/context_test.go:134
FunctionTestKey
(t *testing.T)
pkg/files/store/store_test.go:90
FunctionTestLeader
(t *testing.T)
pkg/k8s/election/election_test.go:14
FunctionTestLeaderElectionConfig
(t *testing.T)
pkg/k8s/election/election_test.go:89
FunctionTestLen
(t *testing.T)
tests/random/math/reverse_test.go:23
FunctionTestLess
(t *testing.T)
tests/random/math/reverse_test.go:33
FunctionTestLog
(t *testing.T)
pkg/discovery/content/reader/mocks/reader_test.go:13
FunctionTestLogger
(t *testing.T)
pkg/context/context_test.go:22
FunctionTestLoggingConfiguration
(t *testing.T)
cmd/proxy/main_test.go:108
FunctionTestLookupKey
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:81
FunctionTestMain
(m *testing.M)
pkg/cache/main_test.go:15
FunctionTestMain
(m *testing.M)
pkg/files/store/main_test.go:21
FunctionTestMain
(m *testing.M)
pkg/handlers/files/main_test.go:14
FunctionTestMax64
(t *testing.T)
pkg/math/compare_test.go:7
FunctionTestMin
(t *testing.T)
pkg/math/compare_test.go:43
FunctionTestMin64
(t *testing.T)
pkg/math/compare_test.go:25
FunctionTestNet
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:16
FunctionTestNew
(t *testing.T)
pkg/peernet/network_test.go:13
FunctionTestNewEngine
(t *testing.T)
pkg/handlers/root_test.go:21
FunctionTestNewHost
(t *testing.T)
pkg/discovery/routing/router_test.go:163
FunctionTestNewMockReader
(t *testing.T)
pkg/discovery/content/reader/mocks/reader_test.go:5
FunctionTestNewMockRouter
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:9
FunctionTestNewRecorderInNode
(t *testing.T)
pkg/k8s/events/events_test.go:51
FunctionTestNewRecorderInPod
(t *testing.T)
pkg/k8s/events/events_test.go:86
FunctionTestNewSegments
(t *testing.T)
pkg/math/segments_test.go:7
FunctionTestNotFoundInP2PMode
(t *testing.T)
pkg/handlers/files/handler_test.go:84
FunctionTestOpenNonP2p
(t *testing.T)
pkg/files/store/store_test.go:57
FunctionTestOpenP2p
(t *testing.T)
pkg/files/store/store_test.go:25
FunctionTestP2pNoInfiniteLoops
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:295
FunctionTestP2pPeerNotFound
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:269
FunctionTestP2pRetries
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:187
FunctionTestP2pSuccess
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:232
← previousnext →201–300 of 350, ranked by callers