core

type AssignmentSelector struct {
	Role          string
	UserIDPattern string
	UserIndexMin  *int
	UserIndexMax  *int
}

type CameraConfig struct {
	PerRoom    int
	FileType   string
	VideoCodec string
	Directory  string
	InMemory   bool
	// MixedRole makes the PerRoom camera-holding participants act as full
	// conference participants (publish AND subscribe) rather than send-only.
	// Set PerRoom == usersPerRoom for an all-participants-send-and-receive
	// conference. Honored by the default scenario; LiveKit-only at the plugin
	// layer.
	MixedRole bool
	SVC       SVCCameraConfig
}

type ChurnScenario struct{}

type Client struct {
	// contains filtered or unexported fields
}

type ConferenceConfig struct {
	Name               string
	UsersPerRoom       int
	TotalRooms         int
	StatsBufferSize    int
	StatsInputChanSize int
	Cameras            CameraConfig
	JoinPolicy         JoinPolicyConfig
	Recording          RecordingConfig
	PacketCapture      PacketCaptureConfig
}

type Config struct {
	APIVersion string
	Kind       string
	Metadata   MetadataConfig
	Spec       SpecConfig
}

type ConnectionState int

type DefaultScenario struct{}

type FreezeDetector struct {
	// contains filtered or unexported fields
}

type GaugeSummary struct {
	Scenario string
	Plugin   string
	Role     string
	Name     string
	Profile  string
	UserID   string
	Current  float64
	Peak     float64
}

type HistogramSnapshot struct {
	Count        int64
	Sum          float64
	Min          float64
	Max          float64
	BucketBounds []float64
	BucketCounts []uint64
}

type HistogramSummary struct {
	Scenario    string
	Plugin      string
	Role        string
	Name        string
	Count       int64
	MeanSeconds float64
	MinSeconds  float64
	MaxSeconds  float64
	P50Seconds  float64
	P95Seconds  float64
	P99Seconds  float64
}

type ImpairmentAssignment struct {
	Match   AssignmentSelector
	Profile string
}

type ImpairmentConfig struct {
	Profiles    map[string]*ImpairmentProfile
	Assignments []ImpairmentAssignment
	Default     string
}

type ImpairmentProfile struct {
	Name         string
	BandwidthBps int
	BaseLatency  time.Duration
	JitterStddev time.Duration
	LossPercent  int
	Seed         int64
}

type JoinPolicyConfig struct {
	Concurrency            int
	AlwaysRetryFailedJoins bool
	JoinStartSpacing       time.Duration
}

type JoinRequest struct {
	RoomID string
	Plugin string
}

type Labels map[string]string

type LeaveRequest struct {
	RoomID string
	Plugin string
}

type LogStreamConfig struct {
	Name  string
	Level string
}

type LoggingConfig struct {
	Console      bool
	ConsoleLevel string
	Color        bool
	Directory    string
	FileLevel    string
	Combined     bool
	Streams      []LogStreamConfig
}

type MetadataConfig struct {
	Name string
}

type MetricsCollector interface {
	IncCounter(name string, value int64, labels Labels)
	ObserveHistogram(name string, value float64, labels Labels)
	SetGauge(name string, value float64, labels Labels)
}

type MetricsConfig struct {
	Port               int
	StatsJSONLPath     string
	Thresholds         []RunThresholdConfig
	ReceiverThresholds []ReceiverThresholdConfig
}

type NetworkConfig struct {
	ServerIP   string
	ServerPort int
	ClientIP   string
	Impairment *ImpairmentConfig
}

type OperationSummary struct {
	Scenario    string
	Plugin      string
	Role        string
	Operation   string
	Attempts    int64
	Successes   int64
	Failures    int64
	FailureRate float64
	MeanSeconds float64
	P50Seconds  float64
	P95Seconds  float64
	P99Seconds  float64
}

type PacketCaptureConfig struct {
	Enabled   bool
	Directory string
}

type Participant interface {
	JoinRoom(ctx context.Context, req *JoinRequest) error
	LeaveRoom(ctx context.Context, req *LeaveRequest) error
	Close() error
}

type Plugin interface {
	Setup(ctx context.Context, e PluginEnv) error
	Shutdown(ctx context.Context) error
	NewParticipant(ctx context.Context, cfg *UserConfig) (Participant, error)
}

