MCPcopy Create free account

hub / github.com/crytic/attacknet / functions

Functions157 in github.com/crytic/attacknet

⨍ Functions 157◇ Types & classes 78
↓ 14 callersMethodGetName
()
pkg/kubernetes/types.go:4
↓ 11 callersFunctiongetDurationValue
(key string, m map[string]string)
pkg/plan/suite/suite_builder.go:82
↓ 6 callersFunctionConvertToNodeIdTag
(networkNodeCount int, node *network.Node, client clientType)
pkg/plan/suite/step_builder.go:20
↓ 5 callersMethodError
()
pkg/plan/suite/targeting.go:19
↓ 5 callersFunctioncomposeWaitForFaultCompletionStep
()
pkg/plan/suite/step_builder.go:44
↓ 4 callersFunctionbuildNode
(index int, execConf, consensusConf ClientVersion)
pkg/plan/network/clients.go:7
↓ 4 callersFunctionchooseTargetsUsingAttackSize
(size AttackSize, networkSize int, targetable []*network.Node)
pkg/plan/suite/targeting.go:45
↓ 4 callersMethodconvertResultToArtifact
( prevArtifact *types.BlockConsensusArtifact, result *types.BlockConsensusTestResult)
pkg/health/ethereum/network_checker.go:82
↓ 4 callersFunctionreportConsensusDataToLogger
(consensusType string, consensusBlockNum []*ClientForkChoice, wrongBlockNum []*ClientForkChoice, consensusB
pkg/health/ethereum/consensus.go:97
↓ 3 callersMethodStartMultiPortForwardToLabeledPods
( pods []KubePod, labelKey, labelValue string, targetPort int)
pkg/kubernetes/port_forward.go:29
↓ 3 callersFunctionconvertFaultSpecToInjectStep
(description string, s interface{})
pkg/plan/suite/faults.go:168
↓ 3 callersFunctionfilterNodes
(nodes []*network.Node, criteria NodeFilterCriteria)
pkg/plan/suite/targeting.go:35
↓ 2 callersFunctionAllChecksPassed
(checks *types.HealthCheckResult)
pkg/health/checker.go:64
↓ 2 callersMethodClose
()
pkg/health/ethereum/beacon_rpc.go:150
↓ 2 callersFunctionCreateOrImportContext
(ctx context.Context, kurtosisCtx *kurtosis_context.KurtosisContext, cfg *types.ConfigParsed)
pkg/kurtosis/kurtosis.go:87
↓ 2 callersFunctionCreatePrefixWriter
(prefix string, writer io.Writer)
pkg/kubernetes/utils.go:10
↓ 2 callersFunctionGetKurtosisContext
()
pkg/kurtosis/kurtosis.go:56
↓ 2 callersMethodGetLatestBlockBy
(ctx context.Context, blockType string)
pkg/health/ethereum/beacon_rpc.go:154
↓ 2 callersMethodGetStatus
todo: we need a better way of monitoring fault injection status. There's a ton of statefulness represented in chaos-mesh that we're glancing over. Sit
pkg/chaos-mesh/session.go:233
↓ 2 callersFunctionInitializeProject
(path string, force bool)
pkg/project/project.go:38
↓ 2 callersMethodIsTargetExecutionClient
()
pkg/plan/types.go:18
↓ 2 callersMethodMatchesLabel
(string, string)
pkg/kubernetes/types.go:6
↓ 2 callersFunctionStartNetwork
(ctx context.Context, enclaveCtx *EnclaveContextWrapper, harnessConfig types.HarnessConfigParsed)
pkg/kurtosis/kurtosis.go:125
↓ 2 callersMethodStartPortForwarding
(pod string, localPort, remotePort int, printToStdout bool)
pkg/kubernetes/port_forward.go:128
↓ 2 callersMethodWrite
(p []byte)
pkg/kubernetes/utils.go:14
↓ 2 callersFunctionbuildPodsUnderTestSlice
(ctx context.Context, client *ChaosClient, podNames []string, expectDeath bool)
pkg/chaos-mesh/session.go:304
↓ 2 callersFunctionconvertFaultSpecToInjectStepSpecial
(description string, s NetworkChaosWrapper)
pkg/plan/suite/faults.go:181
↓ 2 callersFunctiondetermineForkConsensus
(nodes []*ClientForkChoice)
pkg/health/ethereum/consensus.go:46
↓ 2 callersMethodgetBeaconClientConsensus
(ctx context.Context, clients []*BeaconClientRpc, blockType string, maxAttempts int)
pkg/health/ethereum/beacon_rpc.go:25
↓ 2 callersMethodgetExecBlockConsensus
(ctx context.Context, clients []*ExecClientRPC, blockType string, maxAttempts int)
pkg/health/ethereum/execution_rpc.go:20
↓ 2 callersMethodgetKubeFaultResource
(ctx context.Context)
pkg/chaos-mesh/session.go:96
↓ 2 callersFunctiongetPodsToHealthCheck
( ctx context.Context, kubeClient *kubernetes.KubeClient, podsUnderTest []*chaos_mesh.PodUnderTest, podsUn
pkg/health/ethereum/util.go:9
↓ 2 callersFunctiongetUintValue
(key string, m map[string]string)
pkg/plan/suite/suite_builder.go:95
↓ 1 callersFunctionBuildChaosMeshTargetSelectors
(networkNodeCount int, nodes []*network.Node, size AttackSize, targetCriteria TargetCriteriaFilter, impactSele
pkg/plan/suite/targeting.go:227
↓ 1 callersFunctionBuildHealthChecker
(kubeClient *kubernetes.KubeClient, podsUnderTest []*chaos_mesh.PodUnderTest, healthCheckConfig confTypes.Heal
pkg/health/checker.go:20
↓ 1 callersFunctionBuildNodeFilteringLambda
(clientType string, isExecClient bool)
pkg/plan/suite/targeting.go:27
↓ 1 callersFunctionBuildPlan
(planName string, config *PlannerConfig)
pkg/plan/plan.go:10
↓ 1 callersFunctionBuildTestArtifact
( healthResults *healthTypes.HealthCheckResult, podsUnderTest []*chaosMesh.PodUnderTest, test types.SuiteTe
pkg/artifacts/artifacts.go:25
↓ 1 callersMethodClose
()
pkg/kubernetes/port_forward.go:25
↓ 1 callersFunctionComposeNetworkLatencyTest
(description string, targets []*ChaosTargetSelector, delay, jitter, duration, grace *time.Duration, correlatio
pkg/plan/suite/test_builder.go:79
↓ 1 callersFunctionComposeNetworkTopology
(topology Topology, clientUnderTest string, execClients, consClients []ClientVersion)
pkg/plan/network/network_builder.go:34
↓ 1 callersFunctionComposeNodeClockSkewTest
(description string, targets []*ChaosTargetSelector, skew, duration string, graceDuration *time.Duration)
pkg/plan/suite/test_builder.go:8
↓ 1 callersFunctionComposePacketDropTest
(description string, targets []*ChaosTargetSelector, percent int, direction string, duration, grace *time.Dura
pkg/plan/suite/test_builder.go:102
↓ 1 callersFunctionComposeTestSuite
( config PlannerFaultConfiguration, isExecClient bool, nodes []*network.Node)
pkg/plan/suite/suite_builder.go:13
↓ 1 callersMethodCreateDerivedClientWithSchema
(scheme *runtime.Scheme)
pkg/kubernetes/kubernetes.go:51
↓ 1 callersFunctionCreateEthNetworkChecker
(kubeClient *kubernetes.KubeClient, podsUnderTest []*chaos_mesh.PodUnderTest)
pkg/health/ethereum/network_checker.go:19
↓ 1 callersFunctionCreateKubeClient
(namespace string)
pkg/kubernetes/kubernetes.go:25
↓ 1 callersFunctionCreateTestExecutor
(chaosClient *chaos_mesh.ChaosClient, test types.SuiteTest)
pkg/test_executor/executor.go:22
↓ 1 callersMethodDestroy
(ctx context.Context)
pkg/kurtosis/kurtosis.go:26
↓ 1 callersMethodGetLabels
()
pkg/kubernetes/types.go:5
↓ 1 callersMethodGetLabels
()
pkg/kubernetes/types.go:20
↓ 1 callersMethodGetPodLabels
(ctx context.Context, podName string)
pkg/chaos-mesh/client.go:88
↓ 1 callersMethodGetPodsUnderTest
()
pkg/test_executor/executor.go:70
↓ 1 callersMethodIsTargetConsensusClient
()
pkg/plan/types.go:27
↓ 1 callersFunctionLoadPlannerConfigFromPath
(path string)
pkg/plan/config.go:49
↓ 1 callersFunctionLoadSuiteConfigFromName
(suiteName string)
pkg/project/config.go:24
↓ 1 callersFunctionNewFaultSession
(ctx context.Context, client *ChaosClient, faultKind *api.ChaosKind, faultSpec map[string]interface{}, name st
pkg/chaos-mesh/session.go:47
↓ 1 callersFunctionNewMockNetworkUnconfigured
(nodeCount int)
pkg/plan/suite/targeting_test.go:8
↓ 1 callersMethodPodExists
todo: figure out the actual error conditions/pod doesnt exist error
pkg/kubernetes/kubernetes.go:56
↓ 1 callersMethodPodsMatchingLabel
(ctx context.Context, labelKey, labelValue string)
pkg/kubernetes/kubernetes.go:65
↓ 1 callersMethodRunAllChecks
(context.Context, *HealthCheckResult)
pkg/health/types/types.go:6
↓ 1 callersMethodRunChecks
(ctx context.Context)
pkg/health/checker.go:35
↓ 1 callersMethodRunStarlarkRemotePackage
pass-thru func. Figure out how to remove eventually.
pkg/kurtosis/kurtosis.go:48
↓ 1 callersMethodRunTestPlan
(ctx context.Context)
pkg/test_executor/executor.go:26
↓ 1 callersFunctionSerializeNetworkTopology
(nodes []*network.Node, config *network.GenesisConfig)
pkg/plan/serialization.go:10
↓ 1 callersFunctionSerializeTestArtifacts
(artifacts []*TestArtifact)
pkg/artifacts/artifacts.go:46
↓ 1 callersFunctionSetupEnclave
(ctx context.Context, cfg *types.ConfigParsed)
pkg/runtime/runtime.go:60
↓ 1 callersMethodStartFault
(ctx context.Context, faultSpec map[string]interface{})
pkg/chaos-mesh/client.go:49
↓ 1 callersMethodStartMultiPortForwards
(pods []KubePod, targetPort int)
pkg/kubernetes/port_forward.go:45
↓ 1 callersFunctionStartTestSuite
(ctx context.Context, cfg *types.ConfigParsed)
pkg/runtime.go:16
↓ 1 callersFunctionTargetSpecEnumToLambda
(targetSelector TargetingSpec, isExecClient bool)
pkg/plan/suite/targeting.go:178
↓ 1 callersFunctionareExprSelectorsMatchingIdIn
(expressionSelectors []ChaosExpressionSelector)
pkg/plan/suite/step_builder.go:79
↓ 1 callersFunctionbuildClockSkewFault
(description, timeOffset, duration string, expressionSelectors []ChaosExpressionSelector)
pkg/plan/suite/faults.go:194
↓ 1 callersFunctionbuildIOLatencyFault
(description string, expressionSelector ChaosExpressionSelector, delay *time.Duration, percent int, duration *
pkg/plan/suite/faults.go:248
↓ 1 callersFunctionbuildNetworkLatencyFault
(description string, expressionSelectors []ChaosExpressionSelector, delay, jitter, duration *time.Duration, co
pkg/plan/suite/faults.go:285
↓ 1 callersFunctionbuildPacketDropFault
(description string, expressionSelectors []ChaosExpressionSelector, percent int, direction string, duration *t
pkg/plan/suite/faults.go:309
↓ 1 callersFunctionbuildPodRestartFault
(description string, expressionSelectors []ChaosExpressionSelector)
pkg/plan/suite/faults.go:213
↓ 1 callersFunctioncalcNodesNeededToSatisfyTarget
(percentTarget float32, targetedNodeCount int)
pkg/plan/network/network_builder.go:152
↓ 1 callersMethodcheckForFailedRecovery
todo: check which pods are actually expected to die instead of the number of pods.
pkg/chaos-mesh/session.go:167
↓ 1 callersMethodcheckTargetSelectionCompleted
returns True if TargetSelectionCompleted becomes true
pkg/chaos-mesh/session.go:111
↓ 1 callersFunctionclientListsToMaps
(execClients, consClients []ClientVersion)
pkg/plan/network/network_builder.go:8
↓ 1 callersFunctioncomposeBootnode
(bootEl, bootCl string, execClients, consensusClients map[string]ClientVersion)
pkg/plan/network/clients.go:15
↓ 1 callersFunctioncomposeConsensusClient
(config ClientVersion)
pkg/plan/network/consensus.go:41
↓ 1 callersFunctioncomposeConsensusTesterNetwork
(nodeMultiplier int, consensusClient string, execClientList []ClientVersion, consClientMap map[string]ClientVe
pkg/plan/network/consensus.go:14
↓ 1 callersFunctioncomposeExecTesterNetwork
(nodeMultiplier int, execClient string, consClientList []ClientVersion, execClientMap map[string]ClientVersion
pkg/plan/network/execution.go:10
↓ 1 callersFunctioncomposeExecutionClient
(config ClientVersion)
pkg/plan/network/execution.go:37
↓ 1 callersFunctioncomposeIOLatencySteps
(targetsSelected []*ChaosTargetSelector, delay *time.Duration, percent int, duration *time.Duration)
pkg/plan/suite/step_builder.go:91
↓ 1 callersFunctioncomposeIOLatencyTest
(description string, targets []*ChaosTargetSelector, delay *time.Duration, percent int, duration *time.Duratio
pkg/plan/suite/test_builder.go:55
↓ 1 callersFunctioncomposeNetworkLatencySteps
(targetsSelected []*ChaosTargetSelector, delay, jitter, duration *time.Duration, correlation int)
pkg/plan/suite/step_builder.go:115
↓ 1 callersFunctioncomposeNodeClockSkewPlanSteps
(targetsSelected []*ChaosTargetSelector, skew, duration string)
pkg/plan/suite/step_builder.go:48
↓ 1 callersFunctioncomposeNodeRestartSteps
(targetsSelected []*ChaosTargetSelector)
pkg/plan/suite/step_builder.go:63
↓ 1 callersFunctioncomposeNodeRestartTest
(description string, targets []*ChaosTargetSelector, graceDuration *time.Duration)
pkg/plan/suite/test_builder.go:31
↓ 1 callersFunctioncomposeNodesForClTesting
(nodeMultiplier, index int, consensusClient ClientVersion, execClients []ClientVersion)
pkg/plan/network/consensus.go:27
↓ 1 callersFunctioncomposeNodesForElTesting
(nodeMultiplier, index int, execClient ClientVersion, consClientList []ClientVersion)
pkg/plan/network/execution.go:23
↓ 1 callersFunctioncomposeNodesToSatisfyTargetPercent
(percentTarget float32, targetedNodeCount int, startIndex int, clientUnderTest string, execClients, consClient
pkg/plan/network/network_builder.go:93
↓ 1 callersFunctioncomposePacketDropSteps
(targetsSelected []*ChaosTargetSelector, percent int, direction string, duration *time.Duration)
pkg/plan/suite/step_builder.go:130
↓ 1 callersFunctioncomposeTestForFaultType
( faultType FaultTypeEnum, config map[string]string, targetSelectors []*ChaosTargetSelector, targetingDesc
pkg/plan/suite/suite_builder.go:127
↓ 1 callersFunctionconvertFaultSpecToMap
(s T)
pkg/plan/suite/faults.go:138
↓ 1 callersFunctionconvertFaultSpecToMapSpecial
(s NetworkChaosWrapper)
pkg/plan/suite/faults.go:153
↓ 1 callersFunctiondefaultConfig
()
pkg/project/config.go:12
next →1–100 of 157, ranked by callers