| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/eth/fetcher/ |
| H A D | fetcher.go | 108 type Fetcher struct { struct
110 notify chan *announce
111 inject chan *inject
113 blockFilter chan chan []*types.Block
114 headerFilter chan chan *headerFilterTask
115 bodyFilter chan chan *bodyFilterTask
117 done chan common.Hash
118 quit chan struct{}
177 func (f *Fetcher) Start() {
183 func (f *Fetcher) Stop() {
[all …]
|
| /dports/misc/perkeep/perkeep-0.11/pkg/test/ |
| H A D | fetcher.go | 31 type Fetcher struct { struct
32 memory.Storage
35 ReceiveErr error
39 FetchErr func() error
47 …f *Fetcher) Fetch(ctx context.Context, ref blob.Ref) (file io.ReadCloser, size uint32, err error) {
60 …Fetcher) SubFetch(ctx context.Context, ref blob.Ref, offset, length int64) (io.ReadCloser, error) {
73 … *Fetcher) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error) {
85 func (tf *Fetcher) AddBlob(b *Blob) {
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/scanner/ |
| H A D | fetcher.go | 59 type Fetcher struct { struct
61 client *client.LogClient
63 opts *FetcherOptions
66 sth *ct.SignedTreeHead
68 sthBackoff *backoff.Backoff
71 mu sync.Mutex
72 cancel context.CancelFunc
119 func (f *Fetcher) Run(ctx context.Context, fn func(EntryBatch)) error {
157 func (f *Fetcher) Stop() {
166 func (f *Fetcher) genRanges(ctx context.Context) <-chan fetchRange {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/ |
| H A D | chunk_store_utils.go | 83 type Fetcher struct { struct
84 storage Client
85 cache cache.Cache
86 cacheStubs bool
88 wait sync.WaitGroup
89 decodeRequests chan decodeRequest
121 func (c *Fetcher) Stop() {
127 func (c *Fetcher) worker() {
144 func (c *Fetcher) FetchChunks(ctx context.Context, chunks []Chunk, keys []string) ([]Chunk, error) {
175 func (c *Fetcher) writeBackCache(ctx context.Context, chunks []Chunk) error {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/ |
| H A D | chunk_store_utils.go | 82 type Fetcher struct { struct
83 storage Client
84 cache cache.Cache
85 cacheStubs bool
87 wait sync.WaitGroup
88 decodeRequests chan decodeRequest
89 quit chan struct{}
121 func (c *Fetcher) Stop() {
132 func (c *Fetcher) worker() {
154 func (c *Fetcher) FetchChunks(ctx context.Context, chunks []Chunk, keys []string) ([]Chunk, error) {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/ |
| H A D | chunk_store_utils.go | 82 type Fetcher struct { struct
83 storage Client
84 cache cache.Cache
85 cacheStubs bool
87 wait sync.WaitGroup
88 decodeRequests chan decodeRequest
89 quit chan struct{}
121 func (c *Fetcher) Stop() {
132 func (c *Fetcher) worker() {
154 func (c *Fetcher) FetchChunks(ctx context.Context, chunks []Chunk, keys []string) ([]Chunk, error) {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/tools/blocksconvert/builder/ |
| H A D | fetcher.go | 11 type Fetcher struct { struct
12 userID string
14 client chunk.Client
16 fetchedChunks prometheus.Counter
17 fetchedChunksSize prometheus.Counter
29 func (f *Fetcher) fetchChunks(ctx context.Context, chunkIDs []string) ([]chunk.Chunk, error) {
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/swarm/network/ |
| H A D | fetcher.go | 43 type Fetcher struct { struct
44 …tFunc RequestFunc // request function fetcher calls to issue retrieve request for a chunk
45 addr storage.Address // the address of the chunk to be fetched
46 offerC chan *discover.NodeID // channel of sources (peer node id strings)
47 requestC chan struct{}
48 skipCheck bool
122 func (f *Fetcher) Offer(ctx context.Context, source *discover.NodeID) {
139 func (f *Fetcher) Request(ctx context.Context) {
157 func (f *Fetcher) run(ctx context.Context, peers *sync.Map) {
254 … *discover.NodeID, peersToSkip *sync.Map, sources []*discover.NodeID) ([]*discover.NodeID, error) {
|
| /dports/net/bosh-cli/bosh-cli-5.5.0/stemcell/ |
| H A D | fetcher.go | 10 type Fetcher struct { struct
11 TarballProvider bitarball.Provider
12 StemcellExtractor Extractor
15 …Stemcell(deploymentManifest bideplmanifest.Manifest, stage biui.Stage) (ExtractedStemcell, error) {
|
| /dports/misc/perkeep/perkeep-0.11/pkg/schema/ |
| H A D | dirreader.go | 43 func NewDirReader(ctx context.Context, fetcher blob.Fetcher, dirBlobRef blob.Ref) (*DirReader, erro…
60 func (b *Blob) NewDirReader(ctx context.Context, fetcher blob.Fetcher) (*DirReader, error) {
64 func (ss *superset) NewDirReader(fetcher blob.Fetcher) (*DirReader, error) {
71 func (ss *superset) setFromBlobRef(ctx context.Context, fetcher blob.Fetcher, blobRef blob.Ref) err…
104 func staticSet(ctx context.Context, staticSetBlobref blob.Ref, fetcher blob.Fetcher) ([]blob.Ref, e…
|
| /dports/misc/perkeep/perkeep-0.11/pkg/blobserver/gethandler/ |
| H A D | get.go | 40 Fetcher blob.Fetcher member
44 func CreateGetHandler(fetcher blob.Fetcher) http.Handler {
65 func ServeBlobRef(rw http.ResponseWriter, req *http.Request, blobRef blob.Ref, fetcher blob.Fetcher…
|
| /dports/misc/perkeep/perkeep-0.11/internal/video/thumbnail/ |
| H A D | handler.go | 32 func serveRef(rw http.ResponseWriter, req *http.Request, ref blob.Ref, fetcher blob.Fetcher) {
75 func createVideothumbnailHandler(ref blob.Ref, fetcher blob.Fetcher) http.Handler {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/remotes/ |
| H A D | handlers.go | 48 func FetchHandler(ingester content.Ingester, fetcher Fetcher) images.HandlerFunc {
66 func fetch(ctx context.Context, ingester content.Ingester, fetcher Fetcher, desc ocispec.Descriptor…
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/remotes/ |
| H A D | handlers.go | 48 func FetchHandler(ingester content.Ingester, fetcher Fetcher) images.HandlerFunc {
66 func fetch(ctx context.Context, ingester content.Ingester, fetcher Fetcher, desc ocispec.Descriptor…
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 33 static class Fetcher implements Runnable { class in KeepAliveTimerThread
36 Fetcher(String url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 33 static class Fetcher implements Runnable { class in KeepAliveTimerThread
36 Fetcher(String url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 33 static class Fetcher implements Runnable { class in KeepAliveTimerThread
36 Fetcher(String url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 33 static class Fetcher implements Runnable { class in KeepAliveTimerThread
36 Fetcher(String url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 33 static class Fetcher implements Runnable { class in KeepAliveTimerThread
36 Fetcher(String url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 38 static class Fetcher implements Runnable { class in KeepAliveTimerThread
41 Fetcher(URL url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 39 static class Fetcher implements Runnable { class in KeepAliveTimerThread
42 Fetcher(URL url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 39 static class Fetcher implements Runnable { class in KeepAliveTimerThread
42 Fetcher(URL url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 39 static class Fetcher implements Runnable { class in KeepAliveTimerThread
42 Fetcher(URL url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/sun/net/www/http/KeepAliveCache/ |
| H A D | KeepAliveTimerThread.java | 39 static class Fetcher implements Runnable { class in KeepAliveTimerThread
42 Fetcher(URL url) { in Fetcher() method in KeepAliveTimerThread.Fetcher
|
| /dports/lang/go-devel/go-becaeea1199b875bc24800fa88f2f4fea119bf78/src/cmd/vendor/github.com/google/pprof/internal/driver/ |
| H A D | fetch.go | 125 func grabSourcesAndBases(sources, bases []profileSource, fetch plugin.Fetcher, obj plugin.ObjTool, …
169 func chunkedGrab(sources []profileSource, fetch plugin.Fetcher, obj plugin.ObjTool, ui plugin.UI, t…
206 func concurrentGrab(sources []profileSource, fetch plugin.Fetcher, obj plugin.ObjTool, ui plugin.UI…
312 func grabProfile(s *source, source string, fetcher plugin.Fetcher, obj plugin.ObjTool, ui plugin.UI…
|