type PluginEnv interface {
	Config() *Config
	LogRegistry() *log.Registry
	StatsConsumers() []func(vp9_stats.Period, vp9_stats.VideoQualitySample)
	ImpairmentRouter() *pionutil.ImpairmentRouter
	ObserveReceiverRTT(userID string, rtt time.Duration)
}

type PluginFactory func() Plugin

type PluginRegistry map[string]PluginFactory

type PublishVideoRequest struct {
	RoomID string
	Plugin string
}

type ReceiverSummary struct {
	Scenario            string
	Plugin              string
	Role                string
	Profile             string
	UserID              string
	FreezeCount         int64
	FreezeDurationTotal float64
	FrameLossRatio      float64
	MeanBitrateBps      float64
	MeanFPS             float64
	MaxJitterUS         float64
	MeanRTTMS           float64
	MaxRTTMS            float64
	PliCount            int64
	NackCount           int64
}

type ReceiverThresholdConfig struct {
	Scenario          string
	Plugin            string
	Profile           string
	UserID            string
	MaxFreezeCount    *int64
	MaxFreezeDuration *float64
	MaxFrameLossRatio *float64
	MinBitrateBps     *float64
	MinFPS            *float64
	MaxJitterUS       *float64
	MaxMeanRTTMS      *float64
	MaxPLICount       *int64
}

type ReceiverThresholdFailure struct {
	Threshold ReceiverThresholdConfig
	Actual    ReceiverSummary
	Reason    string
}

type RecordingConfig struct {
	Enabled   bool
	Directory string
}

type RunMetricsSnapshot struct {
	Counters   map[string]int64
	Gauges     map[string]float64
	GaugePeaks map[string]float64
	Histograms map[string]HistogramSnapshot
	Receivers  []ReceiverSummary
}

type RunMetricsSummary struct {
	Operations []OperationSummary
	Sessions   []HistogramSummary
	Gauges     []GaugeSummary
	Receivers  []ReceiverSummary
}

type RunThresholdConfig struct {
	Op             string
	Scenario       string
	Plugin         string
	Role           string
	MaxFailureRate *float64
	MaxMean        *time.Duration
	MaxP95         *time.Duration
	MaxP99         *time.Duration
}

type SVCCameraConfig struct {
	Mode           string // "auto" (default), "on", "off"
	SpatialLayers  int    // 1-3 when Mode="on", 0 = auto-detect from IVF
	TemporalLayers int    // 1-3 when Mode="on", 0 = auto-detect from IVF
}

type Scenario interface {
	Run(ctx context.Context, env ScenarioEnv) error
}

type ScenarioEnv interface {
	Config() *Config
	Client() *Client
	Log() *log.Logger
}

type ScenarioFactory func() Scenario

type ScenarioRegistry map[string]ScenarioFactory

type SpecConfig struct {
	Plugin         string
	Scenario       string
	ScenarioConfig map[string]any
	Conference     ConferenceConfig
	Network        NetworkConfig
	PluginConfig   map[string]any
	Logging        LoggingConfig
	Metrics        MetricsConfig
}

type StatsPipeline struct {
	ViewerManager *viewer.Manager
	Publisher     *vp9_stats.Publisher
}

type ThresholdFailure struct {
	Threshold RunThresholdConfig
	Actual    OperationSummary
	Reason    string
}

type UnpublishVideoRequest struct {
	RoomID string
	Plugin string
}

type User struct {
	// contains filtered or unexported fields
}

type UserConfig struct {
	UserID            string
	Role              UserRole
	ImpairmentProfile *ImpairmentProfile
}

type UserMetrics struct {
	JoinAttempts               int64
	JoinSuccesses              int64
	JoinFailures               int64
	JoinLatencyTotal           time.Duration
	LeaveAttempts              int64
	LeaveSuccesses             int64
	LeaveFailures              int64
	LeaveLatencyTotal          time.Duration
	PublishVideoAttempts       int64
	PublishVideoSuccesses      int64
	PublishVideoFailures       int64
	PublishVideoLatencyTotal   time.Duration
	UnpublishVideoAttempts     int64
	UnpublishVideoSuccesses    int64
	UnpublishVideoFailures     int64
	UnpublishVideoLatencyTotal time.Duration
	CloseAttempts              int64
	CloseSuccesses             int64
	CloseFailures              int64
	CloseLatencyTotal          time.Duration
}

