Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Azure/peerd
/ functions
Functions
350 in github.com/Azure/peerd
⨍
Functions
350
◇
Types & classes
50
Method
Open
Open opens the requested file and starts prefetching it.
pkg/files/store/store.go:86
Method
ParseDigest
ParseDigest parses the digest from the given URL. If none found, returns an error.
pkg/urlparser/parser.go:23
Method
PeerInfo
(peer.ID)
pkg/peernet/mocks/peerstore.go:73
Method
Peers
()
pkg/peernet/mocks/peerstore.go:77
Method
PeersWithAddrs
()
pkg/peernet/mocks/peerstore.go:81
Method
PeersWithKeys
()
pkg/peernet/mocks/peerstore.go:85
Method
Peerstore
Peerstore implements host.Host.
pkg/discovery/routing/router_test.go:290
Method
PreadRemote
PreadRemote implements remote.Reader.
pkg/files/files_test.go:78
Method
PreadRemote
PreadRemote is like pread but to a remote file.
pkg/discovery/content/reader/reader.go:51
Method
PreadRemote
PreadRemote implements remote.Reader.
pkg/discovery/content/reader/mocks/reader.go:29
Method
Provide
Provide implements routing.ContentRouting.
pkg/discovery/routing/router_test.go:230
Method
PubKey
(peer.ID)
pkg/peernet/mocks/peerstore.go:99
Method
Put
(p peer.ID, key string, val interface{})
pkg/peernet/mocks/peerstore.go:103
Method
PutSize
PutSize puts the length of the file.
pkg/cache/filecache.go:135
Method
Read
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
Method
RecordLatency
(peer.ID, time.Duration)
pkg/peernet/mocks/peerstore.go:107
Method
RecordPeerDiscovery
RecordPeerDiscovery records the duration of peer discovery for a given IP address.
pkg/metrics/prometheus.go:22
Method
RecordPeerResponse
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
Method
RecordRequest
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
Method
RecordUpstreamResponse
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
Method
RemovePeer
(peer.ID)
pkg/peernet/mocks/peerstore.go:111
Method
RemoveProtocols
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:115
Method
RemoveStreamHandler
(pid protocol.ID)
pkg/peernet/mocks/host.go:67
Method
RemoveStreamHandler
RemoveStreamHandler implements host.Host.
pkg/discovery/routing/router_test.go:295
Method
Resolve
Resolve resolves the given key to a peer address.
pkg/discovery/routing/interface.go:18
Method
RoundTripperFor
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
Method
RunOrDie
RunOrDie runs the leader election.
pkg/k8s/election/election.go:58
Method
Seek
Seek sets the current file offset.
pkg/files/store/interface.go:28
Method
SetAddr
(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)
pkg/peernet/mocks/peerstore.go:119
Method
SetAddrs
(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)
pkg/peernet/mocks/peerstore.go:123
Method
SetProtocols
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:127
Method
SetStreamHandler
(pid protocol.ID, handler network.StreamHandler)
pkg/peernet/mocks/host.go:71
Method
SetStreamHandler
SetStreamHandler implements host.Host.
pkg/discovery/routing/router_test.go:300
Method
SetStreamHandlerMatch
(protocol.ID, func(protocol.ID) bool, network.StreamHandler)
pkg/peernet/mocks/host.go:75
Method
SetStreamHandlerMatch
SetStreamHandlerMatch implements host.Host.
pkg/discovery/routing/router_test.go:305
Method
Size
Size gets the length of the file.
pkg/cache/filecache.go:124
Method
Subscribe
Subscribe returns a channel that will be notified when a blob is added to the store.
pkg/files/store/store.go:81
Method
SupportsProtocols
(peer.ID, ...protocol.ID)
pkg/peernet/mocks/peerstore.go:131
Function
TestAlignDown
(t *testing.T)
pkg/math/segments_test.go:14
Function
TestAll
(t *testing.T)
pkg/math/segments_test.go:74
Function
TestBlobRoutesRegistered
(t *testing.T)
pkg/handlers/root_test.go:53
Function
TestBlobUrl
(t *testing.T)
pkg/context/context_test.go:76
Function
TestBytes
(t *testing.T)
pkg/cache/item_test.go:154
Function
TestClose
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:95
Function
TestContextCop
(t *testing.T)
pkg/context/context_test.go:219
Function
TestDefaultTLSConfig
(t *testing.T)
pkg/peernet/network_test.go:22
Function
TestDrop
(t *testing.T)
pkg/cache/item_test.go:191
Function
TestEmptyConfigOutsidePod
(t *testing.T)
pkg/k8s/k8s_test.go:10
Function
TestExists
(t *testing.T)
pkg/cache/filecache_test.go:36
Function
TestExpectedEvents
(t *testing.T)
pkg/k8s/events/events_test.go:125
Function
TestFetchFile
(t *testing.T)
pkg/files/files_test.go:31
Function
TestFileChunkKey
(t *testing.T)
pkg/files/files_test.go:15
Function
TestFill
(t *testing.T)
pkg/cache/item_test.go:118
Function
TestFill
(t *testing.T)
pkg/handlers/files/handler_test.go:117
Function
TestFillCorrelationId
(t *testing.T)
pkg/context/context_test.go:99
Function
TestFillInvalidFetch
(t *testing.T)
pkg/cache/item_test.go:95
Function
TestFromContext
(t *testing.T)
pkg/k8s/events/events_test.go:143
Function
TestFromContext
(t *testing.T)
pkg/metrics/interface_test.go:30
Function
TestFstat
(t *testing.T)
pkg/files/store/file_test.go:188
Function
TestFstatRemote
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:98
Function
TestFstatRemote
(t *testing.T)
pkg/discovery/content/reader/mocks/reader_test.go:21
Function
TestFstatRemotePartialContent
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:141
Function
TestGetKey
(t *testing.T)
pkg/cache/filecache_test.go:25
Function
TestGetOrCreate
(t *testing.T)
pkg/cache/filecache_test.go:154
Function
TestGetPodNamespace
(t *testing.T)
pkg/k8s/k8s_test.go:17
Function
TestHTTPClientFor
(t *testing.T)
pkg/peernet/network_test.go:91
Function
TestHandler
(t *testing.T)
pkg/handlers/root_test.go:36
Function
TestID
(t *testing.T)
pkg/peernet/mocks/host_test.go:5
Function
TestIsRequestFromPeer
(t *testing.T)
pkg/context/context_test.go:134
Function
TestKey
(t *testing.T)
pkg/files/store/store_test.go:90
Function
TestLeader
(t *testing.T)
pkg/k8s/election/election_test.go:14
Function
TestLeaderElectionConfig
(t *testing.T)
pkg/k8s/election/election_test.go:89
Function
TestLen
(t *testing.T)
tests/random/math/reverse_test.go:23
Function
TestLess
(t *testing.T)
tests/random/math/reverse_test.go:33
Function
TestLog
(t *testing.T)
pkg/discovery/content/reader/mocks/reader_test.go:13
Function
TestLogger
(t *testing.T)
pkg/context/context_test.go:22
Function
TestLoggingConfiguration
(t *testing.T)
cmd/proxy/main_test.go:108
Function
TestLookupKey
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:81
Function
TestMain
(m *testing.M)
pkg/cache/main_test.go:15
Function
TestMain
(m *testing.M)
pkg/files/store/main_test.go:21
Function
TestMain
(m *testing.M)
pkg/handlers/files/main_test.go:14
Function
TestMax64
(t *testing.T)
pkg/math/compare_test.go:7
Function
TestMin
(t *testing.T)
pkg/math/compare_test.go:43
Function
TestMin64
(t *testing.T)
pkg/math/compare_test.go:25
Function
TestNet
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:16
Function
TestNew
(t *testing.T)
pkg/peernet/network_test.go:13
Function
TestNewEngine
(t *testing.T)
pkg/handlers/root_test.go:21
Function
TestNewHost
(t *testing.T)
pkg/discovery/routing/router_test.go:163
Function
TestNewMockReader
(t *testing.T)
pkg/discovery/content/reader/mocks/reader_test.go:5
Function
TestNewMockRouter
(t *testing.T)
pkg/discovery/routing/mocks/router_test.go:9
Function
TestNewRecorderInNode
(t *testing.T)
pkg/k8s/events/events_test.go:51
Function
TestNewRecorderInPod
(t *testing.T)
pkg/k8s/events/events_test.go:86
Function
TestNewSegments
(t *testing.T)
pkg/math/segments_test.go:7
Function
TestNotFoundInP2PMode
(t *testing.T)
pkg/handlers/files/handler_test.go:84
Function
TestOpenNonP2p
(t *testing.T)
pkg/files/store/store_test.go:57
Function
TestOpenP2p
(t *testing.T)
pkg/files/store/store_test.go:25
Function
TestP2pNoInfiniteLoops
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:295
Function
TestP2pPeerNotFound
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:269
Function
TestP2pRetries
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:187
Function
TestP2pSuccess
(t *testing.T)
pkg/discovery/content/reader/reader_test.go:232
← previous
next →
201–300 of 350, ranked by callers