MCPcopy Create free account

hub / github.com/Netflix/p2plab / functions

Functions716 in github.com/Netflix/p2plab

⨍ Functions 716◇ Types & classes 184
↓ 85 callersMethodString
String returns the original query.
query.go:52
↓ 78 callersMethodClose
()
metadata/db.go:49
↓ 49 callersMethodGet
Get returns an Unixfsv1 file from a given cid.
peer.go:47
↓ 36 callersFunctionCommandContext
(c *cli.Context)
pkg/cliutil/attach.go:47
↓ 36 callersMethodNewRequest
(method, url string, opts ...RequestOption)
pkg/httputil/client.go:55
↓ 35 callersMethodSend
(ctx context.Context)
pkg/httputil/request.go:77
↓ 33 callersMethodOption
(key string, value interface{})
pkg/httputil/request.go:45
↓ 32 callersMethodMetadata
()
node.go:41
↓ 31 callersFunctionResolveControl
(c *cli.Context)
cmd/labctl/command/resolve.go:25
↓ 29 callersMethodError
Error logs a message at error priority
pkg/logutil/jaeger.go:32
↓ 29 callersMethodurl
(endpoint string, v ...interface{})
labd/controlapi/controlapi.go:42
↓ 26 callersMethodPrint
(v interface{})
printer/printer.go:23
↓ 24 callersFunctionCommandPrinter
(c *cli.Context, auto printer.OutputType)
cmd/labctl/command/common.go:125
↓ 24 callersMethodID
ID returns a uniquely identifiable string.
query.go:22
↓ 23 callersMethodUpdate
(ctx context.Context, fn func(*bolt.Tx) error)
metadata/db.go:171
↓ 23 callersFunctionWriteJSON
(w http.ResponseWriter, v interface{})
daemon/daemon.go:133
↓ 21 callersMethodRun
Run executes an task on the node.
api.go:60
↓ 18 callersMethodHost
Host returns the libp2p host.
peer.go:32
↓ 18 callersMethodSlice
Slice returns the labeled resources as a slice.
query.go:44
↓ 17 callersFunctionNewGetRoute
(path string, handler Handler)
daemon/router.go:56
↓ 17 callersFunctionStartSpanFromContext
(ctx context.Context, operationName string, opts ...opentracing.StartSpanOption)
pkg/traceutil/tracer.go:43
↓ 14 callersFunctionElapsed
(ctx context.Context, tick time.Duration, msg string)
pkg/logutil/elapsed.go:25
↓ 13 callersMethodView
(ctx context.Context, fn func(*bolt.Tx) error)
metadata/db.go:163
↓ 12 callersFunctiongetBucket
(tx *bolt.Tx, keys ...[]byte)
metadata/buckets.go:76
↓ 11 callersMethodCreate
Create deploys a cluster.
cluster.go:26
↓ 11 callersMethodRemove
Remove removes a labeled resource from the set.
query.go:35
↓ 10 callersFunctionCoalesce
(slice []string)
pkg/stringutil/stringutil.go:17
↓ 10 callersFunctionParse
query := label | '(' func expr ')' expr := query | query expr func := ‘not’ | ‘and’ | ‘or’ label := quoted_string
query/query.go:37
↓ 9 callersMethodAdd
Add adds a labeled resource to the set.
query.go:32
↓ 9 callersMethodList
(ctx context.Context, cluster string, opts ...ListOption)
node.go:30
↓ 9 callersFunctionNewLabeledSet
()
query/labeled_set.go:27
↓ 9 callersMethodOpen
Open creates a reader for the build's binary.
distribution.go:57
↓ 8 callersMethodAdd
Add adds content from an io.Reader into the Peer's storage.
peer.go:44
↓ 8 callersMethodContains
Contains returns whether a labeled resource with the id exists in the set.
query.go:41
↓ 8 callersFunctionNewLabeled
(id string, labels []string)
query/labeled.go:24
↓ 8 callersMethodgit
(ctx context.Context, workDir string, args ...string)
builder/builder.go:216
↓ 7 callersMethodBenchmark
Benchmark returns an implementation of Benchmark API.
api.go:36
↓ 7 callersMethodBody
(value interface{})
pkg/httputil/request.go:62
↓ 7 callersMethodCluster
Cluster returns an implementaiton of Cluster API.
api.go:27
↓ 7 callersFunctionNewHTTPClient
()
pkg/httputil/client.go:27
↓ 7 callersFunctionNewNode
(client *httputil.Client, m metadata.Node)
labd/controlapi/node.go:123
↓ 7 callersFunctionNewPutRoute
(path string, handler Handler)
daemon/router.go:64
↓ 7 callersMethodUpdate
(ctx context.Context, id, link string, pdef metadata.PeerDefinition)
api.go:48
↓ 7 callersFunctionWithQuery
(q string)
cluster.go:100
↓ 6 callersMethodBuild
Build returns an implementation of Build API.
api.go:42
↓ 6 callersFunctionExecute
(ctx context.Context, ls []p2plab.Labeled, q string)
query/execute.go:23
↓ 6 callersMethodExperiment
Experiment returns an implementation of Experiment API.
api.go:39
↓ 6 callersMethodGetExperiment
(ctx context.Context, id string)
metadata/db.go:125
↓ 6 callersFunctionLogWriter
(ctx context.Context)
pkg/logutil/console.go:28
↓ 6 callersFunctionNewPostRoute
(path string, handler Handler)
daemon/router.go:60
↓ 6 callersFunctionNewRoute
(method, path string, handler Handler)
daemon/router.go:40
↓ 6 callersFunctionReadTimestamps
(bkt *bolt.Bucket, created, updated *time.Time)
metadata/helpers.go:30
↓ 6 callersFunctionWriteRemoteLogs
(ctx context.Context, remote io.Reader, writer io.Writer)
pkg/logutil/remote.go:28
↓ 6 callersFunctionWriteTimestamps
(bkt *bolt.Bucket, created, updated time.Time)
metadata/helpers.go:49
↓ 6 callersFunctioncreateBucketIfNotExists
(tx *bolt.Tx, keys ...[]byte)
metadata/buckets.go:89
↓ 6 callersFunctionreadLabels
(bkt *bolt.Bucket)
metadata/helpers.go:181
↓ 6 callersFunctionwriteLabels
(bkt *bolt.Bucket, labels []string)
metadata/helpers.go:196
↓ 5 callersMethodLabel
(ctx context.Context, cluster string, ids, adds, removes []string)
node.go:28
↓ 5 callersMethodListNodes
(ctx context.Context, cluster string)
metadata/db.go:69
↓ 5 callersMethodMatch
Match returns the subset of lset that matches the query.
query.go:55
↓ 5 callersMethodNode
Node returns an implementation of Node API.
api.go:30
↓ 5 callersMethodScenario
Scenario returns an implementation of Scenario API.
api.go:33
↓ 5 callersFunctionWithResponseLogger
(ctx context.Context, w http.ResponseWriter)
pkg/logutil/http.go:27
↓ 5 callersFunctionbatchUpdateLabels
(bkt *bolt.Bucket, ids, adds, removes []string, cb labelCallback)
metadata/helpers.go:128
↓ 4 callersMethodClose
Close closes its signal receiver and waits for its handlers to exit cleanly.
pkg/cliutil/interrupt.go:77
↓ 4 callersFunctionConnect
(ctx context.Context, ns []p2plab.Node)
nodes/connect.go:34
↓ 4 callersMethodConnect
Connect connects to the libp2p peers.
peer.go:38
↓ 4 callersFunctionDigestToCid
(dgst digest.Digest)
pkg/digestconv/digestconv.go:26
↓ 4 callersMethodGetBuild
(ctx context.Context, id string)
metadata/db.go:95
↓ 4 callersFunctionIsNotFound
(err error)
errdefs/errors.go:40
↓ 4 callersFunctionNewDB
(root string)
metadata/db.go:142
↓ 4 callersFunctionNewDeleteRoute
(path string, handler Handler)
daemon/router.go:68
↓ 4 callersFunctionNewInterruptHandler
NewInterruptHandler returns a new interrupt handler that will invoke cancel if any of the signals provided are received.
pkg/cliutil/interrupt.go:38
↓ 4 callersFunctionRecreateBucket
(bkt *bolt.Bucket, key []byte)
metadata/helpers.go:13
↓ 4 callersMethodReport
Report returns all the metrics collected from the peer.
peer.go:53
↓ 4 callersMethodServe
(ctx context.Context)
labd/labd.go:144
↓ 4 callersMethodUpload
Upload uploads a binary for a build.
distribution.go:46
↓ 4 callersMethodView
(ctx context.Context, fn func(*bolt.Tx) error)
metadata/db.go:45
↓ 4 callersFunctionWithRetryMax
(max int)
pkg/httputil/client.go:119
↓ 4 callersFunctionWithTransactionContext
(ctx context.Context, tx *bolt.Tx)
metadata/db.go:32
↓ 4 callersMethodWrite
(p []byte)
pkg/logutil/writer.go:42
↓ 4 callersFunctioncreateBenchmarksBucket
(tx *bolt.Tx)
metadata/buckets.go:161
↓ 4 callersFunctiongetBenchmarksBucket
(tx *bolt.Tx)
metadata/buckets.go:153
↓ 4 callersFunctiongetJSON
slightly less to type repeatedly
cue/parser/p2plab_instance.go:83
↓ 4 callersFunctionreadCluster
(bkt *bolt.Bucket, cluster *Cluster)
metadata/cluster.go:277
↓ 4 callersFunctionreadScenario
(bkt *bolt.Bucket, scenario *Scenario)
metadata/scenario.go:255
↓ 4 callersFunctionwriteCluster
(bkt *bolt.Bucket, cluster *Cluster)
metadata/cluster.go:366
↓ 4 callersFunctionwriteScenario
(bkt *bolt.Bucket, scenario *Scenario)
metadata/scenario.go:312
↓ 3 callersFunctionAttachAppContext
(ctx context.Context, app *cli.App)
pkg/cliutil/attach.go:25
↓ 3 callersFunctionCommandClient
(c *cli.Context)
cmd/labctl/command/common.go:129
↓ 3 callersMethodCompile
Compile is used to compile the given cue source into our runtime it returns a wrapped cue.Instance that provides helper lookup functions
cue/parser/parser.go:88
↓ 3 callersMethodCreateCluster
(ctx context.Context, cluster Cluster)
metadata/db.go:57
↓ 3 callersMethodDeleteCluster
(ctx context.Context, id string)
metadata/db.go:63
↓ 3 callersMethodDownload
Download downloads an artifact with an abstract link.
distribution.go:71
↓ 3 callersMethodGetCluster
(ctx context.Context, id string)
metadata/db.go:53
↓ 3 callersMethodHandler
()
daemon/router.go:29
↓ 3 callersMethodListExperiments
(ctx context.Context)
metadata/db.go:127
↓ 3 callersFunctionNew
(client *http.Client, settings S3UploaderSettings)
uploaders/s3uploader/uploader.go:51
↓ 3 callersFunctionNew
(ctx context.Context, root string, port int, pdef metadata.PeerDefinition)
peer/peer.go:83
↓ 3 callersFunctionNew
(ctx context.Context, service string, logger jaeger.Logger)
pkg/traceutil/tracer.go:47
next →1–100 of 716, ranked by callers