type UserRole string

type VideoPublisher interface {
	PublishVideo(ctx context.Context, req *PublishVideoRequest) error
	UnpublishVideo(ctx context.Context, req *UnpublishVideoRequest) error
}

type YAMLAssignmentSelector struct {
	Role           *string `yaml:"role,omitempty"`
	UserIDPattern  *string `yaml:"userIDPattern,omitempty"`
	UserIndexRange *[2]int `yaml:"userIndexRange,omitempty"`
}

type YAMLCameraConfig struct {
	PerRoom    *int              `yaml:"perRoom,omitempty"`
	FileType   *string           `yaml:"fileType,omitempty"`
	VideoCodec *string           `yaml:"videoCodec,omitempty"`
	Directory  *string           `yaml:"directory,omitempty"`
	InMemory   *bool             `yaml:"inMemory,omitempty"`
	MixedRole  *bool             `yaml:"mixedRole,omitempty"`
	SVC        *YAMLSVCCamConfig `yaml:"svc,omitempty"`
}

type YAMLConferenceConfig struct {
	// Name conference room identifier
	Name *string `yaml:"name,omitempty"`
	// UsersPerRoom number of users per conference room
	UsersPerRoom *int `yaml:"usersPerRoom,omitempty"`
	// TotalRooms defaults to 1
	TotalRooms *int `yaml:"totalRooms,omitempty"`
	// StatsBufferSize optional ring buffer size for video quality stats (default 768)
	StatsBufferSize *int `yaml:"statsBufferSize,omitempty"`
	// StatsInputChanSize optional channel buffer size for stats input (default 65536)
	StatsInputChanSize *int `yaml:"statsInputChanSize,omitempty"`
	// Cameras optional config for some (or all) users to turn on their cameras
	Cameras    *YAMLCameraConfig     `yaml:"cameras,omitempty"`
	JoinPolicy *YAMLJoinPolicyConfig `yaml:"joinPolicy,omitempty"`
	// Recording optional section, defaults to disabled
	Recording *YAMLRecordingConfig `yaml:"recording,omitempty"`
	// PacketCapture optional section, defaults to disabled
	PacketCapture *YAMLPacketCaptureConfig `yaml:"packetCapture,omitempty"`
}

type YAMLConfig struct {
	APIVersion *string             `yaml:"apiVersion,omitempty"`
	Kind       *string             `yaml:"kind,omitempty"`
	Metadata   *YAMLMetadataConfig `yaml:"metadata,omitempty"`
	Spec       *YAMLSpecConfig     `yaml:"spec,omitempty"`
}

type YAMLImpairmentAssignment struct {
	Match   YAMLAssignmentSelector `yaml:"match"`
	Profile string                 `yaml:"profile"`
}

type YAMLImpairmentConfig struct {
	Profiles    map[string]*YAMLImpairmentProfile `yaml:"profiles"`
	Assignments []YAMLImpairmentAssignment        `yaml:"assignments,omitempty"`
	Default     string                            `yaml:"default"`
}

type YAMLImpairmentProfile struct {
	BandwidthKbps *int    `yaml:"bandwidthKbps,omitempty"`
	Latency       *string `yaml:"latency,omitempty"`
	Jitter        *string `yaml:"jitter,omitempty"`
	LossPercent   *int    `yaml:"lossPercent,omitempty"`
	Seed          *int64  `yaml:"seed,omitempty"`
}

type YAMLJoinPolicyConfig struct {
	Concurrency            *int `yaml:"concurrency,omitempty"`
	AlwaysRetryFailedJoins bool `yaml:"alwaysRetryFailedJoins,omitempty"`
	// JoinStartSpacing optional duration parsed with time.ParseDuration (e.g. "2s")
	JoinStartSpacing *string `yaml:"joinStartSpacing,omitempty"`
}

type YAMLLogStreamConfig struct {
	Name  *string `yaml:"name,omitempty"`
	Level *string `yaml:"level,omitempty"`
}

