chat

type Config struct {
	// OrganizationID is the organization that owns the target workspace.
	OrganizationID uuid.UUID `json:"organization_id"`

	// WorkspaceID is the pre-existing workspace to use for this chat run.
	// When empty, the chat runs without workspace context.
	WorkspaceID uuid.UUID `json:"workspace_id"`

	// Prompt is the text content sent on every turn.
	Prompt string `json:"prompt"`

	// ModelConfigID is the scaletest mock LLM model config.
	ModelConfigID uuid.UUID `json:"model_config_id"`

	// Turns is the total number of user to assistant exchanges per chat.
	// Must be at least 1.
	Turns int `json:"turns"`

	// TurnStartDelay is the shared delay between every runner completing
	// its initial turn and the release of the follow-up turns. Set
	// to 0 to send all turns without an inter-phase pause.
	TurnStartDelay time.Duration `json:"turn_start_delay"`

	// TurnStartReadyWaitGroup coordinates the gap between the initial turn
	// finishing and the follow-up turns. Each runner signals exactly
	// once after its first turn reaches a terminal status, or when it
	// knows it will never reach that point.
	TurnStartReadyWaitGroup *sync.WaitGroup `json:"-"`

	// StartTurnsChan blocks follow-up turns until the CLI layer releases them.
	StartTurnsChan chan struct{} `json:"-"`

	Metrics *Metrics `json:"-"`
}

type Metrics struct {
	ChatCreateLatencySeconds        prometheus.Histogram
	ChatMessageLatencySeconds       *prometheus.HistogramVec
	ChatConversationDurationSeconds prometheus.Histogram
	ChatTimeToRunningSeconds        *prometheus.HistogramVec
	ChatTimeToFirstOutputSeconds    *prometheus.HistogramVec
	ChatTimeToTerminalStatusSeconds *prometheus.HistogramVec
	ChatStageFailuresTotal          *prometheus.CounterVec
	ChatTerminalStatusTotal         *prometheus.CounterVec
	ChatTurnsCompletedTotal         prometheus.Counter
	ChatRetryEventsTotal            prometheus.Counter
	ActiveChatStreams               prometheus.Gauge
}

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