MCPcopy Create free account

hub / github.com/Netflix/p2plab / functions

Functions716 in github.com/Netflix/p2plab

⨍ Functions 716◇ Types & classes 184
↓ 3 callersFunctionNew
(service, addr string, logger *zerolog.Logger, routers ...Router)
daemon/daemon.go:42
↓ 3 callersFunctionNewBuild
(client *httputil.Client, url urlFunc, m metadata.Build)
labd/controlapi/build.go:97
↓ 3 callersFunctionNewClient
(hclient *http.Client, opts ...ClientOption)
pkg/httputil/client.go:40
↓ 3 callersFunctionNewWriter
(logger *zerolog.Logger, level zerolog.Level)
pkg/logutil/writer.go:29
↓ 3 callersMethodPath
()
daemon/router.go:28
↓ 3 callersMethodResolve
Resolve resolves a git-ref to a commit it can uniquely build.
distribution.go:31
↓ 3 callersMethodToJSON
ToJSON is a helper function to convert an Experiment into it's JSON representation
metadata/experiment.go:44
↓ 3 callersFunctionTracer
(ctx context.Context)
pkg/traceutil/tracer.go:35
↓ 3 callersMethodUpdateCluster
(ctx context.Context, cluster Cluster)
metadata/db.go:59
↓ 3 callersFunctionWaitHealthy
(ctx context.Context, ns []p2plab.Node)
nodes/healthy.go:30
↓ 3 callersFunctionWithLogger
(logger *zerolog.Logger)
pkg/httputil/client.go:90
↓ 3 callersFunctionawscliWithStdio
(ctx context.Context, stdout, stderr io.Writer, args ...string)
providers/terraform/instances.go:74
↓ 3 callersFunctioncreateClustersBucket
(tx *bolt.Tx)
metadata/buckets.go:113
↓ 3 callersFunctioncreateExperimentsBucket
(tx *bolt.Tx)
metadata/buckets.go:173
↓ 3 callersFunctioncreateNodesBucket
(tx *bolt.Tx, cluster string)
metadata/buckets.go:125
↓ 3 callersFunctioncreateScenariosBucket
(tx *bolt.Tx)
metadata/buckets.go:137
↓ 3 callersMethodexecWithStdio
(ctx context.Context, workDir string, stdout, stderr io.Writer, args ...string)
builder/builder.go:225
↓ 3 callersFunctiongetBuildsBucket
(tx *bolt.Tx)
metadata/buckets.go:141
↓ 3 callersFunctiongetClustersBucket
(tx *bolt.Tx)
metadata/buckets.go:105
↓ 3 callersFunctiongetExperimentsBucket
(tx *bolt.Tx)
metadata/buckets.go:165
↓ 3 callersFunctiongetNodesBucket
(tx *bolt.Tx, cluster string)
metadata/buckets.go:117
↓ 3 callersFunctiongetScenariosBucket
(tx *bolt.Tx)
metadata/buckets.go:129
↓ 3 callersFunctionnewLabeled
(id string)
query/labeled_set_test.go:36
↓ 3 callersFunctionparseAddrs
(addrs []string)
labapp/approuter/router.go:184
↓ 3 callersFunctionreadBenchmark
(bkt *bolt.Bucket, benchmark *Benchmark)
metadata/benchmark.go:255
↓ 3 callersFunctionreadExperiment
(bkt *bolt.Bucket, experiment *Experiment)
metadata/experiment.go:248
↓ 3 callersFunctionreadMap
(bkt *bolt.Bucket, name []byte)
metadata/helpers.go:73
↓ 3 callersFunctionreadNode
(bkt *bolt.Bucket, node *Node)
metadata/node.go:263
↓ 3 callersMethodterraform
(ctx context.Context, args ...string)
providers/terraform/terraform.go:144
↓ 3 callersMethodurl
(endpoint string, v ...interface{})
labapp/appapi/appapi.go:42
↓ 3 callersFunctionwriteBenchmark
(bkt *bolt.Bucket, benchmark *Benchmark)
metadata/benchmark.go:373
↓ 3 callersFunctionwriteExperiment
(bkt *bolt.Bucket, experiment *Experiment)
metadata/experiment.go:308
↓ 3 callersFunctionwriteMap
(bkt *bolt.Bucket, name []byte, m map[string]string)
metadata/helpers.go:91
↓ 3 callersFunctionwriteNode
(bkt *bolt.Bucket, node *Node)
metadata/node.go:336
↓ 2 callersFunctionAddBlob
(ctx context.Context, peer p2plab.Peer, r io.Reader, opts ...p2plab.AddOption)
transformers/oci/oci.go:289
↓ 2 callersFunctionCidToDigest
(c cid.Cid)
pkg/digestconv/digestconv.go:45
↓ 2 callersFunctionComputeAggregates
(reportByNodeId map[string]metadata.ReportNode)
reports/aggregates.go:34
↓ 2 callersFunctionConvert
(ctx context.Context, peer p2plab.Peer, fetcher remotes.Fetcher, store content.Store, desc ocispec.Descriptor,
transformers/oci/oci.go:129
↓ 2 callersMethodCreateBuild
(ctx context.Context, build Build)
metadata/db.go:99
↓ 2 callersMethodCreateExperiment
(ctx context.Context, experiment Experiment)
metadata/db.go:129
↓ 2 callersMethodDeleteExperiment
(ctx context.Context, id string)
metadata/db.go:135
↓ 2 callersFunctionExtractNameFromFilename
(filename string)
cmd/labctl/command/common.go:156
↓ 2 callersMethodGetScenario
(ctx context.Context, id string)
metadata/db.go:81
↓ 2 callersMethodInit
Init initializes the builder.
distribution.go:28
↓ 2 callersFunctionIsAlreadyExists
(err error)
errdefs/errors.go:36
↓ 2 callersMethodLabelExperiments
(ctx context.Context, ids, adds, removes []string)
metadata/db.go:133
↓ 2 callersMethodLabels
Labels returns a unique list of labels.
query.go:25
↓ 2 callersMethodListBenchmarks
(ctx context.Context)
metadata/db.go:113
↓ 2 callersMethodListClusters
(ctx context.Context)
metadata/db.go:55
↓ 2 callersMethodListScenarios
(ctx context.Context)
metadata/db.go:83
↓ 2 callersMethodMethod
()
daemon/router.go:27
↓ 2 callersFunctionNew
New instantiates our helper type
labd/routers/helpers/helpers.go:24
↓ 2 callersFunctionNew
(root, addr, appRoot, appAddr string, logger *zerolog.Logger, opts ...LabagentOption)
labagent/labagent.go:36
↓ 2 callersFunctionNew
(client *httputil.Client, addr string)
labagent/agentapi/agentapi.go:36
↓ 2 callersFunctionNew
(root string, client *http.Client)
transformers/oci/oci.go:56
↓ 2 callersFunctionNew
(root string, settings DownloaderSettings)
downloaders/downloaders.go:41
↓ 2 callersFunctionNew
(client *http.Client, settings S3DownloaderSettings)
downloaders/s3downloader/downloader.go:45
↓ 2 callersFunctionNew
()
daemon/healthcheckrouter/router.go:26
↓ 2 callersFunctionNew
(root string, db metadata.DB, uploader p2plab.Uploader)
builder/builder.go:42
↓ 2 callersFunctionNew
(client *httputil.Client, addr string)
labapp/appapi/appapi.go:35
↓ 2 callersFunctionNewParser
NewParser returns a ready to use cue parser
cue/parser/parser.go:74
↓ 2 callersFunctionNewTerraform
(ctx context.Context, root string)
providers/terraform/terraform.go:37
↓ 2 callersFunctionParse
(objects map[string]cid.Cid, a string)
actions/actions.go:26
↓ 2 callersFunctionParse
Parse reads the cue source file at filename and converts it to a metadata.ExperimentDefinition type
experiments/definition.go:26
↓ 2 callersMethodPeerInfo
(ctx context.Context)
api.go:55
↓ 2 callersFunctionPlan
(ctx context.Context, sdef metadata.ScenarioDefinition, ts *transformers.Transformers, peer p2plab.Peer, lset
scenarios/plan.go:31
↓ 2 callersFunctionReportToCSV
ReportToCSV takes a slice of metadata reports and converts it to csv
experiments/report.go:12
↓ 2 callersFunctionResolveApp
(c *cli.Context, addr string)
cmd/labctl/command/resolve.go:37
↓ 2 callersFunctionRun
(ctx context.Context, lset p2plab.LabeledSet, plan metadata.ScenarioPlan, seederAddrs []string)
scenarios/run.go:41
↓ 2 callersMethodStatus
()
pkg/httputil/handler.go:29
↓ 2 callersMethodTasks
(ctx context.Context, ns []Node)
action.go:26
↓ 2 callersMethodToExperimentDefinition
ToExperimentDefinition returns the cue source as a metadata.ExperimentDefinition type
cue/parser/p2plab_instance.go:17
↓ 2 callersMethodTransform
Transform adds a resource defined by source into an IPFS DAG stored in peer.
transformer.go:27
↓ 2 callersFunctionUpdate
(ctx context.Context, builder p2plab.Builder, ns []p2plab.Node)
nodes/update.go:30
↓ 2 callersMethodUpdate
(ctx context.Context, fn func(*bolt.Tx) error)
metadata/db.go:47
↓ 2 callersMethodUpdateExperiment
(ctx context.Context, experiment Experiment)
metadata/db.go:131
↓ 2 callersFunctionValidateClusterID
(id string)
metadata/validate.go:28
↓ 2 callersFunctionWithDownloaderSettings
(settings downloaders.DownloaderSettings)
labagent/settings.go:25
↓ 2 callersFunctionWithLogWriter
(ctx context.Context, writer io.Writer)
pkg/logutil/console.go:24
↓ 2 callersFunctionWithTracer
(ctx context.Context, tracer opentracing.Tracer)
pkg/traceutil/tracer.go:31
↓ 2 callersMethodacquireLease
()
providers/terraform/terraform.go:128
↓ 2 callersMethodaddHeader
(table *tablewriter.Table, v interface{})
printer/table.go:60
↓ 2 callersMethodaddRow
(table *tablewriter.Table, v interface{})
printer/table.go:77
↓ 2 callersFunctionbuildQuery
(tokens []string)
query/query.go:77
↓ 2 callersFunctioncidrFromAddrInfo
(info libp2ppeer.AddrInfo)
peer/peer.go:342
↓ 2 callersMethodcmd
(ctx context.Context, args ...string)
labagent/supervisor/supervisor.go:275
↓ 2 callersMethodcmdWithStdio
(ctx context.Context, stdout, stderr io.Writer, args ...string)
labagent/supervisor/supervisor.go:279
↓ 2 callersMethodmatchNodes
(ctx context.Context, clusterId, q string)
labd/routers/noderouter/router.go:141
↓ 2 callersFunctionnewLabelQuery
(label string)
query/query.go:271
↓ 2 callersFunctionnewLogger
(c *cli.Context)
cmd/labctl/command/common.go:133
↓ 2 callersMethodnewNode
(id string, agentPort, appPort int)
providers/inmemory/provider.go:149
↓ 2 callersFunctionreadBuild
(bkt *bolt.Bucket, build *Build)
metadata/build.go:140
↓ 2 callersFunctionreadPeerDefinition
(bkt *bolt.Bucket)
metadata/node.go:299
↓ 2 callersFunctionreadReport
(bkt *bolt.Bucket, report *Report)
metadata/report.go:125
↓ 2 callersFunctionreadTaskMap
(bkt *bolt.Bucket, name []byte)
metadata/benchmark.go:336
↓ 2 callersFunctionsortQueryBuckets
(report metadata.Report)
printer/report.go:149
↓ 2 callersMethodurl
(endpoint string, v ...interface{})
labagent/agentapi/agentapi.go:43
↓ 2 callersFunctionwritePeerDefinition
(bkt *bolt.Bucket, pdef PeerDefinition)
metadata/node.go:367
↓ 2 callersFunctionwriteReport
(bkt *bolt.Bucket, report Report)
metadata/report.go:139
↓ 2 callersFunctionwriteTaskMap
(bkt *bolt.Bucket, name []byte, stage map[string]Task)
metadata/benchmark.go:489
← previousnext →101–200 of 716, ranked by callers