type YAMLLoggingConfig struct {
	Console      bool                  `yaml:"console"`
	ConsoleLevel *string               `yaml:"consoleLevel,omitempty"`
	Color        *bool                 `yaml:"color,omitempty"`
	Directory    *string               `yaml:"directory,omitempty"`
	FileLevel    *string               `yaml:"fileLevel,omitempty"`
	Combined     *bool                 `yaml:"combined,omitempty"`
	Streams      []YAMLLogStreamConfig `yaml:"streams,omitempty"`
}

type YAMLMetadataConfig struct {
	Name *string `yaml:"name,omitempty"`
}

type YAMLMetricsConfig struct {
	Port               *int                          `yaml:"port,omitempty"`
	StatsJSONLPath     *string                       `yaml:"statsJSONLPath,omitempty"`
	Thresholds         []YAMLRunThresholdConfig      `yaml:"thresholds,omitempty"`
	ReceiverThresholds []YAMLReceiverThresholdConfig `yaml:"receiverThresholds,omitempty"`
}

type YAMLNetworkConfig struct {
	ServerIP   *string               `yaml:"serverIP,omitempty"`
	ServerPort *int                  `yaml:"serverPort,omitempty"`
	ClientIP   *string               `yaml:"clientIP,omitempty"`
	Impairment *YAMLImpairmentConfig `yaml:"impairment,omitempty"`
}

type YAMLPacketCaptureConfig struct {
	Enabled   *bool   `yaml:"enabled,omitempty"`
	Directory *string `yaml:"directory,omitempty"`
}

type YAMLReceiverThresholdConfig struct {
	Scenario          *string  `yaml:"scenario,omitempty"`
	Plugin            *string  `yaml:"plugin,omitempty"`
	Profile           *string  `yaml:"profile,omitempty"`
	UserID            *string  `yaml:"userID,omitempty"`
	MaxFreezeCount    *int64   `yaml:"maxFreezeCount,omitempty"`
	MaxFreezeDuration *float64 `yaml:"maxFreezeDuration,omitempty"`
	MaxFrameLossRatio *float64 `yaml:"maxFrameLossRatio,omitempty"`
	MinBitrateBps     *float64 `yaml:"minBitrateBps,omitempty"`
	MinFPS            *float64 `yaml:"minFPS,omitempty"`
	MaxJitterUS       *float64 `yaml:"maxJitterUS,omitempty"`
	MaxMeanRTTMS      *float64 `yaml:"maxMeanRTTMS,omitempty"`
	MaxPLICount       *int64   `yaml:"maxPLICount,omitempty"`
}

type YAMLRecordingConfig struct {
	Enabled   *bool   `yaml:"enabled,omitempty"`
	Directory *string `yaml:"directory,omitempty"`
}

type YAMLRunThresholdConfig struct {
	Op             *string  `yaml:"op,omitempty"`
	Scenario       *string  `yaml:"scenario,omitempty"`
	Plugin         *string  `yaml:"plugin,omitempty"`
	Role           *string  `yaml:"role,omitempty"`
	MaxFailureRate *float64 `yaml:"maxFailureRate,omitempty"`
	MaxMean        *string  `yaml:"maxMean,omitempty"`
	MaxP95         *string  `yaml:"maxP95,omitempty"`
	MaxP99         *string  `yaml:"maxP99,omitempty"`
}

type YAMLSVCCamConfig struct {
	Mode           *string `yaml:"mode,omitempty"`
	SpatialLayers  *int    `yaml:"spatialLayers,omitempty"`
	TemporalLayers *int    `yaml:"temporalLayers,omitempty"`
}

type YAMLSpecConfig struct {
	Plugin         *string               `yaml:"plugin,omitempty"`
	Scenario       *string               `yaml:"scenario,omitempty"`
	ScenarioConfig map[string]any        `yaml:"scenarioConfig,omitempty"`
	Conference     *YAMLConferenceConfig `yaml:"conference,omitempty"`
	Network        *YAMLNetworkConfig    `yaml:"network,omitempty"`
	PluginConfig   map[string]any        `yaml:"pluginConfig,omitempty"`
	Logging        *YAMLLoggingConfig    `yaml:"logging,omitempty"`
	Metrics        *YAMLMetricsConfig    `yaml:"metrics,omitempty"`
}