MCPcopy Create free account

hub / github.com/Netflix/p2plab / functions

Functions716 in github.com/Netflix/p2plab

⨍ Functions 716◇ Types & classes 184
↓ 1 callersFunctionWithClusterInstanceType
(instanceType string)
cluster.go:80
↓ 1 callersFunctionWithClusterRegion
(region string)
cluster.go:87
↓ 1 callersFunctionWithClusterSize
(size int)
cluster.go:73
↓ 1 callersFunctionWithDownloaderSettings
(settings downloaders.DownloaderSettings)
labd/settings.go:69
↓ 1 callersFunctionWithHashFunc
WithHashFunc sets the hashing function for the blocks.
peer.go:96
↓ 1 callersFunctionWithLayout
WithLayout sets the format for DAG generation.
peer.go:72
↓ 1 callersFunctionWithLibp2pPort
(port int)
labd/settings.go:34
↓ 1 callersFunctionWithProvider
(provider string)
labd/settings.go:41
↓ 1 callersFunctionWithRawLeaves
WithRawLeaves sets whether to use raw blocks for leaf nodes.
peer.go:88
↓ 1 callersFunctionWithRetryWaitMax
(d time.Duration)
pkg/httputil/client.go:113
↓ 1 callersFunctionWithUploader
(uploader string)
labd/settings.go:55
↓ 1 callersFunctionWithUploaderSettings
(settings uploaders.UploaderSettings)
labd/settings.go:62
↓ 1 callersMethodatomicReplaceBinary
(ctx context.Context, link string)
labagent/supervisor/supervisor.go:226
↓ 1 callersMethodbuildCommit
(ctx context.Context, commit string)
builder/builder.go:153
↓ 1 callersFunctionbuildExpression
(tokens []string)
query/query.go:110
↓ 1 callersMethodclear
(ctx context.Context)
labagent/supervisor/supervisor.go:212
↓ 1 callersMethodconnect
(ctx context.Context, addrs []string)
labapp/approuter/router.go:123
↓ 1 callersMethodconnectOne
(ctx context.Context, addrs []string)
labapp/approuter/router.go:142
↓ 1 callersFunctioncreateBuildsBucket
(tx *bolt.Tx)
metadata/buckets.go:149
↓ 1 callersMethodcreateHTTPHandler
(handler Handler)
daemon/daemon.go:102
↓ 1 callersMethodcreateMux
(routers ...Router)
daemon/daemon.go:87
↓ 1 callersMethoddestroyClusterDir
(id string)
providers/terraform/provider.go:217
↓ 1 callersMethoddisconnect
(ctx context.Context, addrs []string)
labapp/approuter/router.go:165
↓ 1 callersFunctionencodeInt
(i int64)
transformers/oci/metadata.go:99
↓ 1 callersMethodexecuteTfvarsTemplate
(id string, cdef metadata.ClusterDefinition)
providers/terraform/provider.go:222
↓ 1 callersMethodget
(dgst digest.Digest)
transformers/oci/metadata.go:33
↓ 1 callersMethodgetFile
(ctx context.Context, target string)
labapp/approuter/router.go:104
↓ 1 callersFunctiongetIterData
(iter cue.Iterator)
cue/parser/p2plab_instance.go:99
↓ 1 callersFunctiongetScenarioObjectDefinition
(iter cue.Iterator)
cue/parser/p2plab_instance.go:87
↓ 1 callersMethodgoBuild
(ctx context.Context, workDir string, args ...string)
builder/builder.go:207
↓ 1 callersMethodkill
(ctx context.Context)
labagent/supervisor/supervisor.go:185
↓ 1 callersMethodmatchClusters
(ctx context.Context, q string)
labd/routers/clusterrouter/router.go:127
↓ 1 callersFunctionnewAndQuery
(queries []p2plab.Query)
query/query.go:182
↓ 1 callersMethodnewDownloader
(downloaderType string)
downloaders/downloaders.go:65
↓ 1 callersFunctionnewNotQuery
(queries []p2plab.Query)
query/query.go:150
↓ 1 callersFunctionnewOrQuery
(queries []p2plab.Query)
query/query.go:226
↓ 1 callersFunctionnewTestDB
(t *testing.T, path string)
experiments/experiments_test.go:95
↓ 1 callersFunctionnewTestDB
(t *testing.T, path string)
metadata/db_test.go:61
↓ 1 callersFunctionnewTestExperiment
(t *testing.T, sourceFile, name string)
experiments/experiments_test.go:85
↓ 1 callersMethodnewTransformer
(objectType string)
transformers/transformers.go:68
↓ 1 callersMethodpeerDefinitionToFlags
(id string, pdef metadata.PeerDefinition)
labagent/supervisor/supervisor.go:109
↓ 1 callersMethodprepareClusterDir
(id string)
providers/terraform/provider.go:154
↓ 1 callersFunctionprintReport
(report metadata.Report)
printer/report.go:49
↓ 1 callersFunctionprintReportBandwidth
(report metadata.Report)
printer/report.go:68
↓ 1 callersFunctionprintReportBitswap
(report metadata.Report)
printer/report.go:106
↓ 1 callersMethodput
(dgst digest.Digest, desc ocispec.Descriptor)
transformers/oci/metadata.go:64
↓ 1 callersFunctionreadClusterDefinition
(bkt *bolt.Bucket)
metadata/cluster.go:309
↓ 1 callersFunctionreadExperimentDefinition
(bkt *bolt.Bucket, experiment *Experiment)
metadata/experiment.go:295
↓ 1 callersFunctionreadObjects
(bkt *bolt.Bucket)
metadata/scenario.go:372
↓ 1 callersFunctionreadPlan
(bkt *bolt.Bucket, plan *ScenarioPlan)
metadata/benchmark.go:306
↓ 1 callersFunctionreadScenarioDefinition
(bkt *bolt.Bucket)
metadata/scenario.go:285
↓ 1 callersFunctionrun
(addr, ref string)
cmd/ociget/main.go:56
↓ 1 callersFunctionrun
(filename string)
cmd/s3upload/main.go:49
↓ 1 callersFunctionrun
(ref, filename string)
cmd/s3download/main.go:50
↓ 1 callersFunctionrun
(ref string)
cmd/ociadd/main.go:53
↓ 1 callersFunctionrun
(ref string)
cmd/s3build/main.go:52
↓ 1 callersFunctionsortedNodes
(report metadata.Report)
printer/report.go:180
↓ 1 callersMethodstart
(ctx context.Context, flags []string)
labagent/supervisor/supervisor.go:132
↓ 1 callersMethodterraformWithStdio
(ctx context.Context, stdout, stderr io.Writer, args ...string)
providers/terraform/terraform.go:152
↓ 1 callersFunctiontokenize
(q string)
query/query.go:61
↓ 1 callersMethodurl
()
pkg/httputil/request.go:116
↓ 1 callersMethodwait
(ctx context.Context, flags []string)
labagent/supervisor/supervisor.go:152
↓ 1 callersFunctionwalk
(ctx context.Context, nd ipld.Node, ng ipld.NodeGetter)
dag/walker.go:40
↓ 1 callersFunctionwriteBuild
(bkt *bolt.Bucket, build *Build)
metadata/build.go:162
↓ 1 callersFunctionwriteClusterDefinition
(bkt *bolt.Bucket, cdef ClusterDefinition)
metadata/cluster.go:395
↓ 1 callersFunctionwriteExperimentDefinition
(bkt *bolt.Bucket, experiment *Experiment)
metadata/experiment.go:349
↓ 1 callersFunctionwriteObjects
(bkt *bolt.Bucket, objects map[string]ObjectDefinition)
metadata/scenario.go:419
↓ 1 callersFunctionwritePlan
(bkt *bolt.Bucket, plan *ScenarioPlan)
metadata/benchmark.go:451
↓ 1 callersFunctionwriteScenarioDefinition
(bkt *bolt.Bucket, sdef ScenarioDefinition)
metadata/scenario.go:340
MethodAdd
(ctx context.Context, r io.Reader, opts ...p2plab.AddOption)
peer/peer.go:210
MethodAdd
(l p2plab.Labeled)
query/labeled_set.go:33
MethodBenchmark
()
labd/controlapi/controlapi.go:58
MethodBuild
Build compiles the peer at the given commit.
distribution.go:34
MethodBuild
()
labd/controlapi/controlapi.go:66
MethodBuild
(ctx context.Context, commit string)
builder/builder.go:114
MethodClose
()
distribution.go:65
MethodClose
Close releases any resources held by the Transformer.
transformer.go:30
MethodClose
()
labd/labd.go:134
MethodClose
()
uploaders/fileuploader/uploader.go:86
MethodClose
()
uploaders/s3uploader/uploader.go:68
MethodClose
()
providers/inmemory/provider.go:186
MethodClose
()
providers/terraform/terraform.go:140
MethodClose
()
labagent/labagent.go:74
MethodClose
()
transformers/transformers.go:42
MethodClose
()
transformers/oci/content.go:89
MethodClose
()
transformers/oci/oci.go:80
MethodClose
()
pkg/logutil/writer.go:46
MethodClose
()
pkg/traceutil/tracer.go:77
MethodClose
()
metadata/db.go:159
MethodClose
()
daemon/daemon.go:52
MethodClose
()
daemon/cancel_closer.go:21
MethodClose
()
labapp/labapp.go:59
MethodCluster
()
labd/controlapi/controlapi.go:46
MethodConnect
(ctx context.Context, infos []libp2ppeer.AddrInfo)
peer/peer.go:161
MethodContains
(id string)
query/labeled_set.go:45
MethodCreate
Create saves a scenario for the given scenario definition.
scenario.go:26
MethodCreate
Create creates a benchmark of a scenario on a cluster.
benchmark.go:26
MethodCreate
(ctx context.Context, name string, edef metadata.ExperimentDefinition)
experiment.go:26
MethodCreate
(ctx context.Context, name string, sdef metadata.ScenarioDefinition)
labd/controlapi/scenario.go:34
MethodCreate
(ctx context.Context, cluster, scenario string, opts ...p2plab.StartBenchmarkOption)
labd/controlapi/benchmark.go:34
← previousnext →301–400 of 716, ranked by callers