MCPcopy Create free account

hub / github.com/Netflix/p2plab / functions

Functions716 in github.com/Netflix/p2plab

⨍ Functions 716◇ Types & classes 184
↓ 1 callersFunctionAddOptionsFromDefinition
(odef metadata.ObjectDefinition)
scenarios/plan.go:147
↓ 1 callersFunctionApp
(ctx context.Context)
cmd/labd/command/root.go:33
↓ 1 callersFunctionApp
(ctx context.Context)
cmd/labagent/command/root.go:32
↓ 1 callersFunctionApp
(ctx context.Context)
cmd/labctl/command/root.go:24
↓ 1 callersFunctionApp
(ctx context.Context)
cmd/labapp/command/root.go:33
↓ 1 callersMethodApply
(ctx context.Context, id string, cdef metadata.ClusterDefinition)
providers/terraform/terraform.go:54
↓ 1 callersFunctionAttachAppClient
(app *cli.App)
cmd/labctl/command/common.go:103
↓ 1 callersFunctionAttachAppContext
(ctx context.Context, app *cli.App)
cmd/labctl/command/common.go:36
↓ 1 callersFunctionBenchmark
(ctx context.Context, lset p2plab.LabeledSet, benchmark metadata.ScenarioStage)
scenarios/run.go:155
↓ 1 callersFunctionBuildCommits
(ctx context.Context, builder p2plab.Builder, commits []string)
nodes/update.go:114
↓ 1 callersFunctionBuildManifestHandler
(f images.HandlerFunc, peer p2plab.Peer, provider content.Provider, callback func(ocispec.Descriptor), opts ..
transformers/oci/oci.go:232
↓ 1 callersFunctionCollectReports
(ctx context.Context, ns []p2plab.Node)
nodes/reports.go:30
↓ 1 callersFunctionConstructDAGFromManifest
(ctx context.Context, p p2plab.Peer, image ocispec.Descriptor, opts ...p2plab.AddOption)
transformers/oci/oci.go:304
↓ 1 callersFunctionConvertHandler
(conversions map[digest.Digest]ocispec.Descriptor, peer p2plab.Peer, fetcher remotes.Fetcher, store content.St
transformers/oci/oci.go:179
↓ 1 callersMethodCreateBenchmark
(ctx context.Context, benchmark Benchmark)
metadata/db.go:115
↓ 1 callersMethodCreateNodeGroup
CreateNodeGroup returns a healthy cluster of nodes.
node.go:47
↓ 1 callersMethodCreateNodes
(ctx context.Context, cluster string, nodes []Node)
metadata/node.go:140
↓ 1 callersMethodCreateNodes
(ctx context.Context, cluster string, node []Node)
metadata/db.go:73
↓ 1 callersMethodCreateReport
(ctx context.Context, id string, report Report)
metadata/db.go:107
↓ 1 callersMethodCreateScenario
(ctx context.Context, scenario Scenario)
metadata/db.go:85
↓ 1 callersMethodDAGService
DAGService returns the IPLD DAG service.
peer.go:35
↓ 1 callersMethodDeleteBenchmarks
(ctx context.Context, ids ...string)
metadata/db.go:121
↓ 1 callersMethodDeleteScenarios
(ctx context.Context, ids ...string)
metadata/db.go:91
↓ 1 callersMethodDestroy
(ctx context.Context, id string)
providers/terraform/terraform.go:108
↓ 1 callersMethodDestroyNodeGroup
DestroyNodeGroup destroys a cluster of nodes.
node.go:50
↓ 1 callersMethodDisconnect
Disconnect disconnects from libp2p peers.
peer.go:41
↓ 1 callersFunctionDiscoverInstances
(ctx context.Context, asg, region string)
providers/terraform/instances.go:32
↓ 1 callersFunctionDispatchConvertHandler
(f images.HandlerFunc, peer p2plab.Peer, fetcher remotes.Fetcher, store content.Store, opts ...p2plab.AddOptio
transformers/oci/oci.go:157
↓ 1 callersMethodFetchGraph
FetchGraph fetches the full DAG rooted at a given cid.
peer.go:50
↓ 1 callersMethodFromJSON
FromJSON loads the experiment definition with the values from data
metadata/experiment.go:73
↓ 1 callersMethodGenerateLabels
()
metadata/cluster.go:74
↓ 1 callersMethodGet
(id string)
query/labeled_set.go:41
↓ 1 callersMethodGetBenchmark
(ctx context.Context, id string)
metadata/db.go:111
↓ 1 callersMethodGetNode
(ctx context.Context, cluster, id string)
metadata/db.go:67
↓ 1 callersFunctionGetNodeProvider
(root, providerType string, settings ProviderSettings)
providers/providers.go:37
↓ 1 callersFunctionGetPrinter
(output, auto OutputType)
printer/printer.go:36
↓ 1 callersMethodGetReport
(ctx context.Context, id string)
metadata/db.go:105
↓ 1 callersFunctionGetUploader
(root, uploaderType string, settings UploaderSettings)
uploaders/uploaders.go:36
↓ 1 callersMethodHandle
Handle starts handling the given signals, and will call the handler callback function each time a signal is catched. The function is passed the number
pkg/cliutil/interrupt.go:88
↓ 1 callersMethodHealthcheck
(ctx context.Context)
api.go:46
↓ 1 callersMethodID
()
labd/controlapi/build.go:105
↓ 1 callersFunctionIsInvalidArgument
(err error)
errdefs/errors.go:44
↓ 1 callersFunctionIsUnavailable
(err error)
errdefs/errors.go:48
↓ 1 callersFunctionJoinBefore
(fns ...cli.BeforeFunc)
pkg/cliutil/attach.go:51
↓ 1 callersMethodLabelBenchmarks
(ctx context.Context, ids, adds, removes []string)
metadata/db.go:119
↓ 1 callersMethodLabelClusters
(ctx context.Context, ids, adds, removes []string)
metadata/db.go:61
↓ 1 callersMethodLabelNodes
(ctx context.Context, cluster string, ids, adds, removes []string)
metadata/db.go:77
↓ 1 callersMethodLabelScenarios
(ctx context.Context, ids, adds, removes []string)
metadata/db.go:89
↓ 1 callersFunctionLabeledSetToNodes
(lset p2plab.LabeledSet)
scenarios/run.go:53
↓ 1 callersMethodListBuilds
(ctx context.Context)
metadata/db.go:97
↓ 1 callersFunctionNew
(root, addr string, logger *zerolog.Logger, opts ...LabdOption)
labd/labd.go:50
↓ 1 callersFunctionNew
(client *httputil.Client, addr string)
labd/controlapi/controlapi.go:33
↓ 1 callersFunctionNew
New returns a new experiment router initialized with the router helpers
labd/routers/experimentrouter/router.go:60
↓ 1 callersFunctionNew
(db metadata.DB, client *httputil.Client)
labd/routers/noderouter/router.go:37
↓ 1 callersFunctionNew
New returns a new clutser router initialized with the router helpers
labd/routers/clusterrouter/router.go:41
↓ 1 callersFunctionNew
(db metadata.DB)
labd/routers/scenariorouter/router.go:35
↓ 1 callersFunctionNew
(db metadata.DB, uploader p2plab.Uploader, fs *downloaders.Downloaders)
labd/routers/buildrouter/router.go:36
↓ 1 callersFunctionNew
(db metadata.DB, client *httputil.Client, ts *transformers.Transformers, seeder *peer.Peer, builder p2plab.Bui
labd/routers/benchmarkrouter/router.go:53
↓ 1 callersFunctionNew
(root string, logger *zerolog.Logger, settings FileUploaderSettings)
uploaders/fileuploader/uploader.go:44
↓ 1 callersFunctionNew
(root string, db metadata.DB, logger *zerolog.Logger, agentOpts ...labagent.LabagentOption)
providers/inmemory/provider.go:40
↓ 1 callersFunctionNew
(root string)
providers/terraform/provider.go:60
↓ 1 callersFunctionNew
(addr string, s supervisor.Supervisor)
labagent/agentrouter/router.go:35
↓ 1 callersFunctionNew
(root, appRoot, appAddr string, client *httputil.Client, fs *downloaders.Downloaders)
labagent/supervisor/supervisor.go:56
↓ 1 callersFunctionNew
(root string, client *http.Client)
transformers/transformers.go:34
↓ 1 callersFunctionNew
()
downloaders/filedownloader/downloader.go:32
↓ 1 callersFunctionNew
(client *httputil.Client)
downloaders/httpdownloader/downloader.go:29
↓ 1 callersFunctionNew
(ctx context.Context, root, addr string, port int, logger *zerolog.Logger, pdef metadata.PeerDefinition)
labapp/labapp.go:34
↓ 1 callersFunctionNew
(p *peer.Peer)
labapp/approuter/router.go:40
↓ 1 callersFunctionNewBlockstore
(ctx context.Context, ds datastore.Batching)
peer/peer.go:317
↓ 1 callersFunctionNewDatastore
(path string)
peer/peer.go:313
↓ 1 callersFunctionNewIDPrinter
()
printer/id.go:25
↓ 1 callersFunctionNewJSONPrinter
()
printer/json.go:24
↓ 1 callersFunctionNewJaegerLogger
(logger *zerolog.Logger)
pkg/logutil/jaeger.go:26
↓ 1 callersFunctionNewLibp2pPeer
(ctx context.Context, port int, pdef metadata.PeerDefinition, reporter metrics.Reporter)
peer/libp2p.go:39
↓ 1 callersFunctionNewMuxerOption
(muxerType string)
peer/libp2p.go:105
↓ 1 callersFunctionNewProvider
(peer p2plab.Peer)
transformers/oci/content.go:34
↓ 1 callersFunctionNewProviderSystem
(ctx context.Context, ds datastore.Batching, bs blockstore.Blockstore, r routing.ContentRouting)
peer/peer.go:330
↓ 1 callersFunctionNewRoutingOption
(ctx context.Context, routingType string)
peer/libp2p.go:127
↓ 1 callersFunctionNewSecurityOption
(securityType string)
peer/libp2p.go:116
↓ 1 callersFunctionNewTablePrinter
()
printer/table.go:30
↓ 1 callersFunctionNewTransportOption
(transportType string, port int)
peer/libp2p.go:92
↓ 1 callersFunctionNewUnixPrinter
()
printer/unix.go:25
↓ 1 callersFunctionNewWriteFlusher
(w io.Writer)
pkg/logutil/http.go:40
↓ 1 callersFunctionParse
(filename string)
scenarios/definition.go:24
↓ 1 callersFunctionResolveUniqueCommits
(ctx context.Context, builder p2plab.Builder, ns []p2plab.Node)
nodes/update.go:78
↓ 1 callersMethodRoutes
()
daemon/router.go:23
↓ 1 callersMethodSSH
SSH creates a SSH connection to the node.
api.go:51
↓ 1 callersFunctionSeed
(ctx context.Context, lset p2plab.LabeledSet, seed metadata.ScenarioStage, seederAddrs []string)
scenarios/run.go:65
↓ 1 callersFunctionSession
(ctx context.Context, lset p2plab.LabeledSet, benchmark metadata.ScenarioStage)
scenarios/run.go:121
↓ 1 callersFunctionSession
(ctx context.Context, ns []p2plab.Node, fn func(context.Context) error)
nodes/session.go:29
↓ 1 callersMethodSize
()
metadata/cluster.go:66
↓ 1 callersMethodSupervise
(ctx context.Context, id, link string, pdef metadata.PeerDefinition)
labagent/supervisor/supervisor.go:42
↓ 1 callersMethodToTrialDefinitions
ToTrialDefinitions returns the slice of all trials to be run
cue/parser/p2plab_instance.go:28
↓ 1 callersMethodUpdateBenchmark
(ctx context.Context, benchmark Benchmark)
metadata/db.go:117
↓ 1 callersMethodUpdateNode
(ctx context.Context, cluster string, node Node)
metadata/db.go:75
↓ 1 callersMethodValidate
()
metadata/cluster.go:43
↓ 1 callersFunctionWalk
(ctx context.Context, c cid.Cid, ng ipld.NodeGetter)
dag/walker.go:27
↓ 1 callersFunctionWithBenchmarkNoReset
()
benchmark.go:54
↓ 1 callersFunctionWithChunker
WithChunker sets the chunking strategy for the content.
peer.go:80
↓ 1 callersFunctionWithClusterDefinition
(definition string)
cluster.go:66
← previousnext →201–300 of 716, ranked by callers