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
↓ 78 callersFunctionLogInfo
(format string, args ...any)
pkg/logging/logger.go:16
↓ 47 callersMethodError
()
internal/rtp/packetizer.go:253
↓ 39 callersMethodClose
()
internal/pool/participant.go:44
↓ 33 callersFunctionLogWarning
(format string, args ...any)
pkg/logging/logger.go:24
↓ 25 callersFunctionfile_proto_orchestrator_proto_rawDescGZIP
()
internal/protobuf/orchestrator.pb.go:1838
↓ 23 callersFunctionLogSuccess
(format string, args ...any)
pkg/logging/logger.go:20
↓ 18 callersFunctionLogError
(format string, args ...any)
pkg/logging/logger.go:28
↓ 18 callersMethodString
()
internal/protobuf/orchestrator.pb.go:846
↓ 17 callersFunctionFindCommand
(name string)
pkg/utils/exec.go:9
↓ 15 callersMethodGet
(path string)
pkg/utils/http.go:26
↓ 15 callersMethodStop
()
internal/pool/participant.go:43
↓ 14 callersFunctionLogMetrics
(format string, args ...any)
pkg/logging/logger.go:45
↓ 13 callersFunctionLogChaos
(format string, args ...any)
pkg/logging/logger.go:32
↓ 13 callersFunctionLogSimple
(format string, args ...any)
pkg/logging/logger.go:40
↓ 12 callersFunctionGetIntParam
(params map[string]any, key string, defaultVal int)
pkg/config/config.go:193
↓ 10 callersMethodPost
(path string, body any)
pkg/utils/http.go:41
↓ 10 callersMethodStart
()
internal/pool/participant.go:42
↓ 8 callersMethodGetJitter
()
pkg/metrics/stats.go:148
↓ 8 callersFunctionGetProjectRoot
()
pkg/config/config.go:205
↓ 8 callersMethodMarshal
Marshal serializes an RTP packet to bytes
internal/rtp/packetizer.go:148
↓ 8 callersMethodgetTestSession
(r *http.Request)
internal/server/http.go:104
↓ 7 callersFunctionNewDegrader
()
internal/network/degradation.go:21
↓ 7 callersMethodPacketize
Packetize converts a frame into RTP packets with FU-A fragmentation
internal/rtp/packetizer.go:53
↓ 6 callersFunctionGetFloat64
(m map[string]any, key string)
pkg/utils/http.go:87
↓ 6 callersMethodGetPacketLoss
()
pkg/metrics/stats.go:209
↓ 6 callersMethodRecordPacketLost
()
pkg/metrics/stats.go:129
↓ 6 callersFunctionTimestamp
Current time formatted as ISO 8601 with milliseconds
pkg/logging/logger.go:12
↓ 5 callersFunctionGetEnvOrDefault
(key, defaultValue string)
pkg/utils/env.go:8
↓ 5 callersMethodGetJitterP99
()
pkg/metrics/stats.go:154
↓ 5 callersMethodGetMOS
GetMOS calculates Mean Opinion Score using ITU-T G.107 E-model Returns value between 1.0 (bad) and 4.5 (excellent)
pkg/metrics/stats.go:253
↓ 5 callersFunctionLogConfig
(format string, args ...any)
pkg/logging/logger.go:36
↓ 5 callersFunctionNewH264Packetizer
(participantID uint32, payloadType uint8, clockRate uint32)
internal/rtp/packetizer.go:42
↓ 5 callersFunctionapplyJitter
(d time.Duration, jitterPercent int)
internal/scheduler/scheduler.go:297
↓ 4 callersMethodBroadcastSpike
(testID string, spike any)
pkg/k8s/pods.go:97
↓ 4 callersFunctionCalculateMOS
CalculateMOS calculates Mean Opinion Score using ITU-T G.107 E-model Returns value between 1.0 (bad) and 4.5 (excellent)
pkg/utils/mos.go:7
↓ 4 callersMethodGetAudioPacket
Returns the audio packet at the given index, or nil if past end
internal/media/source.go:231
↓ 4 callersMethodGetMetrics
Returns metrics for a given SSRC
internal/rtcp/rtcp.go:120
↓ 4 callersMethodGetRTT
()
pkg/metrics/stats.go:222
↓ 4 callersMethodGetVideoNAL
Returns the NAL unit at the given index, or nil if past end
internal/media/source.go:219
↓ 4 callersMethodIsAvailable
()
pkg/k8s/pods.go:91
↓ 4 callersMethodName
()
internal/scheduler/scheduler.go:13
↓ 4 callersMethodRemoveAll
()
internal/spike/injector.go:129
↓ 4 callersMethodSetTarget
(host string, port int)
internal/pool/participant.go:67
↓ 3 callersMethodCleanup
()
internal/client/k8s/manager.go:72
↓ 3 callersFunctionCleanupTargetFiles
()
pkg/utils/targets.go:54
↓ 3 callersFunctionCommandExists
(name string)
pkg/utils/exec.go:25
↓ 3 callersMethodConnect
(baseURL, testID string, participantID uint32, podName string, verbose bool)
internal/client/webrtc/connection.go:89
↓ 3 callersMethodConnectionState
()
internal/server/handlers.go:207
↓ 3 callersFunctionDefaultConfig
()
internal/scheduler/scheduler.go:36
↓ 3 callersFunctionDefaultSpikeSchedulerConfig
()
internal/scheduler/spike_scheduler.go:39
↓ 3 callersFunctionEnsureDockerRunning
()
pkg/utils/docker.go:11
↓ 3 callersMethodExecOnAllPods
(command string)
pkg/k8s/pods.go:178
↓ 3 callersMethodGetBitrateKbps
()
pkg/metrics/stats.go:228
↓ 3 callersMethodGetBytesSent
()
pkg/metrics/stats.go:248
↓ 3 callersFunctionGetEnvInt
(key string, defaultValue int)
pkg/utils/env.go:15
↓ 3 callersMethodGetFirCount
()
pkg/metrics/stats.go:207
↓ 3 callersMethodGetFramesSent
()
pkg/metrics/stats.go:247
↓ 3 callersFunctionGetGlobalMediaSource
()
internal/media/source.go:41
↓ 3 callersMethodGetNackCount
()
pkg/metrics/stats.go:205
↓ 3 callersMethodGetPacketsSent
()
pkg/metrics/stats.go:249
↓ 3 callersMethodGetPliCount
()
pkg/metrics/stats.go:206
↓ 3 callersMethodGetWebRTCParticipant
(id uint32)
internal/pool/participant.go:121
↓ 3 callersMethodInject
(spike *pb.SpikeEvent)
internal/spike/injector.go:48
↓ 3 callersMethodInjectSpike
(spike *pb.SpikeEvent)
internal/pool/participant.go:195
↓ 3 callersFunctionNewRTPMetrics
(participantID uint32)
pkg/metrics/stats.go:50
↓ 3 callersMethodRecordPacketSent
(size int)
pkg/metrics/stats.go:62
↓ 3 callersFunctionShowPodStatus
()
pkg/k8s/deploy.go:172
↓ 3 callersFunctionUnmarshal
Unmarshal parses an RTP packet from bytes
internal/rtp/packetizer.go:200
↓ 3 callersMethodapplyJitterDelay
()
internal/pool/streaming.go:205
↓ 3 callersMethoddiscoverOrchestratorPods
()
internal/client/k8s/manager.go:126
↓ 3 callersMethodshouldDropPacket
()
internal/pool/streaming.go:190
↓ 2 callersMethodAddICECandidate
(candidate string)
internal/pool/participant.go:41
↓ 2 callersMethodAddSpike
(spike *pb.SpikeEvent)
internal/pool/virtual_participant.go:116
↓ 2 callersMethodApplyBandwidthLimit
Applies bandwidth limiting
internal/network/degradation.go:254
↓ 2 callersMethodApplyLatency
Applies network latency
internal/network/degradation.go:176
↓ 2 callersMethodApplyPacketLoss
Applies packet loss using OS-specific tools
internal/network/degradation.go:88
↓ 2 callersFunctionCalculateResourceConfig
(dockerMemGB int)
pkg/k8s/resources.go:28
↓ 2 callersFunctionCleanupResources
()
pkg/k8s/verify.go:133
↓ 2 callersMethodCreateOffer
()
internal/pool/participant.go:39
↓ 2 callersFunctionDetectDockerMemory
()
pkg/utils/system.go:40
↓ 2 callersMethodDiscoverPodsWithScale
(participantCount int)
internal/client/k8s/manager.go:54
↓ 2 callersMethodExecute
Execute runs the work function for each scheduled item Returns when all items complete or context is cancelled
internal/scheduler/scheduler.go:251
↓ 2 callersFunctionGenerateRandomBytes
(length int)
pkg/utils/crypto.go:8
↓ 2 callersFunctionGetGlobalFeedback
()
internal/rtcp/rtcp.go:64
↓ 2 callersMethodGetMetrics
()
internal/pool/metrics_aggregator.go:125
↓ 2 callersMethodGetMetricsWithRTCP
(feedback *rtcp.FeedbackStore)
internal/pool/virtual_participant.go:147
↓ 2 callersMethodGetTotalAudioFrames
()
internal/media/source.go:289
↓ 2 callersMethodGetTotalVideoFrames
()
internal/media/source.go:283
↓ 2 callersFunctionInjectPacketLossSpike
(cfg *config.Config, podCache *k8s.PodCache, spikeID string, participants []int, duration int)
internal/spike/generator.go:65
↓ 2 callersMethodIsAudioEnabled
is audio streaming enabled
internal/media/source.go:250
↓ 2 callersMethodIsVideoEnabled
is video streaming enabled
internal/media/source.go:243
↓ 2 callersFunctionLoad
(path string)
pkg/config/config.go:93
↓ 2 callersMethodNextFrame
()
internal/webrtc/frame_generator.go:21
↓ 2 callersMethodRecordFrameDropped
()
pkg/metrics/stats.go:131
↓ 2 callersMethodRemove
(SpikeId string)
internal/spike/injector.go:109
↓ 2 callersFunctionSetupCluster
(clusterName string)
pkg/k8s/cluster.go:15
↓ 2 callersMethodSize
()
internal/pool/participant.go:249
↓ 2 callersMethodStateValue
()
internal/server/http.go:42
↓ 2 callersMethodcreateParticipantIDExtension
Creates the custom participant_id extension
internal/rtp/packetizer.go:136
↓ 2 callersFunctiongenerateOpusFrame
(participantID uint32, seq uint16)
internal/webrtc/frame_generator.go:59
next →1–100 of 654, ranked by callers