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
↓ 2 callersFunctionparsePodNames
(output []byte)
internal/client/k8s/manager.go:246
↓ 2 callersMethodrunFrameLoop
()
internal/pool/streaming.go:13
↓ 2 callersMethodsetupPortForwards
(podNames []string, basePort int, podType string)
internal/client/k8s/manager.go:142
↓ 2 callersMethodshouldDropFrame
()
internal/pool/streaming.go:175
↓ 2 callersFunctionstopTest
(client *utils.HTTPClient, testID string, podCache *k8s.PodCache)
tools/chaos-test/main.go:112
↓ 2 callersMethodupdateCachedMetrics
()
internal/pool/metrics_aggregator.go:23
↓ 2 callersFunctionupdateMonitoringResources
(memRequest, memLimit string)
pkg/k8s/resources.go:135
↓ 1 callersMethodAddParticipant
(id uint32, video *pb.VideoConfig, audio *pb.AudioConfig, backendPort int)
internal/pool/participant.go:75
↓ 1 callersMethodAddWebRTCParticipant
(id uint32, participant WebRTCParticipant)
internal/pool/participant.go:108
↓ 1 callersFunctionBuildImage
(projectRoot, clusterName string)
pkg/k8s/deploy.go:16
↓ 1 callersFunctionCalculateOptimalReplicas
(dockerMemGB int)
pkg/utils/system.go:96
↓ 1 callersFunctionCalculateParticipantsPerPod
()
pkg/utils/system.go:114
↓ 1 callersMethodCalculateRTT
Calculate RTT from receiver report's LSR and DLSR fields
internal/rtcp/rtcp.go:82
↓ 1 callersFunctionCheckMetricsPartitions
(replicas int)
pkg/k8s/verify.go:77
↓ 1 callersFunctionCheckPrerequisites
(clusterName string)
pkg/k8s/cluster.go:86
↓ 1 callersFunctionCleanupCluster
(clusterName string)
pkg/k8s/cluster.go:56
↓ 1 callersMethodClose
Closes the H.264 reader
internal/media/h264_reader.go:138
↓ 1 callersMethodClose
()
internal/media/opus_reader.go:139
↓ 1 callersMethodClose
()
internal/media/opus_reader.go:199
↓ 1 callersFunctionCloseConnections
(connections []*ParticipantConnection)
internal/client/stats.go:61
↓ 1 callersMethodConnectBatch
(podURL, testID string, participantIDs []uint32, podName string, concurrency int, verbose bool)
internal/client/webrtc/connection.go:159
↓ 1 callersMethodConnectToParticipantWithRetry
(baseURL, testID string, participantID uint32, podName string, verbose bool)
internal/client/client.go:125
↓ 1 callersMethodConnectToPodParticipants
(podURL, testID string, pod *PodInfo, maxCount int, verbose bool)
internal/client/client.go:129
↓ 1 callersMethodConnectWithRetry
(baseURL, testID string, participantID uint32, podName string, verbose bool)
internal/client/webrtc/connection.go:142
↓ 1 callersFunctionConvertAudioToOpus
Convert audio file to Opus format
internal/media/converter.go:45
↓ 1 callersFunctionConvertVideoToH264
Convert a video file to H.264 Annex B format
internal/media/converter.go:17
↓ 1 callersFunctionDefaultConfig
()
internal/client/client.go:41
↓ 1 callersFunctionDefaultConfig
()
internal/client/udp/receiver.go:18
↓ 1 callersFunctionDeployK8s
(projectRoot string)
pkg/k8s/deploy.go:75
↓ 1 callersFunctionDetectCPUCores
()
pkg/utils/system.go:70
↓ 1 callersFunctionDetectSystemMemory
()
pkg/utils/system.go:10
↓ 1 callersMethodExecOnPod
(podName, command string)
pkg/k8s/pods.go:165
↓ 1 callersMethodFindParticipants
(baseURL, testID string, maxCount int)
internal/client/client.go:141
↓ 1 callersMethodFindParticipantsInPod
(podURL, testID string, partitionID int, maxCount int)
internal/client/client.go:137
↓ 1 callersFunctionGenerateIceCredentials
(ufragLength, passwordLength int)
pkg/utils/crypto.go:14
↓ 1 callersFunctionGenerateTargetFiles
(projectRoot string)
pkg/k8s/verify.go:151
↓ 1 callersFunctionGenerateTargetFilesWithTestID
(projectRoot string, testID string)
pkg/k8s/verify.go:155
↓ 1 callersMethodGetAudioCount
number of audio packets
internal/media/source.go:264
↓ 1 callersMethodGetMediaDuration
()
internal/media/source.go:277
↓ 1 callersMethodGetMetrics
()
internal/pool/virtual_participant.go:143
↓ 1 callersMethodGetNALType
()
internal/client/rtp/parser.go:78
↓ 1 callersMethodGetNackCount
()
internal/protobuf/orchestrator.pb.go:1225
↓ 1 callersMethodGetPacketLossFromSequence
()
pkg/metrics/stats.go:176
↓ 1 callersMethodGetParticipant
(id uint32)
internal/pool/participant.go:102
↓ 1 callersMethodGetPeerConnection
()
internal/pool/participant.go:45
↓ 1 callersMethodGetPliCount
()
internal/protobuf/orchestrator.pb.go:1232
↓ 1 callersFunctionGetPodCache
()
pkg/k8s/pods.go:29
↓ 1 callersMethodGetPodNames
()
pkg/k8s/pods.go:79
↓ 1 callersMethodGetPodURL
(pod *PodInfo)
internal/client/k8s/manager.go:64
↓ 1 callersMethodGetRealMetrics
()
internal/pool/participant.go:47
↓ 1 callersMethodGetSetup
()
internal/pool/virtual_participant.go:186
↓ 1 callersMethodGetStats
()
internal/webrtc/participant.go:193
↓ 1 callersMethodGetTotalPackets
()
internal/client/udp/receiver.go:77
↓ 1 callersMethodGetVideoCount
number of video NAL units
internal/media/source.go:257
↓ 1 callersMethodGetWebRTCConfiguration
()
internal/client/webrtc/connection.go:72
↓ 1 callersMethodHealthCheck
()
pkg/utils/http.go:77
↓ 1 callersMethodICEConnectionState
()
internal/server/handlers.go:206
↓ 1 callersMethodInitialize
()
pkg/k8s/pods.go:38
↓ 1 callersMethodInitialize
(config MediaConfig)
internal/media/source.go:51
↓ 1 callersFunctionInjectBitrateReduceSpike
(cfg *config.Config, podCache *k8s.PodCache, spikeID string, participants []int, duration int)
internal/spike/generator.go:138
↓ 1 callersFunctionInjectFrameDropSpike
(cfg *config.Config, podCache *k8s.PodCache, spikeID string, participants []int, duration int)
internal/spike/generator.go:118
↓ 1 callersFunctionInjectJitterSpike
(cfg *config.Config, podCache *k8s.PodCache, spikeID string, participants []int, duration int)
internal/spike/generator.go:93
↓ 1 callersFunctionInjectRandomSpike
(cfg *config.Config, podCache *k8s.PodCache, spikeNum int)
internal/spike/generator.go:14
↓ 1 callersMethodIsActive
Returns whether degradation is currently active
internal/network/degradation.go:360
↓ 1 callersMethodIsAudioPacket
()
internal/client/rtp/parser.go:74
↓ 1 callersMethodIsAvailable
()
internal/client/client.go:162
↓ 1 callersMethodIsVideoPacket
()
internal/client/rtp/parser.go:70
↓ 1 callersFunctionMustJSON
(v any)
pkg/utils/http.go:82
↓ 1 callersMethodNeedsRecreation
()
internal/pool/participant.go:46
↓ 1 callersFunctionNewConnectionManager
(config *Config)
internal/client/client.go:97
↓ 1 callersFunctionNewFeedbackStore
()
internal/rtcp/rtcp.go:54
↓ 1 callersFunctionNewH264FrameGenerator
(config VideoConfig)
internal/webrtc/frame_generator.go:17
↓ 1 callersFunctionNewH264Reader
(path string)
internal/media/h264_reader.go:32
↓ 1 callersFunctionNewHTTPClient
(baseURL string)
pkg/utils/http.go:17
↓ 1 callersMethodNewHTTPClient
()
internal/client/client.go:64
↓ 1 callersFunctionNewHTTPServer
(addr string)
internal/server/http.go:55
↓ 1 callersFunctionNewInjector
()
internal/spike/injector.go:41
↓ 1 callersFunctionNewKubernetesManager
(config *Config)
internal/client/client.go:149
↓ 1 callersFunctionNewManager
(config *Config)
internal/client/webrtc/connection.go:85
↓ 1 callersFunctionNewManager
(config *Config)
internal/client/k8s/manager.go:35
↓ 1 callersFunctionNewOggReader
(path string)
internal/media/opus_reader.go:31
↓ 1 callersFunctionNewOpusPacketizer
(participantID uint32, payloadType uint8, clockRate uint32)
internal/rtp/opus_packetizer.go:13
↓ 1 callersFunctionNewParticipant
(id uint32, config VideoConfig)
internal/webrtc/participant.go:45
↓ 1 callersFunctionNewParticipantPool
(testID string)
internal/pool/participant.go:50
↓ 1 callersFunctionNewServer
(port int)
internal/rtcp/rtcp.go:287
↓ 1 callersFunctionNewSimpleOpusReader
(path string)
internal/media/opus_reader.go:157
↓ 1 callersFunctionNewSpikeScheduler
(config *SpikeSchedulerConfig, injectFunc SpikeInjectFunc)
internal/scheduler/spike_scheduler.go:48
↓ 1 callersFunctionNewStats
()
internal/client/udp/receiver.go:40
↓ 1 callersFunctionNewVirtualParticipant
(id uint32, video *pb.VideoConfig, audio *pb.AudioConfig, backendPort int)
internal/pool/virtual_participant.go:58
↓ 1 callersMethodNextNAL
NextNAL reads the next NAL unit from the H.264 stream H.264 Annex B format uses start codes: 0x00 0x00 0x01 or 0x00 0x00 0x00 0x01
internal/media/h264_reader.go:47
↓ 1 callersMethodNextPacket
()
internal/media/opus_reader.go:62
↓ 1 callersMethodNextPacket
Reads the next Opus packet (assumes 20ms frames at 48kHz) For raw Opus, we read fixed-size chunks
internal/media/opus_reader.go:170
↓ 1 callersFunctionParsePacket
(data []byte)
internal/client/rtp/parser.go:24
↓ 1 callersFunctionParsePacket
(data []byte)
internal/rtp/helpers.go:15
↓ 1 callersFunctionParsePodNames
(output string)
pkg/k8s/pods.go:199
↓ 1 callersFunctionParseReceiverReport
Parses an RTCP Receiver Report packet
internal/rtcp/rtcp.go:162
↓ 1 callersFunctionProbeMedia
(path string)
internal/media/probe.go:18
↓ 1 callersFunctionPrometheusTemplate
()
pkg/k8s/prometheus.go:97
↓ 1 callersMethodRecordPacket
(header *rtp.Header, packetSize int)
internal/client/udp/receiver.go:49
↓ 1 callersMethodRecordPacketReceived
(rtpTimestamp uint32, seqNum uint16, size int)
pkg/metrics/stats.go:74
← previousnext →101–200 of 654, ranked by callers