MCPcopy Create free account

hub / github.com/MdSadiqMd/AV-Chaos-Monkey / functions

Functions654 in github.com/MdSadiqMd/AV-Chaos-Monkey

⨍ Functions 654◇ Types & classes 108
↓ 1 callersMethodRecordSimulatedJitter
(jitterMs float64)
pkg/metrics/stats.go:136
↓ 1 callersMethodRefresh
()
pkg/k8s/pods.go:52
↓ 1 callersMethodRemoveAll
Removes all network degradation rules
internal/network/degradation.go:316
↓ 1 callersMethodRemoveSpike
(spikeID string)
internal/pool/virtual_participant.go:137
↓ 1 callersMethodRemoveWebRTCParticipant
(id uint32)
internal/pool/participant.go:127
↓ 1 callersFunctionRunLocalUDPRelay
()
pkg/k8s/relay.go:70
↓ 1 callersMethodSchedule
Schedule returns a channel that emits indices at appropriate times The channel closes when all items are scheduled or context is cancelled
internal/scheduler/scheduler.go:16
↓ 1 callersMethodScheduleSpikes
(spikes []*pb.SpikeEvent, config *SpikeSchedulerConfig)
internal/scheduler/spike_scheduler.go:63
↓ 1 callersFunctionSelectParticipants
(cfg *config.Config)
internal/spike/generator.go:46
↓ 1 callersMethodSetRemoteAnswer
(sdpAnswer string)
internal/pool/participant.go:40
↓ 1 callersMethodSetStreamingFPS
sets the FPS used for streaming calculations
internal/media/source.go:296
↓ 1 callersFunctionSetupPortForwarding
()
pkg/k8s/relay.go:17
↓ 1 callersMethodSetupUDP
(host string, port int)
internal/pool/virtual_participant.go:77
↓ 1 callersFunctionSetupUDPRelayChain
(kubectlCmd string)
pkg/k8s/relay.go:49
↓ 1 callersFunctionShowProgress
(current, total int)
pkg/utils/progress.go:8
↓ 1 callersMethodStart
()
internal/server/http.go:76
↓ 1 callersMethodStoreReceiverReport
(rr *ReceiverReport)
internal/rtcp/rtcp.go:68
↓ 1 callersFunctionUpdatePrometheusTargets
(replicas int, projectRoot string)
pkg/k8s/prometheus.go:16
↓ 1 callersFunctionUpdateReplicas
(projectRoot string, replicas int)
pkg/k8s/deploy.go:37
↓ 1 callersFunctionUpdateResourceLimits
(projectRoot string, dockerMemGB int)
pkg/k8s/resources.go:75
↓ 1 callersFunctionUpdateTargetFilesWithTestID
(testID string)
pkg/utils/targets.go:12
↓ 1 callersFunctionUpdateUDPTarget
(projectRoot string, udpTargetHost string, udpTargetPort int)
pkg/k8s/deploy.go:57
↓ 1 callersFunctionValidateSpikeEvent
Validates a spike event
internal/spike/injector.go:258
↓ 1 callersFunctionVerifyPartitionIDs
()
pkg/k8s/verify.go:16
↓ 1 callersFunctionWaitForPods
(replicas int)
pkg/k8s/deploy.go:134
↓ 1 callersMethodapplyBandwidthLimit
Applies real bandwidth limiting
internal/spike/injector.go:226
↓ 1 callersMethodapplyDarwinBandwidth
Applies bandwidth limiting using dnctl for macOS
internal/network/degradation.go:289
↓ 1 callersMethodapplyDarwinLatency
Applies dnctl for latency on macOS
internal/network/degradation.go:226
↓ 1 callersMethodapplyDarwinPacketLoss
Applies pfctl and dnctl for packet loss on macOS
internal/network/degradation.go:139
↓ 1 callersFunctionapplyDefaults
(config *Config)
pkg/config/config.go:116
↓ 1 callersMethodapplyJitter
Applies real network jitter using OS network tools
internal/spike/injector.go:190
↓ 1 callersMethodapplyLinuxBandwidth
Applies bandwidth limiting using tc tbf for Linux
internal/network/degradation.go:269
↓ 1 callersMethodapplyLinuxLatency
Applies tc netem for latency on Linux
internal/network/degradation.go:191
↓ 1 callersMethodapplyLinuxPacketLoss
Applies tc netem for packet loss on Linux
internal/network/degradation.go:107
↓ 1 callersMethodapplyPacketLoss
Applies real packet loss using OS network tools
internal/spike/injector.go:156
↓ 1 callersMethodautoScaleOrchestrators
(participantCount int)
internal/client/k8s/manager.go:79
↓ 1 callersFunctionbuildICEServers
(id uint32)
internal/webrtc/ice_config.go:11
↓ 1 callersFunctioncalculateSafeParticipants
(dockerMemGB int)
tools/start/main.go:129
↓ 1 callersFunctioncheckPortConflict
()
tools/start/main.go:146
↓ 1 callersFunctionconfigureUDPTarget
(participantPool *pool.ParticipantPool)
internal/server/config.go:60
↓ 1 callersFunctionconnectKubernetesMode
(k8sMgr *client.KubernetesManager, connMgr *client.ConnectionManager, testID string, maxConnections int, parti
examples/webrtc_receiver.go:100
↓ 1 callersFunctionconnectLocalMode
(connMgr *client.ConnectionManager, baseURL, testID string, maxConnections int, connMu *sync.Mutex)
examples/webrtc_receiver.go:134
↓ 1 callersFunctioncontains
(s, substr string)
pkg/k8s/resources.go:152
↓ 1 callersFunctioncontainsAt
(s, substr string)
pkg/k8s/resources.go:156
↓ 1 callersMethodcreateParticipantIDExtension
()
internal/rtp/opus_packetizer.go:40
↓ 1 callersMethodcreatePeerConnection
()
internal/client/webrtc/connection.go:220
↓ 1 callersFunctioncreateTest
(client *utils.HTTPClient, cfg *config.Config, podCache *k8s.PodCache)
tools/chaos-test/main.go:74
↓ 1 callersMethoddetectDarwinInterface
Finds the default network interface on macOS
internal/network/degradation.go:64
↓ 1 callersMethoddetectLinuxInterface
Finds the default network interface on Linux
internal/network/degradation.go:41
↓ 1 callersFunctiondetectTURNHost
()
internal/client/client.go:79
↓ 1 callersMethoddiscoverConnectorPods
(participantCount int)
internal/client/k8s/manager.go:102
↓ 1 callersFunctiondisplayMetrics
(client *utils.HTTPClient, cfg *config.Config, podCache *k8s.PodCache, elapsed time.Duration, startTime, endTi
tools/chaos-test/main.go:169
↓ 1 callersMethoddistributeBackLoaded
(spikes []*pb.SpikeEvent, config *SpikeSchedulerConfig, startTime time.Time)
internal/scheduler/spike_scheduler.go:177
↓ 1 callersMethoddistributeEven
(spikes []*pb.SpikeEvent, config *SpikeSchedulerConfig, startTime time.Time)
internal/scheduler/spike_scheduler.go:102
↓ 1 callersMethoddistributeFrontLoaded
(spikes []*pb.SpikeEvent, config *SpikeSchedulerConfig, startTime time.Time)
internal/scheduler/spike_scheduler.go:153
↓ 1 callersMethoddistributeRandom
(spikes []*pb.SpikeEvent, config *SpikeSchedulerConfig, startTime time.Time)
internal/scheduler/spike_scheduler.go:129
↓ 1 callersMethoddistributeSpikes
distributeSpikes calculates execution times based on strategy
internal/scheduler/spike_scheduler.go:84
↓ 1 callersFunctionensureDockerMacOS
()
pkg/utils/docker.go:26
↓ 1 callersFunctionfile_proto_orchestrator_proto_init
()
internal/protobuf/orchestrator.pb.go:1911
↓ 1 callersFunctionfindParticipants
(httpClient *http.Client, baseURL, testID string, maxCount int)
internal/client/discovery.go:40
↓ 1 callersFunctionfindParticipantsInPod
(httpClient *http.Client, podURL, testID string, partitionID int, maxCount int)
internal/client/discovery.go:12
↓ 1 callersFunctionformatPrometheusMetrics
(session *TestSession, metrics *pb.MetricsResponse)
internal/server/metrics_handlers.go:96
↓ 1 callersMethodfragmentNALU
fragmentNALU splits a NALU into fragments
internal/rtp/packetizer.go:118
↓ 1 callersMethodgenerateSyntheticFrame
()
internal/pool/streaming.go:53
↓ 1 callersFunctiongetScriptDir
()
tools/start/main.go:181
↓ 1 callersMethodgetSpikeDistributionConfig
(req *pb.CreateTestRequest)
internal/server/http.go:244
↓ 1 callersFunctiongetTotalPartitions
(httpClient *http.Client, podURL string)
internal/client/discovery.go:136
↓ 1 callersFunctioninitMediaSource
()
internal/server/config.go:13
↓ 1 callersMethodisMyParticipant
(participantID uint32)
internal/server/http.go:69
↓ 1 callersMethodloadAudio
loads audio packets from a file
internal/media/source.go:147
↓ 1 callersMethodloadAudioSimple
loads audio using simple reader
internal/media/source.go:192
↓ 1 callersMethodloadVideo
loads video NAL units from a file
internal/media/source.go:106
↓ 1 callersFunctionlogConnectionMode
(testID string, maxConnections int)
examples/webrtc_receiver.go:90
↓ 1 callersMethodnextPacketLocked
Reads the next packet (must be called with mutex held)
internal/media/opus_reader.go:70
↓ 1 callersFunctionpacketizeH264
converts H.264 NALU to RTP packets with proper fragmentation
internal/webrtc/rtp_packetizer.go:9
↓ 1 callersFunctionparseFPS
parse a frame rate string like "30/1" or "29.97".
internal/media/probe.go:73
↓ 1 callersFunctionparseMaxConnections
()
examples/webrtc_receiver.go:82
↓ 1 callersFunctionprintConfiguration
(replicas, participants int, mediaConfig MediaConfig, dockerMem int)
tools/k8s-start/main.go:186
↓ 1 callersFunctionprintFinalStats
(connections []*client.ParticipantConnection, metricsMap map[uint32]*metrics.RTPMetrics, metricsMu *sync.Mutex
examples/webrtc_receiver.go:269
↓ 1 callersFunctionprintStats
(stats *PacketStats, totalPackets int)
examples/udp_receiver.go:120
↓ 1 callersFunctionprintStatsWithMetrics
(connections []*client.ParticipantConnection, metricsMap map[uint32]*metrics.RTPMetrics, metricsMu *sync.Mutex
examples/webrtc_receiver.go:197
↓ 1 callersFunctionprintUsage
()
examples/webrtc_receiver.go:67
↓ 1 callersFunctionprobeParticipants
(httpClient *http.Client, podURL, testID string, partitionID int, maxCount int)
internal/client/discovery.go:68
↓ 1 callersFunctionprobeParticipantsSingle
(httpClient *http.Client, baseURL, testID string, maxCount int)
internal/client/discovery.go:112
↓ 1 callersMethodprocessSDP
(pc *webrtc.PeerConnection, sdpResp SDPResponse, _ uint32, _ bool)
internal/client/webrtc/connection.go:295
↓ 1 callersMethodreceiveLoop
()
internal/rtcp/rtcp.go:331
↓ 1 callersFunctionrelayFromTCP
(tcpAddr string, udpConn *net.UDPConn, packetCount, byteCount, errorCount *int64)
tools/udp-relay/main.go:101
↓ 1 callersFunctionrelayTCPToUDP
(tcpAddr string, udpConn *net.UDPConn, udpAddr *net.UDPAddr, packetCount *int64, lastLogTime *time.Time)
pkg/k8s/relay.go:107
↓ 1 callersMethodremoveDarwinRules
Removes all pf/dnctl rules on macOS
internal/network/degradation.go:343
↓ 1 callersMethodremoveLinuxRules
Removes all tc rules on Linux
internal/network/degradation.go:331
↓ 1 callersMethodrunAudioLoop
()
internal/pool/streaming.go:136
↓ 1 callersFunctionrunDockerMode
(numParticipants, testDuration int, skipTest, autoDetect bool)
tools/start/main.go:42
↓ 1 callersFunctionrunK8sDeployment
(projectRoot string, userReplicas, userParticipants int, skipTest bool, udpTargetHost string, udpTargetPort in
tools/k8s-start/main.go:95
↓ 1 callersMethodrunMetricsAggregator
()
internal/pool/metrics_aggregator.go:12
↓ 1 callersMethodrunScheduler
(spikes []*ScheduledSpike)
internal/scheduler/spike_scheduler.go:234
↓ 1 callersFunctionrunStatsLoop
(connections []*client.ParticipantConnection, metricsMap map[uint32]*metrics.RTPMetrics, metricsMu *sync.Mutex
examples/webrtc_receiver.go:167
↓ 1 callersFunctionrunTestLoop
(client *utils.HTTPClient, cfg *config.Config, podCache *k8s.PodCache, sigChan chan os.Signal)
tools/chaos-test/main.go:124
↓ 1 callersMethodrunVideoLoop
()
internal/pool/streaming.go:87
↓ 1 callersMethodscaleConnectors
(replicas int)
internal/client/k8s/manager.go:225
↓ 1 callersMethodscheduleCleanup
(SpikeId string, duration time.Duration)
internal/spike/injector.go:104
← previousnext →201–300 of 654, ranked by callers