streaming

type BufferStats struct {
	CurrentSize  int     `json:"current_size"`
	Capacity     int     `json:"capacity"`
	TotalLines   int64   `json:"total_lines"`
	IsFull       bool    `json:"is_full"`
	UsagePercent float64 `json:"usage_percent"`
}

type ChainMode string

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

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

type FileWatcher struct {
	FilePath   string
	IsRemote   bool
	NodeID     string
	LastOffset int64
}

type FilterChain struct {
	ID          string          `json:"id"`
	Name        string          `json:"name"`
	Description string          `json:"description"`
	Filters     []*StreamFilter `json:"filters"`
	Mode        ChainMode       `json:"mode"` // AND or OR
	Active      bool            `json:"active"`
}

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

type FilterPreset struct {
	ID          string          `json:"id"`
	Name        string          `json:"name"`
	Description string          `json:"description"`
	Category    string          `json:"category"`
	Filters     []*StreamFilter `json:"filters"`
	Tags        []string        `json:"tags"`
	Created     time.Time       `json:"created"`
	LastUsed    time.Time       `json:"last_used"`
	UseCount    int             `json:"use_count"`
}

type FilterStats struct {
	MatchCount     int64     `json:"match_count"`
	ProcessedLines int64     `json:"processed_lines"`
	LastMatch      time.Time `json:"last_match"`
	Created        time.Time `json:"created"`
}

type FilterType string

type FilteredStreamManager struct {
	*StreamManager
	// contains filtered or unexported fields
}

type JobStream struct {
	JobID       string               // SLURM job ID
	OutputType  string               // "stdout" or "stderr"
	Buffer      *CircularBuffer      // Memory-efficient output storage
	FilePath    string               // Path to output file
	LastOffset  int64                // File offset for tailing
	IsActive    bool                 // Whether streaming is active
	IsRemote    bool                 // Local or remote file
	NodeID      string               // For remote files
	Subscribers []chan<- StreamEvent // Event subscribers
	FileWatcher *FileWatcher         // Individual file watcher
	LastUpdate  time.Time            // Last update timestamp

}

type LogLevel string

type Match struct {
	Start int    `json:"start"`
	End   int    `json:"end"`
	Text  string `json:"text"`
}

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

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

type SearchOptions struct {
	CaseSensitive bool `json:"case_sensitive"`
	WholeWord     bool `json:"whole_word"`
	UseRegex      bool `json:"use_regex"`
	ContextLines  int  `json:"context_lines"` // Number of lines before/after to include
	MaxResults    int  `json:"max_results"`   // Limit number of results
	Reverse       bool `json:"reverse"`       // Search from bottom to top
}

type SearchResult struct {
	LineNumber int      `json:"line_number"`
	Line       string   `json:"line"`
	Matches    []Match  `json:"matches"`
	Context    []string `json:"context,omitempty"` // Lines before/after for context
}

type SlurmConfig struct {
	// File paths (fallback when SLURM API doesn't provide paths)
	OutputDir    string `json:"output_dir"`    // Default: /var/spool/slurm/slurmd/job_output
	ErrorDir     string `json:"error_dir"`     // Usually same as OutputDir
	FilePattern  string `json:"file_pattern"`  // Default: "slurm-{jobid}.out"
	ErrorPattern string `json:"error_pattern"` // Default: "slurm-{jobid}.err"

	// Node configuration
	RemoteAccess bool     `json:"remote_access"` // Enable SSH for remote files
	LocalNodes   []string `json:"local_nodes"`   // Nodes accessible via local filesystem
	SSHUser      string   `json:"ssh_user"`      // Default SSH username
	SSHKeyPath   string   `json:"ssh_key_path"`  // SSH private key path

	// Performance tuning
	FileCheckInterval time.Duration `json:"file_check_interval"` // 1s
	MaxFileSize       int64         `json:"max_file_size"`       // 100MB
	BufferSize        int           `json:"buffer_size"`         // 10000 lines
}

type Stats struct {
	ActiveStreams int           `json:"active_streams"`
	TotalStreams  int           `json:"total_streams"`
	MemoryUsage   int64         `json:"memory_usage_bytes"`
	TotalEvents   int64         `json:"total_events"`
	ErrorCount    int64         `json:"error_count"`
	Uptime        time.Duration `json:"uptime"`
	LastError     error         `json:"last_error,omitempty"`
	LastErrorTime time.Time     `json:"last_error_time,omitempty"`
}

type StreamConfig struct {
	MaxConcurrentStreams int           `json:"max_concurrent_streams"` // Default: 4
	BufferSize           int           `json:"buffer_size_lines"`      // Default: 10000
	PollInterval         time.Duration `json:"poll_interval"`          // Default: 2s
	MaxMemoryMB          int           `json:"max_memory_mb"`          // Default: 50
	AutoScroll           bool          `json:"auto_scroll_default"`    // Default: true
	ShowTimestamps       bool          `json:"show_timestamps"`        // Default: true
	ExportFormat         string        `json:"export_format"`          // Default: "txt"
}

type StreamEvent struct {
	JobID      string          `json:"job_id"`
	OutputType string          `json:"output_type"` // "stdout" or "stderr"
	Content    string          `json:"content"`
	NewLines   []string        `json:"new_lines"` // New lines added since last event
	Timestamp  time.Time       `json:"timestamp"`
	EventType  StreamEventType `json:"event_type"`
	FileOffset int64           `json:"file_offset"` // Current file position
	Error      error           `json:"error,omitempty"`
}

type StreamEventType string

type StreamFilter struct {
	ID             string         `json:"id"`
	Name           string         `json:"name"`
	Type           FilterType     `json:"type"`
	Enabled        bool           `json:"enabled"`
	Pattern        string         `json:"pattern"`    // For keyword/regex filters
	Regex          *regexp.Regexp `json:"-"`          // Compiled regex
	TimeStart      time.Time      `json:"time_start"` // For time range filters
	TimeEnd        time.Time      `json:"time_end"`
	LogLevels      []LogLevel     `json:"log_levels"` // For log level filters
	Invert         bool           `json:"invert"`     // Invert the filter results
	CaseSensitive  bool           `json:"case_sensitive"`
	Highlight      bool           `json:"highlight"` // Highlight matches
	HighlightColor string         `json:"highlight_color"`
	Stats          FilterStats    `json:"stats"`
}

type StreamInfo struct {
	JobID       string    `json:"job_id"`
	OutputType  string    `json:"output_type"`
	FilePath    string    `json:"file_path"`
	IsRemote    bool      `json:"is_remote"`
	NodeID      string    `json:"node_id"`
	BufferSize  int       `json:"buffer_size"`
	BufferUsage float64   `json:"buffer_usage_percent"`
	LastUpdate  time.Time `json:"last_update"`
	Subscribers int       `json:"subscribers"`
}

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

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

type StreamingStats = Stats

type SubscriptionInfo struct {
	JobID       string `json:"job_id"`
	OutputType  string `json:"output_type"`
	Subscribers int    `json:"subscribers"`
}